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 Zdigestrg r& )rZ ri ZsslobjZcertZgot�host�port�_rO rO rP �check� s
zFingerprint.check)rJ rK rL r r r rc �bytesrh �propertyra �asyncioZ Transportrm 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)rq rr rs 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 ) �
ConnectionKeyrj rk �is_sslNrq �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�sessionrq �
proxy_headers�tracesr= r@ rB )rR rQ r� rT r� r� r� r� r� r� r� r� r� r� r� r� r� r� rq 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 )-rp Zget_event_looprz r �AssertionErrorrG r �_sessionr ZqueryZ
with_query�extend� original_url�
with_fragmentrQ �upperrR r� r� r� Zlengthr= 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� rq r� r� �qZurl2Zreal_response_classrO rO rP rh � sP
zClientRequest.__init__rV c C s | j jdkS )N)ZhttpsZwss)rQ �schemerY rO rO rP r� A s zClientRequest.is_sslr; c C s | j S rX )r� rY rO rO rP rq 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 rj rk r� rq 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 ZretrO rO rP rj [ s zClientRequest.hostc C s | j jS rX )rQ rk rY rO rO rP rk 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 Zusernamer� 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)rz 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�:rj )r rT r rM rQ r� r �is_ipv6_addressrk Zis_default_portr ZHOSTrz �dictr r r� �lower�add)rZ rT Znetloc�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 rz 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 setZdeflateT)
rT rd r ZCONTENT_ENCODINGr� r� re rz 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 ZterO 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� rz 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)rz 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 rz 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� �_writerrz r� r ZPayload�writern � bytearrayZ write_eof�OSErrorr" �errnorQ � __context__� __cause__�
set_exceptionrp ZCancelledError�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� rk 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� rp �AbstractEventLoopr r) r r; r? r rh r� ro rq r r� rj r� rk r> r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r r� r rn 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 )rz 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� ru )rw rx ry 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 rj r� rY rO rO rP rj 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( rx �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*$ZrelrQ )�joinrT �getallr r �rer� r� �groups�Mr� rd rQ r )
rZ Z links_str�linksr� r� rQ Z
params_strr� r7 Zparamr� rl r� rO rO rP r= 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�r2 r" rT �d �� �e TrO z!Can not load response cookies: %s)!r r� Z _protocolr# r� �readr ZHttpProcessingErrorr# r� r6 �coder" rT r� r/ Zon_eof�
_response_eofr� r2 r/ r r r �contentr9 r Z
SET_COOKIEr� r� r r4 Zwarning)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$ r% rY rO rO rP rD � 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 rG )� _released�_notify_contentr r r
r# r� r% rY rO rO rP r� � s
zClientResponse.closec C sH | j s| �� | jrt� S d| _| jd k r:| j�� d | _| �� t� S rG )rH rI r r- r# r$ r% 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� r> )r2 r/ r� r$ r# r� r6 rT rY rO rO rP rJ � 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 r% � s
z ClientResponse._cleanup_writerc C s. | j }|r$|�� d kr$|�td�� d| _d S )N�Connection closedT)rE Z exceptionr� r! rH )rZ rE rO rO rP rI � 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.NrL ) r rE rB r� Z send_response_chunk_receivedrR rQ �
BaseExceptionr� rH r! )rZ r
rO rO rP rB 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 Zsubtyper � RuntimeError�chardetZdetect)rZ �ctypeZmimetyperQ rO rO rP � get_encoding s.
��
�zClientResponse.get_encoding�strict)rQ �errorsrW c � s8 | j dkr| �� I dH |dkr(| �� }| j j||d�S )z!Read response payload and decode.N)rY )r rB rW r0 )rZ rQ rY rO rO rP �text1 s
zClientResponse.textr� )rQ �loads� content_type)rQ r[ r\ 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 rB rT rd r r r� r� r$ r� r6 r� rW r0 )rZ rQ r[ r\ rV �strippedrO rO rP rP ; 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 r_ r` ra rO rO rP � __aexit__^ s zClientResponse.__aexit__)NrX )ArJ rK rL r� r2 r/ rE r r r# r� r rH rM r r r) r> r rp r rh r. rQ r rU rj rT r: r r� rF r rw r r) r5 ro r r r6 r= rF rD r� r� r� r$ rK rJ r% rI rM rn rB rW rZ r6 r7 rP r^ r rN r rb rO rO rO rP r= � s� � # #2
��
�r= )krp rR r r- r: r� r� rw 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: rq r; � ImportError�objectZcchardetrU �__all__Zclientr@ Z connectorrA �tracingrB �compiler� �srF r> r? r� rG r{ rn r~ r rM r� r< r= rO rO rO rP �<module> s� 4 (
"
� 5
� h