File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/client_reqrep.cpython-310.pyc
o
���g�� �
@ sx d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
m Z m Z d dl
mZmZmZ d dlmZmZ d dlmZmZmZmZmZmZmZm Z m Z m 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/m0Z0 dd l1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7 dd l8m9Z9 dd
l:m;Z; ddl+m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZF ddl,mGZGmHZHmIZImJZJmKZK ddlLmMZM ddlNmOZO ddlPmQZQmRZRmSZSmTZTmUZUmVZV er�d dlWZWd dlWmXZX nz d dlWZWd dlWmXZX W n eY�y
dZWeZZXY nw dZ[e�r%ddl\m]Z] ddl^m_Z_ ddl`maZa e�bd�Zce�bd�Zddeefdd �Zfe!jgd d d d �G d d � d ��ZhG d!d"� d"e �ZiG d#d$� d$ei�ZjG d%d&� d&�ZkeWdu�rkeWjXelekemd�fZnnelemd�fZnd'e d(elekf d)e el d*e d( d+e eo de d(elekf f
d,d-�Zpeqd.�ZrG d/d0� d0e �Zsd1eed2eedelfd3d4�ZtG d5d6� d6�Zue2d7�ZvG d8d9� d9e?�ZwdS ):� N)�md5�sha1�sha256)� CookieError�Morsel� SimpleCookie)�MappingProxyType�
TracebackType) �
TYPE_CHECKING�Any�Callable�Dict�Iterable�List�Mapping�
NamedTuple�Optional�Tuple�Type�Union)� CIMultiDict�CIMultiDictProxy� MultiDict�MultiDictProxy)�URL� )�hdrs�helpers�http� multipart�payload)�AbstractStreamWriter)�ClientConnectionError�
ClientOSError�ClientResponseError�ContentTypeError�
InvalidURL�ServerFingerprintMismatch��
HAS_BROTLI)�FormData) � _SENTINEL�BaseTimerContext� BasicAuth� HeadersMixin� TimerNoop�basicauth_from_netrc�netrc_from_env�noop�reify�
set_exception�
set_result)�SERVER_SOFTWARE� HttpVersion�
HttpVersion10�
HttpVersion11� StreamWriter)�
client_logger)� StreamReader)�DEFAULT_JSON_DECODER� JSONDecoder� LooseCookies� LooseHeaders�Query�
RawHeaders)�
SSLContext)�
ClientRequest�ClientResponse� RequestInfo� Fingerprint)�
ClientSession)�
Connection)�Tracez[^-!#$%&'*+.^_`|~0-9a-zA-Z]z!^application/(?:[\w.+-]+?\+)?json�returnc C s t rdS dS )Nzgzip, deflate, brz
gzip, deflater( � rL rL �@/usr/local/lib/python3.10/dist-packages/aiohttp/client_reqrep.py� _gen_default_accept_encodingd � rN T)� 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__rL rL rL rM rS h s
rS c @ s. e Zd ZU eed< eed< ded< eed< dS )� _RequestInfo�url�method�CIMultiDictProxy[str]�headers�real_urlN)rW rX rY r r[ rZ rL rL rL rM r\ o s
r\ c @ s. e Zd Zefdededddedd f
dd�Zd S )
rF r] r^ r` r_ ra rK c C s$ t �| ||||tu r|f�S |f�S )zuCreate a new RequestInfo instance.
For backwards compatibility, the real_url parameter is optional.
)�tuple�__new__r+ )�clsr] r^ r` ra rL rL rM rc x s
��zRequestInfo.__new__N)rW rX rY r+ r rZ rc rL rL rL rM rF v s ������rF c @ sP e Zd Zeeed�Zdeddfdd�Ze defdd��Z
d e j ddfd
d �Z
dS ) rG )� � � � fingerprintrK Nc C sH t |�}| j�|�}|std��|tu s|tu r 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)�selfrh � digestlen�hashfuncrL rL rM �__init__� s
zFingerprint.__init__c C � | j S �N)rn �ro rL rL rM rh � � zFingerprint.fingerprint� transportc C s` |� d�sd S |� d�}|jdd�}| �|��� }|| jkr.|� d�^}}}t| j|||��d S )N�
sslcontext�
ssl_objectT)� binary_form�peername)�get_extra_info� getpeercertrm �digestrn r' )ro rw �sslobj�cert�got�host�port�_rL rL rM �check� s
�zFingerprint.check)rW rX rY r r r rj �bytesrr �propertyrh �asyncio� Transportr� rL rL rL rM rG � s �
rG �sslrC �
verify_ssl� ssl_contextrh c C s� | d u rd} |d ur |s t jdtdd� | dur td��d} |d ur4t jdtdd� | dur2td��|} |d urLt jdtdd� | durHtd��t|�} t| t�sXtd �| ���| S )
NTz/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�DeprecationWarningrl rG �
isinstance�SSL_ALLOWED_TYPES� TypeError�format)r� r� r� rh rL rL rM �_merge_ssl_params� sR ������
�r� )�https�wssc @ s` e Zd ZU eed< ee ed< eed< ee ee
f ed< ee ed< ee ed< ee ed< dS ) �
ConnectionKeyr� r� �is_sslr� �proxy�
proxy_auth�proxy_headers_hashN)
rW rX rY rZ r[ r �int�boolr rC rG r r- rL rL rL rM r� � s
r� �response_content_type�expected_content_typec C s |dkr t �| �d uS || v S )N�application/json)�json_re�match)r� r� rL rL rM �_is_expected_content_type� s r� c 0 @ s� e Zd ZU ejejejejhZej ej
ej hZ e�
e ��
ejh�Zejdeje� iZdZeed< dZdZdZdZdZe d ed< dddddde j ddddddddddddddd �d
e d e d e!d
e e" de e#e dede e$ de e% de j&de'e e(df de e( de(de e)j* de e+d de e de e% de e, d e d d e'e-e(e.f d e e" d e e/d! d"e(d#e e f.d$d%�Z0ded&e1d'dfd(d)�Z2e3d'e4d fd*d+��Z5e3d'e d, fd-d.��Z6e6j7dfd0d.��Z6d'e(fd1d2�Z8e3d'e'd3e(e.f fd4d5��Z9e3d'e:fd6d7��Z;e3d'e fd8d9��Z<e3d'e e= fd:d;��Z>e3d'e?fd<d=��Z@d e d'dfd>d?�ZAde'e j&e f d'dfd@dA�ZBd
e e" d'dfdBdC�ZCde e#e d'dfdDdE�ZDde e$ d'dfdFdG�ZEded'dfdHdI�ZFdgdJdK�ZGdhde e% d"e(d'dfdLdM�ZHded'dfdNdO�ZIdhdPe(d'dfdQdR�ZJde e de e% d e e" d'dfdSdT�ZKd/eLdUdVd'dfdWdX�ZMdidYdZ�ZNdgd[d\�ZOdgd]d^�ZPd
e d e d_eQd'dfd`da�ZRd
e d e d
dbd'dfdcdd�ZSdS )jrD z*/*� �bodyNzCIMultiDict[None]�_skip_auto_headersFT)�paramsr` �skip_auto_headers�data�cookies�auth�version�compress�chunked� expect100�loop�response_classr� r� �timer�sessionr� �
proxy_headers�traces� trust_env�server_hostnamer^ r] r� r` r� r� r� r� r� r� r� r� r� r� rE r� r� r� r� rH r� r� r� rJ r� r� c C s� |
d u rt �� }
t�|� }r td|�d|�� �d���t|�tu s&J |��|d ur4t|�tu s4J |��tr<|d us<J �|| _ |rF|�
|�}|| _ |j rQ|�
d �n|| _|�� | _| | _|
| _|
| _d | _|d u rlt}n|}|| _|d urw|nt� | _|d ur�|nd| _|| _|
�� r�t � t � d��| _ | �!| � | �"|� | �#|� | �$|� | �%|� | �&|� | �'||� | �(|||� | �)|� |d us�| j| j*vr�| �+� | �,| � |d u r�g | _-d S || _-d S )Nz+Method cannot contain non-token characters z (found at least �)Tr ).r� �get_event_loop�_CONTAINS_CONTROL_CHAR_RE�searchrl �grouprT r r
�_session� extend_query� original_url� raw_fragment�
with_fragmentr] �upperr^ r� r� r� �lengthrE r� r/ �_timer�_sslr� � 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)ro r^ r] r� r` r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �real_response_classrL rL rM rr sZ ��
zClientRequest.__init__r� rK c C �
d | _ d S rt ��_ClientRequest__writer�ro r� rL rL rM �__reset_writerl �
z ClientRequest.__reset_writerc C s | j pt� S rt )r� r ru rL rL rM r� o s z ClientRequest.skip_auto_headers�asyncio.Task[None]c C rs rt r� ru rL rL rM �_writers rv zClientRequest._writer�writerc C s. | j d ur | j �| j� || _ |�| j� d S rt )r� �remove_done_callback� _ClientRequest__reset_writer�add_done_callback�ro r� rL rL rM r� w s
c C s | j jtv S rt )r] �scheme� _SSL_SCHEMESru rL rL rM r� ~ rO zClientRequest.is_sslrC c C rs rt )r� ru rL rL rM r� � rv zClientRequest.sslc
C sT | j }rtt|�� ��}nd }| j}t�t|jpd|j|j t
v | j | j | j
|f�S )N� )r� �hashrb �itemsr] rc r� �raw_hostr� r� r� r� r� r� )ro r� �hr] rL rL rM �connection_key� s
��z ClientRequest.connection_keyc C s | j j}|d us
J �|S rt )r] r� )ro �retrL rL rM r� � s zClientRequest.hostc C s | j jS rt )r] r� ru rL rL rM r� � s zClientRequest.portc C s$ t | j�}t�t| j| j|| jf�S rt )r r` rb rc rF r] r^ r� )ro r` rL rL rM � request_info� s
�zClientRequest.request_infoc C s< |j st|��|js
|jr t�|jpd|jpd�| _dS dS )z8Update destination host, port and connection type (ssl).r� N) r� r& �raw_user� raw_passwordr r- �user�passwordr� )ro r] rL rL rM r� � s
�zClientRequest.update_hostc C sj t |t�r0dd� |�dd�D �}zt�t|d �t|d ��}W n ty/ td|� ��d�w || _dS )zdConvert request version to two elements tuple.
parser HTTP version '1.1' => (1, 1)
c S s g | ]}|� � �qS rL )�strip)�.0�partrL rL rM �
<listcomp>� s z0ClientRequest.update_version.<locals>.<listcomp>�.r r z#Can not parse http version number: N)r� rZ �splitr r7 r� rl r� )ro r� �vrL rL rM r� � s
���
z ClientRequest.update_versionc C s~ t � | _| jj}|dusJ �|| jtj< |sdS t|ttt f�r$|�
� }|D ]\}}|tj v r5|| j|< q&| j� ||� q&dS )zUpdate request headers.N)
r r` r] �host_port_subcomponentr �HOSTr� �dictr r r� �HOST_ALL�add)ro r` r� �key�valuerL rL rM r� � s
�z ClientRequest.update_headersc C s� |d ur t dd� t|�D ��| _| j�� }|�| j� n| j}| j�� D ]
\}}||vr1|| j|< q$tj |vr?t
| jtj < d S d S )Nc s s � | ]}|d fV qd S rt rL )r� �hdrrL rL rM � <genexpr>� s �
�z4ClientRequest.update_auto_headers.<locals>.<genexpr>) r �sortedr� r` �copy�extend�DEFAULT_HEADERSr� r �
USER_AGENTr6 )ro r� � used_headersr �valrL rL rM r� � s
�
�
�z!ClientRequest.update_auto_headersc C s� |sdS t � }tj| jv r |�| j�tjd�� | jtj= t|t�r'|�� }n|}|D ]$\}}t|t �rK|�|j
t � �}|� |j
|j |j
� |||< q+|||< q+|jddd��� | jtj< dS )z Update request cookies header.Nr� �;)�header�sep)r r �COOKIEr` �loadrk r� r r� r r �setr � coded_value�outputr� )ro r� �c� iter_cookies�namer �mrsl_valrL rL rM r� � s
z ClientRequest.update_cookiesc C sb |sd| _ dS | j�tj�r| j rtd��dS | j r/t| j t�s#d| _ | j | jtj< d| _dS dS )z Set request content encoding.Nz9compress can not be set if Content-Encoding header is set�deflateT) r� r` rk r �CONTENT_ENCODINGrl r� rZ r� )ro r� rL rL rM r� s ��
�z%ClientRequest.update_content_encodingc C s� | j �tjd��� }d|v r| jrtd��dS | jr,tj| j v r$td��d| j tj< dS tj| j vr?tt | j
��| j tj< dS 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) r` rk r �TRANSFER_ENCODING�lowerr� rl �CONTENT_LENGTHrZ ri r� )ro �terL rL rM r� s �� � �z&ClientRequest.update_transfer_encodingc C s� |du r| j }|du r2|r2| jjdur2t� }t�t�� t|| jj�}W d � n1 s-w Y |du r8dS t|t j
�sBt d��|� � | j
tj< dS )zSet basic auth.Nz%BasicAuth() tuple is required instead)r� r] r� r1 �
contextlib�suppress� LookupErrorr0 r� r r- r� �encoder` r �
AUTHORIZATION)ro r� r� � netrc_objrL rL rM r� 4 s � zClientRequest.update_authc C s� |d u rd S t |t�r|� }z
tjj|d d�}W n tjy' t|�� }Y nw || _| jsGtj | j
vrG|j }d urDt |�| j
tj < nd| _|j
sLJ �| j
}| j
}|j
�� D ]\}}||v sg|d urh||v rhqW|||< qWd S )N)� dispositionT)r� r* r �PAYLOAD_REGISTRYrk r# r� r� r r r` �sizerZ r� r� )ro r� r) r` � skip_headersr r rL rL rM r� D s,
�
�z#ClientRequest.update_body_from_data�expectc C sN |r d| j tj< ntj| j v r| j tj �� dkrd}|r%| j�� | _d S d S )Nz 100-continueT)r` r �EXPECTr r� �
create_future� _continue)ro r+ rL rL rM r� c s �z$ClientRequest.update_expect_continuec C sd || _ |d u rd | _d | _d S |rt|tj�std��|| _|d ur-t|ttf�s-t |�}|| _d S )Nz,proxy_auth must be None or BasicAuth() tuple)
r� r� r� r� r r- rl r r r )ro r� r� r� rL rL rM r� o s
�
zClientRequest.update_proxy�connrI c
� sh �| j dur|�� I dH | j I dH |j}|dus J �z.t| jtj�r.| j�|�I dH nt| jtt f�r;| jf| _| jD ]
}|�|�I dH q>W n\ t
y} } z'|}|j dup_t|t j
� }|rlt|j d| j���}t|||� W Y d}~dS d}~w t jy� |�� � ty� } zt|td|���|� W Y d}~dS d}~ww |�� I dH |�� dS )z-Support coroutines that yields bytes objects.Nz Can not write request body for z4Failed to send bytes into the underlying connection )r. �drain�protocolr� r� r �Payload�writer� � bytearray�OSError�errnor� � TimeoutErrorr# r] r4 �CancelledError�close� Exceptionr" � write_eof�
start_timeout)ro r� r/ r1 �chunk�underlying_exc� reraised_exc�exc_is_not_timeoutrL rL rM � write_bytes� sR �
� �
������ zClientRequest.write_bytesc � sB �| j tjkr| jj}|d usJ �|� d| jj� �}n| jr(| �� s(t| j�}n| jj }|j
}|d us5J �t || j | j
rFt�| j| j | j�nd | j
rTt�| j| j | j�nd d�}| jra|�| j� | jd urj|�� | j | jv r�| jd u s{tj| jvr�tj| jvr�d| jtj< | j}tj| jvr�|j j r�|t kr�d| jtj< n
|t kr�d| jtj< | j � d|� d|j � d|j!� �}|�"|| j�I d H | j#s�| j$d us�|j%r�| �&||�}t'j(d kr�t)j*|| j d
d �} n| j �+|�} | �,� r�d } n| | _-n
|�.� |�/� d } | j0}
|
d u�sJ �|
| j | j1| | j$| j2| j3| j
| j | j4d � | _5| j5S )
N�:)�
on_chunk_sent�on_headers_sentzapplication/octet-streamr9 z
keep-alive� z HTTP/r� )r� � T)r� � eager_start)r� � continue100r� r� r� r� r� )6r^ r � METH_CONNECTr] �host_subcomponentr� r� r� rZ � raw_path_qsr1 r: r� r� � functools�partial�_on_chunk_request_sent�_on_headers_request_sentr� �enable_compressionr� �enable_chunking� POST_METHODSr� � CONTENT_TYPEr` r� �
CONNECTION�
_connector� force_closer9 r8 �major�minor�
write_headersr� r. �writing_pausedrA r� � version_infor� �Task� create_task�doner� r< �set_eofr� r� r� r� r� �response) ro r/ � connect_host�pathr1 r� r� � status_line�coro�taskr� rL rL rM �send� s� � ���
�
� zClientRequest.sendc � sf �| j d ur1z | j I d H W d S tjy0 tjdkr't�� }r*|�� r-� Y d S Y d S Y d S w d S �N)r� � )r� r� r8 r� r[ � current_task�
cancelling�ro re rL rL rM r9 s �
�����zClientRequest.closec C s: | j d ur| j�� s| j �� | j �| j� d | _ d S d S rt )r� r� � is_closed�cancelr� r� ru rL rL rM � terminate" s
�zClientRequest.terminater= c � �& �| j D ] }|�|||�I d H qd S rt )r� �send_request_chunk_sent)ro r^ r] r= �tracerL rL rM rN ) s �
�z$ClientRequest._on_chunk_request_sentzCIMultiDict[str]c � ro rt )r� �send_request_headers)ro r^ r] r` rq rL rL rM rO - s �
�z&ClientRequest._on_headers_request_sentrt )r� r� rK N�rK N)F)r/ rI rK rE )TrW rX rY r �METH_GET� METH_HEAD� METH_OPTIONS�
METH_TRACEr� �
METH_PATCH� METH_POST�METH_PUTrR �union� METH_DELETE� ALL_METHODS�ACCEPT�ACCEPT_ENCODINGrN r r� r r[ r� r` r� r. r� r r r9 rZ r rA r@ r r? r- r7 r r� r� �AbstractEventLoopr r, rC rG r rr �objectr� r� r r� r� �setterr� r� r� r� r� r� r� rF r� r� r� r� r� r� r� r� r� r� r� r� r! rA rf r9 rn r� rN rO rL rL rL rM rD � s
�� �����
�� �
� � �
���
����� ��
��
�O
���
���
�
1
`
����rD �Connection closedc @ s� e Zd ZU dZee ed< dZeed< dZ ee
ed< dZ e ed< dZ
ee ed< dZee
ed< dZed ed
< dZeed < dZed ed
< dZee ed< dZed ed< dZeej ed< dZ ed ed< dZ dZ dZ dd� Z e!d ege
f ed< dZ"ed ed< de
d e#d d d ed d e$d!e%d"e&d# d$e'j(d%dd&dfd'd(�Z)dd)e*d&dfd*d+�Z+e,d&ed fd,d-��Z-e-j.d ed d&dfd.d-��Z-e,d&efd/d0��Z/e/j.d1ed&dfd2d0��Z/e0d&e#fd3d4��Z1e0d&e#fd5d6��Z2e0d&e#fd7d8��Z3e0d&e
fd9d:��Z4e0d�d<d=��Z5e0d&efd>d?��Z6e0d&e%fd@dA��Z7e0d&ee8 fdBdC��Z9e:fdDe;d&dfdEdF�Z<d&e
fdGdH�Z=e,d&ed fdIdJ��Z>e0d&ed fdKdL��Z?e0d�dNdO��Z@d�dQdR�ZAd�dSdT�ZBe,d&eCfdUdV��ZDd�dWdX�ZEd&e;fdYdZ�ZFe,d&eCfd[d\��ZGd�d]d^�ZHd�d_d`�ZId�dadb�ZJd�dcdd�ZKd�dedf�ZLd�dgdh�ZMd&efdidj�ZNd&e
fdkdl�ZOd�dnee
doe
d&e
fdpdq�ZPdeQdrds�dnee
dteRduee
d&e;fdvdw�ZSd�dxdy�ZTdzeeUeV d{eeV d|eeW d&dfd}d~�ZXdS )�rE Nr� �status�reason�content�_body�_headersrL )rE .�_history� _raw_headersrI � _connection�_cookieszasyncio.Future[bool]r. r� rH r� TFc G s dS )N�utf-8rL )r� rL rL rM �<lambda>R s zClientResponse.<lambda>�_resolve_charsetr� �_ClientResponse__writerr^ r] r� z Optional[asyncio.Task[None]]rH r� r� r� rJ r� r� rK c
C s� t |�tu sJ �|| _|| _|jr|�d �n|| _|d ur || _|d ur'|| _|| _ |d ur0|nt
� | _ i | _ || _
|| _| d urH| | _| j| _|�� rWt�t�d��| _d S d S )Nr )rT r r^ � _real_urlr� r� �_urlr� r. �
_request_infor/ r� �_cacher� �_loopr� r� r� r� r� r� r� r� )
ro r^ r] r� rH r� r� r� r� r� rL rL rM rr V s& �zClientResponse.__init__r� c C r� rt �r� r� rL rL rM r� } r� z ClientResponse.__reset_writerc C rs )z�The writer task for streaming data.
_writer is only provided for backwards compatibility
for subclasses that may need to access it.
r� ru rL rL rM r� � s zClientResponse._writerc C sL | j dur | j �| j� || _ |du rdS |�� r d| _ dS |�| j� dS )z'Set the writer task for streaming data.N)r� r� � _ClientResponse__reset_writerr^ r� r� rL rL rM r� � s
c C s | j d u r t� | _ | j S rt )r� r ru rL rL rM r� � s
zClientResponse.cookiesr� c C s
|| _ d S rt )r� )ro r� rL rL rM r� � s
c C rs rt )r� ru rL rL rM r] � rv zClientResponse.urlc C s t jdtdd� | jS )NzDeprecated, use .url #1654� r� )r� r� r� r� ru rL rL rM �url_obj� s zClientResponse.url_objc C rs rt )r� ru rL rL rM ra � rv zClientResponse.real_urlc C s | j jd usJ �| j jS rt )r� r� ru rL rL rM r� � s zClientResponse.hostr_ c C rs rt )r� ru rL rL rM r` � rv zClientResponse.headersc C rs rt )r� ru rL rL rM � raw_headers� rv zClientResponse.raw_headersc C rs rt )r� ru rL rL rM r� � rv zClientResponse.request_infoc C sF | j �tj�}|d u r
d S t�|�\}}t|�}t�|�}t|||�S rt ) r� rk r �CONTENT_DISPOSITIONr �parse_content_dispositionr � content_disposition_filenamerS )ro �raw�disposition_type�
params_dctr� rV rL rL rM �content_disposition� s
z"ClientResponse.content_disposition� _warningsc C s� | j rd S | jd ur>| j�� | �� | j�� r@d| i}|jd| ��tfi |�� | dd�}| jr6| j|d< | j� |� d S d S d S )N�sourcezUnclosed response zUnclosed response)�client_response�message�source_traceback)
�_closedr� �release�_cleanup_writerr� r� r� �ResourceWarningr� �call_exception_handler)ro r� �kwargs�contextrL rL rM �__del__� s
�zClientResponse.__del__c C s` t �� }t| j�}| jr| j�dd��d�}nd}td�|| j |�|d� t| j
|d� |� � S )N�ascii�backslashreplace�Nonez <ClientResponse({}) [{} {}]>)�file) �io�StringIOrZ r] r� r$ �decode�printr� r� r` �getvalue)ro �out�ascii_encodable_url�ascii_encodable_reasonrL rL rM �__repr__� s"
����zClientResponse.__repr__c C rs rt )r� ru rL rL rM �
connection� rv zClientResponse.connectionc C rs )z2A sequence of of responses, if redirects occurred.)r� ru rL rL rM �history� s zClientResponse.history�/MultiDictProxy[MultiDictProxy[Union[str, URL]]]c
C s� d� | j�dg ��}|stt� �S t� }t�d|�D ][}t�d|�}|d u r'q|�� \}}|�d�dd � }t� }|D ] } t�d| tj �}|d u rJq;|�� \}
} } } |�
|
| � q;|� d|�}
|�
d | j � t
|��� |�
t|
�t|�� qt|�S )
Nz, �linkz ,(?=\s*<)z
\s*<(.*)>(.*)r r z%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$�relr] )�joinr` �getallr r �rer� r� �groups�Mr rk r] r rZ )
ro � links_str�linksr r� r] �
params_strr� r� �paramr r� r rL rL rM r� � s*
zClientResponse.linksr� c � sx �d| _ |j| _|| _| j�S z| j}|�� I dH \}}W n tjy: } zt| j | j
|j |j |j
d�|�d}~ww |j dk sJ|j dksJ|j dkrKn| jdurYt| jd� d| _qW d � n1 sdw Y |�| j� |j| _|j | _|j| _|j
| _|j| _|| _| j
�tjd� }r�t � }|D ]!}z|� |� W q� t y� } z t � d |� W Y d}~q�d}~ww || _!| S )
zStart response processing.FTN�r� r� r` �d �� �e rL z!Can not load response cookies: %s)"r� r1 � _protocolr� r� �readr �HttpProcessingErrorr$ r� r� �coder� r` r. r5 �on_eof�
_response_eofr� r� r� r� r� r� r� r� r �
SET_COOKIEr r r r; �warningr� ) ro r� r1 r� r �exc� cookie_hdrsr� r rL rL rM �start s^ �����
� � ��zClientResponse.startc C sD | j rd S | jo | jj}|d ur|jrd S d| _ | �� | �� d S �NT)r� r� r1 �upgradedr� �_release_connection)ro r1 rL rL rM r� N s z ClientResponse._response_eofc C rs rt )r� ru rL rL rM �closed[ rv zClientResponse.closedc C sV | j s| �� d| _| jd u s| j�� rd S | �� | jd ur)| j�� d | _d S d S r� )� _released�_notify_contentr� r� rl r� r� r9 ru rL rL rM r9 _ s
�zClientResponse.closec C s* | j s| �� d| _| �� | �� t� S r� )r� r� r� r� r� r2 ru rL rL rM r� l s zClientResponse.releasec C s
d| j kS )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� )r� ru rL rL rM �okv s
zClientResponse.okc C sB | j s | jd us
J �| js| �� t| j| j| j| j| jd��d S )Nr� ) r� r� � _in_contextr� r$ r� r� r� r` ru rL rL rM �raise_for_status s ��z ClientResponse.raise_for_statusc sD � j d ur � jd u r� j �� d � _ d S � j�� fdd�� d S d S )Nc s � � � S rt )r� )�fru rL rM r� � s z4ClientResponse._release_connection.<locals>.<lambda>)r� r� r� r� ru rL ru rM r� � s
�z"ClientResponse._release_connectionc � �^ �| j d ur)z| j I d H W n tjy( tjdkr&t�� }r&|�� r&� Y nw | �� d S rg )r� r� r8 r� r[ ri rj r� rk rL rL rM �_wait_released� � �
���� z ClientResponse._wait_releasedc C s | j d ur
| j �� d | _d S rt )r� rm r� ru rL rL rM r� � s
z ClientResponse._cleanup_writerc C s* | j }|r|�� d u rt|t� d| _d S r� )r� � exceptionr4 � _CONNECTION_CLOSED_EXCEPTIONr� )ro r� rL rL rM r� � s
z ClientResponse._notify_contentc � r� rg )r� r� r8 r� r[ ri rj r� rk rL rL rM �wait_for_close� r� z ClientResponse.wait_for_closec � s� �| j du r1z | j�� I dH | _ | jD ]}|�| j| j| j �I dH qW n ty0 | �� � w | j r8t
d��| j o>| j j }|du sF|j
sM| �� I dH | j S )zRead response payload.Nr� )r� r� r� r� � send_response_chunk_receivedr^ r] �
BaseExceptionr9 r� r" r� r1 r� r� )ro rq r1 rL rL rM r� � s& �
�� �zClientResponse.readc C s� | j �tjd��� }t�|�}|j�d�}|r3t� t
t �� t �
|�jW d � S 1 s.w Y |jdkrD|jdksB|jdkrDdS | jd u rMtd��| �| | j�S )Nr� �charset� application�json�rdapr� z7Cannot compute fallback encoding of a not yet read body)r` rk r rS r r �parse_mimetyperU r! r" r# rl �codecs�lookupr rT �subtyper� � RuntimeErrorr� )ro �ctype�mimetype�encodingrL rL rM � get_encoding� s
�
�zClientResponse.get_encoding�strictr� �errorsc � s: �| j du r
| �� I dH |du r| �� }| j j||d�S )z!Read response payload and decode.N)r� )r� r� r� r� )ro r� r� rL rL rM �text� s �
zClientResponse.textr� )r� �loads� content_typer� r� c � s� �| j du r
| �� I dH |r-| j�tjd��� }t||�s-t| j | j
| j d| | jd��| j � � }|s6dS |du r>| �
� }||�|��S )z Read and decodes JSON response.Nr� z3Attempt to decode JSON with unexpected mimetype: %sr� )r� r� r` rk r rS r r� r% r� r� r� r� r� r� )ro r� r� r� r� �strippedrL rL rM r� � s& �
�
zClientResponse.jsonc � s �d| _ | S r� )r� ru rL rL rM �
__aenter__ s �zClientResponse.__aenter__�exc_type�exc_val�exc_tbc � s" �d| _ | �� | �� I d H d S )NF)r� r� r� )ro r� r r rL rL rM � __aexit__ s �zClientResponse.__aexit__rt )rK r_ )rK r� )r� rI rK rE rs )Nr� )rK rE )YrW rX rY r� r r7 r[ r� r� r� rZ r� r< r� r� r� r r� r r� rB r� r� r r. r� r� � StackSummaryr� r� r� r� r� r r� r r, rF r r� r� rr r� r� r� r� r� r� r3 r] r� ra r� r` r� r� rS r� r� r r� r� r� r� r� r� r� r� r� r9 r� r� r� r� r� r� r� r� r� r� r� r= r> r� r� r r� r r rL rL rL rM rE 7 s�
������ �
� �
�'
#
6
����
�
!
����rE )xr� r� r! rL r� r� r� r� r� �hashlibr r r � http.cookiesr r r �typesr r �typingr
r r r
r r r r r r r r �attr� multidictr r r r �yarlr r� r r r r r �abcr! �client_exceptionsr" r# r$ r% r& r' �compression_utilsr) �formdatar* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: �logr; �streamsr< �typedefsr= r> r? r@ rA rB r� rC � ImportErrorr� �__all__�clientrH � connectorrI �tracingrJ �compiler� r� rZ rN �srS r\ rF rG r� rT r� r� r� � frozensetr� r� r� rD r� rE rL rL rL rM �<module> s� 8 4
�
����
�7 ��
� 9