HEX

File: //opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/client_reqrep.cpython-37.pyc
B

�k�a��	@s8ddlZddlZddlZddlZddlZddlZddlZddlZddlm	Z	m
Z
mZddlm
Z
mZmZddlmZmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddl m!Z!m"Z"m#Z#m$Z$ddl%m&Z&dd	l'm(Z(m)Z)m*Z*m+Z+m,Z,dd
l-m.Z.ddl/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7dd
l)m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?ddl*m@Z@mAZAmBZBmCZCddlDmEZEddlFmGZGddlHmIZImJZJmKZKmLZLmMZMyddlNZNddlNmOZOWnePk
�r�dZNeQZOYnXyddlRZSWnePk
�rddlTZSYnXdZUe�r2ddlVmWZWddlXmYZYddlZm[Z[e�\d�Z]ej^dddd�Gdd�d��Z_ej^dddd�Gdd�d��Z`Gdd�d�ZaeNdk	�r�eNjOebeaecd�fZdnecd�Zded ebeadfeebed eeeed ebeadfd!�d"d#�Zfej^dddd$�Gd%d&�d&��Zgehehebd'�d(d)�ZiGd*d+�d+�ZjGd,d-�d-e;�ZkdS).�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.eZdZUeeed<ded<eeed<dS)�ContentDisposition�typezMappingProxyType[str, str]�
parameters�filenameN)�__name__�
__module__�__qualname__r�str�__annotations__�rOrO�H/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/client_reqrep.pyrFWs
rFc@sJeZdZUeed<eed<ded<e��Zeed<ej	ed�dd��Z
d	S)
r>�url�methodzCIMultiDictProxy[str]�headers�real_url)�returncCs|jS)N)rQ)�selfrOrOrP�real_url_defaulteszRequestInfo.real_url_defaultN)rJrKrLrrNrM�attrZibrT�defaultrWrOrOrOrPr>^s
r>c@sLeZdZeeed�Zedd�dd�Ze	ed�dd��Z
ejdd	�d
d�Z
dS)r?)��� N)�fingerprintrUcCsJt|�}|j�|�}|s"td��n|tks2|tkr:td��||_||_dS)Nzfingerprint has invalid lengthz8md5 and sha1 are insecure and not supported. Use sha256.)�len�HASHFUNC_BY_DIGESTLEN�get�
ValueErrorrr�	_hashfunc�_fingerprint)rVr]Z	digestlenZhashfuncrOrOrP�__init__qs
zFingerprint.__init__)rUcCs|jS)N)rc)rVrOrOrPr]}szFingerprint.fingerprint)�	transportrUcCs`|�d�sdS|�d�}|jdd�}|�|���}||jkr\|�d�^}}}t|j|||��dS)NZ
sslcontextZ
ssl_objectT)Zbinary_formZpeername)Zget_extra_infoZgetpeercertrb�digestrcr&)rVreZsslobjZcertZgot�host�port�_rOrOrP�check�s


zFingerprint.check)rJrKrLrrrr_�bytesrd�propertyr]�asyncioZ	TransportrjrOrOrOrPr?jsr?r;)�ssl�
verify_ssl�ssl_contextr]rUcCs�|dk	r2|s2tjdtdd�|dk	r.td��nd}|dk	r`tjdtdd�|dk	r\td��n|}|dk	r�tjdtdd�|dk	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�DeprecationWarningrar?�
isinstance�SSL_ALLOWED_TYPES�	TypeError�format)rnrorpr]rOrOrP�_merge_ssl_params�s@
rz)rCrErDc@sbeZdZUeed<eeed<eed<ee	dee
fed<eeed<eeed<eeed<dS)	�
ConnectionKeyrgrh�is_sslNrn�proxy�
proxy_authZproxy_headers_hash)
rJrKrLrMrNr�int�boolrr;r?rr*rOrOrOrPr{�s
r{)�response_content_type�expected_content_typerUcCs|dkrt�|�dk	S||kS)Nzapplication/json)�json_re�match)r�r�rOrOrP�_is_expected_content_type�sr�c@s�eZdZejejejejhZej	ej
ejhZe�
e��
ejh�ZejdejdiZdZdZdZdZdZdde�dddejddddddddddddd�eeeeeefeee ee!ee"ee#ej$eeee%e%ee&j'ee(deeee#ee)ede*e+e%e,dfeeee-d	d
�dd�Z.e%d
�dd�Z/e0e*dde%e,fd
�dd��Z1e0e2d
�dd��Z3e0ed
�dd��Z4e0ee5d
�dd��Z6e0e7d
�dd��Z8edd�dd�Z9e*ej$efdd�dd �Z:eedd!�d"d#�Z;e edd$�d%d&�Z<ee"dd'�d(d)�Z=e!dd*�d+d,�Z>dd
�d-d.�Z?ee#dd/�d0d1�Z@e!dd2�d3d4�ZAdOe%dd5�d6d7�ZBeeee#eedd8�d9d:�ZCe%d
�d;d<�ZDeEd=dd>�d?d@�ZFd=ddA�dBdC�ZGdd
�dDdE�ZHdd
�dFdG�ZIeeeJddH�dIdJ�ZKeedKddL�dMdN�ZLdS)Pr<z*/*z
gzip, deflate�NF)�paramsrS�skip_auto_headers�data�cookies�auth�version�compress�chunked�	expect100�loop�response_classr}r~�timer�sessionrn�
proxy_headers�tracesr=r@rB)rRrQr�rSr�r�r�r�r�r�r�r�r�r�r}r~r�r�rnr�r�cCs�|
dkrt��}
t|t�s"t|��t|ttd�f�s<t|��td|�|_|rvt|j	�}|�
|�}|�|j	�|�
|�}||_|�
d�|_|��|_||_|
|_|
|_d|_|dkr�t}n|}||_|dk	r�|nt�|_||_|
��r�t�t�d��|_|� |	�|�!|�|�"|�|�#|�|�$|�|�%|�|�&|�|�'|||�|�(|�|dk	�sl|j|j)k�rt|�*�|�+|�|dk�r�g}||_,dS)Nr@r)-rmZget_event_looprvr�AssertionErrorrGr�_sessionr�queryZ
with_query�extend�original_url�
with_fragmentrQ�upperrRr�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)rVrRrQr�rSr�r�r�r�r�r�r�r�r�r�r}r~r�r�rnr�r��qZurl2Zreal_response_classrOrOrPrd�sP













zClientRequest.__init__)rUcCs|jjdkS)N)�https�wss)rQ�scheme)rVrOrOrPr|AszClientRequest.is_sslr;cCs|jS)N)r�)rVrOrOrPrnDszClientRequest.sslcCsL|j}|r&ttdd�|��D���}nd}t|j|j|��|j|j	|j
|�S)Ncss|]\}}||fVqdS)NrO)�.0�k�vrOrOrP�	<genexpr>Msz/ClientRequest.connection_key.<locals>.<genexpr>)r��hash�tuple�itemsr{rgrhr|rnr}r~)rVr��hrOrOrP�connection_keyHszClientRequest.connection_keycCs|jj}|dk	st�|S)N)rQ�raw_hostr�)rV�retrOrOrPrg[szClientRequest.hostcCs|jjS)N)rQrh)rVrOrOrPrhaszClientRequest.portcCst|j�}t|j|j||j�S)N)rrSr>rQrRr�)rVrSrOrOrP�request_infoes
zClientRequest.request_info)rQrUcCs6|jst|��|j|j}}|r2t�||p,d�|_dS)z8Update destination host, port and connection type (ssl).�N)r�r%�user�passwordrr*r�)rVrQ�usernamer�rOrOrPr�js
zClientRequest.update_host)r�rUcCspt|t�rfdd�|�dd�D�}y t�t|d�t|d��}Wn$tk
rdtd|���d�YnX||_dS)zdConvert request version to two elements tuple.

        parser HTTP version '1.1' => (1, 1)
        cSsg|]}|���qSrO)�strip)r��partrOrOrP�
<listcomp>{sz0ClientRequest.update_version.<locals>.<listcomp>�.rrz#Can not parse http version number: N)rvrM�splitr�HttpVersionrrar�)rVr�r�rOrOrPr�us
 

zClientRequest.update_version)rSrUcCs�t�|_tt|jj�}t�|�r,d|�d�}|jjdk	rV|j�	�sV|dt|jj�7}||jt
j<|r�t|t
ttf�r~|��}x6|D].\}}|��dkr�||j|<q�|j�||�q�WdS)zUpdate request headers.�[�]N�:rg)rrSrrMrQr�r�is_ipv6_addressrhZis_default_portrZHOSTrv�dictrrr��lower�add)rVrS�netloc�key�valuerOrOrPr��s
zClientRequest.update_headers)r�rUcCsvtdd�t|�D��|_|j��}|�|j�x,|j��D]\}}||kr:|j�||�q:Wt	j
|krrt|jt	j
<dS)Ncss|]}|dfVqdS)NrO)r��hdrrOrOrPr��sz4ClientRequest.update_auto_headers.<locals>.<genexpr>)r�sortedr�rS�copyr��DEFAULT_HEADERSr�r�rZ
USER_AGENTr0)rVr�Zused_headersr��valrOrOrPr��s

z!ClientRequest.update_auto_headers)r�rUcCs�|sdSt�}tj|jkr:|�|j�tjd��|jtj=t|t�rN|��}n|}xP|D]H\}}t|t	�r�|�|j
t	��}|�|j
|j|j
�|||<qX|||<qXW|jddd���|jtj<dS)zUpdate request cookies header.Nr��;)�header�sep)rrZCOOKIErS�loadr`rvrr�rr��setr�Zcoded_value�outputr�)rVr��cZiter_cookies�namer�Zmrsl_valrOrOrPr��s 




zClientRequest.update_cookies)r�rUcCsd|dkrdS|j�tjd���}|r4|jr`td��n,|jr`t|jt�sLd|_|j|jtj<d|_	dS)zSet request content encoding.Nr�z9compress can not be set if Content-Encoding header is set�deflateT)
rSr`rZCONTENT_ENCODINGr�r�rarvrMr�)rVr��encrOrOrPr��sz%ClientRequest.update_content_encodingcCsz|j�tjd���}d|kr,|jrvtd��nJ|jrTtj|jkrFtd��d|jtj<n"tj|jkrvtt	|j
��|jtj<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)rSr`rZTRANSFER_ENCODINGr�r�ra�CONTENT_LENGTHrMr^�body)rV�terOrOrPr��sz&ClientRequest.update_transfer_encoding)r�rUcCsB|dkr|j}|dkrdSt|tj�s.td��|��|jtj<dS)zSet basic auth.Nz%BasicAuth() tuple is required instead)	r�rvrr*rx�encoderSrZ
AUTHORIZATION)rVr�rOrOrPr��szClientRequest.update_auth)r�rUcCs�|dkrdSt|t�r|�}ytjj|dd�}Wn tjk
rPt|��}YnX||_|js�tj	|j
kr�|j}|dkr�d|_ntj	|j
kr�t|�|j
tj	<|j
s�t
�x8|j
��D]*\}}||j
kr�q�||jkr�q�||j
|<q�WdS)N)ZdispositionT)rvr'rZPAYLOAD_REGISTRYr`�LookupErrorr�r�rr�rS�sizerMr�r�r�)rVr�r�r�r�rOrOrPr��s.



z#ClientRequest.update_body_from_data)�expectrUcCsB|rd|jtj<n|j�tjd���dkr.d}|r>|j��|_dS)Nz100-continuer�T)rSrZEXPECTr`r�r�Z
create_future�	_continue)rVr�rOrOrPr�sz$ClientRequest.update_expect_continue)r}r~r�rUcCs.|rt|tj�std��||_||_||_dS)Nz,proxy_auth must be None or BasicAuth() tuple)rvrr*rar}r~r�)rVr}r~r�rOrOrPr� s
zClientRequest.update_proxycCsN|jtkrdS|jtkr4|j�tj�dkr.dSdSn|j�tj�dkrJdSdS)NFz
keep-aliveT�close)r�r1rSr`r�
CONNECTION)rVrOrOrP�
keep_alive,s

zClientRequest.keep_aliverA)�writer�connrUc
�sf|jdk	r$|��IdH|jIdH|j}|dk	s6t��z ynt|jtj�r^|j�|�IdHn:t|jt	t
f�rx|jf|_x|jD]}|�|�IdHq�W|��IdHWn�tk
r�}z,t
|jd|j�}||_||_|�|�Wdd}~XYndtjk
�r(}z|j�s|�|�Wdd}~XYn.tk
�rT}z|�|�Wdd}~XYnXWdd|_XdS)z-Support coroutines that yields bytes objects.Nz!Can not write request body for %s)r�Zdrain�protocolr�rvr�rZPayload�writerk�	bytearrayZ	write_eof�OSErrorr"�errnorQ�__context__�	__cause__�
set_exceptionrm�CancelledError�closed�	Exception�_writer)rVr�r�r��chunk�exc�new_excrOrOrP�write_bytes:s2

 zClientRequest.write_bytes)r�rUc	�s�|jtjkrJ|jj}|dk	s t�t�|�r6d|�d�}|�d|jj��}n:|j	rd|�
�sdt|j�}n |jj}|jj
r�|d|jj
7}|j}|dk	s�t�t||jt�|j|j|j�t�|j|j|j�d�}|jr�|�|j�|jdk	r�|��|j|jk�r"tj|jk�r"tj|jk�r"d|jtj<|j�tj�}|�sb|���rR|j t!k�rbd}n|j t"k�rbd}|dk	�rx||jtj<d	�#|j||j �}|�$||j�IdH|j�%|�&||��|_'|j(}|dk	�s�t�||j|j)|j'|j*|j+|j,|j-|j|j.d
�	|_/|j/S)Nr�r�r��?)Z
on_chunk_sentZon_headers_sentzapplication/octet-streamz
keep-aliver�z{0} {1} HTTP/{2[0]}.{2[1]})r��continue100r�r�r�r�r�)0rRrZMETH_CONNECTrQr�r�rr�rhr}r|rMZraw_pathZraw_query_stringr�r3r��	functools�partial�_on_chunk_request_sent�_on_headers_request_sentr�Zenable_compressionr�Zenable_chunking�POST_METHODS�CONTENT_TYPEr�rSr`r�r�r�r1r2ryZ
write_headersZcreate_taskrr�r�r�r�r�r�r�r��response)	rVr�Zconnect_host�pathr�r��
connectionZstatus_liner�rOrOrP�send_sl



zClientRequest.sendc�s(|jdk	r$z|jIdHWdd|_XdS)N)r�)rVrOrOrPr��s
zClientRequest.closecCs(|jdk	r$|j��s|j��d|_dS)N)r�r��	is_closed�cancel)rVrOrOrP�	terminate�s


zClientRequest.terminate)rRrQr�rUc�s(x"|jD]}|�|||�IdHqWdS)N)r�Zsend_request_chunk_sent)rVrRrQr��tracerOrOrPr�sz$ClientRequest._on_chunk_request_sentzCIMultiDict[str])rRrQrSrUc�s(x"|jD]}|�|||�IdHqWdS)N)r�Zsend_request_headers)rVrRrQrSrrOrOrPr�sz&ClientRequest._on_headers_request_sent)F)MrJrKrLrZMETH_GETZ	METH_HEADZMETH_OPTIONSZ
METH_TRACEr�Z
METH_PATCHZ	METH_POSTZMETH_PUTr	�unionZMETH_DELETEZALL_METHODSZACCEPTZACCEPT_ENCODINGr�r�r�rr�r��	frozensetrr2rMrrrr9r
rr8r*r�r�rm�AbstractEventLooprr)rr;r?rrdr|rlrnr{r�rgrrhr>r�r�r�r�r�r�r�r�r�r�r�r�r�r rrr�rrkrrrOrOrOrPr<�s�
�3"#Qr<c@steZdZdZdZdZdZdZdZdZ	dZ
dZdZe
ededeeedejddd�
d	d
�Zeed�dd
��Zeed�dd��Zeed�dd��Zee
d�dd��Zedd�dd��Zeed�dd��Zeed�dd��Zeeed�dd��Z e!fe"dd�dd�Z#e
d�d d!�Z$e%ed"d�d#d$��Z&ee'd%d�d&d'��Z(ed(d�d)d*��Z)d"dd+�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;dd�dMdN�Z<ee=e>ee>ee?ddO�dPdQ�Z@dS)Sr=NTFzasyncio.Task[None]zasyncio.Future[bool]rBr@)
rRrQr�rr�r�r�r�r�rUc
Cs�t|t�st�||_t�|_||_|�d�|_d|_	||_
||_d|_d|_
||_|dk	r^|nt�|_i|_||_||_|	|_|��r�t�t�d��|_dS)NTrOr)rvrr�rRrr��	_real_urlr��_url�_bodyr�r��_closed�_history�
_request_infor,r��_cacher��_loopr�r�r�r�r�r�r�)
rVrRrQr�rr�r�r�r�r�rOrOrPrd�s$
zClientResponse.__init__)rUcCs|jS)N)r)rVrOrOrPrQ�szClientResponse.urlcCstjdtdd�|jS)NzDeprecated, use .url #1654�)rr)rsrtrur)rVrOrOrP�url_objszClientResponse.url_objcCs|jS)N)r)rVrOrOrPrTszClientResponse.real_urlcCs|jjdk	st�|jjS)N)rrgr�)rVrOrOrPrg
szClientResponse.hostzCIMultiDictProxy[str]cCs|jS)N)�_headers)rVrOrOrPrSszClientResponse.headerscCs|jS)N)�_raw_headers)rVrOrOrP�raw_headersszClientResponse.raw_headerscCs|jS)N)r)rVrOrOrPr�szClientResponse.request_infocCsF|j�tj�}|dkrdSt�|�\}}t|�}t�|�}t|||�S)N)	r r`rZCONTENT_DISPOSITIONrZparse_content_dispositionrZcontent_disposition_filenamerF)rV�rawZdisposition_typeZ
params_dctr�rIrOrOrP�content_dispositions
z"ClientResponse.content_disposition)�	_warningsrUcCs�|jr
dS|jdk	r~|j��|��|j��r~tr>d|i}ni}|jd|��tf|�|dd�}|j	rr|j	|d<|j�
|�dS)N�sourcezUnclosed response zUnclosed response)Zclient_response�messageZsource_traceback)r�_connection�release�_cleanup_writerrr�r(rt�ResourceWarningr�Zcall_exception_handler)rVr%�kwargs�contextrOrOrP�__del__%s





zClientResponse.__del__cCsbt��}t|j�}|jr.|j�dd��d�}n|j}td�||j	|�|d�t|j
|d�|��S)N�ascii�backslashreplacez<ClientResponse({}) [{} {}]>)�file)�io�StringIOrMrQ�reasonr��decode�printry�statusrS�getvalue)rV�outZascii_encodable_urlZascii_encodable_reasonrOrOrP�__repr__8s

zClientResponse.__repr__rAcCs|jS)N)r()rVrOrOrPr
JszClientResponse.connection)r=.cCs|jS)z2A sequence of of responses, if redirects occurred.)r)rVrOrOrP�historyNszClientResponse.historyz/MultiDictProxy[MultiDictProxy[Union[str, URL]]]c
Cs�d�|j�dg��}|s"tt��St�}x�t�d|�D]�}t�d|�}|dkrPq6|��\}}|�d�dd�}t�}xB|D]:}	t�d|	tj	�}|dkr�qz|��\}
}}}|�
|
|�qzW|�d|�}
|�
d	|j�t
|���|�
|
t|��q6Wt|�S)
Nz, �linkz	,(?=\s*<)z
\s*<(.*)>(.*)r�rz%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$�relrQ)�joinrS�getallrr�rer�r��groups�Mr�r`rQr)
rVZ	links_str�linksr�r�rQZ
params_strr�r<�paramr�rir�rOrOrPrCSs*

zClientResponse.links)r
rUc�sdd|_|j|_||_|j��x�y|j}|��IdH\}}WnBtjk
r|}z"t|j	|j
|j|j|j
d�|�Wdd}~XYnX|jdks�|jdks�|jdkr�P|jdk	rt|jd�d|_qWWdQRX|�|j�|j|_|j|_|j|_|j
|_|j|_||_x\|j
�tjd�D]H}y|j�|�Wn0tk
�rX}zt� d	|�Wdd}~XYnX�qW|S)
zStart response processing.FN)r7r'rS�d���eTrOz!Can not load response cookies: %s)!rr�Z	_protocolr(r��readrZHttpProcessingErrorr#r�r;�coder'rSr�r/Zon_eof�
_response_eofr�r7r4r r"r!�contentr?rZ
SET_COOKIEr�r�rr4�warning)rVr
r�r'rrr�rOrOrP�startwsD
$zClientResponse.startcCsP|jr
dS|jdk	r>|jjdk	r.|jjjr.dS|j��d|_d|_|��dS)NT)rr(r�Zupgradedr)r*)rVrOrOrPrJ�s


zClientResponse._response_eofcCs|jS)N)r)rVrOrOrPr��szClientResponse.closedcCs\|js|��|jrdSd|_|jdks2|j��r6dS|jdk	rP|j��d|_|��dS)NT)�	_released�_notify_contentrrrr(r�r*)rVrOrOrPr��s

zClientResponse.closecCsH|js|��|jrt�Sd|_|jdk	r:|j��d|_|��t�S)NT)rNrOrr-r(r)r*)rVrOrOrPr)�s

zClientResponse.releasecCs
d|jkS)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.
        i�)r7)rVrOrOrP�ok�szClientResponse.okcCs<|js8|jdk	st�|��t|j|j|j|j|jd��dS)N)r7r'rS)	rPr4r�r)r#r�r;r7rS)rVrOrOrP�raise_for_status�szClientResponse.raise_for_statuscCs$|jdk	r|j��d|_d|_dS)N)r�rr�)rVrOrOrPr*�s

zClientResponse._cleanup_writercCs.|j}|r$|��dkr$|�td��d|_dS)NzConnection closedT)rK�	exceptionr�r!rN)rVrKrOrOrPrO�szClientResponse._notify_contentc�s0|jdk	r$z|jIdHWdd|_X|��dS)N)r�r))rVrOrOrP�wait_for_closes

zClientResponse.wait_for_closec�s�|jdkrly@|j��IdH|_x(|jD]}|�|j|j|j�IdHq&WWqztk
rh|���YqzXn|j	rzt
d��|jS)zRead response payload.NzConnection closed)rrKrHr�Zsend_response_chunk_receivedrRrQ�
BaseExceptionr�rNr!)rVrrOrOrPrHs

zClientResponse.readcCs�|j�tjd���}t�|�}|j�d�}|rVyt�	|�Wnt
k
rTd}YnX|s�|jdkr~|jdksx|jdkr~d}n$|j
dkr�td��nt�|j
�d}|s�d}|S)	Nr��charsetZapplication�jsonZrdapzutf-8z0Cannot guess the encoding of a not yet read body�encoding)rSr`rr
r�rZparse_mimetyperH�codecs�lookupr�rG�subtyper�RuntimeError�chardet�detect)rV�ctypeZmimetyperWrOrOrP�get_encodings&



zClientResponse.get_encoding�strict)rW�errorsrUc�s8|jdkr|��IdH|dkr(|��}|jj||d�S)z!Read response payload and decode.N)ra)rrHr_r5)rVrWrarOrOrP�text5s
zClientResponse.textzapplication/json)rW�loads�content_type)rWrcrdrUc�s�|jdkr|��IdH|rT|j�tjd���}t||�sTt|j	|j
d||jd��|j��}|sfdS|dkrv|��}||�
|��S)zRead and decodes JSON response.Nr�z3Attempt to decode JSON with unexpected mimetype: %s)r'rS)rrHrSr`rr
r�r�r$r�r;r�r_r5)rVrWrcrdr^�strippedrOrOrPrVAs 



zClientResponse.jsonc�s|S)NrO)rVrOrOrP�
__aenter__aszClientResponse.__aenter__)�exc_type�exc_val�exc_tbrUc�s|��dS)N)r))rVrgrhrirOrOrP�	__aexit__ds	zClientResponse.__aexit__)Nr`)ArJrKrLr�r7r4rKr r!r(r�rrNrMrrr)r>rrmrrdr.rQrrTrgrSr:r"r�rFr$rsrr.r:rlr
rr;rCrMrJr�r�r�r)rPrQr*rOrSrkrHr_rbr6r7rVrfrrTr	rjrOrOrOrPr=�s�	#3

r=)lrmrXrr2r@r�r�rs�hashlibrrrZhttp.cookiesrrr�typesrr	�typingr
rrr
rrrrrrrrXZ	multidictrrrrZyarlrr�rrrrr�abcr Zclient_exceptionsr!r"r#r$r%r&Zformdatar'r(r)r*r+r,r-r.r/r0r1r2r3�logr4Zstreamsr5Ztypedefsr6r7r8r9r:rnr;�ImportError�objectZcchardetr\Zcharset_normalizer�__all__Zclientr@Z	connectorrA�tracingrB�compiler��srFr>r?r�rGrwrkrzr{rMr�r<r=rOrOrOrP�<module>st4 (


"
0o