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 jAdkZDeCsddlEZEeEF zddlmGZG W n" eHk
r ddl5mGZG Y nX de$ejI e&d dddZJeCreKedZJe)dZLe)d ZMeN ZOePe jQRd ZSeKe jTd d pde jTjU odePe jQRd ZVd!d" eWdd#D ZXd$d" eWdd%D eYd&hB ZZd'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8eYd9hZ[eXeZA e[A Z\G d:d; d;Z]G d<d= d=ed=d>d?d@gZ^e8e'e8e$e^ f dAdBdCZ_e$ej dDdEdFZ`e1jadGdGdGdHG dIdJ dJZbe ecebf dDdKdLZdde$ejI dMddNdOZede$ejI ejIddPdQZfeePdRdSdTZge1jadGdGdGdHG dUdV dVZhejidWdXecehdYdZd[Zjdee$ec e$ec d\d]d^ZkdecePececd_d`daZlG dbdc dce6ZmG ddde dee eL ZnenZozddflpmnZq eSsNeqZnW n eHk
rf Y nX dgZrdhZse terZue jtese jvdiZwe terxdjZye jtesxdje jvdiZze%ec e%e{ e$e*ece{f ePdkdldmZ|e}e|eueyZ~e}e|ewezZe$e*ece{eef ePdndodpZejdDdqdrZdadsaecdDdtduZdvdw Zdxdy Zdzd{ ZG d|d} d}ZG d~d deGd ZG dd deZG dd deZG dd de0jZG dd dZdeLddddZdeddddZG dd de#ecef ZdS )zVarious helper functions N)
namedtuple)suppress)ceil)Path)
TracebackType)AnyCallableDict GeneratorGenericIterableIteratorListMappingOptionalPatternSetTupleTypeTypeVarUnioncast)quote)
getproxies) MultiDictMultiDictProxy)ProtocolURL )hdrs)
client_loggerinternal_logger)PathLike) BasicAuth
ChainMapProxy) )r& )r& )ContextManagerzasyncio.Task[Any]loopreturnc C s t tj| }dd |D S )Nc S s h | ]}| s|qS )done).0tr. r. B/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/helpers.py <setcomp>L s z all_tasks.<locals>.<setcomp>)listasyncioTask all_tasks)r, Ztasksr. r. r2 r7 H s r7 _T_SZAIOHTTP_NO_EXTENSIONSdev_modeFZPYTHONASYNCIODEBUGc C s h | ] }t |qS r. chrr0 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 dddZdS )noop)NNNr- 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 ddd Zedd
eee d d d d
Z
edddZ Z S )r$ z!Http basic authentication helper. latin1)loginpasswordencodingr- c sB |d krt d|d kr t dd|kr0t dt | |||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))
ValueErrorsuper__new__)clsr` ra rb __class__r. r2 re s zBasicAuth.__new__) auth_headerrb r- c C s z| dd\}}W n tk
r0 tdY nX | dkrJtd| z tj|ddd|}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 %sasciiT)ZvalidatezInvalid base64 encoding.rI zInvalid credentials.rb ) splitrc lowerbase64Z b64decodeencodedecodebinasciiError)rf ri rb Z auth_typeZencoded_credentialsZdecodedZusernamera r. r. r2 rp s( zBasicAuth.decoderk )urlrb r- c C s6 t |tstd|jdkr dS | |j|jp.d|dS )zCreate BasicAuth from url.z url should be yarl.URL instanceNr^ rk )
isinstancer TypeErroruserra )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 jd} | dk r t| }nZz t }W n4 tk
r^ } ztd| 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| rt
d| W 5 d}~X Y nX dS ) zAttempt 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)osenvirongetr home RuntimeErrorr! debugplatformsystemnetrcry ZNetrcParseErrorwarningOSErroris_file)Z netrc_envZ
netrc_pathZhome_direr. r. r2 netrc_from_env s,
r T)Z auto_attribsfrozenslotsc @ s" e Zd ZU eed< ee ed< dS ) ProxyInfoproxyZ
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`td| q8|r|d krd }|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 ))Zhttphttpsr r0 kvr. 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_objstrippedZretprotovalr r| Zauth_from_netrcZloginsra r` r. r. r2 proxies_from_env s&
r zOptional[asyncio.Task[Any]]c C s" t rtj| dS tjj| dS d S )Nr, )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_runningwarningswarnDeprecationWarningZ 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 )NisasyncgenfunctionF)getattrinspect)r funcr. r. r2 r ) s r c @ s. e Zd ZU eed< eed< eed< ded< dS )MimeTypetypesubtypesuffixzMultiDictProxy[str]
parametersN)r[ r\ r] ry r r. r. r. r2 r 1 s
r 8 )maxsize)mimetyper- c
C s | st dddtt dS | d}t }|dd D ]R}|s@q6ttttf d|kr`|ddn|df\}}|| | d q6|d }|d krd
}d |krttttf |d dn|df\}}d |krttttf |d dn|df\}} t ||| t|dS )
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 partsparamsitemkeyvalueZfulltypeZmtypestyper r. r. r2 parse_mimetype9 s@
( r )r defaultr- c C s@ t | dd }|r<t|tr<|d dkr<|d dkr<t|jS |S )Nnamer 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| | }|rg }| D ]f\}}|rJt t|ksZtd|||rht|dn|}||d| f |dkr2|dd| f q2dd d
|D }d||f}|S ) zSets ``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>)TOKENsetrc 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 ddddZd
eee e
eddd 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__)instownerr- 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 dd 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 )regexregexbr r- c C sZ |d kr dS t |tr$t| |S t |tttfrBt||S td|t |d S )NFz {} [{}] is not a str or bytes)
rt ry boolmatchbytes 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_addressis_ipv6_address)r r. r. r2
is_ip_address s r c C s$ t j t jjjddt jdd S )z8Return current time rounded up to the next whole second.r )Z microsecond)Zseconds)datetimenowtimezoneZutcreplaceZ 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)inttime_cached_current_datetimegmtime_cached_formatted_datetime) r Z _weekdaynameZ
_monthnameZyearZmonthZdayZhhZmmZssZwdtailr. 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 )inforefr obr. r. r2 _weakref_handle s
r c C sH |d k rD|dkrD| | }|dkr,t|}||tt| |fS 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 ddddZe d e
e
dddd Z dd
d d Z eej
d
d
dZdd
ddZdd
ddZdS )
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)callbackargskwargsr- 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|| jS d S d S r )r r r r r __call__)rY r r r. r. r2 startD s zTimeoutHandle.startBaseTimerContextc 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 ZedddZeee ee ee ddddZ dS )r rV c C s | S rW r. rX r. r. r2 __enter__c s zTimerNoop.__enter__Nexc_typeexc_valexc_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 ZdZejddddZedddZe e
e e e e e e e
d d
d Zddd 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| jD ] }| 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 ZejdddZdS ) 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 ZedddgZdZdZeZe ddddZ
e e dd d
Z e e
e dd d Ze e
e dd
dZdS ) 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_headerrY 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"| | | jdS )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])futresultr- 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 ddddZddddZ eed d
d Z
deeed d
dZ e dddZ
ee dddZeed ddZedddZedddZdS )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| jd 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 | jD ]}|| qt|S rW )reversedr3 updateiter)rY dr7 r. r. r2 __iter__ s zChainMapProxy.__iter__c s t fdd| jD S )Nc 3 s | ]} |kV qd S rW r. )r0 mr r. r2 r s z-ChainMapProxy.__contains__.<locals>.<genexpr>anyr3 )rY r r. rB r2 __contains__ s zChainMapProxy.__contains__c C s
t | jS rW rC rX r. r. r2 __bool__ s zChainMapProxy.__bool__c C s d tt| j}d| dS )Nz, zChainMapProxy(rC )r mapreprr3 )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 resysr 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_environmentDEBUGrangeZCHARr< 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_patterncompileZ _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
= (
/
( .
,,