qgDddlZddlZddlZddlmZmZmZmZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlmZmZddlmZddlmZmZdZdZdZd Zej:d ej<ezZej:d Z ej:d Z!ej:d Z"GddZ#Gdde#Z$y)N) ChunkedReader LengthReader EOFReaderBody) InvalidHeaderInvalidHeaderName NoMoreDataInvalidRequestLineInvalidRequestMethodInvalidHTTPVersionLimitRequestLineLimitRequestHeadersUnsupportedTransferCodingObsoleteFolding)InvalidProxyLineForbiddenProxyRequest)InvalidSchemeHeaders) bytes_to_strsplit_request_uriiiz!#$%&'*+-.^_`|~z[%s0-9a-zA-Z]+z[a-z#]zHTTP/(\d)\.(\d)z[\0\r\n]c2eZdZdZdZdZddZdZdZy) Messagecf||_||_||_||_d|_g|_g|_d|_|jrdnd|_ d|_ |j|_ |jdks|jtkDr t|_ |j|_ |jdkr t|_ |jxst}|j|dzzdz|_|j!|j}|jj#||j%y)NhttpshttpFr)cfgunreader peer_addr remote_addrversionheaderstrailersbodyis_sslscheme must_closelimit_request_fields MAX_HEADERSlimit_request_field_sizeDEFAULT_MAX_HEADERFIELD_SIZEmax_buffer_headersparseunreadset_body_reader)selfrrrmax_header_field_sizeunuseds S/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/gunicorn/http/message.py__init__zMessage.__init__"s  "$    !$g %($<$<!  % % *,,{:(3D %(+(D(D%  ( (1 ,,HD )!% = = ]A]"&";"; "Q &#(*+#,DMM* V$ cd|_y)NT)r'r0s r3 force_closezMessage.force_close@s r5ctN)NotImplementedError)r0rs r3r-z Message.parseCs !##r5cd|j}g}|jdDcgc] }t|}}d}i}g} |rn[d|jvs5t |j t r|j d|jvr|j}|j} |rt||jk\r td|jd} t| tdz} | jddkr t| | jdd\} } |jjr| j!d } t"j%| s t'| | j)} | j+d g} |r|dj-d r|jj.s t1| |jd} | t| tdzz } | |j2cxkDrdkDr td | j5| j+d |r|dj-d rd j7| } t8j;| r t| | |j2cxkDrdkDr td | |vr2| || k(}|rdnd}|r||j<k7rt?d}||_d| vrI| | vsd| vrn@|jj@dk(rn&|jj@dk(rot'| |j5| | f|r|Scc}w)N F*rzlimit request headers fieldsz : )  z!limit request headers fields sizez rBrrT_ dangerousdrop)!rsplitrforwarded_allow_ips isinstancertuplesecure_scheme_headersforwarder_headerslenr(rpopfindrstrip_header_spacesrstripTOKEN_RE fullmatchrupperstrip startswithpermit_obsolete_foldingrr*appendjoin!RFC9110_5_5_INVALID_AND_DANGEROUSsearchr&r header_map)r0data from_trailerrr"linelines scheme_headerrKrLcurr header_lengthnamevaluesecurer&s r3 parse_headerszMessage.parse_headersFshh15 70CDd#DD "  S,,,T^^U3"c&=&==$'$=$= ! # 5 5 7|t888)*HII99Q#D))t<<@q@)*MNNA,,"7"==$* ,244$(M"(DKd{,,7H0HXX((K7XX((F2,D11 NND%= )QTyEsL-cd}d}|jD]\}}|dk(r| td||}|dk(s#|jdDcgc]}|j}}|D]}|j dk(r|r td|d}(|j dk(r|s>td||j d vr |r td||j }t ||rP|jd kr td|| td|tt||j|_ y|k t|jr t|}n td| |d kr td|tt!|j||_ ytt#|j|_ ycc}w#t$rtd|wxYw) NFzCONTENT-LENGTH)reqzTRANSFER-ENCODING,chunkedTidentity)compressdeflategzip)r@r@r)r"rrGrUlowerr8rr!rrrr$str isnumericint ValueErrorrr)r0rkcontent_lengthrdrevvalsvals r3r/zMessage.set_body_readers!\\ ?MT5''!-'(8dCC!&,,,1;;s+;>#? ?8 ||f$#$7TBB)$$4$??]4?@DI  ' @~&002%(%8N'(8dCC# !#$4$??\$--HIDIYt}}56DI]=L @#$4$?? @sG2GG,c|jry|jD]9\}}|dk(s |jjd}|dk(ry|dk(ryn|jdkS)NT CONNECTIONrAclosez keep-aliveFr@r)r'r"rprUr!)r0hrvs r3 should_closezMessage.should_closesh ??ll FQL GGIOOE*<,&  ||v%%r5NF) __name__ __module__ __qualname__r4r8r-rgr/r~r5r3rr!s#<$aF:7x &r5rcXeZdZd fd Zd dZdZd dZdZdZdZ dZ fd Z xZ S) Requestcd|_d|_d|_d|_d|_|j |_|j dks|j t k\r t |_||_d|_t|)|||yNr) methoduripathqueryfragmentlimit_request_lineMAX_REQUEST_LINE req_numberproxy_protocol_infosuperr4)r0rrrr __class__s r3r4zRequest.__init__s{    #&"8"8  # #a '**.>>&6D #$#'  h 2r5c|j}|s%|r tt|j|j |yr:)read StopIterationr getvaluewrite)r0rbufstopr]s r3get_datazRequest.get_datas7}}#o%S\\^, , $r5cntj}|j||d|j|||j\}}|j t |rEtj}|j||j|||j\}}|j|tj}|j||j}|jd}|dddk(} |jd}|dddk(}|dkrG|sE|j|||j}t||jkDr tdng|r|jj|ddy|j!|d|d |_||d zd}d}|S) NT)rs rr=rzmax buffer headersr5F)r^r)ioBytesIOr read_linerproxy_protocolrrparse_request_linerrOrMr,rrr.rgr") r0rrr_rbufr]idxdonerets r3r-z Request.parse sjjl h$ /^^Hc43J3JK d   |D1 2**,C IIdO#t7N7NOJD$ %jjl $||~ii $BQx7"))K(C8w&DQwt h,||~t9t666-.BCC  MM ab *))$t*5)I 378n r5cD|j} |jd}|dk\r||cxkDrdkDrnn t||nRt|dz |cxkDrdkDrnntt|||j |||j}|d|||dzdfS)Nr=rr)rrOr rMr)r0rrlimitr]rs r3rzRequest.read_line:s||~))G$Cax??*3664y1}u(q(&s4y%88 MM(C (<<>DTc S1WX  r5c|jjsy|jdk7ry|jdsy|j |j |y)z Detect, check and parse proxy protocol. :raises: ForbiddenProxyRequest, InvalidProxyLine. :return: True for proxy protocol line else False Fr@PROXYT)rrrrVproxy_protocol_access_checkparse_proxy_protocol)r0r_s r3rzRequest.proxy_protocolLsOxx&& ??a w' ((* !!$'r5cd|jjvrYt|jtr>|jd|jjvrt |jdyyy)Nr>r)rproxy_allow_ipsrIrrJrr7s r3rz#Request.proxy_protocol_access_checkasa txx// / t~~u -q!)A)AA'q(9: :B . 0r5c|jd}t|dk7r t||d}|d}|d}|dvrtd|z|dk(rJ tjtj |tjtj |nN|d k(rI tjtj|tjtj| t|d }t|d }d |cxkrdkrnn d |cxkrdksntd |z|||||d|_ y#t $r t|wxYw#t $r t|wxYw#t$rtd |zwxYw)NrBr@r)TCP4TCP6zprotocol '%s' not supportedrrrzinvalid port %sri)r client_addr client_port proxy_addr proxy_port) rGrMrsocket inet_ptonAF_INETOSErrorAF_INET6rsrtr)r0r_bitsprotos_addrd_addrs_portd_ports r3rzRequest.parse_proxy_protocolhszz# t9>"4( (Qaa ( ("#@5#HI I F? -  8  8f_ -  &9  &9 =a\Fa\Ff%%A,@5,@"#4t#;< <$!!  $  ' -&t,, -  -&t,, -  ="#4t#;< < =s&AD=!AE*E-=EE*-Fc|jddDcgc] }t|}}t|dk7rtt||d|_|j j sbtj|jrt|jdt|dcxkrdksnt|jtj|jst|j|j jr|jj|_|d|_t|jdk(rtt| t|j}|j"xsd|_|j$xsd|_|j&xsd|_t(j|d}|t+|dt-|j/dt-|j/df|_d|j0cxkrd ks.n|j j2st+|j0yycc}w#t $rtt|wxYw) N rrrr@r|)rr)rGrrMr rr!permit_unconventional_http_methodMETHOD_BADCHAR_REr[r rRrScasefold_http_methodrTrrrtrrr VERSION_REr rsgroupr!"permit_unconventional_http_version)r0 line_bytesbitrpartsmatchs r3rzRequest.parse_request_lines -7-=-=dA-FGc S!GG t9>$\*%=> >1g xx99 '' 4*4;;77DG ***4;;77!!$++.&t{{3 3 88 ( (++++-DK7 txx=A $\*%=> > ?%dhh/EJJ$" [[&B ," $$T!W- =$T!W- -EKKN+SQ-@A ..88>>(66?/cHL ?$\*%=> > ?sI&-I++J ct|t|jjt r%t t|jd|_yyr) rr/rIr$readerrrrr)r0rs r3r/zRequest.set_body_readers> ! dii&& 2\$--;rs  KK I59 # 2 2::'92995Q+RS TBJJx( RZZ* + $.BJJ{$;!O&O&d\=g\=r5