| Server IP : 192.158.238.246 / Your IP : 3.141.38.5 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/ |
Upload File : |
B
�k�a� � @ 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 yd dlNZNd dlNmOZO W n ePk
�r� dZNeQZOY nX y d dlRZSW n ePk
�r d dlTZSY nX dZUe�r2ddlVmWZW ddlXmYZY ddlZm[Z[ e�\d�Z]e j^dddd�G dd� d��Z_e j^dddd�G d d � d ��Z`G d d � d �ZaeNdk �r�eNjOebeaecd�fZdnecd�Zde d ebeadf eeb ed eee e d ebeadf d!�d"d#�Zfe j^dddd$�G d%d&� d&��Zgehehebd'�d(d)�ZiG d*d+� d+�ZjG d,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. 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/python37/lib64/python3.7/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�methodzCIMultiDictProxy[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 �attrZibrT �defaultrW 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)� fingerprintrU 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)rV r] Z digestlenZhashfuncrO rO rP �__init__q s
zFingerprint.__init__)rU c C s | j S )N)rc )rV rO rO rP r] } s zFingerprint.fingerprint)� transportrU c C s` |� d�sd S |� d�}|jdd�}| �|��� }|| jkr\|� d�^}}}t| j|||��d S )NZ
sslcontextZ
ssl_objectT)Z binary_formZpeername)Zget_extra_infoZ getpeercertrb �digestrc r& )rV re ZsslobjZcertZgot�host�port�_rO rO rP �check� s
zFingerprint.check)rJ rK rL r r r r_ �bytesrd �propertyr] �asyncioZ Transportrj rO rO rO rP r? j s r? r; )�ssl�
verify_ssl� ssl_contextr] rU 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�DeprecationWarningra r? �
isinstance�SSL_ALLOWED_TYPES� TypeError�format)rn ro rp r] rO rO rP �_merge_ssl_params� s@
rz )rC rE rD c @ sb e Zd ZU eed< ee ed< eed< ee dee
f ed< ee ed< ee ed< ee ed< dS ) �
ConnectionKeyrg rh �is_sslNrn �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_typerU c C s |dkrt �| �d k S || kS )Nzapplication/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�ZAdOe%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�ZKee dKddL�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 )rR rQ r� rS r� r� r� r� r� r� r� r� r� r� r} r~ r� r� rn 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��| _ | � | � | �!|� | �"|� | �#|� | �$|� | �%|� | �&|� | �'|||� | �(|� |d k �sl| j| j)k�rt| �*� | �+| � |d k�r�g }|| _,d S )Nr@ r )-rm Zget_event_looprv 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)rV rR rQ r� rS r� r� r� r� r� r� r� r� r� r� r} r~ r� r� rn r� r� �qZurl2Zreal_response_classrO rO rP rd � sP
zClientRequest.__init__)rU c C s | j jdkS )N)�https�wss)rQ �scheme)rV rO rO rP r| A s zClientRequest.is_sslr; c C s | j S )N)r� )rV rO rO rP rn D s zClientRequest.sslc C sL | j }|r&ttdd� |�� D ���}nd }t| j| j| �� | j| j | j
|�S )Nc s s | ]\}}||fV qd S )NrO )�.0�k�vrO rO rP � <genexpr>M s z/ClientRequest.connection_key.<locals>.<genexpr>) r� �hash�tuple�itemsr{ rg rh r| rn r} r~ )rV r� �hrO rO rP �connection_keyH s z ClientRequest.connection_keyc C s | j j}|d k st�|S )N)rQ �raw_hostr� )rV �retrO rO rP rg [ s zClientRequest.hostc C s | j jS )N)rQ rh )rV rO rO rP rh a s zClientRequest.portc C s t | j�}t| j| j|| j�S )N)r rS r> rQ rR r� )rV rS rO rO rP � request_infoe s
zClientRequest.request_info)rQ rU 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� )rV rQ �usernamer� rO rO rP r� j s
zClientRequest.update_host)r� rU c C sp t |t�rfdd� |�dd�D �}y 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)rv rM �splitr � HttpVersionr ra r� )rV r� r� rO rO rP r� u s
z ClientRequest.update_version)rS rU c C s� 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�W dS )zUpdate request headers.�[�]N�:rg )r rS r rM rQ r� r �is_ipv6_addressrh Zis_default_portr ZHOSTrv �dictr r r� �lower�add)rV rS �netloc�key�valuerO rO rP r� � s
z ClientRequest.update_headers)r� rU c C sv t dd� t|�D ��| _| j�� }|�| j� x,| j�� D ] \}}||kr:| j�||� q:W t j
|krrt | jt j
< d S )Nc s s | ]}|d fV qd S )NrO )r� �hdrrO rO rP r� � s z4ClientRequest.update_auto_headers.<locals>.<genexpr>) r �sortedr� rS �copyr� �DEFAULT_HEADERSr� r� r Z
USER_AGENTr0 )rV r� Z used_headersr� �valrO rO rP r� � s
z!ClientRequest.update_auto_headers)r� rU c C s� |sdS t � }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 )z Update request cookies header.Nr� �;)�header�sep)r r ZCOOKIErS �loadr` rv r r� r r� �setr� Z coded_value�outputr� )rV r� �cZ iter_cookies�namer� Zmrsl_valrO rO rP r� � s
z ClientRequest.update_cookies)r� rU c C sd |dkr dS | j �tjd��� }|r4| jr`td��n,| jr`t| jt�sLd| _| j| j tj< d| _ dS )z Set request content encoding.Nr� z9compress can not be set if Content-Encoding header is set�deflateT)
rS r` r ZCONTENT_ENCODINGr� r� ra rv rM r� )rV 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) rS r` r ZTRANSFER_ENCODINGr� r� ra �CONTENT_LENGTHrM r^ �body)rV �terO rO rP r� � s z&ClientRequest.update_transfer_encoding)r� rU c C sB |dkr| j }|dkrdS t|tj�s.td��|�� | jtj< dS )zSet basic auth.Nz%BasicAuth() tuple is required instead) r� rv r r* rx �encoderS r Z
AUTHORIZATION)rV r� rO rO rP r� � s zClientRequest.update_auth)r� rU c C s� |d kr d S t |t�r |� }ytjj|d d�}W n tjk
rP t|�� }Y nX || _| js�tj | j
kr�|j }|d kr�d| _n tj | j
kr�t |�| j
tj < |j
s�t
�x8|j
�� D ]*\}}|| j
kr�q�|| jkr�q�|| j
|< q�W d S )N)Z dispositionT)rv r' r ZPAYLOAD_REGISTRYr` � LookupErrorr� r� r r� rS �sizerM r� r� r� )rV r� r� r� r� rO rO rP r� � s.
z#ClientRequest.update_body_from_data)�expectrU c C sB |rd| j tj< n | j �tjd��� dkr.d}|r>| j�� | _d S )Nz 100-continuer� T)rS r ZEXPECTr` r� r� Z
create_future� _continue)rV r� rO rO rP r� s z$ClientRequest.update_expect_continue)r} r~ r� rU c C s. |rt |tj�std��|| _|| _|| _d S )Nz,proxy_auth must be None or BasicAuth() tuple)rv r r* ra r} r~ r� )rV 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 )NFz
keep-aliveT�close)r� r1 rS r` r �
CONNECTION)rV rO rO rP �
keep_alive, s
zClientRequest.keep_aliverA )�writer�connrU c
� sf | j dk r$|�� I dH | j I dH |j}|dk s6t��z ynt| jtj�r^| j�|�I dH n:t| jt t
f�rx| jf| _x | jD ]}|�|�I dH q�W |� � I dH W n� t k
r� } z,t
|jd| j �}||_||_|�|� W dd}~X Y nd tjk
�r( } z|j�s|�|� W dd}~X Y n. tk
�rT } z|�|� W dd}~X Y nX W dd| _X dS )z-Support coroutines that yields bytes objects.Nz!Can not write request body for %s)r� Zdrain�protocolr� rv r� r ZPayload�writerk � bytearrayZ write_eof�OSErrorr" �errnorQ � __context__� __cause__�
set_exceptionrm �CancelledError�closed� Exception�_writer)rV r� r� r� �chunk�exc�new_excrO rO rP � write_bytes: s2
zClientRequest.write_bytes)r� rU 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�t�| j| j | j�d�}| jr�|�| j� | jd k r�|�� | j | jk�r"tj| jk�r"tj| j k�r"d| j tj< | j � tj �}|�sb| � � �rR| j t!k�rbd}n| j t"k�rbd}|d k �rx|| j tj < 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_sentZon_headers_sentzapplication/octet-streamz
keep-aliver� z{0} {1} HTTP/{2[0]}.{2[1]})r� � continue100r� r� r� r� r� )0rR r Z METH_CONNECTrQ r� r� r r� rh r} r| rM Zraw_pathZraw_query_stringr� r3 r� � functools�partial�_on_chunk_request_sent�_on_headers_request_sentr� Zenable_compressionr� Zenable_chunking� POST_METHODS� CONTENT_TYPEr� rS r` r� r� r� r1 r2 ry Z
write_headersZ create_taskr r� r� r� r� r� r� r� r� �response) rV r� Z connect_host�pathr� r� �
connectionZ status_liner� rO rO rP �send_ sl
zClientRequest.sendc � s( | j d k r$z| j I d H W d d | _ X d S )N)r� )rV rO rO rP r� � s
zClientRequest.closec C s( | j d k r$| j�� s | j �� d | _ d S )N)r� r� � is_closed�cancel)rV rO rO rP � terminate� s
zClientRequest.terminate)rR rQ r� rU c � s( x"| j D ]}|�|||�I d H qW d S )N)r� Zsend_request_chunk_sent)rV rR rQ r� �tracerO rO rP r � s z$ClientRequest._on_chunk_request_sentzCIMultiDict[str])rR rQ rS rU c � s( x"| j D ]}|�|||�I d H qW d S )N)r� Zsend_request_headers)rV rR rQ rS r rO rO rP r � s z&ClientRequest._on_headers_request_sent)F)MrJ 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� rm �AbstractEventLoopr r) r r; r? r rd r| rl rn r{ r� rg r rh r> r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r� r rk r r rO rO rO rP r< � s�
�3 " #Qr< 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� rU c
C s� t |t�st�|| _t� | _|| _|�d �| _d | _ || _
|| _ d| _ d| _
|| _|d k r^|nt� | _i | _|| _|| _| | _|�� r�t�t�d��| _d S )NTrO r )rv r r� rR r r� � _real_urlr� �_url�_bodyr� r� �_closed�_history�
_request_infor, r� �_cacher� �_loopr� r� r� r� r� r� r� )
rV rR rQ r� r r� r� r� r� r� rO rO rP rd � s$
zClientResponse.__init__)rU c C s | j S )N)r )rV rO rO rP rQ � s zClientResponse.urlc C s t jdtdd� | jS )NzDeprecated, use .url #1654� )rr )rs rt ru r )rV rO rO rP �url_obj s zClientResponse.url_objc C s | j S )N)r )rV rO rO rP rT s zClientResponse.real_urlc C s | j jd k st�| j jS )N)r rg r� )rV rO rO rP rg
s zClientResponse.hostzCIMultiDictProxy[str]c C s | j S )N)�_headers)rV rO rO rP rS s zClientResponse.headersc C s | j S )N)� _raw_headers)rV rO rO rP � raw_headers s zClientResponse.raw_headersc C s | j S )N)r )rV rO rO rP r� s zClientResponse.request_infoc C sF | j �tj�}|d krd S t�|�\}}t|�}t�|�}t|||�S )N) r r` r ZCONTENT_DISPOSITIONr Zparse_content_dispositionr Z content_disposition_filenamerF )rV �rawZdisposition_typeZ
params_dctr� rI rO rO rP �content_disposition s
z"ClientResponse.content_disposition)� _warningsrU 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( rt �ResourceWarningr� Zcall_exception_handler)rV 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�printry �statusrS �getvalue)rV �outZascii_encodable_urlZascii_encodable_reasonrO rO rP �__repr__8 s
zClientResponse.__repr__rA c C s | j S )N)r( )rV rO rO rP r
J s zClientResponse.connection)r= .c C s | j S )z2A sequence of of responses, if redirects occurred.)r )rV rO rO rP �historyN s zClientResponse.historyz/MultiDictProxy[MultiDictProxy[Union[str, URL]]]c
C s� d� | j�dg ��}|s"tt� �S t� }x�t�d|�D ]�}t�d|�}|d krPq6|�� \}}|�d�dd � }t� }xB|D ]:} t�d| tj �}|d kr�qz|�� \}
} } } |�
|
| � qzW |� d|�}
|�
d | j � t
|��� |�
|
t|�� q6W t|�S )
Nz, �linkz ,(?=\s*<)z
\s*<(.*)>(.*)r� r z%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$�relrQ )�joinrS �getallr r �rer� r� �groups�Mr� r` rQ r )
rV Z links_str�linksr� r� rQ Z
params_strr� r< �paramr� ri r� rO rO rP rC S s*
zClientResponse.links)r
rU c � sd d| _ |j| _|| _| j�� x�y | j}|�� I dH \}}W nB tjk
r| } z"t| j | j
|j |j |j
d�|�W dd}~X Y nX |j dk s�|j dks�|j dkr�P | jdk r t| jd� d| _q W W dQ R X |�| j� |j| _|j | _|j| _|j
| _|j| _|| _x\| j
�tjd�D ]H}y| j � |� W n0 t k
�rX } zt � d |� W dd}~X Y nX �qW | S )
zStart response processing.FN)r7 r' rS �d �� �e TrO z!Can not load response cookies: %s)!r r� Z _protocolr( r� �readr ZHttpProcessingErrorr# r� r; �coder' rS r� r/ Zon_eof�
_response_eofr� r7 r4 r r" r! �contentr? r Z
SET_COOKIEr� r� r r4 �warning)rV r
r� r' r r r� rO rO rP �startw 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* )rV rO rO rP rJ � s
z ClientResponse._response_eofc C s | j S )N)r )rV 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 )NT)� _released�_notify_contentr r r r( r� r* )rV rO rO rP r� � s
zClientResponse.closec C sH | j s| �� | jrt� S d| _| jd k r:| j�� d | _| �� t� S )NT)rN rO r r- r( r) r* )rV rO rO rP r) � 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� )r7 )rV rO rO rP �ok� s zClientResponse.okc C s< | j s8| jd k st�| �� t| j| j| j| j| jd��d S )N)r7 r' rS ) rP r4 r� r) r# r� r; r7 rS )rV rO rO rP �raise_for_status� s z ClientResponse.raise_for_statusc C s$ | j d k r| j �� d | _ d | _d S )N)r� r r� )rV rO rO rP r* � s
z ClientResponse._cleanup_writerc C s. | j }|r$|�� d kr$|�td�� d| _d S )NzConnection closedT)rK � exceptionr� r! rN )rV rK rO rO rP rO � s z ClientResponse._notify_contentc � s0 | j d k r$z| j I d H W d d | _ X | �� d S )N)r� r) )rV rO rO rP �wait_for_close s
z ClientResponse.wait_for_closec � s� | j dkrly@| j�� I dH | _ x(| jD ] }|�| j| j| j �I dH q&W W qz tk
rh | �� � Y qzX n| j rzt
d��| j S )zRead response payload.NzConnection closed) r rK rH r� Z send_response_chunk_receivedrR rQ �
BaseExceptionr� rN r! )rV r rO rO rP rH s
zClientResponse.readc C s� | j �tjd��� }t�|�}|j�d�}|rVyt� |� 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)rS r` r r
r� r Zparse_mimetyperH �codecs�lookupr� rG �subtyper � RuntimeError�chardet�detect)rV �ctypeZmimetyperW rO rO rP � get_encoding s&
zClientResponse.get_encoding�strict)rW �errorsrU c � s8 | j dkr| �� I dH |dkr(| �� }| j j||d�S )z!Read response payload and decode.N)ra )r rH r_ r5 )rV rW ra rO rO rP �text5 s
zClientResponse.textzapplication/json)rW �loads� content_type)rW rc rd rU 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' rS )r rH rS r` r r
r� r� r$ r� r; r� r_ r5 )rV rW rc rd r^ �strippedrO rO rP rV A s
zClientResponse.jsonc � s | S )NrO )rV rO rO rP �
__aenter__a s zClientResponse.__aenter__)�exc_type�exc_val�exc_tbrU c � s | � � d S )N)r) )rV rg rh ri rO rO rP � __aexit__d s zClientResponse.__aexit__)Nr` )ArJ rK rL r� r7 r4 rK r r! r( r� r rN rM r r r) r> r rm r rd r. rQ r rT rg rS r: r" r� rF r$ rs r r. r: rl r
r r; rC rM rJ r� r� r� r) rP rQ r* rO rS rk rH r_ rb r6 r7 rV rf r rT r rj rO rO rO rP r= � s� #3
r= )lrm rX r r2 r@ r� r� rs �hashlibr r r Z http.cookiesr r r �typesr r �typingr
r r r
r r r r r r r rX 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: rn r; � ImportError�objectZcchardetr\ Zcharset_normalizer�__all__Zclientr@ Z connectorrA �tracingrB �compiler� �srF r> r? r� rG rw rk rz r{ rM r� r< r= rO rO rO rP �<module> st 4 (
"
0 o