Ë
|
ê^i#% ã ó d dl mZ d dlZd dlZd dlZd dlmZ d dlm Z d dl
|
m Z d dl m Z mZ ddlmZmZ dd lmZ dd
|
lmZ d d lmZ ej0 rdd lmZmZ ej8 e « Z e G d d« « Z G d de« Z y)é )Ú annotationsN)Úcontextmanager)Ú dataclass)Ú HTTPException)ÚBytesIOÚIOBaseé )Ú InvalidHeaderÚ TimeoutError)ÚBaseHTTPResponse)ÚRetryé )ÚEmscriptenRequest)ÚBaseHTTPConnectionÚBaseHTTPSConnectionc ó6 e Zd ZU ded< ded< ded< ded< y )
|
ÚEmscriptenResponseÚintÚ status_codezdict[str, str]ÚheaderszIOBase | bytesÚbodyr ÚrequestN)Ú__name__Ú
|
__module__Ú __qualname__Ú__annotations__© ó õv H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\urllib3/contrib/emscripten/response.pyr r s
àÓØ ÓØ
|
ÓØ Ô r r c óJ e Zd Z d d fd Zedd« Zej dd« Zedd« Zedd« Zej dd« Z d ddZ ddZ
|
d d d Z d dd
|
Z d d Z d d Zed d « Zd dZd dZed d« Z xZS )!Ú EmscriptenHttpResponseWrapperc ó$ d | _ d | _ || _ || _ || _ d| _ t | |j |j |dddd¬« | j | j j j « | _ d| _ y )NFr zHTTP/?Ú T)r ÚstatusÚ request_urlÚversionÚversion_stringÚreasonÚdecode_content)Ú_poolÚ_bodyÚ _responseÚ_urlÚ _connectionÚ_closedÚsuperÚ__init__r r Ú _init_lengthr ÚmethodÚlength_remainingÚlength_is_certain)ÚselfÚinternal_responseÚurlÚ
|
connectionÚ __class__s r r1 z&EmscriptenHttpResponseWrapper.__init__ s ø ð
|
Ø
|
Ø*Ø Ø%ÔØ Ü ÑØ%×-Ñ-Ø$×0Ñ0ØØØ#ØØ ð ô
|
ð !%× 1Ñ 1°$·.±.×2HÑ2H×2OÑ2OÓ PÔ Ø!&Õ r c ó | j S ©N©r- ©r6 s r r8 z!EmscriptenHttpResponseWrapper.url7 s àyyÐr c ó || _ y r< r= )r6 r8 s r r8 z!EmscriptenHttpResponseWrapper.url; s à r c ó | j S r< )r. r> s r r9 z(EmscriptenHttpResponseWrapper.connection? s à× Ñ Ð r c ó | j S r< ©Ú_retriesr> s r Úretriesz%EmscriptenHttpResponseWrapper.retriesC s à}}Ð r c ó || _ y r< rB )r6 rD s r rD z%EmscriptenHttpResponseWrapper.retriesG s ð r c # óD K | j ||¬« }|r| ny w)a_
|
A generator wrapper for the read() method. A call will block until
|
``amt`` bytes have been read from the connection or until the
|
connection is closed.
|
|
:param amt:
|
How much of the content to read. The generator will return up to
|
much data per iteration, but may return less. This is particularly
|
likely when using compressed data. However, the empty string will
|
never be returned.
|
|
:param decode_content:
|
If True, will attempt to decode the body based on the
|
'content-encoding' header.
|
)Úamtr) N©Úread)r6 rG r) Údatas r Ústreamz$EmscriptenHttpResponseWrapper.streamL s- è ø ð$ Ø99 °^9ÓDDáØ
|
àð ùs c ó | j j d« }|\ |j d« D ch c] }t |« }}t |« dkD rt d|z « |j « }|dk rd }nd }| j dv s d| j cxk rdk sn |d k( rd}|S c c}w # t $ r d }Y @w xY w)
|
Nzcontent-lengthú,r z8Content-Length contained multiple unmatching values (%s)r )éÌ i0 éd éÈ ÚHEAD) r ÚgetÚsplitr Úlenr
|
ÚpopÚ
|
ValueErrorr$ )r6 Úrequest_methodÚcontent_lengthÚvalÚlengthsÚlengths r r2 z*EmscriptenHttpResponseWrapper._init_lengthf sÜ à%)§\¡\×%5Ñ%5Ð6FÓ%Gà Ð %ð "ð 0>×/CÑ/CÀCÓ/HÖI¨3s8ÐIÐIÜw< !Ò#Ü'ð1Ø3AñBóð ð ! ð A:Ø !Fð Fð KK:Ñ %ØdkkÔ' CÔ'Ø Ò'àFà ùò1 Jøô ò Ø ð ús" B/ ²B*Á.B/ Â*B/ Â/ B=Â<B=c óî | j sP| j Dt | j j t « r!| j j j
|
ry| j « 5 t | j j t « sYt | j j « | _ d| _ t | j j « | j _ |-|dk\ r(d}| j j j |« }n-| j j j « }|r|| _ | j 't | j t |« z
|
d« | _ t |« dk( s| j r3| j dk( r$| j j j « t j t" |« cd d d « S # 1 sw Y y xY w)Nr Tr F)r/ r, Ú
|
isinstancer r ÚclosedÚ_error_catcherrT r4 r5 r rI r+ ÚmaxÚcloseÚtypingÚcastÚbytes)r6 rG r) Ú cache_contentrJ s r rI z"EmscriptenHttpResponseWrapper.read sj ð LLØ~~Ð%Ü4>>×.Ñ.´Ô7¸D¿N¹N×<OÑ<O×<VÒ<Vàà × Ñ Ó "ñ ,ä dnn× 1Ñ 1´6Ô:Ü(+¨D¯N©N×,?Ñ,?Ó(@Ô%Ø)-Ô&ä&-¨d¯n©n×.AÑ.AÓ&BÔ#Ø 3¨!¢8à % Ø~~×*Ñ*×/Ñ/°Ó4à~~×*Ñ*×/Ñ/Ó1Ù Ø!%DJØ×$Ñ$Ð0Ü(+¨D×,AÑ,AÄCÈÃIÑ,MÈqÓ(QÔ%Ü4yA~Ø×&Ò&¨4×+@Ñ+@ÀAÒ+Eð ×#Ñ#×)Ñ)Ô+Ü;;u dÓ+÷- ,÷ ,ò ,ús Á.E3G+Ç+G4c # ó@ K | j ||« }|sy | wr< rH )r6 rG r) rd s r Ú read_chunkedz*EmscriptenHttpResponseWrapper.read_chunked° s+ è ø ð ØIIc >Ó2EÙØØKð ùs c ó | j r | j sy | j j | j « d | _ y r< )r* r. Ú _put_connr> s r Ú release_connz*EmscriptenHttpResponseWrapper.release_conn¼ s4 Øzz ×!1Ò!1Øà
|
|
× Ñ T× -Ñ -Ô.Ø Õr c ó$ | j « y r< )ra r> s r Ú
|
drain_connz(EmscriptenHttpResponseWrapper.drain_connà s Ø
|
|
r c óV | j r | j S | j d¬« S )NT)re )r+ rI r> s r rJ z"EmscriptenHttpResponseWrapper.dataÆ s$ à ::Ø::Ð à99¨49Ó0Ð 0r c ób | j j d« }t j |« S )aÄ
|
Deserializes the body of the HTTP response as a Python object.
|
|
The body of the HTTP response must be encoded using UTF-8, as per
|
`RFC 8529 Section 8.1 <https://www.rfc-editor.org/rfc/rfc8259#section-8.1>`_.
|
|
To use a custom JSON decoder pass the result of :attr:`HTTPResponse.data` to
|
your custom decoder instead.
|
|
If the body of the HTTP response is not decodable to UTF-8, a
|
`UnicodeDecodeError` will be raised. If the body of the HTTP response is not a
|
valid JSON document, a `json.JSONDecodeError` will be raised.
|
|
Read more :ref:`here <json_content>`.
|
|
:returns: The body of the HTTP response as a Python object.
|
zutf-8)rJ ÚdecodeÚ_jsonÚloads)r6 rJ s r Újsonz"EmscriptenHttpResponseWrapper.jsonÍ s' ð$ yy× Ñ Ó(Ü{{4Ó Ð r c ó | j s}t | j j t « r$| j j j « | j r!| j j « d | _ d| _ y y )NT)r/ r] r, r r ra r. r> s r ra z#EmscriptenHttpResponseWrapper.closeâ sb Ø||Ü$..×-Ñ-¬vÔ6Ø×#Ñ#×)Ñ)Ô+Ø× Ò Ø× Ñ ×&Ñ&Ô(Ø#'Ô Ø DLð r c # óø K ddl m}m} d} d d} |syt | j j t « rD| j j j s$| j j j « | j « yt | j j t « r2| j j j r| j « yyy# |$ r}t t |« « d}~w|$ r}t t |« « d}~ww xY w# |syt | j j t « rD| j j j s$| j j j « | j « w t | j j t « r2| j j j r| j « w w w xY ww)zý
|
Catch Emscripten specific exceptions thrown by fetch.py,
|
instead re-raising urllib3 variants, so that low-level exceptions
|
are not leaked in the high-level api.
|
|
On exit, release the connection back to the pool.
|
r )Ú _RequestErrorÚ _TimeoutErrorFNT) Úfetchru rv r Ústrr r] r, r r r^ ra rj )r6 ru rv Ú
|
clean_exitÚes r r_ z,EmscriptenHttpResponseWrapper._error_catcherë sv è ø ÷ 8à
|
ð (Û ð Jñ ô t~~× 2Ñ 2´FÔ;Ø NN× /Ñ /× 6Ò 6àNN×'Ñ'×-Ñ-Ô/à×!Ñ!Õ#ô
|
t~~× 2Ñ 2´FÔ;Ø ×+Ñ+×2Ò2à×%Ñ%Õ'ð 3ð <øð+ ò 'Ü s 1vÓ&Ð &ûØ ò (Ü ¤ A£Ó'Ð 'ûð (ûñ
|
ô t~~× 2Ñ 2´FÔ;Ø NN× /Ñ /× 6Ò 6àNN×'Ñ'×-Ñ-Ô/à×!Ñ!Õ#ô
|
t~~× 2Ñ 2´FÔ;Ø ×+Ñ+×2Ò2à×%Ñ%Õ'ð 3ð <üsA G:C' CG:Ã'D!Ã,D Ä D!ÄD Ä D!Ä!D$ Ä$CG7Ç7G:)NN)r7 r r8 ú
|
str | Noner9 ú/BaseHTTPConnection | BaseHTTPSConnection | None)Úreturnr{ )r8 r{ r} ÚNone)r} r| )r} ú Retry | None)rD r r} r~ )i N)rG ú
|
int | Noner) ú bool | Noner} ztyping.Generator[bytes])rW r{ r} r )NNF)rG r r) r re Úboolr} rd )r} r~ )r} rd )r} z
|
typing.Any)r} ztyping.Generator[None])r r r r1 Úpropertyr8 Úsetterr9 rD rK r2 rI rg rj rl rJ rr ra r r_ Ú __classcell__)r: s @r r! r! s_ ø ð ØFJð 'à-ð'ð ð'ð Dõ 'ð0 òó ðð ZZòó ðð ò ó ð ð ò ó ð ð ^^ò ó ð ð
|
FJðØ ðØ7Bðà óó4#ðN Ø&*Ø #ð #,à ð#,ð $ð#,ð ð #,ð
|
|
ó #,ðN Ø&*ð
|
à ð
|
ð $ð
|
ð
|
!ó
|
ó óð ò1ó ð1ó !ó* ð ò)(ó ô)(r r! )!Ú
|
__future__r rr rp Úloggingrb Ú
|
contextlibr Ú dataclassesr Ú http.clientr Úior r Ú
|
exceptionsr
|
r Úresponser Ú
|
util.retryr r r Ú TYPE_CHECKINGÚ_base_connectionr r Ú getLoggerr Úlogr r! r r r ú<module>r so ðÝ "ã Û Û Ý %Ý !Ý 6ß ç 5Ý (Ý Ý &à ×ÒßKàg×ÑÓ!ð ÷ ð ó ð ôw(Ð$4õ w(r
|
