U
'�7`�Y � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ dd l,m-Z- dd
l.m/Z/ ddl0Z0ddl1Z1dd l2m3Z3m4Z4 dd l5m6Z6 dd
l7m8Z8 ddl9m:Z: ddl;m<Z<m=Z= ddl>m?Z? dZ@e jAdkZBe jAdkZCe jAdkZDeC�s�ddlEZEeE�F� zddlmGZG W n" eHk
�r� ddl5mGZG Y nX d�e$ejI e&d d�dd�ZJeC�reKed�ZJe)d�ZLe)d �ZMeN� ZOePe jQ�Rd ��ZSeKe jTd d ��pde jTjU �odePe jQ�Rd ��ZVd!d"� eWdd#�D �ZXd$d"� eWdd%�D �eYd&�hB ZZd'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8eYd9�hZ[eXeZA e[A Z\G d:d;� d;�Z]G d<d=� d=ed=d>d?d@g��Z^e8e'e8e$e^ f dA�dBdC�Z_e$ej dD�dEdF�Z`e1jadGdGdGdH�G dIdJ� dJ��Zbe ecebf dD�dKdL�Zdd�e$ejI dMd�dNdO�Zed�e$ejI ejId�dPdQ�ZfeePdR�dSdT�Zge1jadGdGdGdH�G dUdV� dV��ZhejidWdX�ecehdY�dZd[��Zjd�ee$ec e$ec d\�d]d^�Zkd�ecePececd_�d`da�ZlG dbdc� dce6�ZmG ddde� dee eL �ZnenZozddflpmnZq eS�sNeqZnW n eHk
�rf Y nX dgZrdhZse �ter�Zue jtese jvdi�Zwe �ter�xdj��Zye jtes�xdj�e jvdi�Zze%ec e%e{ e$e*ece{f ePdk�dldm�Z|e�}e|euey�Z~e�}e|ewez�Ze$e*ece{e�e�f ePdn�dodp�Z�ejdD�dqdr�Z�da�dsa�ecdD�dtdu�Z�dvdw� Z�dxdy� Z�dzd{� Z�G d|d}� d}�Z�G d~d� deGd �Z�G d�d�� d�e��Z�G d�d�� d�e��Z�G d�d�� d�e0j��Z�G d�d�� d��Z�d�eLdd��d�d��Z�d�e�dd��d�d��Z�G d�d�� d�e#ecef �Z�dS )�zVarious helper functions� N)�
namedtuple)�suppress)�ceil)�Path)�
TracebackType)�Any�Callable�Dict� Generator�Generic�Iterable�Iterator�List�Mapping�Optional�Pattern�Set�Tuple�Type�TypeVar�Union�cast)�quote)�
getproxies)� MultiDict�MultiDictProxy)�Protocol��URL� )�hdrs)�
client_logger�internal_logger)�PathLike)� BasicAuth�
ChainMapProxy)� � )r& � )r& � )�ContextManagerzasyncio.Task[Any]��loop�returnc C s t tj�| ��}dd� |D �S )Nc S s h | ]}|� � s|�qS � )�done)�.0�tr. r. �B/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/helpers.py� <setcomp>L s z all_tasks.<locals>.<setcomp>)�list�asyncio�Task� all_tasks)r, Ztasksr. r. r2 r7 H s r7 �_T�_SZAIOHTTP_NO_EXTENSIONS�dev_modeFZPYTHONASYNCIODEBUGc C s h | ] }t |��qS r. ��chr�r0 �ir. r. r2 r3 a s r3 � c C s h | ] }t |��qS r. r; r= r. r. r2 r3 b s � � �(�)�<�>�@�,�;�:�\�"�/�[�]�?�=�{�}� � c @ s e Zd Zed d�dd�ZdS )�noop)NNN�r- c c s
d V d S �Nr. ��selfr. r. r2 � __await__~ s znoop.__await__N)�__name__�
__module__� __qualname__r
rZ r. r. r. r2 rU } s rU c st e Zd ZdZdeeed d�� fdd�
Zedeed d�dd ��Zedd
�eee d d �d d
��Z
ed�dd�Z � Z S )r$ z!Http basic authentication helper.� �latin1)�login�password�encodingr- c sB |d krt d��|d kr t d��d|kr0t d��t� �| |||�S )Nz"None is not allowed as login valuez%None is not allowed as password valuerI z5A ":" is not allowed in login (RFC 1945#section-11.1))�
ValueError�super�__new__)�clsr` ra rb �� __class__r. r2 re � s zBasicAuth.__new__)� auth_headerrb r- c C s� z|� dd�\}}W n tk
r0 td��Y nX |�� dkrJtd| ��z tj|�d�dd��|�}W n tjk
r� td ��Y nX z|� d
d�\}}W n tk
r� td ��Y nX | |||d �S )
z<Create a BasicAuth object from an Authorization HTTP header.rS r z%Could not parse authorization header.Zbasicz Unknown authorization method %s�asciiT)ZvalidatezInvalid base64 encoding.rI zInvalid credentials.�rb ) �splitrc �lower�base64Z b64decode�encode�decode�binascii�Error)rf ri rb Z auth_typeZencoded_credentialsZdecodedZusernamera r. r. r2 rp � s( ��zBasicAuth.decoderk )�urlrb r- c C s6 t |t�std��|jdkr dS | |j|jp.d|d�S )zCreate BasicAuth from url.z url should be yarl.URL instanceNr^ rk )�
isinstancer � TypeError�userra )rf rs rb r. r. r2 �from_url� s
zBasicAuth.from_urlrV c C s0 | j � d| j� ��| j�}dt�|��| j� S )zEncode credentials.rI zBasic %s)r` ra ro rb rn Z b64encoderp )rY Zcredsr. r. r2 ro � s zBasicAuth.encode)r^ r_ )r_ )
r[ r\ r] �__doc__�strre � classmethodrp r r rw ro �
__classcell__r. r. rg r2 r$ � s � � r$ r` ra rb )rs r- c C s, t �| �}|d kr| d fS | �d �|fS d S rW )r$ rw Z with_user)rs �authr. r. r2 �strip_auth_from_url� s
r} rV c
C s� t j�d�} | dk r t| �}nZz t�� }W n4 tk
r^ } zt�d|� W Y �dS d}~X Y nX |t� � dkrrdnd }zt
�
t |��W S t
j k
r� } zt�
d|� W 5 d}~X Y n: tk
r� } z | s�|�� r�t�
d|� W 5 d}~X Y nX dS ) z�Attempt to load the netrc file from the path specified by the env-var
NETRC or in the default location in the user's home directory.
Returns None if it couldn't be found or fails to parse.
ZNETRCNzHCould not resolve home directory when trying to look for .netrc file: %sZWindowsZ_netrcz.netrcz Could not parse .netrc file: %sz Could not read .netrc file: %s)�os�environ�getr �home� RuntimeErrorr! �debug�platform�system�netrcry ZNetrcParseError�warning�OSError�is_file)Z netrc_envZ
netrc_pathZhome_dir�er. r. r2 �netrc_from_env� s,
�� r� T)Z auto_attribs�frozen�slotsc @ s" e Zd ZU eed< ee ed< dS )� ProxyInfo�proxyZ
proxy_authN)r[ r\ r] r �__annotations__r r$ r. r. r. r2 r� � s
r� c C s� dd� t � �� D �} t� }dd� | �� D �}i }|�� D ]�\}}|\}}|jdkr`t�d|� q8|r�|d kr�d }|jd k r�|�|j�}|d k r�|�^ } }
| d r�| d n| d } tt t
| �t t
|
��}t ||�||< q8|S )Nc S s" i | ]\}}|d kr|t |��qS ))Zhttp�httpsr �r0 �k�vr. r. r2 �
<dictcomp>� s z$proxies_from_env.<locals>.<dictcomp>c S s i | ]\}}|t |��qS r. )r} r� r. r. r2 r� � s r� z,HTTPS proxies %s are not supported, ignoringr ���) r �itemsr� Zschemer! r� �hostZauthenticatorsr$ r ry r� ) Z
proxy_urlsZ netrc_obj�strippedZret�proto�valr� r| Zauth_from_netrcZloginsra r` r. r. r2 �proxies_from_env� s&
r� zOptional[asyncio.Task[Any]]c C s" t rtj| d�S tjj| d�S d S )N�r, )�PY_37r5 � current_taskr6 r� r. r. r2 r� s r� c C sB | d krt �� } | �� s>tjdtdd� | �� r>tjddd� | S )Nz5The object should be created within an async functionr& )�
stacklevelT)Z
stack_info) r5 Zget_event_loopZ
is_running�warnings�warn�DeprecationWarningZ get_debugr" r� r� r. r. r2 �get_running_loop s � �r� )�objr- c C s$ t tdd �}|d k r || �S dS d S )N�isasyncgenfunctionF)�getattr�inspect)r� �funcr. r. r2 r� ) s r� c @ s. e Zd ZU eed< eed< eed< ded< dS )�MimeType�type�subtype�suffixzMultiDictProxy[str]�
parametersN)r[ r\ r] ry r� r. r. r. r2 r� 1 s
r� �8 )�maxsize)�mimetyper- c
C s | st dddtt� �d�S | �d�}t� }|dd� D ]R}|s@q6ttttf d|kr`|�dd�n|df�\}}|�|�� � � |� d�� q6|d � � �� }|d kr�d
}d |kr�ttttf |�d d��n|df\}}d |kr�ttttf |�d d��n|df\}} t ||| t|�d�S )
a Parses a MIME type into its components.
mimetype is a MIME type string.
Returns a MimeType object.
Example:
>>> parse_mimetype('text/html; charset=utf-8')
MimeType(type='text', subtype='html', suffix='',
parameters={'charset': 'utf-8'})
r^ )r� r� r� r� rH r NrP z "r �*z*/*rL �+)
r� r r rl r r ry �addrm �strip)
r� �parts�params�item�key�valueZfulltypeZmtype�styper� r. r. r2 �parse_mimetype9 s@ �
� � �(� �r� )r� �defaultr- c C s@ t | dd �}|r<t|t�r<|d dkr<|d dkr<t|�jS |S )N�namer rD r� rE )r� rt ry r r� )r� r� r� r. r. r2 �guess_filenamei s &
r� )�disptype� quote_fieldsr� r- c K s� | rt t| �ks td�| ���| }|r�g }|�� D ]f\}}|rJt t|�ksZtd�||���|rht|d�n|}|�|d| f� |dkr2|�dd| f� q2d�d d
� |D ��}d�||f�}|S ) z�Sets ``Content-Disposition`` header.
disptype is a disposition type: inline, attachment, form-data.
Should be valid extension token (see RFC 2183)
params is a dict with disposition params.
z!bad content disposition type {!r}z+bad content disposition parameter {!r}={!r}r^ z"%s"�filenamez filename*zutf-8''z; c s s | ]}d � |�V qdS )rP N)�join)r0 Zpairr. r. r2 � <genexpr>� s z-content_disposition_header.<locals>.<genexpr>)�TOKEN�setrc �formatr� r �appendr� ) r� r� r� r� Zlparamsr� r� ZqvalZsparamsr. r. r2 �content_disposition_headerp s"
�r� c @ s e Zd ZU eeef ed< dS )�_TSelf�_cacheN)r[ r\ r] r ry r r� r. r. r. r2 r� � s
r� c @ sV e Zd ZdZedef dd�dd�Zd
eee e
ed�dd �Z eedd
�d d �Z dS )�reifyaR Use as a class method decorator. It operates almost exactly like
the Python `@property` decorator, but it puts the result of the
method it decorates into the instance dict after the first call,
effectively replacing the function it decorates with an instance
variable. It is, in Python parlance, a data descriptor.
.N)�wrappedr- c C s || _ |j| _|j| _d S rW )r� rx r[ r� )rY r� r. r. r2 �__init__� s zreify.__init__)�inst�ownerr- c C sr zFz|j | j W W S tk
rB | �|�}||j | j< | Y W S X W n& tk
rl |d krf| Y S � Y nX d S rW )r� r� �KeyErrorr� �AttributeError)rY r� r� r� r. r. r2 �__get__� s
z
reify.__get__)r� r� r- c C s t d��d S )Nz reified property is read-only)r� )rY r� r� r. r. r2 �__set__� s z
reify.__set__)N)
r[ r\ r] rx r r8 r� r� r r r r� r� r. r. r. r2 r� � s
r� )r� z[^(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$a� ^(?:(?:(?:[A-F0-9]{1,4}:){6}|(?=(?:[A-F0-9]{0,4}:){0,6}(?:[0-9]{1,3}\.){3}[0-9]{1,3}$)(([0-9A-F]{1,4}:){0,5}|:)((:[0-9A-F]{1,4}){1,5}:|:)|::(?:[A-F0-9]{1,4}:){5})(?:(?:25[0-5]|2[0-4][0-9]|1[0-9][0-9]|[1-9]?[0-9])\.){3}(?:25[0-5]|2[0-4][0-9]|1[0-9][0-9]|[1-9]?[0-9])|(?:[A-F0-9]{1,4}:){7}[A-F0-9]{1,4}|(?=(?:[A-F0-9]{0,4}:){0,7}[A-F0-9]{0,4}$)(([0-9A-F]{1,4}:){1,7}|:)((:[0-9A-F]{1,4}){1,7}|:)|(?:[A-F0-9]{1,4}:){7}:|:(:[A-F0-9]{1,4}){7})$)�flagsrj )�regex�regexbr� r- c C sZ |d kr dS t |t�r$t| �|��S t |tttf�rBt|�|��S td�|t |����d S )NFz {} [{}] is not a str or bytes)
rt ry �bool�match�bytes� bytearray�
memoryviewru r� r� )r� r� r� r. r. r2 �_is_ip_address� s
r� )r� r- c C s t | �pt| �S rW )�is_ipv4_address�is_ipv6_address)r� r. r. r2 �
is_ip_address� s r� c C s$ t j �t jj�jdd�t jdd� S )z8Return current time rounded up to the next whole second.r )Z microsecond)Zseconds)�datetime�now�timezoneZutc�replaceZ timedeltar. r. r. r2 �next_whole_second� s
�
�r� r^ c C s\ t t�� �} | tkrXd}d}t�| �^}}}}}}} }
d|| ||| ||||f a| atS )N)ZMonZTueZWedZThuZFriZSatZSun)
r^ ZJanZFebZMarZAprZMayZJunZJulZAugZSepZOctZNovZDecz#%s, %02d %3s %4d %02d:%02d:%02d GMT)�int�time�_cached_current_datetime�gmtime�_cached_formatted_datetime) r� Z _weekdaynameZ
_monthnameZyearZmonthZdayZhhZmmZssZwd�tailr. r. r2 �rfc822_formatted_time� s � r� c C s: | \}}|� }|d k r6t t�� t||�� W 5 Q R X d S rW )r � Exceptionr� )�info�refr� �obr. r. r2 �_weakref_handle s
r� c C sH |d k rD|dkrD|� � | }|dkr,t|�}|�|tt�| �|f�S d S �Nr � )r� r �call_atr� �weakrefr� )r� r� �timeoutr, �whenr. r. r2 �weakref_handle s
r� c C s< |d k r8|dkr8|� � | }|dkr,t|�}|�|| �S d S r� )r� r r� )�cbr� r, r� r. r. r2 �
call_later( s
r� c @ s~ e Zd ZdZejee dd�dd�Ze d e
e
dd�dd �Z dd
�d d �Z eej
d
�d
d�Zdd
�dd�Zdd
�dd�ZdS )�
TimeoutHandlez Timeout handle N)r, r� r- c C s || _ || _g | _d S rW )�_timeout�_loop�
_callbacks)rY r, r� r. r. r2 r� 3 s �zTimeoutHandle.__init__).N)�callback�args�kwargsr- c O s | j �|||f� d S rW )r� r� )rY r� r r r. r. r2 �register< s zTimeoutHandle.registerrV c C s | j �� d S rW )r� �clearrX r. r. r2 �closeA s zTimeoutHandle.closec C sL | j }|d k rD|dkrD| j�� | }|dkr4t|�}| j�|| j�S d S d S r� )r� r� r� r r� �__call__)rY r� r� r. r. r2 �startD s zTimeoutHandle.start�BaseTimerContextc C s8 | j d k r.| j dkr.t| j�}| �|j� |S t� S d S )Nr )r� � TimerContextr� r r� � TimerNoop)rY �timerr. r. r2 r
N s
zTimeoutHandle.timerc
C s> | j D ](\}}}tt�� |||� W 5 Q R X q| j �� d S rW )r� r r� r )rY r� r r r. r. r2 r V s
zTimeoutHandle.__call__)r[ r\ r] rx r5 �AbstractEventLoopr �floatr� r r r r ZHandler r
r r. r. r. r2 r� 0 s �
�
r� c @ s e Zd ZdS )r N)r[ r\ r] r. r. r. r2 r ^ s r c @ s> e Zd Zed�dd�Zeee ee ee dd�dd�Z dS )r rV c C s | S rW r. rX r. r. r2 � __enter__c s zTimerNoop.__enter__N��exc_type�exc_val�exc_tbr- c C s d S rW r. �rY r r r r. r. r2 �__exit__f s zTimerNoop.__exit__)
r[ r\ r] r r
r r �
BaseExceptionr r r. r. r. r2 r b s
�r c @ sf e Zd ZdZejdd�dd�Zed�dd�Ze e
e e e e e e e
d �d
d �Zdd�d d
�ZdS )r z( Low resolution timeout context manager Nr+ c C s || _ g | _d| _d S )NF)r� �_tasks�
_cancelled)rY r, r. r. r2 r� r s zTimerContext.__init__rV c C sB t | jd�}|d kr td��| jr2|�� tjd �| j�|� | S )Nr� �4Timeout context manager should be used inside a task) r� r� r� r �cancelr5 � TimeoutErrorr r� �rY Ztaskr. r. r2 r
w s � zTimerContext.__enter__r c C s, | j r| j �� |tjkr(| jr(tjd �d S rW )r �popr5 ZCancelledErrorr r r r. r. r2 r � s
zTimerContext.__exit__c C s( | j s$t| j�D ] }|�� qd| _ d S )NT)r r� r r r r. r. r2 r� � s
zTimerContext.timeout)r[ r\ r] rx r5 r r� r r
r r r r r� r r� r. r. r. r2 r o s
�
r c @ s e Zd Zejd�dd�ZdS )� CeilTimeoutrV c C sh | j d k rdt| jd�| _| jd kr*td��| j�� }| j }|| }|dkrRt|�}| j�|| j�| _ | S )Nr� r r� )
r� r� r� Z_taskr� r� r r� Z _cancel_taskZ_cancel_handler)rY r� Zdelayr� r. r. r2 r
� s
�
zCeilTimeout.__enter__N)r[ r\ r] �
async_timeoutr� r
r. r. r. r2 r � s r c @ st e Zd Zedddg�ZdZdZeZe dd�dd�Z
e e d�d d
��Z e e
e d�d d ��Ze e
e d�d
d��ZdS )� HeadersMixin�
_content_type�
_content_dict�_stored_content_typeN)�rawr- c C s2 || _ |d kr d| _i | _nt�|�\| _| _d S )Nzapplication/octet-stream)r! r r �cgiZ parse_header�rY r" r. r. r2 �_parse_content_type� s
z HeadersMixin._parse_content_typerV c C s( | j �tj�}| j|kr"| �|� | jS )z7The value of content part for Content-Type HTTP header.)�_headersr� r � CONTENT_TYPEr! r% r r$ r. r. r2 � content_type� s
zHeadersMixin.content_typec C s. | j �tj�}| j|kr"| �|� | j�d�S )z7The value of charset part for Content-Type HTTP header.�charset)r& r� r r' r! r% r r$ r. r. r2 r) � s
zHeadersMixin.charsetc C s& | j �tj�}|dk r t|�S dS dS )z(The value of Content-Length HTTP header.N)r& r� r ZCONTENT_LENGTHr� )rY �content_lengthr. r. r2 r* � s zHeadersMixin.content_length)r[ r\ r] � frozensetZATTRSr r �sentinelr! ry r% �propertyr( r r) r� r* r. r. r. r2 r � s r zasyncio.Future[_T])�fut�resultr- c C s | � � s| �|� d S rW )r/ �
set_result)r. r/ r. r. r2 r0 � s r0 )r. �excr- c C s | � � s| �|� d S rW )r/ �
set_exception)r. r1 r. r. r2 r2 � s r2 c @ s� e Zd ZdZeeeef dd�dd�Zdd�dd�Z eed �d
d �Z
deeed �d
d�Z e d�dd�Z
ee d�dd�Zeed �dd�Zed�dd�Zed�dd�ZdS )r% )�_mapsN)�mapsr- c C s t |�| _d S rW )�tupler3 )rY r4 r. r. r2 r� � s zChainMapProxy.__init__rV c C s t d�| j���d S )Nz4Inheritance class {} from ChainMapProxy is forbidden)ru r� r[ )rf r. r. r2 �__init_subclass__� s
��z ChainMapProxy.__init_subclass__)r� r- c C s< | j D ](}z|| W S tk
r, Y qX qt|��d S rW )r3 r� )rY r� �mappingr. r. r2 � __getitem__� s
zChainMapProxy.__getitem__)r� r� r- c C s || kr| | S |S rW r. )rY r� r� r. r. r2 r� � s zChainMapProxy.getc C s t t� j| j� �S rW )�lenr� �unionr3 rX r. r. r2 �__len__� s zChainMapProxy.__len__c C s& i }t | j�D ]}|�|� qt|�S rW )�reversedr3 �update�iter)rY �dr7 r. r. r2 �__iter__� s zChainMapProxy.__iter__c s t � fdd�| jD ��S )Nc 3 s | ]}� |kV qd S rW r. )r0 �m�r� r. r2 r� s z-ChainMapProxy.__contains__.<locals>.<genexpr>��anyr3 )rY r� r. rB r2 � __contains__ s zChainMapProxy.__contains__c C s
t | j�S rW rC rX r. r. r2 �__bool__ s zChainMapProxy.__bool__c C s d� tt| j��}d|� d�S )Nz, zChainMapProxy(rC )r� �map�reprr3 )rY Zcontentr. r. r2 �__repr__
s zChainMapProxy.__repr__)N)r[ r\ r] � __slots__r r ry r r� r6 r8 r� r� r; r
r@ �objectr� rE rF rI r. r. r. r2 r% � s r% )N)N)N)N)T)�rx r5 rn rq r# r� � functoolsr� r� r~ r� �re�sysr� r� r� � collectionsr �
contextlibr Zmathr �pathlibr �typesr �typingr r r r
r r r
r r r r r r r r r r Z urllib.parser Zurllib.requestr r �attrZ multidictr r Ztyping_extensionsr Zyarlr r^ r �logr! r" Ztypedefsr# �__all__� version_infoZPY_36r� ZPY_38Zidna_sslZpatch_match_hostnamer* � ImportErrorr r7 r� r8 r9 rK r, r� r r� Z
NO_EXTENSIONSr� �ignore_environment�DEBUG�rangeZCHARr< ZCTLZ
SEPARATORSr� rU r$ r} r� �sr� ry r� r� r� r� r� � lru_cacher� r� r� r� r� Zreify_pyZ_helpersZreify_cZ
_ipv4_patternZ
_ipv6_pattern�compileZ _ipv4_regex�
IGNORECASEZ _ipv6_regexro Z _ipv4_regexbZ _ipv6_regexbr� r� �partialr� r� r� r� r� r� r� r� r� r� r� r� r� r r r r� r r r0 r r2 r% r. r. r. r2 �<module> s0 L
��
��� = ( ��
��
/ � � ��
�
( .
,,