rPj<UddlZddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z m Z m Z mZmZmZmZmZddlmZmZmZddlmZdd lmZdd lmZdd lmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+dd l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7m8Z8m9Z9ddl:m;Z;mZ>e rddl?m@Z@dZAedZBeCejZEeeCeFeGd<ejdZIeeFeGd<ejdeIdZKee eFeGd<ejdejZMee eFeGd<ejdejZNee eFeGd<ejdZOee ePeGd<ejd ZQee eFeGd!<ejd"ZRee eFeGd#<d$eFd%eSfd&ZTeUhd'ZVeeUeFeGd(<Gd)d*eZWGd+d,eZXed-eWeXZYGd.d/eZZGd0d1eZ[Gd2d3eZ\Gd4d5Z]d6eeFd%eSfd7Z^Gd8d9ejeeYZ`Gd:d;e`eWZaGd<d=e`eXZbGd>d?ZcGd@dAZdeaZeebZfeWZgeXZh e)sddBlimaZambZbmWZWmXZXeaZjebZkeWZleXZmyy#en$rYywxYw)CN)suppress)IntEnum)Pattern) TYPE_CHECKINGAnyClassVarFinalGenericLiteral NamedTupleTypeVar) CIMultiDictCIMultiDictProxyistr)URL)hdrs) BaseProtocol) HAS_BROTLIHAS_ZSTDBrotliDecompressorZLibDecompressorZSTDDecompressor) _EXC_SENTINELDEBUGDEFAULT_CHUNK_SIZEEMPTY_BODY_METHODSEMPTY_BODY_STATUS_CODES NO_EXTENSIONSBaseTimerContext set_exception) BadHttpMessage BadHttpMethod BadStatusLineContentEncodingErrorContentLengthError InvalidHeaderInvalidURLError LineTooLongTransferEncodingError) HttpVersion HttpVersion10 HttpVersion11) EMPTY_PAYLOAD StreamReader) RawHeaders)ResponseHandler) HeadersParser HttpParserHttpRequestParserHttpResponseParserRawRequestMessageRawResponseMessage)  ASCIISETz!#$%&'*+-.^_`|~_TCHAR_SPECIALSz [0-9A-Za-zz]+TOKENREzHTTP/(\d)\.(\d)VERSREz\d+DIGITSs [0-9a-fA-F]+ HEXDIGITSz[\x00-\x08\x0a-\x1f\x7f]_FIELD_VALUE_FORBIDDEN_CTL_REz[\x00-\x1f\x7f]_TARGET_FORBIDDEN_CTL_REtargetreturncL|jdd}|dddk(xr|dddvS)aTell if an absolute-form request target has "//" and a non-empty authority. RFC 9110 section 4.2 requires a host for http and https. yarl's default WHATWG mode reads a host from "http:host/p" or "http:///host/p", so the target is checked before it is parsed. :Nz//)/?#) partition)rBrests X/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/aiohttp/http_parser.py_has_authorityrO\s;   C  #D 8t  DQq 1D DD> user-agent content-type max-forwards content-rangecontent-lengthcontent-locationtransfer-encodingetaghostserverSINGLETON_HEADERScxeZdZUeed<eed<eed<ded<eed<eed<edzed <eed <eed <eed <y) r6methodpathversionCIMultiDictProxy[str]headers raw_headers should_closeN compressionupgradechunkedurl) __name__ __module__ __qualname__str__annotations__r+r0boolrrPrNr6r6|s= K I  $$t M M HrPr6cteZdZUeed<eed<eed<eeed<eed<e ed<edzed<e ed <e ed <y) r7r_codereasonrarbrcNrdrerf) rhrirjr+rlintrkrr0rmrnrPrNr7r7s=  I K c ""t M MrPr7_MsgTceZdZdZdZdZy) PayloadStaterrrFN)rhrirjPAYLOAD_COMPLETEPAYLOAD_NEEDS_INPUTPAYLOAD_HAS_PENDING_INPUTrnrPrNrurus !rPruceZdZdZdZdZdZy) ParseStaterrrFrGN)rhrirj PARSE_NONE PARSE_LENGTH PARSE_CHUNKEDPARSE_UNTIL_EOFrnrPrNrzrzsJLMOrPrzc eZdZdZdZdZdZdZy) ChunkStaterrrFrGN)rhrirjPARSE_CHUNKED_SIZEPARSE_CHUNKED_CHUNKPARSE_CHUNKED_CHUNK_EOFPARSE_MAYBE_TRAILERSPARSE_TRAILERSrnrPrNrrsNrPrc ReZdZ d dededededdf dZdeeded e ffd Z y) r2 max_line_size max_headersmax_field_sizelaxrCNc<||_||_||_||_yN)rrr_lax)selfrrrrs rN__init__zHeadersParser.__init__s#+&, rPlinesr`ct}g}d}||}t|}|r |jdd\}}t|dk(r t ||d|dhddhzr t ||j d}|j dd } tj| s t ||dz }||}|jxr |xr|dd v} | rt|} |g} | r| t|z } | |jkDr3|d zd j| z} t| dd dz|j| j||dz }||kr||}|r |dd v} nd }n| rd j| }|jd}|j dd }|jrd|vsd|vsd|vr+t |tj!|r t ||js)| |vr%| j#t$vrt'd| d|j)| ||j||f|rt+|t-|fS#t$r t |dwxYw)Nr:r s utf-8surrogateescape)rrs: rPd...  z Duplicate 'z' header found.)rlensplit ValueErrorr'lstripdecoder< fullmatchrrjoinr)appendstripr@searchlowerr[r"addrtuple)rrrarb lines_idxline line_countbnamebvaluename continuation header_length bvalue_lst header_linevalues rN parse_headerszHeadersParser.parse_headerss%0M  YZ  4 $ 4 3 v5zQ#E**a%)$Aw.#D))]]6*F<<):;D$$T*#E** NI#D 99DD$q'W2DL #F $X "!SY.M$t':'::&+emchhz6J&J )'-68K8K%%d+NI :-$Y/+/7g+=L"##$*-\\&)FMM'+<=Eyy5=DEMVu_'//.55e<#F++99TZZ\EV5V${4&%HII KKe $   v /B!)5+=>>{ 4#D)t3 4s II$)irF) rhrirjrrrmrlistbytesrr0rrnrPrNr2r2sl" "        L?%[L? & 2 3L?rPr2rac|jtjd}|jxr|j dvS)z)Check if the upgrade header is supported.rH>tcp websocket)getrUPGRADEisasciir)raus rN_is_supported_upgrader s3 DLL"%A 99; <1779(<<C$$C-r8rPdataSEPEMPTYCONTENT_LENGTH METH_CONNECTSEC_WEBSOCKET_KEY1cg}|jr|j|zdc}|_t|}d} |j} |j} d} | |ks |jrL|j k|j s^|jr'|j|jk\r|| d|_|}n|j|| } | | k(r|js| t|z} | | k\r| r td|| | }|dk(r|jd}t|| kDrt|dddz| |jj||j} t|j|j kDr td | t|z} |jd |k(r|j t|jz } |j#|j|jj%d t&dzffd }|}|j(vr t+|j,xrt/j(}t1d |j2}t1dd}|j4J|t6vxs)t9|j2xr|j2t:v}|s||dkDs j<rt?|j4|j@| |jB}tE||j<|jF|jH|jJ|jL|jN|jP|j|j||jB}|jRs||_||_*n||k(rtWtXsJt?|j4|j@| |jB}d|_tE|j2jF|jL|jN|jP|j|j||jB |_n|s||jZrt?|j4|j@| |jB}tE||j<|jF|jH|jJ|jL|jN|jP|j|j||jB}|jRs||_n|rd|_t\}nt\}|j|f|jr|xjdz c_j^} n-|| d|_d|jvr tdt|j|jkDr&t|jdddz|j|}n|j |j r|jrJn|jrJ|j J |j ja|| d|\}}|tljrk(|_|tljnurnCd} t|}d|_|jTrd|_d|_*| |kr>|jrL|r | |kr|| d}n|}||j |fS#|jj%wxYw#tb$r}}|}|jd|jetg|}ti|j jj||tljn}d}tW|t*tpfrYd}~,d}~wwxYw)NrPrFzData after `Connection: close`r9 rrzToo many headers receivedrrCcjj}|ytj|s t t |Sr)rarr>rr'rr) length_hdrrmsgs rNget_content_lengthz0HttpParser.feed_data..get_content_lengthsC),)HJ)1'+ $*#3#3J#?&3N&C C#&z?2rPr]rp)rrr) lengthrfr]rdrprrrheaders_parserrr max_trailersrT) r]rdrrrrrrrrzBad line ending, expected CRLF):rrrrrrrrrfindrr"rstripr)rrrrclearrrrar'rergetattrr]rrrmrrfr/rrHttpPayloadParserrdrprrrrrr isinstancer6rr.rc feed_datarrrkr!payloadrurvr*rx)rrrrrrrmessagesdata_len start_posrmax_line_lengthrcposrrrrupgradedr]rp empty_bodyrpayload_parser payload_stateunderlying_exc reraised_excrs ` @rNrzHttpParser.feed_databs ::#zzD0# D$*t9 yy,, ("d&A&A##+DNN,,++t/G/GG "&ij!1DJ DiiY/)#DKK #c#hI)##,-MNN #.De|#{{514y?2)$t*v*=OOKK&&t,&*&9&9O4;;'$*:*::,-HII #c#hI{{2%/'+'7'7#dkk:J'J 0)-););DKK)HC KK--/ 3C$J 3"4!5-<"/0B"CC#&;;#U3H3U!(h !D&sFA6#}}888 &*-D%D& KKMDKK;M,MI  *#/FQJ3;;&2 $ &*jj%)&*kk 'G .? ''-(+ '-,/OO%)YY373J3J040E0E$(HH/3/C/C.2.@.@/3/B/B-9&*kk.N $2#6#67E 49A 5#|3#-c3D#EE#E&2 $ &*jj%)&*kk 'G .2DN3D ''*zz,/OO040E0E$(HH/3/C/C.2.@.@/3/B/B-9&*kk 4D0",4CVCV&2 $ &*jj%)&*kk 'G .? ''-(+ '-,/OO%)YY373J3J040E0E$(HH/3/C/C.2.@.@/3/B/B-9&*kk.N $2#6#67E 4%.2DN&3G&3G g733 //14/'*'7'7 !%ij!1DJ *,-MNN4::););;)$**Tc*:V*CTEWEWXX D%%-$..;;& ;;&++777*.*>*>*H*HYZ(#+'M4,"\%K%KK+! (E(EE t9'+$((&*DN,1D)O("d&A&AR I( #DD--!KK--/l!2@L--9'+'='=c.>Q'R !,,44$& %1$A$AMD!&8M(Ns%[ "[* ['* ]03A2]++]0r`c|jj|\}}d}d}d}d}|jtjd}|r|D chc]A} d| j dDD]$} | r | j r| j&C} } } d| vrd}nd| vrd}d | vr!|jtjrd}|jtjd } | j r| j} | d vr| }|jtj} | 0|j| rd}tj|vr td ||||||fScc} } w) zParses RFC 5322 headers from a stream. Line continuations are supported. Returns list of header name and value pairs. Header name is in upper case. NFrnc3>K|]}|jdyw) N)r).0parts rN z+HttpParser.parse_headers..~sRDdjj/Rs,closeTz keep-alivererH>brgzipzstddeflatez6Transfer-Encoding can't be present with Content-Length)rrgetallr CONNECTIONrrrrrCONTENT_ENCODINGTRANSFER_ENCODINGrrr")rrrarb close_connencodingrerf conn_values conn_valuetoken conn_tokensencrs rNrzHttpParser.parse_headersgs| $33AA%H nnT__b9 #.RJ""2&""g-$Lj(GWMMEsAE(valc||_y)zZSet connection upgraded (to websocket) mode. :param bool val: new state. N)r)rr!s rN set_upgradedzHttpParser.set_upgradeds rP)NNirrNNNNTFTrrCN)&rhrirjrrrmrlrasyncioAbstractEventLooprrr rktype BaseExceptionrabcabstractmethodrrrsrrrrrrrrr_SEPrrr/rr0rr#rnrPrNr3r3s6C$)-15!")-!8<#'$ $"#, %, ''$.,  ,  ,  , ,  $&, Dj, d ,  .5, !, , ,  , !, \ =4;=5==2222-% %$,(#22 --#'#:#:C.C.C. C.  C.  C.!C. tE%-./u< =C.J6N%[6N TD[#*dDP 6NprPr3c6eZdZdZdeedefdZdede fdZ y)r4zRead request status line. Exception .http_exceptions.BadStatusLine could be raised in case of any errors in status line. Returns RawRequestMessage. rrCc J|djdd} |jdd\}}}tj |s t||j }tj|r*t|jdjdtj |}| t|tt|jd t|jd}|d k(rQ t!j"|d }|j$} | t|jdjd|j'd rD|j)d\} } } | j)d\} } }t!j"| || d }n|dk(r|dk(rt!|d }n{t+|s*t|jdjd t!|d }|j$} | *t|jdjd|j-|d d\}}}}}}|t.k(rt0j2|vr t5d||t6krd }nd}t9|||||||||| S#t$r t|dwxYw#t$r+t|jdjdwxYw#t$r+t|jdjdwxYw)Nrrr rFmaxsplit)errorslatin1rCONNECTT) authorityencodedrIrKrJ)r^ query_stringfragmentr6*OPTIONS)r6z!Missing 'Host' header in request.F)rrrr#r<rupperrArr(encoder=r$r+rrgrouprbuildraw_host startswithrLrOrr-rHOSTr"r,r6)rrrr]r^r_match version_orgrY path_part_hash_separator url_fragment_question_mark_separatorqs_partrarbrrdrerfs rNrzHttpRequestParser.parse_messages:Qxw(9: 0$(JJsQJ$? !FD'   (' ' $ * *4 0! #4 5<0F)rrrr$rr=rr+rrr=rr>rr,rrrr7)rrrr_statusrqrBrCstatus_irarbrrdrerfs rNrz HttpResponseParser.parse_message?sQxw(9: 0"jj!j4OGV #\\1\5NFF   ) =% %EKKN 3SQ5HI  v;! 6#3#3F#;% %v;   uQRy )       =M)&3&(j*@$$/43I3IW3T!   LLN        U 0%4 / 0  \\^FF sE E9 E69FFrcn|jdddjdjdk(S)Nrrr0rr rf)rJrrrs rNrz!HttpResponseParser._is_chunked_teys3yyqy)"-33E:@@BiOOrPr)rhrirjrKrlrrrr,rrrr7r/rmrrrkr __classcell__)rQs@rNr5r5(s  )C   = =D[ = =  = tE,l:;|s6t3|d|jAd d } t5|j| | tCtE|d } ||t |zd}| dk(r8t"j(|_|j6r|jGd r}|d d}nwt"j$|_| |_$|jjKn@d|vr#t3d} t5|j| | ||_tjLdfS|j t"j$k(r|jr d|_ ||_tjdfS|jH}t |t |z d|_$|jj|d|||_ ||d}|jr|jHrd|_ tjLdfSt"jN|_|jjQ|j t"jNk(r|j6r|jGd r|d d}|dt ||k(r$|t |d}t"j.|_ndt |t |k\s||dt |k7r#t3d} t5|j| | ||_tjLdfS|j t"j(k(r|j1|}|dkr@d|vr#t3d} t5|j| | ||_tjLdfS|d|} ||t |zd}|dk(r| jSd } t | |j*kDrt-| dddz|j*|jTjW| t |jT|jXkDr t[d|jTddk(ro |j\j_|jT\} }|jTja|jjtj|fS|rm|jr{n|jtjbk(r|jj|t ||_ |jrS|jrd|_ tjdfS|jjdd|_ |jrS|jdr:|jjd|_3d|_2tjdfStjLdfS#|jTjawxYw)aReceive a chunk of data to process. Return: PayloadState - The current state of payload processing. This function may be called with empty bytes after returning PAYLOAD_HAS_PENDING_INPUT to continue processing after a pause. bytes - If payload is complete, this is the unconsumed bytes intended for the next message/payload, b"" otherwise. rPrNFrrr9z"Unexpected LF in chunk-extension: asciirrrz)Bad chunk-size line ending, expected CRLFz3Chunk size mismatch: expected CRLF after chunk dataz&Bad trailer line ending, expected CRLFzToo many trailers receivedrT)4r_rzr|rbr]maxrrrrfr^rurxrrvr}r`rrrcrrdr)rrr*r!rrrerr?rrrrr@rabegin_http_chunk_receivingrwrend_http_chunk_receivingrrgrrer"rrrr~rhr)rrorrprequiredrrisize_bextexcsizertrailers raw_trailerss rNrzHttpPayloadParser.feed_datas ::00 0((50#& ||Hx#e*4a8DL(, (>(>ix ()D %++<<#(DL',XY'7D$'AA3FF,0LL,B,B3,J) ++||q  %%'#44eHI6FFF ZZ:33 3;;*"@"@@&*&9&9O{{j&?&??*.*>*>4++,>) ,,Tc2V;_((50#& 444;;*"?"??**S/Cax!4!44"-eDSkF.BDDWDW"XX!JJy!S96%*2AYF$a )<=&;&H$P'"!.dllC @&) %*4C[F99%+\\^F!||Iv>"7 %ds 2 27"7 H#C*$,,<"%I+0(+??DD #;D!#C."23Ee|#{{514y4#7#77)$t*v*=t?S?STT''..t44../$2D2DD,-IJJ**2.#58595I5I5W5W $ 3 362Hl!//557 --/+<(>uc%j(QD %++<<#(DL'AA3FF,0LL,B,B3,J) ++    %%'  $)!#44c99//44'!//557s (bb!)NFNNNTTFr%)r8;)rhrirjrr/rrrmrkr2rrrrr,rrurrnrPrNrr~s""&!#' $;$""'!;$;$d ;$ ;$ 4Z ;$ Dj ;$d ;$!;$;$;$&;$;$;$;$ !;$" #;$z@EIB5B5!%B5D"D:c|jj}|rJ|jdkDr0|jdk(r!|jjs t d|j jy)Nrr)rflushr}reofr%rr)rros rNrzDeflateBuffer.feed_eofs`!!'')y 99q=}} )$2C2C2G2G*955 rPc8|jjyr)rrvrs rNrvz(DeflateBuffer.begin_http_chunk_receivings ++-rPc8|jjyr)rrwrs rNrwz&DeflateBuffer.end_http_chunk_receivings ))+rPr%)rhrirjrKrrlrr/rkrrrrr)r!rrmrrrvrwrnrPrNririsN $6 8 8*8! 8  8F$10 0!0  0 0u 0C 0D 0D .,rPri)r4r5r6r7)or*r&rustringr contextlibrenumrrtypingrrrr r r r r multidictrrryarlrrHr base_protocolrcompression_utilsrrrrrhelpersrrrrrrr r!http_exceptionsr"r#r$r%r&r'r(r)r* http_writerr+r,r-streamsr.r/typedefsr0 client_protor1__all__r,set printabler:rkrlescaper;compiler<ASCIIr=r>r?rr@rArmrO frozensetr[r6r7rsrurzrr2rABCr3r4r5rriHttpRequestParserPyHttpResponseParserPyRawRequestMessagePyRawResponseMessagePy _http_parserHttpRequestParserCHttpResponseParserCRawRequestMessageCRawResponseMessageC ImportErrorrnrPrNrs     :9'      CB0 - ~ 0 01%C/1(bii(9:s:)rzzJ6Gr*JKws| K(bjj);RXXFgclF(bjj:gcl:#-2::.>#? 5 ?5?RZZ6uWS\21; ;M0N% -NE3E4E ,5  ,53(       *,>?"7" Y?Y?x=#3C#8=T=S'%.Sl ~H #45~HBSP$67SPlb5b5J _,_,D()')   /0.0   s;JJJ