U
f!' @ s 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 ejrdd
lmZmZ e e Z e G dd dZ G dd deZ dS ) ) annotationsN)contextmanager) dataclass)
HTTPException)BytesIOIOBase )
InvalidHeader TimeoutError)BaseHTTPResponse)Retry )EmscriptenRequest)BaseHTTPConnectionBaseHTTPSConnectionc @ s. e Zd ZU ded< ded< ded< ded< d S )
EmscriptenResponseint status_codezdict[str, str]headerszIOBase | bytesbodyr requestN)__name__
__module__ __qualname____annotations__ r r T/opt/alt/python38/lib/python3.8/site-packages/urllib3/contrib/emscripten/response.pyr s
r c s4 e Zd Zd5dddd fdd
Zeddd d
Zejdd d d
d
ZeddddZeddddZejdd dddZd6ddddddZ ddd d d Z
d7ddd d!d"d#d$Z d8ddddd%d&Z d dd'd(Z
d dd)d*Zed!dd+d,Zd-dd.d/Zd dd0d1Zed2dd3d4Z ZS )9 EmscriptenHttpResponseWrapperNr z
str | Nonez/BaseHTTPConnection | BaseHTTPSConnection | None)internal_responseurl
connectionc s^ d | _ d | _|| _|| _|| _d| _t j|j|j |ddddd |
| jj j | _
d| _d S )NFr zHTTP/? T)r status request_urlversionversion_stringreasondecode_content)_pool_body _response_url _connection_closedsuper__init__r r _init_lengthr methodlength_remaininglength_is_certain)selfr r r __class__r r r/ s" z&EmscriptenHttpResponseWrapper.__init__)returnc C s | j S Nr+ r4 r r r r 7 s z!EmscriptenHttpResponseWrapper.urlNone)r r7 c C s
|| _ d S r8 r9 )r4 r r r r r ; s c C s | j S r8 )r, r: r r r r ? s z(EmscriptenHttpResponseWrapper.connectionz Retry | Nonec C s | j S r8 Z_retriesr: r r r retriesC s z%EmscriptenHttpResponseWrapper.retries)r= r7 c C s
|| _ d S r8 r< )r4 r= r r r r= G s z
int | Nonez bool | Nonez#typing.Generator[bytes, None, None])amtr' r7 c c s" | j ||d}|r |V q q q dS )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.
)r? r' Nread)r4 r? r' datar r r streamL s z$EmscriptenHttpResponseWrapper.stream)request_methodr7 c C s | j d}|d k rtz8dd |dD }t|dkrBtd| | }W n tk
rd d }Y qxX |dk rxd }nd }| jdksd | j krd
k sn |d krd}|S ) Nzcontent-lengthc S s h | ] }t |qS r )r ).0valr r r q s z=EmscriptenHttpResponseWrapper._init_length..,r
z8Content-Length contained multiple unmatching values (%s)r ) i0 d HEAD)r getsplitlenr pop
ValueErrorr" )r4 rD content_lengthlengthslengthr r r r0 f s6
z*EmscriptenHttpResponseWrapper._init_lengthFboolbytes)r? r'
cache_contentr7 c
C sz | j s(| jd ks(t| jjtr,| jjjr,dS | : t| jjtsjt| jj| _d| _ t
| jj| j_|d k r|dkrd}| jj |}| jd k rt | jt| d| _| j r| jdkst||k r| jj
tt|W 5 Q R S | jj }|r|| _| jd k r&t | jt| d| _t|dksH| j rT| jdkrT| jj
tt|W 5 Q R S W 5 Q R X d S )N Tr F)r- r*
isinstancer r closed_error_catcherrO r2 r3 r rA maxclosetypingcastrV r) )r4 r? r' rW rB r r r rA sL
z"EmscriptenHttpResponseWrapper.readc c s | ||}|sq|V q d S r8 r@ )r4 r? r' rV r r r read_chunked s z*EmscriptenHttpResponseWrapper.read_chunkedc C s( | j r | jsd S | j | j d | _d S r8 )r( r, _put_connr: r r r release_conn s z*EmscriptenHttpResponseWrapper.release_connc C s | d S r8 )r] r: r r r
drain_conn s z(EmscriptenHttpResponseWrapper.drain_connc C s | j r | j S | jddS d S )NT)rW )r) rA r: r r r rB s z"EmscriptenHttpResponseWrapper.dataz
typing.Anyc C s | j d}t|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 `_.
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 `.
:returns: The body of the HTTP response as a Python object.
zutf-8)rB decode_jsonloads)r4 rB r r r json s z"EmscriptenHttpResponseWrapper.jsonc C s@ | j s N)NNF)NN)r r r r/ propertyr setterr r= rC r0 rA r` rb rc rB rg r] r r[
__classcell__r r r5 r r s@ ' / r )!
__future__r rg re loggingr^
contextlibr dataclassesr http.clientr ior r
exceptionsr r
responser Z
util.retryr r r
TYPE_CHECKINGZ_base_connectionr r getLoggerr logr r r r r r s"