­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ U '7`=x @slddlZddlZddlZddlZddlZddlZddlmZddlm Z m Z m Z m Z m Z mZddlmZmZmZddlmZddlmZddlmZdd lmZmZdd lmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%dd l&m'Z'dd l(m)Z)m*Z*ddl+m,Z,zddl-Z-dZ.Wne/k r&dZ.YnXdZ0e1ej2Z3e4dZ5e4dZ6e4dZ7e8dddddddddddg Z9e8d dd!d"ddddddg Z:Gd#d$d$eZ;Gd%d&d&eZZ?Gd+d,d,e?Z@Gd-d.d.e?ZAGd/d0d0ZBGd1d2d2ZCe@ZDeAZEe9ZFe:ZGz2esNdd3lHm@Z@mAZAm9Z9m:Z:e@ZIeAZJe9ZKe:ZLWne/k rfYnXdS)4N)IntEnum)AnyListOptionalTupleTypeUnion) CIMultiDictCIMultiDictProxyistr)URL)hdrs) BaseProtocol) NO_EXTENSIONSBaseTimerContext) BadStatusLineContentEncodingErrorContentLengthError InvalidHeader LineTooLongTransferEncodingError) HttpVersion HttpVersion10)internal_logger) EMPTY_PAYLOAD StreamReader) RawHeadersTF) HeadersParser HttpParserHttpRequestParserHttpResponseParserRawRequestMessageRawResponseMessagez[!#$%&'*+\-.^_`|~0-9A-Za-z]+zHTTP/(\d+).(\d+)s'[\x00-\x1F\x7F()<>@,;:\[\]={} \t\\\\\"]r"methodpathversionheaders raw_headersZ should_close compressionupgradechunkedurlr#codereasonc@seZdZdZdZdZdZdS) ParseStaterr N)__name__ __module__ __qualname__ PARSE_NONE PARSE_LENGTH PARSE_CHUNKEDPARSE_UNTIL_EOFr9r9F/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/http_parser.pyr/[sr/c@s eZdZdZdZdZdZdZdS) ChunkStaterr r0r1N)r2r3r4PARSE_CHUNKED_SIZEPARSE_CHUNKED_CHUNKPARSE_CHUNKED_CHUNK_EOFPARSE_MAYBE_TRAILERSPARSE_TRAILERSr9r9r9r:r;cs r;c@s>eZdZd eeeddddZeeedefdd d Z dS) rN) max_line_size max_headersmax_field_sizereturncCs||_||_||_dSN)rDrErF)selfrDrErFr9r9r:__init__lszHeadersParser.__init__CIMultiDictProxy[str]linesrGcCst}g}d}|d}t|}|rz|dd\}}Wntk rVt|dYnX|d}|}t|r|t|t||j krt d | ddt |j t t|t|} |d7}||}|o|ddk} | rv|g} | rj| t|7} | |j kr(t d | ddt |j t | | ||d7}||kr`||}|rh|ddk} qd }qjqd | }n0| |j krt d | ddt |j t | |}| d d } | d d } || | |||fqt|t|fS) Nr :s zrequest header name {}utf8xmlcharrefreplacer) zrequest header field {}utf-8surrogateescape)r lensplit ValueErrorrstriplstripHDRREsearchrFrformatdecodestrappendjoinaddr tuple)rIrMr'r(Z lines_idxlineZ line_countZbnameZbvalue header_lengthZ continuationZ bvalue_lstnamevaluer9r9r: parse_headersvsz               zHeadersParser.parse_headers)rBrCrB) r2r3r4intrJrbytesrrrhr9r9r9r:rks  rc@seZdZdeeeejeeeeeeeeee e ee e e e e dddd Z ejeeed d d Zed ddZddejejejfeeeee eeeee efdddZeeedeee ee e e fd ddZe ddddZdS)rNrBrCFT)protocollooplimitrDrErFtimerr-r$readallpayload_exceptionresponse_with_bodyread_until_eofauto_decompressrGcCs||_||_||_||_||_||_||_| |_| |_| |_ | |_ | |_ g|_ d|_ d|_d|_d|_||_||_t||||_dS)NrSF)rlrmrDrErFror-r$rprqrrrs_lines_tail _upgraded_payload_payload_parser_auto_decompress_limitr_headers_parser)rIrlrmrnrDrErFror-r$rprqrrrsrtr9r9r:rJs(zHttpParser.__init__rLcCsdSrHr9)rIrMr9r9r: parse_messageszHttpParser.parse_messagerGcCsz|jdk r|jd|_nZ|jr0|j|j|jrv|jddkrP|jdz||jWStk rtYdSXdS)Nz rS)ryfeed_eofrvrur`r} ExceptionrIr9r9r:rs   zHttpParser.feed_eof rS)dataSEPEMPTYCONTENT_LENGTH METH_CONNECTSEC_WEBSOCKET_KEY1rGc Csg}|jr|j|d}|_t|}d} |j} | |kr|jdkr|js||| } | | krp|jsp| d} q.| | kr|j|| | | d} |jd|krz| |j} W5|jX| j |} | dk rz t | } Wnt k rt|YnX| dkrt||| j kr,t|| j|_t| d|j}|jdk sRt| dk rf| dksv| jr| jst|j|j| |jd}t|| | j|| j|j|j|j|jd }|jsv||_n||krt|j|j| |jd}d|_t|| j| jd|jd |_nrt| d d d krr| dkrr|jrrt|j|j| |jd}t|| | j|| j|jd|j|jd }|jsv||_nt }|| |fn|| d|_|}qq.|jdkr|jr|jrtqq.|r| |kr|jrt|jdk stz|j!|| d\}}Wn`t"k rl}z@|j#dk rF|jj$%|#t&|n|jj$%|d}d}W5d}~XYnX|rd} t|}d|_q.q.qq.|r| |kr|| d}n|}||j|fS) NrSrr0rr$)rormrn)lengthr+r$r)r-rprrrtT)r$r)rprtr-d)'rvrVrmryrwfindrur`clearr}r'getrirXrr*getattrr$rlAssertionErrorr+rror{HttpPayloadParserr)r-rprrrzdonersr feed_data BaseExceptionrqpayload set_exceptionr_)rIrrrrrrmessagesZdata_lenZ start_posrmposmsgrr$rZpayload_parsereofexcr9r9r:rs                  zHttpParser.feed_datarKc Cs|j|\}}d}d}d}d}|tj}|r`|} | dkrFd}n| dkrTd}n | dkr`d}|tj} | r| } | dkr| }|tj} | rd| krd}||||||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. NFcloseTz keep-aliver*)gzipdeflatebrr+)r|rhrrZ CONNECTIONlowerZCONTENT_ENCODINGZTRANSFER_ENCODING) rIrMr'r(Z close_connencodingr*r+Zconnvencter9r9r:rhs.    zHttpParser.parse_headers)valrGcCs ||_dS)zYSet connection upgraded (to websocket) mode. :param bool val: new state. N)rw)rIrr9r9r: set_upgradedszHttpParser.set_upgraded)NNrkrBrCrBNNNFNTFT)r2r3r4rrasyncioZAbstractEventLooprirr_boolrrrJabcabstractmethodrrjrr}rrrrrr rrrrhrr9r9r9r:rsn  ' . )rc@s$eZdZdZeeedddZdS)r zRead request status line. Exception .http_exceptions.BadStatusLine could be raised in case of any errors in status line. Returns RawRequestMessage. rLcCs\|ddd}z|dd\}}}Wntk rDt|dYnXt||jkrntdt|jtt||d\}}}|d\}} } t |st|zB| dr|d dd d \} } t t | t | } nt|Wntk rt|YnX||\}}}}}}|dkr4| tkr0d }nd }t||| ||||||tj|| |d d S)NrrTrUr0Status line is too long#?zHTTP/.r TF)r%Z query_stringfragmentencoded)r^rWrXrrVrDrr_ partitionMETHREmatch startswithrrirrhrr"r build)rIrMrdr$r%r&Z path_partZ_hash_separatorZ url_fragmentZ_question_mark_separatorZqs_partZn1Zn2 version_or'r(rr)r*r+r9r9r:r}sf       zHttpRequestParser.parse_messageNr2r3r4__doc__rrjrr}r9r9r9r:r sr c@s$eZdZdZeeedddZdS)r!zRead response status line and headers. BadStatusLine could be raised in case of any errors in status line. Returns RawResponseMessagerLc CsT|ddd}z|dd\}}Wntk rBt|dYnXz|dd\}}Wntk rpd}YnXt||jkrtdt|jtt|t |}|dkrt|t t | dt | d}z t |}Wntk rt|dYnX|dkrt|| |\} } } } } }| dkr8|tk} t|||| | | | | | S) NrrTrUr rr0i)r^rWrXrrVrDrr_VERSRErrrigrouprhrr#rY)rIrMrdr&statusr.rrZstatus_ir'r(rr)r*r+r9r9r:r}3s\       z HttpResponseParser.parse_messageNrr9r9r9r:r!-sr!c @sjeZdZdeeeeeeeeeeeeedd ddZdddd Z de e e e ee fd d dZ dS)rNFT) rrr+r)r-r$rprrrtrGc Csd|_tj|_tj|_d|_d|_| |_ d|_ |rH|rH|j rHt ||} n|} |shtj|_| d|_ n||rvtj |_nn|dk rtj|_||_|jdkr| d|_ n>|r|dkrtj|_n(|dkrtdtj|_| d|_ | |_dS)NrrSFT)ZPUTZPOSTz6Content-Length or Transfer-Encoding header is required)_lengthr/r5_typer;r=_chunk _chunk_size _chunk_tailrzr DeflateBufferrr7r6r8rwarningr) rIrrr+r)r-r$rprrrtZ real_payloadr9r9r:rJnsF     zHttpPayloadParser.__init__r~cCsF|jtjkr|jn*|jtjkr.tdn|jtjkrBtddS)Nz2Not enough data for satisfy content length header.z3Not enough data for satisfy transfer length header.) rr/r8rrr6rr7rrr9r9r:rs    zHttpPayloadParser.feed_eofr;)chunkr CHUNK_EXTrGc Cs:|jtjkr|j}t|}||krT|||_|j|||jdkr|jdSn6d|_|j|d|||jd||dfSn|jtjkr|j r|j |}d|_ |r6|j t j kr| |}|dkr| |d|}|dkr|d|}n |d|}ztt|d} Wn@tk r\t|d|dd} |j| | dYnX||dd}| dkrt j|_ nt j|_ | |_|jn ||_ d S|j t jkr"|j}t|}||kr|||_|j||d Sd|_|j|d||||d}t j|_ |j|j t jkrb|dd|krX|dd}t j |_ n ||_ d S|j t jkr|dd} | |kr|jd|ddfS| sd S| |dd kr| |_ d St j|_ |j t jkr| |}|dkr||dd}t j|_ q||_ d Sqn |jtjkr6|j|t|d S) Nr)TrSTrSasciirUr0)FrSr )rr/r6rrVrrrr7rrr;r=rrirjrXrr^rr@r>rbegin_http_chunk_receivingr?end_http_chunk_receivingrAr8) rIrrrrequiredZ chunk_lenriZsize_bsizerheadr9r9r:rs                           zHttpPayloadParser.feed_data)NFNNNFTT)rr) r2r3r4rrrirr_rJrrjrrr9r9r9r:rms: 8  rc@sreZdZdZeeeddddZeddddZ e e dd d d Z dd d dZ dd ddZdd ddZdS)rzDDeflateStream decompress stream and feed data into specified stream.N)outrrGcCsb||_d|_||_d|_|dkr8ts,tdt|_n&|dkrJdt j nt j }t j |d|_dS)NrFrzGCan not decode content-encoding: brotli (br). Please install `brotlipy`rrZwbits) rrr_started_decoding HAS_BROTLIrbrotliZ Decompressor decompressorzlib MAX_WBITS decompressobj)rIrrZ zlib_moder9r9r:rJ/s zDeflateBuffer.__init__)rrGcCs|j|dSrH)rr)rIrr9r9r:r@szDeflateBuffer.set_exception)rrrGcCs|sdS|j|7_|jsH|jdkrH|dd@dkrHtjtj d|_z|j|}Wn"tk rzt d|jYnXd|_|r|j |t |dS)Nrrrz#Can not decode content-encoding: %sT) rrrrrrr decompressrrrrrV)rIrrr9r9r:rCs& zDeflateBuffer.feed_datar~cCsR|j}|s|jdkrD|j|t||jdkrD|jjsDtd|j dS)Nrr) rflushrrrrVrrrr)rIrr9r9r:ras  zDeflateBuffer.feed_eofcCs|jdSrH)rrrr9r9r:rksz(DeflateBuffer.begin_http_chunk_receivingcCs|jdSrH)rrrr9r9r:rnsz&DeflateBuffer.end_http_chunk_receiving)r2r3r4rrrr_rJrrrjrirrrrr9r9r9r:r,s r)r r!r"r#)Mrr collectionsrestringrenumrtypingrrrrrrZ multidictr r r Zyarlr rrZ base_protocolrZhelpersrrZhttp_exceptionsrrrrrrZ http_writerrrlogrZstreamsrrZtypedefsrrr ImportError__all__set printableZASCIISETcompilerrr[ namedtupler"r#r/r;rABCrr r!rrZHttpRequestParserPyZHttpResponseParserPyZRawRequestMessagePyZRawResponseMessagePyZ _http_parserZHttpRequestParserCZHttpResponseParserCZRawRequestMessageCZRawResponseMessageCr9r9r9r:s            ^K@@F