관리-도구
편집 파일: client_reqrep.cpython-37.opt-1.pyc
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 Zdigestrc r& )rV re ZsslobjZcertZgot�host�port�_rO rO rP �check� s zFingerprint.check)rJ rK rL r r r r_ �bytesrd �propertyr] �asyncioZ Transportri 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)rm rn ro r] rO rO rP �_merge_ssl_params� s@ ry )rC rE rD c @ sb e Zd ZU eed< ee ed< eed< ee dee f ed< ee ed< ee ed< ee ed< dS ) � ConnectionKeyrf rg �is_sslNrm �proxy� proxy_authZproxy_headers_hash) rJ rK rL rM rN r �int�boolr r; r? r r* rO rO rO rP rz � s rz )�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�sessionrm � proxy_headers�tracesr= r@ rB )rR rQ r� rS r� r� r� r� r� r� r� r� r� r� r| r} r� r� rm 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 )-rl Zget_event_loopru r �AssertionErrorrG r �_sessionr ZqueryZ 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� rm r� r� �qZurl2Zreal_response_classrO rO rP rd � sP zClientRequest.__init__)rU c C s | j jdkS )N)ZhttpsZwss)rQ Zscheme)rV rO rO rP r{ A s zClientRequest.is_sslr; c C s | j S )N)r� )rV rO rO rP rm 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�itemsrz rf rg r{ rm 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 ZretrO rO rP rf [ s zClientRequest.hostc C s | j jS )N)rQ rg )rV rO rO rP rg 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 Zusernamer� 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)ru 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�:rf )r rS r rM rQ r� r �is_ipv6_addressrg Zis_default_portr ZHOSTru �dictr r r� �lower�add)rV rS Znetloc�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` ru 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 setZdeflateT) rS r` r ZCONTENT_ENCODINGr� r� ra ru 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 ZterO 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� ru r r* rw �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)ru 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)ru 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� ru r� r ZPayload�writerj � bytearrayZ write_eof�OSErrorr" �errnorQ � __context__� __cause__� set_exceptionrl ZCancelledError�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� rg 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 rx 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 rl �AbstractEventLoopr r) r r; r? r rd r{ rk rm rz r� rf r~ rg r> r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r r� r rj 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 )ru 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� )rq )rr rs rt 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 rf r� )rV rO rO rP rf 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( rs �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�printrx �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*$ZrelrQ )�joinrS �getallr r �rer� r� �groups�Mr� r` rQ r ) rV Z links_str�linksr� r� rQ Z params_strr� r1 Zparamr� rh r� rO rO rP r7 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)r, r rS �d �� �e TrO z!Can not load response cookies: %s)!r r� Z _protocolr r� �readr ZHttpProcessingErrorr# r� r0 �coder rS r� r/ Zon_eof� _response_eofr� r, r) r r r �contentr3 r Z SET_COOKIEr� r� r r4 Zwarning)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 r= � 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)r@ rA 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� )r, )rV rO rO rP �ok� s zClientResponse.okc C s< | j s8| jd k st�| �� t| j| j| j| j| jd��d S )N)r, r rS ) rB r) r� r r# r� r0 r, 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)r> Z exceptionr� r! r@ )rV r> rO rO rP rA � 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 r> r; r� Z send_response_chunk_receivedrR rQ � BaseExceptionr� r@ r! )rV r rO rO rP r; 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 Zsubtyper � RuntimeError�chardetZdetect)rV �ctypeZmimetyperH rO rO rP � get_encoding s& zClientResponse.get_encoding�strict)rH �errorsrU c � s8 | j dkr| �� I dH |dkr(| �� }| j j||d�S )z!Read response payload and decode.N)rP )r r; rN r* )rV rH rP rO rO rP �text5 s zClientResponse.textzapplication/json)rH �loads� content_type)rH rR rS 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 r; rS r` r r� r� r� r$ r� r0 r� rN r* )rV rH rR rS rM �strippedrO rO rP rG 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 rV rW rX rO rO rP � __aexit__d s zClientResponse.__aexit__)NrO )ArJ rK rL r� r, r) r> r r r r� r r@ rM r r r) r> r rl r rd r. rQ r rT rf rS r: r r� rF r rr r r# r/ rk r r r0 r7 r? r= r r� r� r rB rC r rA rD rj r; rN rQ r6 r7 rG rU r rE r rY rO rO rO rP r= � s� #3 r= )lrl rI r� r' r4 r� r� rr Zhashlibr 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: rm r; � ImportError�objectZcchardetrL Zcharset_normalizer�__all__Zclientr@ Z connectorrA �tracingrB �compiler� �srF r> r? r rG rv rj ry rz rM r� r< r= rO rO rO rP �<module> st 4 ( " 0 o