File: //opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/client_reqrep.cpython-38.pyc
U
'�7`W� � @ s8 d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
Z
m Z d dl m
Z
mZmZ d dlmZmZ d dlmZmZmZmZmZmZmZmZm Z m Z m Z d dl Z d dl m!Z!m"Z"m#Z#m$Z$ d dl%m&Z& dd l'm(Z(m)Z)m*Z*m+Z+m,Z, dd
l-m.Z. dd l/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5 dd l6m7Z7 dd
l)m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z? ddl*m@Z@mAZAmBZBmCZC ddlDmEZE ddlFmGZG ddlHmIZImJZJmKZKmLZLmMZM zd dlNZNd dlNmOZO W n ePk
�r� dZNeQZOY nX z d dlRZSW n ePk
�r d dlSZSY nX dZTe�r2ddlUmVZV ddlWmXZX ddlYmZZZ e�[d�Z\e j]dddd�G dd� d��Z^e j]dddd�G d d � d ��Z_G d d � d �Z`eNdk �r�eNjOeae`ebd�fZcnebd�Zce d eae`df eea ed eed e d eae`df d!�d"d#�Zee j]dddd$�G d%d&� d&��Zfegegead'�d(d)�ZhG d*d+� d+�ZiG d,d-� d-e;�ZjdS ).� N)�md5�sha1�sha256)� CookieError�Morsel� SimpleCookie)�MappingProxyType�
TracebackType) �
TYPE_CHECKING�Any�Dict�Iterable�List�Mapping�Optional�Tuple�Type�Union�cast)� CIMultiDict�CIMultiDictProxy� MultiDict�MultiDictProxy)�URL� )�hdrs�helpers�http� multipart�payload)�AbstractStreamWriter)�ClientConnectionError�
ClientOSError�ClientResponseError�ContentTypeError�
InvalidURL�ServerFingerprintMismatch)�FormData)�PY_36�BaseTimerContext� BasicAuth� HeadersMixin� TimerNoop�noop�reify�
set_result)�SERVER_SOFTWARE�
HttpVersion10�
HttpVersion11� StreamWriter)�
client_logger)� StreamReader)�DEFAULT_JSON_DECODER� JSONDecoder� LooseCookies� LooseHeaders�
RawHeaders)�
SSLContext)�
ClientRequest�ClientResponse� RequestInfo� Fingerprint)�
ClientSession)�
Connection)�Tracez!^application/(?:[\w.+-]+?\+)?jsonT)� auto_attribs�frozen�slotsc @ s. e Zd ZU ee ed< ded< ee ed< dS )�ContentDisposition�typezMappingProxyType[str, str]�
parameters�filenameN)�__name__�
__module__� __qualname__r �str�__annotations__� rO rO �H/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/client_reqrep.pyrF W s
rF c @ sJ e Zd ZU eed< eed< ded< e�� Zeed< ej ed�dd��Z
d S )
r> �url�method�CIMultiDictProxy[str]�headers�real_url��returnc C s | j S �N)rQ ��selfrO rO rP �real_url_defaulte s z RequestInfo.real_url_defaultN) rJ rK rL r rN rM �attrZibrU �defaultr[ rO rO rO rP r> ^ s
r> c @ sL e Zd Zeeed�Zedd�dd�Ze ed�dd��Z
e j dd �d
d �Z
dS ) r? )� � � N)� fingerprintrW c C sJ t |�}| j�|�}|s"td��n|tks2|tkr:td��|| _|| _d S )Nz fingerprint has invalid lengthz8md5 and sha1 are insecure and not supported. Use sha256.)�len�HASHFUNC_BY_DIGESTLEN�get�
ValueErrorr r � _hashfunc� _fingerprint)rZ ra Z digestlenZhashfuncrO rO rP �__init__q s
�zFingerprint.__init__rV c C s | j S rX )rg rY rO rO rP ra } s zFingerprint.fingerprint)� transportrW c C s` |� d�sd S |� d�}|jdd�}| �|��� }|| jkr\|� d�^}}}t| j|||��d S )NZ
sslcontextZ
ssl_objectT)Z binary_formZpeername)Zget_extra_infoZ getpeercertrf �digestrg r& )rZ ri ZsslobjZcertZgot�host�port�_rO rO rP �check� s
zFingerprint.check)rJ rK rL r r r rc �bytesrh �propertyra �asyncioZ Transportrn rO rO rO rP r? j s � r? r; )�ssl�
verify_ssl� ssl_contextra rW c C s� |d k r2|s2t jdtdd� | d k r.td��nd} |d k r`t jdtdd� | d k r\td��n|} |d k r�t jdtdd� | d k r�td��nt|�} t| t�s�td�| ���| S ) Nz/verify_ssl is deprecated, use ssl=False instead� ��
stacklevelzNverify_ssl, ssl_context, fingerprint and ssl parameters are mutually exclusiveFz2ssl_context is deprecated, use ssl=context insteadzCfingerprint is deprecated, use ssl=Fingerprint(fingerprint) insteadzFssl should be SSLContext, bool, Fingerprint or None, got {!r} instead.) �warnings�warn�DeprecationWarningre r? �
isinstance�SSL_ALLOWED_TYPES� TypeError�format)rr rs rt ra rO rO rP �_merge_ssl_params� sP ������
��r )rC rE rD c @ sb e Zd ZU eed< ee ed< eed< ee dee
f ed< ee ed< ee ed< ee ed< dS ) �
ConnectionKeyrk rl �is_sslNrr �proxy�
proxy_authZproxy_headers_hash)
rJ rK rL rM rN r �int�boolr r; r? r r* rO rO rO rP r� � s
r� )�response_content_type�expected_content_typerW c C s |dkrt �| �d k S || kS )N�application/json)�json_re�match)r� r� rO rO rP �_is_expected_content_type� s r� c @ s� e Zd ZejejejejhZej ej
ej hZ e�
e ��
ejh�ZejdejdiZdZdZdZdZdZdde� dddejddddddddddddd�ee e e eef e e e e e!e e" e e# ej$e e e e% e%e e&j' e e(d e e e e# e e) e d e*e+e%e,df e e e e-d d
�d d �Z.e%d
�dd�Z/e0e*dde%e,f d
�dd��Z1e0e2d
�dd��Z3e0ed
�dd��Z4e0e e5 d
�dd��Z6e0e7d
�dd��Z8e dd�d d �Z9e*ej$ef dd �d d �Z:e e dd!�d"d#�Z;e e dd$�d%d&�Z<e e" dd'�d(d)�Z=e!dd*�d+d,�Z>dd
�d-d.�Z?e e# dd/�d0d1�Z@e!dd2�d3d4�ZAdKe%dd5�d6d7�ZBe e e e# e e dd8�d9d:�ZCe%d
�d;d<�ZDeEd=dd>�d?d@�ZFd=ddA�dBdC�ZGdd
�dDdE�ZHdd
�dFdG�ZIee eJddH�dIdJ�ZKdS )Lr< z*/*z
gzip, deflate� NF)�paramsrT �skip_auto_headers�data�cookies�auth�version�compress�chunked� expect100�loop�response_classr� r� �timer�sessionrr �
proxy_headers�tracesr= r@ rB )rR rQ r� rT r� r� r� r� r� r� r� r� r� r� r� r� r� r� rr r� r� c C s� |
d krt �� }
t|t�s"t|��t|ttd �f�s<t|��td|�| _|rvt|j �}|�
|�}|� |j � |�
|�}|| _ |�
d �| _|�� | _| | _|
| _|
| _d | _|d kr�t}n|}|| _|d k r�|nt� | _|| _|
�� r�t� t � d��| _ | � | � | �!|� | �"|� | �#|� | �$|� | �%|� | �&|� | �'|||� | �(|� |�sh| j| j)k�rp| �*� | �+| � |d k�r�g }|| _,d S )Nr@ r )-rq Zget_event_loopr{ r �AssertionErrorrG r �_sessionr �queryZ
with_query�extend� original_url�
with_fragmentrQ �upperrR r� r� r� �lengthr= r� r, �_timer�_ssl� get_debug� traceback�
extract_stack�sys� _getframe�_source_traceback�update_version� update_host�update_headers�update_auto_headers�update_cookies�update_content_encoding� update_auth� update_proxy�update_body_from_data� GET_METHODS�update_transfer_encoding�update_expect_continue�_traces)rZ rR rQ r� rT r� r� r� r� r� r� r� r� r� r� r� r� r� r� rr r� r� �qZurl2Zreal_response_classrO rO rP rh � sP
zClientRequest.__init__rV c C s | j jdkS )N)�https�wss)rQ �schemerY rO rO rP r� A s zClientRequest.is_sslr; c C s | j S rX )r� rY rO rO rP rr D s zClientRequest.sslc C sL | j }|r&ttdd� |�� D ���}nd }t| j| j| �� | j| j | j
|�S )Nc s s | ]\}}||fV qd S rX rO )�.0�k�vrO rO rP � <genexpr>M s z/ClientRequest.connection_key.<locals>.<genexpr>) r� �hash�tuple�itemsr� rk rl r� rr r� r� )rZ r� �hrO rO rP �connection_keyH s ��z ClientRequest.connection_keyc C s | j j}|d k st�|S rX )rQ �raw_hostr� )rZ �retrO rO rP rk [ s zClientRequest.hostc C s | j jS rX )rQ rl rY rO rO rP rl a s zClientRequest.portc C s t | j�}t| j| j|| j�S rX )r rT r> rQ rR r� )rZ rT rO rO rP � request_infoe s
zClientRequest.request_info)rQ rW c C s6 |j st|��|j|j }}|r2t�||p,d�| _dS )z8Update destination host, port and connection type (ssl).� N)r� r% �user�passwordr r* r� )rZ rQ �usernamer� rO rO rP r� j s
zClientRequest.update_host)r� rW c C sp t |t�rfdd� |�dd�D �}z t�t|d �t|d ��}W n$ tk
rd td|� ��d�Y nX || _dS )zdConvert request version to two elements tuple.
parser HTTP version '1.1' => (1, 1)
c S s g | ] }|� � �qS rO )�strip)r� �partrO rO rP �
<listcomp>{ s z0ClientRequest.update_version.<locals>.<listcomp>�.r r z#Can not parse http version number: N)r{ rM �splitr � HttpVersionr� re r� )rZ r� r� rO rO rP r� u s
��z ClientRequest.update_version)rT rW c C s� t � | _tt| jj�}t�|�r,d|� d�}| jjdk rV| j� � sV|dt| jj� 7 }|| jt
j < |r�t |t
ttf�r~|�� }|D ].\}}|�� dkr�|| j|< q�| j�||� q�dS )zUpdate request headers.�[�]N�:rk )r rT r rM rQ r� r �is_ipv6_addressrl Zis_default_portr ZHOSTr{ �dictr r r� �lower�add)rZ rT �netloc�key�valuerO rO rP r� � s
z ClientRequest.update_headers)r� rW c C sr t dd� t|�D ��| _| j�� }|�| j� | j�� D ] \}}||kr8| j�||� q8t j
|krnt | jt j
< d S )Nc s s | ]}|d fV qd S rX rO )r� �hdrrO rO rP r� � s z4ClientRequest.update_auto_headers.<locals>.<genexpr>) r �sortedr� rT �copyr� �DEFAULT_HEADERSr� r� r Z
USER_AGENTr0 )rZ r� Z used_headersr� �valrO rO rP r� � s �
z!ClientRequest.update_auto_headers)r� rW c C s� |sdS t � }tj| jkr:|�| j�tjd�� | jtj= t|t�rN|�� }n|}|D ]H\}}t|t �r�|�|j
t � �}|� |j
|j |j
� |||< qV|||< qV|jddd��� | jtj< dS )z Update request cookies header.Nr� �;)�header�sep)r r ZCOOKIErT �loadrd r{ r r� r r� �setr� Z coded_value�outputr� )rZ r� �cZ iter_cookies�namer� Zmrsl_valrO rO rP r� � s
z ClientRequest.update_cookies)r� rW c C s` |sdS | j �tjd��� }|r0| jr\td��n,| jr\t| jt�sHd| _| j| j tj< d| _ dS )z Set request content encoding.Nr� z9compress can not be set if Content-Encoding header is set�deflateT)
rT rd r ZCONTENT_ENCODINGr� r� re r{ rM r� )rZ r� �encrO rO rP r� � s � z%ClientRequest.update_content_encodingc C sz | j �tjd��� }d|kr,| jrvtd��nJ| jrTtj| j krFtd��d| j tj< n"tj| j krvtt | j
��| j tj< dS )z!Analyze transfer-encoding header.r� r� zDchunked can not be set if "Transfer-Encoding: chunked" header is setz6chunked can not be set if Content-Length header is setN) rT rd r ZTRANSFER_ENCODINGr� r� re �CONTENT_LENGTHrM rb �body)rZ �terO rO rP r� � s � � z&ClientRequest.update_transfer_encoding)r� rW c C sB |dkr| j }|dkrdS t|tj�s.td��|�� | jtj< dS )zSet basic auth.Nz%BasicAuth() tuple is required instead) r� r{ r r* r} �encoderT r Z
AUTHORIZATION)rZ r� rO rO rP r� � s zClientRequest.update_auth)r� rW c C s� |sd S t |t�r|� }ztjj|d d�}W n tjk
rL t|�� }Y nX || _| js�tj | j
kr�|j }|d kr|d| _n tj | j
kr�t |�| j
tj < |j
s�t
�|j
�� D ]*\}}|| j
kr�q�|| jkr�q�|| j
|< q�d S )N)Z dispositionT)r{ r' r ZPAYLOAD_REGISTRYrd � LookupErrorr� r� r r� rT �sizerM r� r� r� )rZ r� r� r� r� rO rO rP r� � s.
z#ClientRequest.update_body_from_data)�expectrW c C sB |rd| j tj< n | j �tjd��� dkr.d}|r>| j�� | _d S )Nz 100-continuer� T)rT r ZEXPECTrd r� r� Z
create_future� _continue)rZ r� rO rO rP r� s z$ClientRequest.update_expect_continue)r� r� r� rW c C sD |r|j dkstd��|r.t|tj�s.td��|| _|| _|| _d S )Nr z Only http proxies are supportedz,proxy_auth must be None or BasicAuth() tuple)r� re r{ r r* r� r� r� )rZ r� r� r� rO rO rP r� s zClientRequest.update_proxyc C sN | j tk rdS | j tkr4| j�tj�dkr.dS dS n| j�tj�dkrJdS dS )NF�
keep-aliveT�close)r� r1 rT rd r �
CONNECTIONrY rO rO rP �
keep_alive. s
zClientRequest.keep_aliverA )�writer�connrW c
� sb | j dk r$|�� I dH | j I dH |j}|dk s6t��z zjt| jtj�r^| j� |�I dH n6t| jt
t f�rx| jf| _| jD ]}|� |�I dH q~|� � I dH W n� t
k
r� } z,t|jd| j �}||_||_|�|� W 5 d}~X Y nd tjk
�r$ } z|j�s|�|� W 5 d}~X Y n. tk
�rP } z|�|� W 5 d}~X Y nX W 5 d| _X dS )z-Support coroutines that yields bytes objects.Nz!Can not write request body for %s)r� Zdrain�protocolr� �_writerr{ r� r ZPayload�writero � bytearrayZ write_eof�OSErrorr" �errnorQ � __context__� __cause__�
set_exceptionrq �CancelledError�closed� Exception)rZ r� r� r� �chunk�exc�new_excrO rO rP � write_bytes< s6
� zClientRequest.write_bytes)r� rW c � s� | j tjkrJ| jj}|d k s t�t�|�r6d|� d�}|� d| jj� �}n:| j rd| �
� sdt | j�}n | jj }| jj
r�|d| jj
7 }|j}|d k s�t�t|| jt�| j| j | j�d�}| jr�|�| j� | jd k r�|�� | j | jk�rtj| jk�rtj| jk�rd| jtj< | j� tj �}|�sP| � � �r@| j t k�rPd}n| j t!k�rPd}|d k �rf|| jtj < d �"| j || j �}|�#|| j�I d H | j�$| �%||��| _&| j'}|d k �s�t�|| j | j(| j&| j)| j*| j+| j,| j| j-d
� | _.| j.S ) Nr� r� r� �?)Z
on_chunk_sentzapplication/octet-streamr� r� z{0} {1} HTTP/{2[0]}.{2[1]})r� � continue100r� r� r� r� r� )/rR r Z METH_CONNECTrQ r� r� r r� rl r� r� rM Zraw_pathZraw_query_stringr� r3 r� � functools�partial�_on_chunk_request_sentr� Zenable_compressionr� Zenable_chunking� POST_METHODS� CONTENT_TYPEr� rT rd r� r� r� r1 r2 r~ Z
write_headersZ create_taskr r� r� r� r� r� r� r� r� �response) rZ r� Z connect_host�pathr� r� �
connectionZ status_liner� rO rO rP �senda s~
��
�
�
�
�� zClientRequest.sendc � s( | j d k r$z| j I d H W 5 d | _ X d S rX )r� rY rO rO rP r� � s
zClientRequest.closec C s( | j d k r$| j�� s | j �� d | _ d S rX )r� r� � is_closed�cancelrY rO rO rP � terminate� s
zClientRequest.terminate)rR rQ r rW c � s$ | j D ]}|�|||�I d H qd S rX )r� Zsend_request_chunk_sent)rZ rR rQ r �tracerO rO rP r � s
z$ClientRequest._on_chunk_request_sent)F)LrJ rK rL r ZMETH_GETZ METH_HEADZ METH_OPTIONSZ
METH_TRACEr� Z
METH_PATCHZ METH_POSTZMETH_PUTr �unionZ METH_DELETEZ ALL_METHODSZACCEPTZACCEPT_ENCODINGr� r� r� r r� r� � frozensetr r2 rM r r r r9 r
r r8 r* r� r� rq �AbstractEventLoopr r) r r; r? r rh r� rp rr r� r� rk r� rl r> r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r� r ro r rO rO rO rP r< � s� � � �
� J " � � %Nr< c @ st e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ e
eded eeed ejddd�
d d
�Zeed �d d
��Zeed �dd��Zeed �dd��Zee
d �dd��Zedd �dd��Zee d �dd��Z eed �dd��Z eee d �dd ��Z e!fe"dd �d d �Z#e
d �d d!�Z$e%ed" d �d#d$��Z&ee'd% d �d&d'��Z(ed(d �d)d*��Z)d"d d+�d,d-�Z*dd �d.d/�Z+e%e,d �d0d1��Z-dd �d2d3�Z.e"d �d4d5�Z/e%e,d �d6d7��Z0dd �d8d9�Z1dd �d:d;�Z2dd �d<d=�Z3dd �d>d?�Z4e5d �d@dA�Z6e
d �dBdC�Z7dRee
e
e
dE�dFdG�Z8de9dHdI�ee
e:ee
e"dJ�dKdL�Z;d d �dMdN�Z<ee=e> ee> ee? ddO�dPdQ�Z@dS )Sr= NTFzasyncio.Task[None]zasyncio.Future[bool]rB r@ )
rR rQ r� r r� r� r� r� r� rW c
C s� t |t�st�|| _t� | _|| _|�d �| _d | _ || _
|| _ d| _ d| _
|| _|d k r^|nt� | _i | _|| _|| _| | _|�� r�t�t�d��| _d S )NTrO r )r{ r r� rR r r� � _real_urlr� �_url�_bodyr� r� �_closed�_history�
_request_infor, r� �_cacher� �_loopr� r� r� r� r� r� r� )
rZ rR rQ r� r r� r� r� r� r� rO rO rP rh � s$
zClientResponse.__init__rV c C s | j S rX )r rY rO rO rP rQ � s zClientResponse.urlc C s t jdtdd� | jS )NzDeprecated, use .url #1654� rv )rx ry rz r rY rO rO rP �url_obj� s zClientResponse.url_objc C s | j S rX )r rY rO rO rP rU � s zClientResponse.real_urlc C s | j jd k st�| j jS rX )r rk r� rY rO rO rP rk s zClientResponse.hostrS c C s | j S rX )�_headersrY rO rO rP rT s zClientResponse.headersc C s | j S rX )� _raw_headersrY rO rO rP � raw_headers s zClientResponse.raw_headersc C s | j S rX )r! rY rO rO rP r� s zClientResponse.request_infoc C sF | j �tj�}|d krd S t�|�\}}t|�}t�|�}t|||�S rX ) r& rd r ZCONTENT_DISPOSITIONr Zparse_content_dispositionr Z content_disposition_filenamerF )rZ �rawZdisposition_typeZ
params_dctr� rI rO rO rP �content_disposition s
z"ClientResponse.content_disposition)� _warningsrW c C s� | j r
d S | jd k r~| j�� | �� | j�� r~tr>d| i}ni }|jd| ��tf|� | dd�}| j rr| j |d< | j�
|� d S )N�sourcezUnclosed response zUnclosed response)Zclient_response�messageZsource_traceback) r � _connection�release�_cleanup_writerr# r� r( ry �ResourceWarningr� Zcall_exception_handler)rZ r+ �kwargs�contextrO rO rP �__del__ s
zClientResponse.__del__c C sb t �� }t| j�}| jr.| j�dd��d�}n| j}td�|| j |�|d� t| j
|d� |� � S )N�ascii�backslashreplacez <ClientResponse({}) [{} {}]>)�file) �io�StringIOrM rQ �reasonr� �decode�printr~ �statusrT �getvalue)rZ �outZascii_encodable_urlZascii_encodable_reasonrO rO rP �__repr__1 s(
�� ��zClientResponse.__repr__rA c C s | j S rX )r. rY rO rO rP r C s zClientResponse.connection)r= .c C s | j S )z2A sequence of of responses, if redirects occurred.)r rY rO rO rP �historyG s zClientResponse.historyz/MultiDictProxy[MultiDictProxy[Union[str, URL]]]c
C s� d� | j�dg ��}|s"tt� �S t� }t�d|�D ]�}t�d|�}|d krNq4|�� \}}|�d�dd � }t� }|D ]:} t�d| tj �}|d kr�qv|�� \}
} } } |�
|
| � qv|� d|�}
|�
d | j � t
|��� |�
|
t|�� q4t|�S )
Nz, �linkz ,(?=\s*<)z
\s*<(.*)>(.*)r� r z%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$�relrQ )�joinrT �getallr r �rer� r� �groups�Mr� rd rQ r )
rZ Z links_str�linksr� r� rQ Z
params_strr� rB �paramr� rm r� rO rO rP rI L s*
zClientResponse.links)r rW c � sX d| _ |j| _|| _| j�� z| j�� I dH \}}W nB tjk
rv } z"t| j | j
|j |j |j
d�|�W 5 d}~X Y nX |j dk s�|j dks�|j dkr�q�| jdk r t| jd� d| _q W 5 Q R X |�| j� |j| _|j | _|j| _|j
| _|j| _|| _| j
�tjd�D ]H}z| j � |� W n0 t k
�rN } zt � d |� W 5 d}~X Y nX �q
| S )
zStart response processing.FN�r= r- rT �d �� �e TrO z!Can not load response cookies: %s)!r r� Z _protocolr. r� �readr ZHttpProcessingErrorr# r� rA �coder- rT r� r/ Zon_eof�
_response_eofr� r= r: r& r( r' �contentrE r Z
SET_COOKIEr� r� r r4 �warning)rZ r r- r r r� rO rO rP �startp sD ��
"zClientResponse.startc C sP | j r
d S | jd k r>| jjd k r.| jjjr.d S | j�� d | _d| _ | �� d S �NT)r r. r� Zupgradedr/ r0 rY rO rO rP rQ � s
��
z ClientResponse._response_eofc C s | j S rX )r rY rO rO rP r � s zClientResponse.closedc C s\ | j s| �� | jrd S d| _| jd ks2| j�� r6d S | jd k rP| j�� d | _| �� d S rU )� _released�_notify_contentr r# r r. r� r0 rY rO rO rP r� � s
zClientResponse.closec C sH | j s| �� | jrt� S d| _| jd k r:| j�� d | _| �� t� S rU )rV rW r r- r. r/ r0 rY rO rO rP r/ � s
zClientResponse.releasec C s( z | � � W n tk
r" Y dS X dS )z�Returns ``True`` if ``status`` is less than ``400``, ``False`` if not.
This is **not** a check for ``200 OK`` but a check that the response
status is under 400.
FT)�raise_for_statusr# rY rO rO rP �ok� s
zClientResponse.okc C s@ d| j kr<| jd k st�| �� t| j| j| j | j| jd��d S )Ni� rK )r= r: r� r/ r# r� rA rT rY rO rO rP rX � s
�z ClientResponse.raise_for_statusc C s$ | j d k r| j �� d | _ d | _d S rX )r� r r� rY rO rO rP r0 � s
z ClientResponse._cleanup_writerc C s. | j }|r$|�� d kr$|�td�� d| _d S )N�Connection closedT)rR � exceptionr r! rV )rZ rR rO rO rP rW � s z ClientResponse._notify_contentc � s0 | j d k r$z| j I d H W 5 d | _ X | �� d S rX )r� r/ rY rO rO rP �wait_for_close� s
z ClientResponse.wait_for_closec � s| | j dkrhz<| j�� I dH | _ | jD ] }|�| j| j| j �I dH q$W qv tk
rd | �� � Y qvX n| j rvt
d��| j S )zRead response payload.NrZ ) r rR rO r� Z send_response_chunk_receivedrR rQ �
BaseExceptionr� rV r! )rZ r rO rO rP rO s
�
zClientResponse.readc C s� | j �tjd��� }t�|�}|j�d�}|rVzt� |� W n t
k
rT d }Y nX |s�|j dkr~|j dksx|j dkr~d}n$| j
d kr�td��nt�| j
�d }|s�d}|S ) Nr� �charsetZ application�jsonZrdapzutf-8z0Cannot guess the encoding of a not yet read body�encoding)rT rd r r r� r Zparse_mimetyperH �codecs�lookupr� rG �subtyper � RuntimeError�chardet�detect)rZ �ctypeZmimetyper` rO rO rP � get_encoding s.
��
�zClientResponse.get_encoding�strict)r` �errorsrW c � s8 | j dkr| �� I dH |dkr(| �� }| j j||d�S )z!Read response payload and decode.N)rj )r rO rh r; )rZ r` rj rO rO rP �text1 s
zClientResponse.textr� )r` �loads� content_type)r` rl rm rW c � s� | j dkr| �� I dH |rT| j�tjd��� }t||�sTt| j | j
d| | jd��| j � � }|sfdS |dkrv| � � }||�
|��S )z Read and decodes JSON response.Nr� z3Attempt to decode JSON with unexpected mimetype: %s)r- rT )r rO rT rd r r r� r� r$ r� rA r� rh r; )rZ r` rl rm rg �strippedrO rO rP r_ ; s"
�
zClientResponse.jsonc � s | S rX rO rY rO rO rP �
__aenter__[ s zClientResponse.__aenter__)�exc_type�exc_val�exc_tbrW c � s | � � d S rX )r/ )rZ rp rq rr rO rO rP � __aexit__^ s zClientResponse.__aexit__)Nri )ArJ rK rL r� r= r: rR r& r' r. r� r rV rM r r r) r> r rq r rh r. rQ r% rU rk rT r: r( r� rF r* rx r r4 r@ rp r r rA rI rT rQ r� r r� r/ rY rX r0 rW r\ ro rO rh rk r6 r7 r_ ro r r] r rs rO rO rO rP r= � s� � # #2
��
�r= )krq ra r r8 rF r� r� rx Zhashlibr r r Z http.cookiesr r r �typesr r �typingr
r r r
r r r r r r r r\ Z multidictr r r r Zyarlr r� r r r r r �abcr Zclient_exceptionsr! r" r# r$ r% r& Zformdatar' r( r) r* r+ r, r- r. r/ r0 r1 r2 r3 �logr4 Zstreamsr5 Ztypedefsr6 r7 r8 r9 r: rr r; � ImportError�object�cchardetre �__all__Zclientr@ Z connectorrA �tracingrB �compiler� �srF r> r? r� rG r| ro r r� rM r� r< r= rO rO rO rP �<module> s� 4 (
"
� 5
� h