Ë
|
¸^i_ ã ól U d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z m
|
Z
|
m Z m Z m Z mZmZmZmZmZmZmZmZmZ d dlmZmZmZ d dlm Z ddl m Z dd l m Z dd
|
l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' dd l(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ dd l0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z: dd l;m<Z<m=Z= ddl>m?Z?m@Z@ ddlAmBZB dZCed ZD eEej « ZGe eeH eId< ej d« ZKe eH eId< ej deK d« ZMe eeH eId< ej dej « ZOe eeH eId< ej dej « ZPe eeH eId< ej d « ZQe eeR eId < G d d e« ZS G d d!e« ZT ed"eSeT« ZU G d# d$e« ZV G d% d&e« ZW G d' d(« ZXd)eeH d*eYfd+ZZ G d, d-e j¶ e eU « Z\ G d. d/e\eS « Z] G d0 d1e\eT « Z^ G d2 d3« Z_ G d4 d5« Z`e]Zae^ZbeSZceTZd e-sdd6lem]Z]m^Z^mSZSmTZT e]Zfe^ZgeSZheTZiyy# ej$ r Y yw xY w)7é N)Úsuppress)ÚIntEnum)ÚAnyÚClassVarÚFinalÚGenericÚListÚLiteralÚ
|
NamedTupleÚOptionalÚPatternÚSetÚTupleÚTypeÚTypeVarÚUnion)Ú CIMultiDictÚCIMultiDictProxyÚistr)ÚURLé )Úhdrs)Ú BaseProtocol)ÚDEFAULT_MAX_DECOMPRESS_SIZEÚ
|
HAS_BROTLIÚHAS_ZSTDÚBrotliDecompressorÚZLibDecompressorÚZSTDDecompressor)Ú _EXC_SENTINELÚDEBUGÚEMPTY_BODY_METHODSÚEMPTY_BODY_STATUS_CODESÚ NO_EXTENSIONSÚBaseTimerContextÚ set_exception)
|
ÚBadHttpMessageÚ BadHttpMethodÚ BadStatusLineÚContentEncodingErrorÚContentLengthErrorÚDecompressSizeErrorÚ InvalidHeaderÚInvalidURLErrorÚ LineTooLongÚTransferEncodingError)Ú HttpVersionÚ HttpVersion10)Ú EMPTY_PAYLOADÚ StreamReader)Ú
|
RawHeaders)Ú HeadersParserÚ
|
HttpParserÚHttpRequestParserÚHttpResponseParserÚRawRequestMessageÚRawResponseMessage)ó
|
ó
|
ÚASCIISETz!#$%&'*+-.^_`|~Ú_TCHAR_SPECIALSz
|
[0-9A-Za-zz]+ÚTOKENREzHTTP/(\d)\.(\d)ÚVERSREz\d+ÚDIGITSs [0-9a-fA-F]+Ú HEXDIGITSc óx e Zd ZU eed< eed< eed< ded< eed< eed< ee ed< eed < eed
|
< e ed < y ) r: ÚmethodÚpathÚversionúCIMultiDictProxy[str]ÚheadersÚ raw_headersÚ should_closeÚ compressionÚupgradeÚchunkedÚurlN)
|
Ú__name__Ú
|
__module__Ú __qualname__ÚstrÚ__annotations__r1 r5 Úboolr r © ó õf H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/http_parser.pyr: r: Y s=
Ø KØ
|
IØ ÓØ $Ó$ØÓØÓØ# Ó Ø MØ MØ HrW r: c ót e Zd ZU eed< eed< eed< ee ed< eed< e ed< e
|
e ed< e ed< e ed < y
|
) r; rG ÚcodeÚreasonrI rJ rK rL rM rN N) rP rQ rR r1 rT ÚintrS r r5 rU r rV rW rX r; r; f s=
Ø ÓØ
|
IØ KØ cÑ "Ó"ØÓØÓØ# Ó Ø MØ MrW r; Ú_MsgTc ó e Zd ZdZdZdZdZy)Ú
|
ParseStater r é é N)rP rQ rR Ú
|
PARSE_NONEÚ PARSE_LENGTHÚ PARSE_CHUNKEDÚPARSE_UNTIL_EOFrV rW rX r_ r_ u s àJØLØMØOrW r_ c ó e Zd ZdZdZdZdZdZy)Ú
|
ChunkStater r r` ra é N)rP rQ rR ÚPARSE_CHUNKED_SIZEÚPARSE_CHUNKED_CHUNKÚPARSE_CHUNKED_CHUNK_EOFÚPARSE_MAYBE_TRAILERSÚPARSE_TRAILERSrV rW rX rg rg } s ØÐØÐØ ÐØ ÐØNrW rg c óR e Zd Z d dededededdf
|
dZdee ded e f fd
|
Z
|
y) r6 Ú max_line_sizeÚ max_headersÚmax_field_sizeÚlaxÚreturnNc ó< || _ || _ || _ || _ y ©N)ro rp rq Ú_lax)Úselfro rp rq rr s rX Ú__init__zHeadersParser.__init__ s# ð +ÔØ&ÔØ ,ÔØ rW ÚlinesrH c ó¸ t « }g }d}|| }t |« }|r |j dd« \ }}t |« dk( r t |« |d |d hddhz r t |« |j d« }t |« | j kD rQt dj |j d d
|
« « t | j « t t |« « « |j d d « } t j | « s t |« t |« }
|
|dz }|| }| j xr |xr |d d v } | r¬|g} | r|
|
t |« z }
|
|
|
| j kD rHt dj |j d d
|
« « t | j « t |
|
« « | j |« |dz }||k r|| }|r |d d v } nd}n| rdj | « }nW|
|
| j kD rHt dj |j d d
|
« « t | j « t |
|
« « |j! d« }|j d d « } d| v sd| v sd| v r t |« |j# | | « |j ||f« |rt% |« t' |« fS # t $ r t |« d w xY w)Nr ó :r éÿÿÿÿé é s zrequest header name {}Úutf8Úbackslashreplaceúutf-8Úsurrogateescape)r} r~ zrequest header field {}rW ú
|
ú ú )r ÚlenÚsplitÚ
|
ValueErrorr- Úlstriprq r/ ÚformatÚdecoderS r@ Ú fullmatchrv ÚappendÚjoinÚstripÚaddr Útuple)rw ry rI rJ Ú lines_idxÚlineÚ
|
line_countÚbnameÚbvalueÚnameÚ header_lengthÚ continuationÚ
|
bvalue_lstÚvalues rX Ú parse_headerszHeadersParser.parse_headers s ô %0£Mà à ØYÑ ÜZ
|
âð 4Ø $§
|
¡
|
¨4°Ó 3 vô 5zQÜ# EÓ*Ð*ð a% )Ð$¨¨A wÒ.Ü# DÓ)Ð)à]] 6Ó*FÜ5zD× /Ñ /Ò/Ü!Ø,×3Ñ3Ø VÐ-?Ó@óô ×+Ñ+Ó,ÜE
|
Oó ð ð << Ð):Ó;DÜ×$Ñ$ TÔ*Ü# EÓ*Ð*ä KMð NIØÑ#Dð 99ÒD¨ÒD°$°q±'¸WÐ2DLñ Ø $X
|
Ù"Ø!¤S¨£YÑ.MØ$ t×':Ñ':Ò:Ü )Ø 5× <Ñ <Ø %§ ¡ ¨VÐ5GÓ Hó ô × 3Ñ 3Ó 4Ü Ó .ó ð ð ×%Ñ% dÔ+ð NIØ :Ò-Ø $ YÑ /Ù Ø+/°©7°gÐ+=Là "Ø ò) #ð* *Ó-à 4×#6Ñ#6Ò6Ü%Ø1×8Ñ8Ø !LL¨Ð1CÓ Dóô D× /Ñ /Ó0ÜMÓ*ó ð ð \\ &Ó)FØMM 'Ð+<Ó=Eð u} ¨¡ °¸5± Ü# FÓ+Ð+à KKeÔ $Ø × Ñ vÔ /ó_ ôb ! Ó)¬5°Ó+=Ð>Ð>øô[ ò 4Ü# DÓ)¨tÐ3ð 4ús £K ËK)éþ é r F) rP rQ rR r\ rU rx r Úbytesr r5 r rV rW rX r6 r6
sl ð "Ø Ø "Øñ
|
àð
|
ð ð
|
ð ð
|
ð
|
ð
|
ð
|
ó
|
ð\?Ø%[ð\?à Ð&¨
|
Ð2Ñ 3ô\?rW r6 rI rs c ó | j t j d« }|j « xr |j « dv S )z)Check if the upgrade header is supported.Ú > ÚtcpÚ websocket)Úgetr ÚUPGRADEÚisasciiÚlower)rI Úus rX Ú_is_supported_upgrader© ñ s3 à DLL "Ó%Aà 99;Ò <1779Ð(<Ð<Ð<rW c óü e Zd ZU dZee ed< d%dee dee j de de de d e d
|
ee d ee d ee d eee dedededdf dZej$ dee defd« Zej$ de defd« Zdee fdZddej4 ej6 ej8 fdede d ed e d e d e de ee ee f eef fd Z!dee de d!e"ee ee eef fd"Z#d#eddfd$Z$y)&r7 Frr NÚprotocolÚloopÚlimitro rp rq ÚtimerrZ rE Úpayload_exceptionÚresponse_with_bodyÚread_until_eofÚauto_decompressrs c ó: || _ || _ || _ || _ || _ || _ || _ | | _ |
|
| _ | | _ | | _
|
g | _ d| _ d| _ d | _ d | _ | | _ || _ t% |||| j& « | _ y )NrW F)r« r¬ ro rp rq r® rZ rE r¯ r° r± Ú_linesÚ_tailÚ _upgradedÚ_payloadÚ_payload_parserÚ_auto_decompressÚ_limitr6 rr Ú_headers_parser)rw r« r¬ r ro rp rq r® rZ rE r¯ r° r± r² s rX rx zHttpParser.__init__û s¤ ð ! Ø Ø *ÔØ&ÔØ ,ÔØ
|
Ø Ø Ø!2Ô Ø"4Ô Ø ,Ôà#% Ø
|
Ø Ø Ø<@Ô Ø /Ô Ø Ü ,Ø ;¨¸¿¹ó
|
Õ rW ry c ó y ru rV )rw ry s rX Ú parse_messagezHttpParser.parse_message" s Ø:=rW Útec ó y ru rV ©rw r¾ s rX Ú_is_chunked_tezHttpParser._is_chunked_te% s Ø/2rW c ó´ | j "| j j « d | _ y | j r%| j j | j « | j ra| j d dk7 r| j j d« t t « 5 | j | j « cd d d « S y # 1 sw Y y xY w)Nr| z
|
rW )r¸ Úfeed_eofrµ r´ r r Ú Exceptionr½ ©rw s rX rà zHttpParser.feed_eof( sª Ø × Ñ Ð +Ø × Ñ × )Ñ )Ô +Ø#'DÔ ð ð zzØ ×"Ñ" 4§:¡:Ô.à{{Ø;;r? fÒ,ØKK×&Ñ& sÔ+Ü iÓ(ñ ;Ø ×-Ñ-¨d¯k©kÓ:÷;ñ ;à÷;àús Â(CÃCr< rW ÚdataÚSEPÚEMPTYÚCONTENT_LENGTHÚ METH_CONNECTÚSEC_WEBSOCKET_KEY1c ó°
|
g }| j r| j |z dc}| _ t |« }d} | j }
|
d} | |k rX| j ¾| j s±|j || « } | | k( r| j s| t |« z } R| | k\ rl| r t d« || | } |dk( r| j d« } | j j | « | t |« z } | j d |k( r | j | j « | j j « dt t ffd } |« }|j v r t |« j xr t# j « | _ t% d
|
| j& « }t% d d« }| j( J |t* v xs t- |xr |t. v « }|s½||dkD s j0 rª| j st3 | j( | j4 |
|
| j6 ¬ « }t9 ||j0 |j: | j< | j> | j@ | jB | jD ¬ «
|
}|jF sO|| _ nF||k( rtI tJ « sJ t3 | j( | j4 |
|
| j6 ¬ « }d| _ t9 |j& j: | j@ | jB | jD ¬« | _ n²|sª|¨| jL rt3 | j( | j4 |
|
| j6 ¬ « }t9 ||j0 |j: | j< | j> | j@ | jB | jD ¬ «
|
}|jF s|| _ ntN }|j |f« jP } n|| d | _ |}n| j | j r| j rJ nf|r\| |k rW| j rJ | j J | j jS || d |« \ }}|rd} t |« }d | _ Vn| |k rX|r | |k r|| d }n|}|| j |fS # | j j « w xY w# tT $ rn}|}| jV | jW tY |« « }t[ | j j\ ||« d}d}tI |t t^ f« r Y d }~Ïd }~ww xY w)NrW r Fz Data after `Connection: close`r= ó r| rs c ó j j « } | y t j | « s t « t | « S ru )rI r¤ rB r r- r\ )Ú
|
length_hdrrÉ Úmsgs rX Úget_content_lengthz0HttpParser.feed_data.<locals>.get_content_lengthi sC ø à),¯©¯ © ¸ Ó)HJØ )Ð 1Ø'+ô
|
$*×#3Ñ#3°JÔ#?Ü&3°NÓ&CÐ Cä#& z£?Ð 2rW rE rZ )r® r¬ r ) ÚlengthrN rE rL rZ r° r² rr Úheaders_parserT)rE rL r² rr rÓ )0rµ r r¬ r¸ r¶ Úfindr´ r' Úrstripr r½ Úclearr r\ rI r- rM r© ÚgetattrrE r« r# rU r" rN r4 r® rº ÚHttpPayloadParserrL rZ r° r¹ rr r» ÚdoneÚ
|
isinstancer: r± r3 rK Ú feed_dataÚ BaseExceptionr¯ rS r& Úpayloadr0 )rw rÆ rÇ rÈ rÉ rÊ rË ÚmessagesÚdata_lenÚ start_posr¬ rK Úposr rÑ rÒ rE rZ Ú
|
empty_bodyrÝ Úpayload_parserÚeofÚunderlying_excÚ reraised_excrÐ s ` @rX rÛ zHttpParser.feed_data8 s ù ð à ::Ø #zz¨DÑ 0°#Ð D$*ät9Ø Øyyà Ø(Ó"ð ×#Ñ#Ñ+°D·N³NØii YÓ/à)Ò#¨D¯KªKØ #¤c¨#£h¡IØ à)Ó#Ù#Ü ,Ð-MÓ NÐNð ¨#Ð.DØe|Ø #{{¨5Ó 1ØKK×&Ñ& tÔ,Ø #¤c¨#£h¡Ið {{ 2¨%Ó/ð0Ø)-×);Ñ);¸D¿K¹KÓ)HCà KK× -Ñ -Ô /ð 3´H¼S±Mö 3ñ "4Ó!5à-°·±Ñ<Ü"/Ð0BÓ"CÐ Cà),¯©ò *Ô9NØ KKó:ô ")¨¨h¸¿ ¹ Ó!Dä & s¨F°AÓ 6à #}}Ð 8Ð8Ð 8à%)Ô-DÐ%Dò &ÌØ "Ò C vÔ1CÐ'CóI
|
ñ *Ø $Ð 0°V¸a²ZÀCÇKÂKØ$(§N¢Nä&2Ø $§ ¡ Ø&*§j¡jØ%)Ø&*§k¡kô ' Gô .?Ø 'Ø'-Ø(+¯ © Ø'-Ø,/¯O©OØ%)§Y¡YØ37×3JÑ3JØ04×0EÑ0EØ$(§H¡HØ/3×/CÑ/Cô . Nð $2×#6Ó#6Ø7E Ö 4Ø # |Ò 3Ü#-¨cÔ3DÔ#EÐ EÐ#EÜ&2Ø $§ ¡ Ø&*§j¡jØ%)Ø&*§k¡kô ' Gð .2DNÜ3DØ 'Ø'*§z¡zØ,/¯O©OØ04×0EÑ0EØ$(§H¡HØ/3×/CÑ/Cô 4 DÕ 0ñ ",°°À4×CVÒCVÜ&2Ø $§ ¡ Ø&*§j¡jØ%)Ø&*§k¡kô ' Gô .?Ø 'Ø'-Ø(+¯ © Ø'-Ø,/¯O©OØ%)§Y¡YØ37×3JÑ3JØ04×0EÑ0EØ$(§H¡HØ/3×/CÑ/Cô . Nð $2×#6Ò#6Ø7E Õ 4ä&3Gà ¨¨g¨Ô7Ø'*×'7Ñ'7 à!% i jÐ!1DJØ DØð ×%Ñ%Ð-°$·.².Ø ;;Ð&Øñ ) hÒ.Ø ;;Ð&Ø×+Ñ+Ð7Ð7Ð7ð Ø $× 4Ñ 4× >Ñ >¸tÀIÀJÐ?OÐQTÓ UICñ& Ø !IÜ " 4yHØ+/DÔ(Ù àðQ (Ô"ñT I Ò(Ø
|
Ð#DàDà ¨Ð-Ð-øði !KK× -Ñ -Õ /ûôj %ò Ø#1LØ×-Ñ-Ð9Ø'+×'=Ñ'=¼cÀ.Ó>QÓ'R ä!Ø ×,Ñ,×4Ñ4Ø$Ø&ôð CØ DÜ!Ø&¬ Ô8MÐ(Nôð ôûð ús% Ä R? Ñ "S Ò? SÓ UÓ'A$UÕUrH c
|
óÔ | j j |« \ }d}d}d}d}t j t j t j
|
t j t j t j t j t j t j t j f
|
}t fd|D « d« }|t d| d« j t j « } | rF| j# « }
|
|
|
dk( rd}n.|
|
dk( rd}n&|
|
d k( r! j t j$ « rd} j t j& d
|
« } | j) « r| j# « d v r| } j t j « } | 0| j+ | « rd}t j v r t 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.
|
NFc 3 ó` K | ]% }t j |d « « dkD s"| ' yw)rV r N)r Úgetall)Ú.0ÚhrI s rX ú <genexpr>z+HttpParser.parse_headers.<locals>.<genexpr> s( øè ø ÒPa´°W·^±^ÀAÀrÓ5JÓ1KÈaÓ1OÑPùs #.§.z Duplicate 'z' header found.ÚcloseTz
|
keep-aliverM r¡ > ÚbrÚgzipÚzstdÚdeflatez6Transfer-Encoding can't be present with Content-Length)r» r r rÉ ÚCONTENT_LOCATIONÚ CONTENT_RANGEÚ CONTENT_TYPEÚETAGÚHOSTÚ MAX_FORWARDSÚSERVERÚTRANSFER_ENCODINGÚ
|
USER_AGENTÚnextr' r¤ Ú
|
CONNECTIONr§ r¥ ÚCONTENT_ENCODINGr¦ rÁ )rw ry rJ Ú
|
close_connÚencodingrM rN Ú
|
singletonsÚbad_hdrÚconnÚvÚencr¾ rI s @rX r zHttpParser.parse_headersý s© ø ð $× 3Ñ 3× AÑ AÀ%Ó HÑ Ø
|
ØØØô
|
× Ñ Ü × !Ñ !Ü × Ñ Ü × Ñ Ü IIÜ IIÜ × Ñ Ü KKÜ × "Ñ "Ü OOð
|
|
ô ÓP :ÔPÐRVÓWØ Ð Ü ;¨w¨i°Ð!GÓHÐ Hð {{4??Ó+Ù Ø
|
|
AØG|Ø !
|
ØlÒ"Ø "
|
ài G§K¡K´· ± Ô$=Ø ð kk$×/Ñ/°Ó4Ø ;;=SYY[Ð,MÑ MØHð [[×/Ñ/Ó 0Ø >Ø×"Ñ" 2Ô&Ø ä×"Ñ" gÑ-Ü$ØLóð ð j°(¸GÀWÐMÐMrW Úvalc ó || _ y)zZSet connection upgraded (to websocket) mode.
|
|
:param bool val: new state.
|
N)r¶ )rw r s rX Ú set_upgradedzHttpParser.set_upgraded= s ð
|
rW ) NNi r r r NNNNTFT)%rP rQ rR rr r rU rT r r ÚasyncioÚAbstractEventLoopr\ r% rS r rÜ rx ÚabcÚabstractmethodr r r] r½ rÁ rà r rÉ rÊ rË Ú_SEPr r r4 rÛ r5 r r rV rW rX r7 r7 ø s!
Ø C$ Ó ð ,0Ø48ØØ !Ø Ø "Ø,0Ø "Ø $Ø;?Ø#'Ø $Ø $ñ %
|
à<Ñ(ð%
|
ð w×0Ñ0Ñ1ð%
|
ð ð %
|
ð
|
ð %
|
ð ð %
|
ð ð%
|
ð Ð(Ñ)ð%
|
ð smð%
|
ð ð%
|
ð $ D¨ Ñ$7Ñ8ð%
|
ð !ð%
|
ð ð%
|
ð ð %
|
ð
|
ó %
|
ðN ×ÑØ= 4¨¡;Ð=°5Ò=ó Ø=à×ÑØ2 Ð2¨Ò2ó Ø2ð( 5/ó ð& ØØ #× 2Ñ 2Ø × -Ñ -Ø#'×#:Ñ#:ñC.àðC.ð ðC.ð ð C.ð
|
ð C.ð ð C.ð !ðC.ð
|
tE% Ð-Ñ.Ñ/°°uÐ<Ñ =óC.ðJ>NØ%[ð>Nà Ø ¨X°d©^¸XÀc¹]ÈDÐRVÐVñ
|
ó>Nð@ ð ¨ô rW r7 c ó6 e Zd ZdZdee defdZdede fdZ
|
y)r8 z¥Read request status line.
|
|
Exception .http_exceptions.BadStatusLine
|
could be raised in case of any errors in status line.
|
Returns RawRequestMessage.
|
ry rs c ó< |d j dd« } |j dd¬« \ }}}t |« | j
|
kD r2t dt | j
|
« t t |« « « t j |« s t |« t j |« }| t |« t t |j d« « t |j d« « « }|d k( rt j |d
|
¬ « }n³|j# d « rD|j% d « \ } }
|
} | j% d« \ } } } t j | | | d
|
¬« }n^|dk( r|dk( rt |d
|
¬« }nFt |d
|
¬« }|j& dk( r*t) |j+ d¬« j d« « | j- |dd « \ }}}}}}||t. k rd
|
}nd}t1 ||||||||||«
|
S # t $ r t |« d w xY w)Nr r r ú r` ©ÚmaxsplitúStatus line is too longr ÚCONNECTT)Ú authorityÚencodedú/ú#ú?)rF Ú query_stringÚfragmentr Ú*ÚOPTIONS)r r¡ )ÚerrorsÚlatin1F)r r r r( r ro r/ rS r@ r rA r) r1 r\ Úgroupr ÚbuildÚ
|
startswithÚ partitionÚschemer. Úencoder r2 r: )rw ry r rE rF rG ÚmatchÚ version_orO Ú path_partÚ_hash_separatorÚ url_fragmentÚ_question_mark_separatorÚqs_partrI rJ rí rL rM rN s rX r½ z HttpRequestParser.parse_messageM s1 àQxwÐ(9Ó:ð 0Ø$(§J¡J¨s¸Q JÓ$?Ñ !FD'ô t9t×)Ñ)Ò )Ü Ø)¬3¨t×/AÑ/AÓ+BÄCÌÈDË ÃNóð ô
|
× Ñ Ô(Ü Ó'Ð 'ô × Ñ Ó)Ø =Ü Ó%Ð %Ü ¤ E§K¡K°£NÓ 3´S¸¿¹ÀQ» Ó5HÓI à YÒ ô )) d°DÔ9CØ __SÔ !ð 8<·~±~ÀcÓ7JÑ 4I¨ Ø;D×;NÑ;NÈsÓ;SÑ 8IÐ/°ô ))Ø Ø $Ø%Ø ô Cð S[V yÒ 0äd DÔ)Cô d DÔ)CØzzRÒ ä%ØKKÐ'8KÓ9×@Ñ@ÀÓJóð ð × Ñ u Q RyÓ )ñ
|
Ø Ø Ø Ø Ø Ø ð =ØMÒ)Ø à ä Ø Ø Ø Ø Ø Ø Ø Ø Ø Ø ó
|
ð
|
øôG ò 0Ü Ó%¨4Ð /ð 0ús H ÈHr¾ c óª |j dd¬« d j d« }|j « r|j « dk( ryt d« ) Nú,r r r| ú rN Tz'Request has invalid `Transfer-Encoding`)Úrsplitr r¦ r§ r' rÀ s rX rÁ z HttpRequestParser._is_chunked_te¢ sI Ø YYs QYÓ '¨Ñ +× 1Ñ 1°%Ó 8à ::<BHHJ¨)Ò 3Øä Ð FÓGÐGrW N) rP rQ rR Ú__doc__r r r: r½ rS rU rÁ rV rW rX r8 r8 E s9 ñðS
|
4¨¡;ð S
|
Ð3Dó S
|
ðjH ð H¨ô HrW r8 c ó e Zd ZdZe Z d dedee de de de
|
e e
|
e e f eef f
|
fd Zde e de fd Zd
|
edefd Z xZS ) r9 zRead response status line and headers.
|
|
BadStatusLine could be raised in case of any errors in status line.
|
Returns RawResponseMessage.
|
rÆ rÇ ÚargsÚkwargsrs c óD |
|
t rdnd}t | ||g|¢i |¤S )Nr< r= )r! ÚsuperrÛ )rw rÆ rÇ r2 r3 Ú __class__s rX rÛ z HttpResponseParser.feed_dataµ s/ ø ð ;Ý "'¨CÜwÑ sÐ<¨TÒ<°VÑ<Ð<rW ry c óÊ |d j dd« } |j d¬« \ }} |j d¬« \ }}t |« | j kD r2t dt | j « t t |« « « t j |« }| t |« t t |j d« « t |j d« « « }t |« d k7 st j |« s t |« t |« }| j |dd « \ } }
|
} } } }| I|t k rd
|
} n=d |cxk rd k sn |d v rd} n)t" j$ | v st" j& | v rd} nd
|
} t) |||j « | |
|
| | | |« S # t $ r t |« d w xY w# t $ r |j « }d}Y w xY w)Nr r r r r r¡ r r` ra Téd éÈ > é0 éÌ F)r r r r) r r ro r/ rS rA r r1 r\ r rB r r2 r rÉ rù r; )rw ry r rG Ústatusr[ r% r& Ústatus_irI rJ rí rL rM rN s rX r½ z HttpResponseParser.parse_messageÀ sê ØQxwÐ(9Ó:ð 0Ø "jj°!jÓ 4OGVð Ø #\\°1\Ó 5NFFô
|
v;×+Ñ+Ò +Ü Ø)¬3¨t×/AÑ/AÓ+BÄCÌÈFË ÓDTóð ô
|
× Ñ Ó)Ø =Ü Ó%Ð %Ü ¤ E§K¡K°£NÓ 3´S¸¿¹ÀQ» Ó5HÓI ô v;!Ò ¤6×#3Ñ#3°FÔ#;Ü Ó%Ð %Üv;ð × Ñ u Q RyÓ )ñ
|
Ø Ø Ø Ø Ø Ø ð =ØMÒ)Ø àÔ& 3Ô&¨(°jÑ*@Ø Ü×$Ñ$¨Ñ/´4×3IÑ3IÈWÑ3TØ ð ä!Ø Ø Ø LLNØ Ø Ø Ø Ø Ø ó
|
|
ð
|
|
øô_ ò 0Ü Ó%¨4Ð /ð 0ûô
|
ò Ø\\^FØFð ús F* G Æ*G ÇG"Ç!G"r¾ c ón |j dd¬« d j d« j « dk( S )Nr- r r r| r. rN )r/ r r§ rÀ s rX rÁ z!HttpResponseParser._is_chunked_teÿ s3 àyy qyÓ)¨"Ñ-×3Ñ3°EÓ:×@Ñ@ÓBÀiÑOÐOrW ru )rP rQ rR r0 r! rr r r r r r r r; r4 rU rÛ r½ rS rÁ Ú __classcell__)r6 s @rX r9 r9 « s ø ñð )Cð
|
#ñ =àð =ð d^ð =ð ð =ð
|
ð =ð
|
tEÐ,¨lÐ:Ñ;Ñ<¸dÀEÐIÑ Jõ =ð=
|
4¨¡;ð =
|
Ð3Eó =
|
ð~P ð P¨÷ PrW r9 c ó e Zd Z ddedee dedee dee dee ded ed
|
ed ed dfd Z ddZ
|
dde de de d e ee f fdZy)rØ NrÝ rÒ rN rL rZ rE r° r² rr rÓ rs c
|
óF d| _ t j | _ t j
|
| _ d| _ d| _ || _ | | _
|
|
|
| _ g | _ d| _ |r|r| j r t ||« } n|} |s4t j | _ | j! « d| _ | | _ y |r t j" | _ | | _ y |Bt j$ | _ || _ | j dk( r| j! « d| _ | | _ y )Nr rW FT)Ú_lengthr_ re Ú_typerg ri Ú_chunkÚ _chunk_sizeÚ _chunk_tailr¹ rv r» Ú_trailer_linesrÙ Ú DeflateBufferrb rà rd rc rÝ ) rw rÝ rÒ rN rL rZ rE r° r² rr rÓ Ú real_payloads rX rx zHttpPayloadParser.__init__ s ð Ü ×/Ñ/
|
Ü ×3Ñ3 Ø ÔØ ÔØ /Ô Ø Ø -Ô Ø+-ÔØ ñ ¡+°$×2GÒ2GÜ?LØó@Lð #Lñ "ä#×.Ñ.DJØ × !Ñ !Ô #Ø DIð $ ñ Ü#×1Ñ1DJð $ ð Ð Ü#×0Ñ0DJØ!DLØ||qÒ Ø ×%Ñ%Ô'Ø à# rW c ó | j t j k( r| j j « y | j t j
|
k( r t d« | j t j k( r t d« y )Nz1Not enough data to satisfy content length header.z2Not enough data to satisfy transfer length header.) rC r_ re rÝ rà rc r+ rd r0 rÅ s rX rà zHttpPayloadParser.feed_eof7 so Ø ::×3Ñ3Ò 3Ø LL× !Ñ !Õ #Ø ZZ:×2Ñ2Ò 2Ü$ØCóð ð ZZ:×3Ñ3Ò 3Ü'ØDóð ð 4rW ÚchunkrÇ Ú CHUNK_EXTc óv
|
| j t j k( r´| j }t |« }||k\ rP||z
|
| _ | j
|
j ||« | j dk( rb| j
|
j « yd| _ | j
|
j |d | |« | j
|
j « d||d fS y | j t j k( ré| j r| j |z }d| _ |rÃ| j t j k( rv|j |« }|dk\ rW|j |d|« }|dk\ r4|d | }d||| x} v r+t d| « }
|
t | j
|
|
|
« |
|
|d | }| j r|j# « }t% j& t( |« s6t |d | j+ dd« « }
|
t | j
|
|
|
« |
|
t- t/ |« d « } ||t |« z d }| dk( r8t j0 | _
|
| j rV|j3 d
|
« rE|d d }n?t j4 | _
|
| | _ | j
|
j9 « n|| _ y | j t j4 k( r| j6 }t |« }||kD r'||z
|
| _ | j
|
j ||« y d| _ | j
|
j |d | |« ||d }t j: | _
|
| j
|
j= « | j t j: k( r_| j r|j3 d
|
« r|d d }|d t |« |k( r$|t |« d }t j | _
|
n|| _ y | j t j0 k( rØ|j |« }|dk r|| _ y |d | } ||t |« z d }|dk( r| j? d
|
« } | j@ jC | « | j@ d dk( ra | jD jG | j@ « \ } }| j@ jI « | j
|
j « d|fS |rÃy | j t jJ k( r%| j
|
j |t |« « y # | j@ jI « w xY w)Nr )TrW TrW r= z"Unexpected LF in chunk-extension: Úasciir é rÍ r )FrW r| )&rC r_ rc rB r rÝ rÛ rà rd rF rD rg ri rÔ r0 r& rv r Úrer rC r r\ r rm r! rj rE Úbegin_http_chunk_receivingrk Úend_http_chunk_receivingrÕ rG r r» r rÖ re )rw rK rÇ rL ÚrequiredÚ chunk_lenrá ÚiÚsize_bÚextÚexcÚsizer ÚtrailersÚ raw_trailerss rX rÛ zHttpPayloadParser.feed_dataC s¨ ð ::×0Ñ0Ò 0Ø||HÜE
|
Ià9Ò$Ø '¨)Ñ 3 Ø ×&Ñ& u¨iÔ8Ø<< 1Ò$ØLL×)Ñ)Ô+Ø$à Ø ×&Ñ& u¨Y¨hÐ'7¸ÔBØ ×%Ñ%Ô'ØU 8 9Ð -Ð-Ð-ðV ðQ ZZ:×3Ñ3Ó 3Ø× Ò Ø ×(Ñ(¨5Ñ0Ø#&Ô âð ;;¤*×"?Ñ"?Ó?Ø ** S/CØaxØ !JJ y°!°SÓ 9Ø 6Ø%*¨2¨A YFà $°°a¸° Ð)<¨Ñ =Ü&;Ø&HÈÈÐ$Pó'" ô !.¨d¯l©l¸CÔ @Ø&) à%*¨4¨C [Fà 99Ø%+§\¡\£^Fä !||¬I°vÔ >Ü"7Ø % d s × 2Ñ 2°7Ð<MÓ Nó# Cô *¨$¯,©,¸Ô <Ø"%IÜ "¤5¨£=°"Ó 5à % c¬C°«H¡nÐ&6Ð 7Ø 19Ü*4×*CÑ*CDKØ #yy¨U×-=Ñ-=¸eÔ-DØ(-¨a¨b¨ ¡ä*4×*HÑ*HDKØ/3DÔ ,Ø LL× CÑ CÕ Eà+0Ô(Ø )ð ;;¤*×"@Ñ"@Ò@Ø #× /Ñ /HÜ # E£
|
Ià )Ò+Ø+3°iÑ+?Ô(Ø ×.Ñ.¨u°iÔ@Ø )à+,Ô(Ø ×.Ñ.¨u°Y°hÐ/?ÀÔJØ % h iÐ 0Ü&0×&HÑ&H Ø ×=Ñ=Ô?ð ;;¤*×"DÑ"DÒDØyy U×%5Ñ%5°eÔ%<Ø % a b Ø Zs 3xÐ(¨CÒ/Ø %¤c¨#£h jÐ 1Ü&0×&CÑ&C à+0Ô(Ø )à;;¤*×";Ñ";Ò;Ø ** S/CØQwØ+0Ô(Ø )à #;DØ ! #¬¨C«¡.Ð"2Ð 3EØe|Ø #{{¨5Ó 1Ø×'Ñ'×.Ñ.¨tÔ4ð ×*Ñ*¨2Ñ.°#Ò5ð8Ø59×5IÑ5I×5WÑ5WØ $× 3Ñ 3ó6 Ñ 2H lð !× /Ñ /× 5Ñ 5Ô 7Ø ×-Ñ-Ô/Ø # U{Ð*ó{ ðF ð ZZ:×5Ñ5Ò 5Ø LL× "Ñ " 5¬#¨e«*Ô 5àøð !× /Ñ /× 5Ñ 5Õ 7ús Ñ4(T Ô T8)NFNNNTTF©rs N)r< ó ;)rP rQ rR r4 r r\ rU rS r6 rx rà r r r rÛ rV rW rX rØ rØ sÝ ð !%Ø Ø%)Ø "Ø $Ø#'Ø $Øñ0$à ð0$ð ð0$ð ð 0$ð
|
c]ð 0$ð smð 0$ð ð0$ð !ð0$ð ð0$ð ð0$ð &ð0$ð
|
ó0$ód
|
ð EIñ}Øð}Ø!%ð}Ø<Að}à tU{Ñ ô}rW rØ c ó e Zd ZU dZeed< efdedee de
|
ddfdZ e fd e d
|
e ddfd Zd ed e
|
ddfdZddZddZddZy)rH zDDeflateStream decompress stream and feed data into specified stream.Ú decompressorÚoutrÿ Úmax_decompress_sizers Nc óF || _ d| _ | j |_ || _ d| _ | |dk( r(t
|
s t d« t « | _ || _ y |dk( r(t s t d« t « | _ || _ y t |¬« | _ || _ y )Nr Frî zECan not decode content-encoding: brotli (br). Please install `Brotli`rð zRCan not decode content-encoding: zstandard (zstd). Please install `backports.zstd`)rÿ ) r` rY Útotal_compressed_bytesrÿ Ú_started_decodingr r* r r_ r r r Ú_max_decompress_size)rw r` rÿ ra s rX rx zDeflateBuffer.__init__È s± ð Ø Ø%)§Y¡YÔ"Ø Ø!&Ô á Ø tÒ Ý Ü*ð.óð ô !3Ó 4DÔ ð %8Õ!ð Ò ÝÜ*ð6óð ô !1Ó 2DÔ ð %8Õ!ô !1¸(Ô CDÔ à$7Õ!rW rX Ú exc_causec ó2 t | j ||« y ru )r& r` )rw rX rf s rX r& zDeflateBuffer.set_exceptionè s ô
|
dhh YÕ/rW rK rY c óL |sy | xj |z c_ | j | j _ | j s6| j dk( r'|d dz dk7 r t | j d¬« | _ | j j || j dz ¬« }d| _ t |« | j kD rt d
|
| j z « |r&| j j |t |« « y y # t $ r t d | j z « w xY w) Nrñ r é é T)rÿ Úsuppress_deflate_headerr )Ú
|
max_lengthz#Can not decode content-encoding: %sz:Decompressed data exceeds the configured limit of %d bytes)rY r` rc rd rÿ r r_ Údecompress_syncre rÄ r* r r, rÛ )rw rK rY s rX rÛ zDeflateBuffer.feed_dataï s ÙØ à TÑ Ø*.¯)©)Ô'ð ×&Ò&Ø Ò*Øa3 !Ò#ô !1Ø Àô!DÔ ð à×%Ñ%×5Ñ5Ø $×";Ñ";¸aÑ"?ð 6ó Eð "&Ô ô u:×1Ñ1Ò 1Ü%ØLØ×+Ñ+ñ,óð ñ
|
Ø HH× Ñ u¤c¨%£jÕ 1ð øô ò Ü&Ø5¸¿ ¹ ÑEóð ð ús Á7*D Ä"D#c ó8 | j j « }|s| j dkD rU| j j |t |« « | j dk( r!| j j s t d« | j j « y )Nr rñ )
|
r_ ÚflushrY r` rÛ r rÿ rä r* rà )rw rK s rX rà zDeflateBuffer.feed_eof sp Ø×!Ñ!×'Ñ'Ó)á DII MØ HH× Ñ u¤c¨%£jÔ 1Ø}} Ò)°$×2CÑ2C×2GÒ2GÜ*¨9Ó5Ð5à ×ÑÕrW c ó8 | j j « y ru )r` rQ rÅ s rX rQ z(DeflateBuffer.begin_http_chunk_receiving$ s Ø ×+Ñ+Õ-rW c ó8 | j j « y ru )r` rR rÅ s rX rR z&DeflateBuffer.end_http_chunk_receiving' s Ø ×)Ñ)Õ+rW r\ )rP rQ rR r0 r rT r r4 r rS r\ rx r rÜ r& r rÛ rà rQ rR rV rW rX rH rH à s
ÙNàÓð $?ñ 8à ð 8ð 3-ð 8ð !ð 8ð
|
|
ó 8ðF $1ñ0à ð0ð !ð0ð
|
ó 0ð)2uð )2¨Cð )2°Dó )2óV ó.ô,rW rH )r8 r9 r: r; )kr
|
r rP ÚstringÚ
|
contextlibr Úenumr Útypingr r r r r r
|
r r r r r r r r Ú multidictr r r Úyarlr r¡ r Ú base_protocolr Úcompression_utilsr r r r r r Úhelpersr r! r" r# r$ r% r& Úhttp_exceptionsr' r( r) r* r+ r, r- r. r/ r0 Ú http_writerr1 r2 Ústreamsr3 r4 Útypedefsr5 Ú__all__r ÚsetÚ printabler> rS rT Úescaper? Úcompiler@ ÚASCIIrA rB rC r r: r; r] r_ rg r6 rU r© ÚABCr7 r8 r9 rØ rH ÚHttpRequestParserPyÚHttpResponseParserPyÚRawRequestMessagePyÚRawResponseMessagePyÚ _http_parserÚHttpRequestParserCÚHttpResponseParserCÚRawRequestMessageCÚRawResponseMessageCÚ ImportErrorrV rW rX ú<module>r ss ðÜ
|
Û Û Û Ý Ý ÷÷ ÷ ÷ ÷" :Ñ 9Ý å Ý '÷÷ ÷÷ ñ ÷ ÷ ÷ ÷ 4ß 0Ý ð ð ~Ñ á × 0Ñ 0Ó 1%C/Ó 1ð (biiÐ(9Ó :sÓ :Ø )rzz¨J°Ð6GÀrÐ*JÓ Kws|Ñ Ó KØ (bjjÐ);¸R¿X¹XÓ FgclÑÓ FØ (bjj¨°·±Ó :gclÑÓ :Ø#- 2§:¡:Ð.>Ó#? 5 Ñ Ó ?ô
|
|
ô
|
ô ô ñ Ð*Ð,>Ó?ôô ôô ÷i?ñ i?ðX=Ð#3°CÑ#8ð =¸Tó =ôJ ' %.ô J ôZ
|
cH
|
Ð#4Ñ5ô cHôLVPÐ$6Ñ7ô VP÷r|ñ |÷~e,ñ e,ðP (Ð Ø)Ð Ø'Ð Ø)Ð ð Ù ÷
|
ó
|
ð /ÐØ 0ÐØ .ÐØ 0Ñð øð ò Ùð ús ÈH+ È+H3È2H3
|
