o 4jE@sUddlZddlZddlZddlZddlZddlmZddlmZddlm 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@dZAedZBeCejDZEeeCeFeGd<eHdZIeeFeGd<eJdeIdZKee eFeGd<eJdejLZMee eFeGd<eJdejLZNee eFeGd<eJdZOee ePeGd<eJd ZQee eFeGd!<eRhd"ZSeeReFeGd#<Gd$d%d%eZTGd&d'd'eZUed(eTeUZVGd)d*d*eZWGd+d,d,eZXGd-d.d.eZYGd/d0d0ZZd1eeFd2e[fd3d4Z\Gd5d6d6ej]eeVZ^Gd7d8d8e^eTZ_Gd9d:d:e^eUZ`Gd;d<d<ZaGd=d>d>Zbe_Zce`ZdeTZeeUZfze)sdd?lgm_Z_m`Z`mTZTmUZUe_Zhe`ZieTZjeUZkWdSWdSelyYdSw)@N)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_RE> user-agent content-type max-forwards content-rangecontent-lengthcontent-locationtransfer-encodingetaghostserverSINGLETON_HEADERSc@sbeZdZUeed<eed<eed<ded<eed<eed<edBed <eed <eed <eed <dS) r5methodpathversionCIMultiDictProxy[str]headers raw_headers should_closeN compressionupgradechunkedurl) __name__ __module__ __qualname__str__annotations__r*r/boolrr\r\P/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/aiohttp/http_parser.pyr5os   r5c@s^eZdZUeed<eed<eed<eeed<eed<e ed<edBed<e ed <e ed <dS) r6rMcodereasonrOrPrQNrRrSrT) rVrWrXr*rZintrYrr/r[r\r\r\r]r6|s    r6_MsgTc@seZdZdZdZdZdS) PayloadStaterrN)rVrWrXPAYLOAD_COMPLETEPAYLOAD_NEEDS_INPUTPAYLOAD_HAS_PENDING_INPUTr\r\r\r]rbsrbc@seZdZdZdZdZdZdS) ParseStaterrrcN)rVrWrX PARSE_NONE PARSE_LENGTH PARSE_CHUNKEDPARSE_UNTIL_EOFr\r\r\r]rgs rgc@s eZdZdZdZdZdZdZdS) ChunkStaterrrcrhN)rVrWrXPARSE_CHUNKED_SIZEPARSE_CHUNKED_CHUNKPARSE_CHUNKED_CHUNK_EOFPARSE_MAYBE_TRAILERSPARSE_TRAILERSr\r\r\r]rms rmc @sReZdZ    ddededededd f d d Zd eeded e ffddZ d S)r1F max_line_size max_headersmax_field_sizelaxreturnNcCs||_||_||_||_dSN)rvrwrx_lax)selfrvrwrxryr\r\r]__init__s zHeadersParser.__init__linesrNcCst}g}d}||}t|}|rz |dd\}}Wn ty(t|dwt|dkr3t||d|dhddh@rCt||d}|dd } t| sWt||d7}||}|j oi|oi|dd v} | rt|} |g} | r| t|7} | |j kr|d d | } t | dd d|j | ||d7}||kr||}|r|dd v} nd }n| sud | }|d}|dd }|j rd|vsd|vsd|vrt|n t|rt||j s| |vr| tvrtd| d|| || ||f|st|t|fS)Nr:r s utf-8surrogateescape)rrs: d...  z Duplicate 'z' header found.)r lensplit ValueErrorr&lstripdecoder; fullmatchr|rxjoinr(appendstripr?searchlowerrJr!addrtuple)r}rrOrP lines_idxline line_countbnamebvaluename continuation header_length bvalue_lst header_linevaluer\r\r] parse_headerssr               AzHeadersParser.parse_headers)rtrurtF) rVrWrXr`r[r~listbytesrr/rr\r\r\r]r1s*   r1rOrzcCs"|tjd}|o|dvS)z)Check if the upgrade header is supported.>tcp websocket)getrUPGRADEisasciir)rOur\r\r]_is_supported_upgradesrc@seZdZUdZeeed<              d6d edBd ej dBd e d e d e de de dBde dBde dBde edBdededede ddfddZejdeedefddZejde defddZd7d d!Zd7d"d#ZdedBfd$d%Zd&d'ejejejfd(ed)ed*ed+ed,e d-ede ee ee!feeffd.d/Z"deede d0e#edBe dBeeffd1d2Z$d3eddfd4d5Z%dS)8r2FryNrtTrprotocollooplimitrvrwrxtimerr^rKpayload_exceptionresponse_with_bodyread_until_eofauto_decompressmax_msg_queue_sizerzcCs||_||_||_||_||_||_||_||_| |_| |_| |_ | |_ g|_ d|_ d|_ d|_d|_d|_d|_| |_||_t||||j|_||_d|_dS)NrFr)rrrvrwrxrr^rKrrr_lines_tail _upgraded_pending_upgrade_payload_payload_parser_payload_has_more_data_auto_decompress_limitr1ry_headers_parser_max_msg_queue_size_msg_in_flight)r}rrrrvrwrxrr^rKrrrrrr\r\r]r~s4  zHttpParser.__init__rcCdSr{r\)r}rr\r\r] parse_message5zHttpParser.parse_messagetecCrr{r\r}rr\r\r]_is_chunked_te8rzHttpParser._is_chunked_tecCs|jdusJ|jdSr{)r pause_readingr}r\r\r]r;szHttpParser.pause_readingcCs |jdkr|jd8_dSdS)z;Protocol drained a queued message; free a slot for parsing.rrN)rrr\r\r]message_consumed?s zHttpParser.message_consumedcCs|jdur|j|jjrd|_dS|jr|j|j|jrG|jddkr-|jdtt||jWdS1sBwYdS)Nrz r) rfeed_eofdonerrrr Exceptionrrr\r\r]rDs       zHttpParser.feed_eofr7rdataSEPEMPTYCONTENT_LENGTH METH_CONNECTSEC_WEBSOCKET_KEY1cs>g}|jr|j|d}|_t|}d} |j} |j} d} | |ks$|jr|jdur|js|jr@|j|jkr@|| d|_nH| || } | | krT|j sT| t|} q| | kr| r_t d|| | }|dkrn| d}t|| krt |ddd| |j ||j} t|j |jkrt d | t|} |j d |kr|jt|j }z ||j W|j n|j wd tdBffd d }|}|jvrt|jotj}td|j}tdd}|jdusJ|tvpt|o|tv}|sA|dur |dksjrAt|j|j | |j!d}t"||j|j#|j$|j%|j&|j'|j(|j|j||j!d}|j)s@||_||_*ny||krtt+t,sNJt|j|j | |j!d}d|_t"|jj#|j&|j'|j(|j|j||j!d |_nF|s|dur|j-rt|j|j | |j!d}t"||j|j#|j$|j%|j&|j'|j(|j|j||j!d}|j)s||_n |rd|_t.}nt.}||f|jr|jd7_j/} n|| d|_d|jvrt dt|j|jkrt |jddd|j|}n|jdur |jr |j r Jn}|j rJ|jdusJz|j0|| d|\}}Wn8t1y`}z+|}|j2dur@|2t3|}t4|jj5||t6j7}d}t+|tt8frVWYd}~nd}~ww|t6j9k|_|t6j7urnnd} t|}d|_|j*rd|_d|_*| |ks$|js$|r| |kr|| d}n|}||j|fS)NrrFzData after `Connection: close`r8 rrzToo many headers receivedrrzcs2j}|dur dSt|stt|Sr{)rOrr=rr&r`) length_hdrrmsgr\r]get_content_lengths  z0HttpParser.feed_data..get_content_lengthrKr^)rrr) lengthrTrKrRr^rrryheaders_parserrvrx max_trailersrT) rKrRrryrrvrxrrrzBad line ending, expected CRLF):rrrrvrrrrrfindrr!rstripr(rrxrwrclearr`rOr&rSrgetattrrKrrr[rrTr.rrHttpPayloadParserrRr^rrryrrr isinstancer5rr-rQ feed_datarrrYr payloadrbrdr)rf)r}rrrrrrmessagesdata_len start_posrmax_line_lengthrQposrrrrupgradedrKr^ empty_bodyrpayload_parser payload_stateunderlying_exc reraised_excr\rr]rUsn                         d zHttpParser.feed_datarNc Cs|j|\}}d}d}d}d}|tjd}|r9dd|D} d| vr'd}nd| vr-d}d | vr9|tjr9d}|tjd } | rL| d vrL| }|tj } | durf| | r]d}tj |vrft d ||||||fS) 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. NFr\cSs:h|]}dd|dDD] }|r|r|qqS)css|]}|dVqdS) N)r).0partr\r\r] ksz5HttpParser.parse_headers...,)rrr)r conn_valuetokenr\r\r] hsz+HttpParser.parse_headers..closeTz keep-aliverSr>brgzipzstddeflatez6Transfer-Encoding can't be present with Content-Length)rrgetallr CONNECTIONrrCONTENT_ENCODINGrrTRANSFER_ENCODINGrrr!) r}rrOrP close_connencodingrSrT conn_values conn_tokensencrr\r\r]rTs8    zHttpParser.parse_headersvalcCs ||_dS)zZSet connection upgraded (to websocket) mode. :param bool val: new state. N)r)r}r r\r\r] set_upgradeds zHttpParser.set_upgraded)NNrrtrrtNNNNTFTrrzN)&rVrWrXryrr[rZrasyncioAbstractEventLoopr`rrYtype BaseExceptionr~abcabstractmethodrrrarrrrrrrrr_SEPrrr.rr/rr r\r\r\r]r2s       .    6r2c@s8eZdZdZdeedefddZdede fddZ d S) r3zRead request status line. Exception .http_exceptions.BadStatusLine could be raised in case of any errors in status line. Returns RawRequestMessage. rrzc Cs|ddd}z |jddd\}}}Wn ty t|dwt|s*t||}t|}|dur;t|t t | dt | d}|dkrVt j |d d }nD|d ru|d \} } } | d \} } } t j | | | d d}n%|dkr|dkrt |d d}nt |d d}|jdkrt|jddd||dd\}}}}}}|tkrtj|vrtd|dur|tkrd }nd}t|||||||||| S)Nrrr rcmaxsplitrCONNECTT) authorityencoded/#?)rL query_stringfragmentr*OPTIONS)rr)errorslatin1z!Missing 'Host' header in request.F)rrrr"r;rupperr<r#r*r`grouprbuild startswith partitionschemer'encoderr,rHOSTr!r+r5)r}rrrKrLrMmatch version_orU path_part_hash_separator url_fragment_question_mark_separatorqs_partrOrPrrRrSrTr\r\r]rsr        zHttpRequestParser.parse_messagercCs8|jddddd}|r|dkrdStd) NrrrrrrTTz'Request has invalid `Transfer-Encoding`)rsplitrrrr!rr\r\r]rsz HttpRequestParser._is_chunked_teN) rVrWrX__doc__rrr5rrYr[rr\r\r\r]r3sTr3cseZdZUdZded<e Z ddededBde de d e e e e e feeff fd d Zd e ed e fd dZded efddZZS)r4zRead response status line and headers. BadStatusLine could be raised in case of any errors in status line. Returns RawResponseMessage. r0rNrrargskwargsrzcs0|dur trdnd}tj||g|Ri|S)Nr7r8)rsuperr)r}rrr3r4 __class__r\r]rs zHttpResponseParser.feed_datarc Csb|ddd}z |jdd\}}Wn tyt|dwz |jdd\}}Wnty8|}d}Ynwt|}|durFt|tt| dt| d}t |dks`t |sdt|t|}| |dd\} } } } } }| dur|t krd } n!d |krd ksn|d vrd } ntj| vstj| vrd } nd } t|||| | | | | | S)NrrrrrrrcrhTr>0F)rrrr#rr<rr*r`r#rr=rr+rrrr6)r}rrrMstatusr_r*r+status_irOrPrrRrSrTr\r\r]rs\     z HttpResponseParser.parse_messagercCs |jddddddkS)NrrrrrrT)r1rrrr\r\r]rHs z!HttpResponseParser._is_chunked_ter{)rVrWrXr2rZrryrrrrrr6r.r[rrrYr __classcell__r\r\r6r]r4s$  :r4c @seZdZ        d#dddeddededBd ed edBd edBd edBd ededededededededdfddZ d$ddZ d$ddZ d%de de d e deee ffd!d"ZdS)&rNFTrtr)rvrxrrrrrTrRr^rKrrryrrvrxrrrzc Csd|_d|_tj|_tj|_d|_d|_ ||_ | |_ | |_ | |_ | |_| |_d|_g|_d|_d|_|rA|rA|j rAt|||d}n|}|sQtj|_|d|_n!|rXtj|_n|durrtj|_||_||_|jdkrr|d|_||_dS)NrFr)max_decompress_sizeT)_length_pausedrgrl_typermro_chunk _chunk_size _chunk_tailrr|r_max_line_size_max_field_size _max_trailers_more_data_available_trailer_linesr _eof_pending DeflateBufferrirrkrj_length_expectedr)r}rrrTrRr^rKrrryrrvrxrr real_payloadr\r\r]r~NsF   zHttpPayloadParser.__init__cCs d|_dS)NT)r@rr\r\r]rs zHttpPayloadParser.pause_readingcCs|jtjkr,d|_|jr|jrd|_dS|jdd|_|js |jd|_ d|_dS|jtj krD|j |j }t d|d|j d|jtjkrNtddS) NTFrrz;Not enough data to satisfy content length header (received z of z bytes).z2Not enough data to satisfy transfer length header.)rArgrlrJrHr@rrrrrjrLr?r%rkr))r}receivedr\r\r]rs2      zHttpPayloadParser.feed_eofr7;chunkr CHUNK_EXTcCs|jtjkr_|jr|j|}d|_|j}t|t|d|_|j|d|||_ |j rJ|j r?d|_ ||d|_t j dfS|jdd|_ |j s-|jdkr]|j t j||dfSn|jtjkr|jr|jtjkr|j}|jtjkr{|j}t|j|krt|jddd||j|}d|_|s|j r|jtjkrb||}|dkrI||jkrt|ddd|j||d|}|dkr|d|}d|||} vrtd| } t|j| | n|d|}|jr|}tt|st|d| d d } t|j| | t!t"|d } ||t|d}| dkrrr`rr%rCbegin_http_chunk_receivingrerqend_http_chunk_receivingrrIrrGr!rrrrlrJr)r}rPrrQrequiredrrisize_bextexcsizertrailers raw_trailersr\r\r]rs2                              (                   zHttpPayloadParser.feed_data)NFNNNTTFr )r7rO)rVrWrXrr.r`r[rYr1r~rrrrrrbrr\r\r\r]rMsr      =  rc @seZdZUdZeed<efdededBde ddfdd Z e fd e d e ddfd d Z dede defddZdddZdddZdddZdS)rKzDDeflateStream decompress stream and feed data into specified stream. decompressoroutrNr>rzcCsv||_d|_|j|_||_d|_||dkr!tstdt|_n|dkr0t s+tdt |_nt |d|_||_ dS)NrFrzECan not decode content-encoding: brotli (br). Please install `Brotli`rzRCan not decode content-encoding: zstandard (zstd). Please install `backports.zstd`)r) rar]total_compressed_bytesr_started_decodingrr$rr`rrr_max_decompress_size)r}rarr>r\r\r]r~ns(    zDeflateBuffer.__init__r\ exc_causecCst|j||dSr{)r ra)r}r\rer\r\r]r szDeflateBuffer.set_exceptionrPr]cCs|j|7_|j|j_|js)|r)|jdkr&|dd@dkr&t|jdd|_d|_|jj}|tj kr4dnt |j |}z |jj ||d}Wnt yRtd|jw|r^|j|t||jjS) NrrT)rsuppress_deflate_header) max_lengthz#Can not decode content-encoding: %s)r]rarbrcrrr` _low_watersysmaxsizerTrddecompress_syncrr$rrdata_available)r}rPr] low_waterrir\r\r]rs*   zDeflateBuffer.feed_datacCsD|j}|r J|jdkr|jdkr|jjstd|jdS)Nrr)r`flushr]reofr$rar)r}rPr\r\r]rs  zDeflateBuffer.feed_eofcC|jdSr{)rarVrr\r\r]rVz(DeflateBuffer.begin_http_chunk_receivingcCrrr{)rarWrr\r\r]rWrsz&DeflateBuffer.end_http_chunk_receivingr )rVrWrXr2rrZrr.rYr`r~rrr rr[rrrVrWr\r\r\r]rKis2  #  " rK)r3r4r5r6)mrr rUstringrk contextlibrenumrrtypingrrrrr r r r multidictr rryarlrrr base_protocolrcompression_utilsrrrrrhelpersrrrrrrrr http_exceptionsr!r"r#r$r%r&r'r(r) http_writerr*r+r,streamsr-r.typedefsr/ client_protor0__all__rset printabler9rYrZescaper:compiler;ASCIIr<r=r>rr? frozensetrJr5r6rarbrgrmr1r[rABCr2r3r4rrKHttpRequestParserPyHttpResponseParserPyRawRequestMessagePyRawResponseMessagePy _http_parserHttpRequestParserCHttpResponseParserCRawRequestMessageCRawResponseMessageC ImportErrorr\r\r\r]s    (   (,      "  \eVb