­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ U '7`Y@sdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZddlmZddlmZddlmZddlmZmZmZmZmZm 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 l2m3Z3m4Z4dd l5m6Z6dd l7m8Z8ddl9m:Z:ddl;mm?Z?dZ@e jAdkZBe jAdkZCe jAdkZDeCsddlEZEeEFzddlmGZGWn"eHk rddl5mGZGYnXde$ejIe&ddddZJeCreKedZJe)dZLe)dZMeNZOePe jQRdZSeKe jTddpde jTjU odePe jQRd ZVd!d"eWdd#DZXd$d"eWdd%DeYd&hBZZd'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8eYd9hZ[eXeZAe[AZ\Gd:d;d;Z]Gdd?d@gZ^e8e'e8e$e^fdAdBdCZ_e$ejdDdEdFZ`e1jadGdGdGdHGdIdJdJZbeecebfdDdKdLZdde$ejIdMddNdOZede$ejIejIddPdQZfeePdRdSdTZge1jadGdGdGdHGdUdVdVZhejidWdXecehdYdZd[Zjdee$ece$ecd\d]d^ZkdecePececd_d`daZlGdbdcdce6ZmGdddedeeeLZnenZozddflpmnZqeSsNeqZnWneHk rfYnXdgZrdhZse terZue jtese jvdiZwe terxdjZye jtesxdje jvdiZze%ece%e{e$e*ece{fePdkdldmZ|e}e|eueyZ~e}e|ewezZe$e*ece{eefePdndodpZejdDdqdrZdadsaecdDdtduZdvdwZdxdyZdzd{ZGd|d}d}ZGd~ddeGdZGdddeZGdddeZGddde0jZGdddZdeLddddZdeddddZGddde#ecefZdS)zVarious helper functionsN) namedtuple)suppress)ceil)Path) TracebackType)AnyCallableDict GeneratorGenericIterableIteratorListMappingOptionalPatternSetTupleTypeTypeVarUnioncast)quote) getproxies) MultiDictMultiDictProxy)ProtocolURL)hdrs) client_loggerinternal_logger)PathLike) BasicAuth ChainMapProxy))r&)r&)ContextManagerzasyncio.Task[Any]loopreturncCsttj|}dd|DS)NcSsh|]}|s|qS)done).0tr.r.B/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/helpers.py Lszall_tasks..)listasyncioTask all_tasks)r,Ztasksr.r.r2r7Hsr7_T_SZAIOHTTP_NO_EXTENSIONSdev_modeFZPYTHONASYNCIODEBUGcCsh|] }t|qSr.chrr0ir.r.r2r3asr3cCsh|] }t|qSr.r;r=r.r.r2r3bs ()<>@,;:\"/[]?={} c@seZdZeddddZdS)noop)NNNr-ccs dVdSNr.selfr.r.r2 __await__~sznoop.__await__N)__name__ __module__ __qualname__r rZr.r.r.r2rU}srUcsteZdZdZdeeeddfdd Zedeedddd Zedd eee dd d d Z edddZ Z S)r$z!Http basic authentication helper.latin1)loginpasswordencodingr-csB|dkrtd|dkr tdd|kr0tdt||||S)Nz"None is not allowed as login valuez%None is not allowed as password valuerIz5A ":" is not allowed in login (RFC 1945#section-11.1)) ValueErrorsuper__new__)clsr`rarb __class__r.r2reszBasicAuth.__new__) auth_headerrbr-cCsz|dd\}}Wntk r0tdYnX|dkrJtd|ztj|ddd|}Wntjk rtd YnXz|d d\}}Wntk rtd YnX||||d S) zsz$proxies_from_env..cSsi|]\}}|t|qSr.)rrr.r.r2rsrz,HTTPS proxies %s are not supported, ignoringr) ritemsrschemer!rhostZauthenticatorsr$rr~r) Z proxy_urlsZ netrc_objstrippedretprotovalrrZauth_from_netrcZloginsrar`r.r.r2proxies_from_envs&      rzOptional[asyncio.Task[Any]]cCs"trtj|dStjj|dSdS)Nr,)PY_37r5 current_taskr6rr.r.r2rs rcCsB|dkrt}|s>tjdtdd|r>tjddd|S)Nz5The object should be created within an async functionr&) stacklevelT) stack_info) r5Zget_event_loopZ is_runningwarningswarnDeprecationWarningZ get_debugr"rrr.r.r2get_running_loopsr)objr-cCs$ttdd}|dk r||SdSdS)NisasyncgenfunctionF)getattrinspect)rfuncr.r.r2r)s rc@s.eZdZUeed<eed<eed<ded<dS)MimeTypetypesubtypesuffixzMultiDictProxy[str] parametersN)r[r\r]r~rr.r.r.r2r1s r8)maxsize)mimetyper-c Cs|stdddttdS|d}t}|ddD]R}|s@q6ttttfd|kr`|ddn|df\}}|| | dq6|d }|d krd }d |krttttf|d dn|df\}}d |krttttf|d dn|df\}} t||| t|dS) aParses 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^)rrrrrHrNrPz "r*z*/*rL+) rrrrmrrr~addrnstrip) rpartsparamsitemkeyvalueZfulltypeZmtypestyperr.r.r2parse_mimetype9s@  (r)rdefaultr-cCs@t|dd}|rsz-content_disposition_header..)TOKENsetrcformatrrappendr) rrrrZlparamsrrZqvalZsparamsr.r.r2content_disposition_headerps"  rc@seZdZUeeefed<dS)_TSelf_cacheN)r[r\r]r r~rrr.r.r.r2rs rc@sVeZdZdZedefddddZd eee e eddd Z eedd d d Z dS)reifyaRUse 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-cCs||_|j|_|j|_dSrW)rr}r[r)rYrr.r.r2__init__szreify.__init__)instownerr-cCsrzFz|j|jWWStk rB||}||j|j<|YWSXWn&tk rl|dkrf|YSYnXdSrW)rrKeyErrorrAttributeError)rYrrrr.r.r2__get__s  z reify.__get__)rrr-cCs tddS)Nzreified property is read-only)r)rYrrr.r.r2__set__sz reify.__set__)N) r[r\r]r}rr8rrrrrrrr.r.r.r2rs r)rz[^(?:(?: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)regexregexbrr-cCsZ|dkr dSt|tr$t||St|tttfrBt||Std|t |dS)NFz{} [{}] is not a str or bytes) rxr~boolmatchbytes bytearray memoryviewryrr)rrrr.r.r2_is_ip_addresss r)rr-cCst|pt|SrW)is_ipv4_addressis_ipv6_address)rr.r.r2 is_ip_addresssrcCs$tjtjjjddtjddS)z8Return current time rounded up to the next whole second.r) microsecond)seconds)datetimenowtimezoneutcreplace timedeltar.r.r.r2next_whole_seconds  rr^c Cs\tt}|tkrXd}d}t|^}}}}}}} } d|| |||||||fa|atS)N)MonTueWedThuFriSatSun) r^JanFebMarAprMayJunJulAugSepOctNovDecz#%s, %02d %3s %4d %02d:%02d:%02d GMT)inttime_cached_current_datetimegmtime_cached_formatted_datetime) rZ _weekdaynameZ _monthnameyearmonthdayZhhmmsswdtailr.r.r2rfc822_formatted_times   rc Cs:|\}}|}|dk r6ttt||W5QRXdSrW)r Exceptionr)inforefrobr.r.r2_weakref_handles  rcCsH|dk rD|dkrD||}|dkr,t|}||tt||fSdSNr)r rcall_atrweakrefr)rrtimeoutr,whenr.r.r2weakref_handles  r cCs<|dk r8|dkr8||}|dkr,t|}|||SdSr)r rr)cbrr,rr.r.r2 call_later(s  r"c@s~eZdZdZejeeddddZe de e dddd Z dd d d Z eej d d dZdd ddZdd ddZdS) TimeoutHandlez Timeout handle N)r,rr-cCs||_||_g|_dSrW)_timeout_loop _callbacks)rYr,rr.r.r2r3szTimeoutHandle.__init__).N)callbackargskwargsr-cOs|j|||fdSrW)r&r)rYr'r(r)r.r.r2register<szTimeoutHandle.registerrVcCs|jdSrW)r&clearrXr.r.r2closeAszTimeoutHandle.closecCsL|j}|dk rD|dkrD|j|}|dkr4t|}|j||jSdSdSr)r$r%r rr__call__)rYrrr.r.r2startDszTimeoutHandle.startBaseTimerContextcCs8|jdk r.|jdkr.t|j}||j|StSdS)Nr)r$ TimerContextr%r*r TimerNoop)rYtimerr.r.r2r2Ns   zTimeoutHandle.timerc Cs>|jD](\}}}tt|||W5QRXq|jdSrW)r&rrr+)rYr!r(r)r.r.r2r-Vs zTimeoutHandle.__call__)r[r\r]r}r5AbstractEventLooprfloatrrrr*r,Handler.r2r-r.r.r.r2r#0s   r#c@s eZdZdS)r/N)r[r\r]r.r.r.r2r/^sr/c@s>eZdZedddZeeeeeeeddddZ dS)r1rVcCs|SrWr.rXr.r.r2 __enter__cszTimerNoop.__enter__Nexc_typeexc_valexc_tbr-cCsdSrWr.rYr8r9r:r.r.r2__exit__fszTimerNoop.__exit__) r[r\r]r/r6rr BaseExceptionrr<r.r.r.r2r1bs  r1c@sfeZdZdZejddddZedddZe e e e e e e e e d d d Zddd d ZdS)r0z( Low resolution timeout context manager Nr+cCs||_g|_d|_dS)NF)r%_tasks _cancelled)rYr,r.r.r2rrszTimerContext.__init__rVcCsBt|jd}|dkrtd|jr2|tjd|j||S)Nr4Timeout context manager should be used inside a task) rr%rr?cancelr5 TimeoutErrorr>rrYZtaskr.r.r2r6ws  zTimerContext.__enter__r7cCs,|jr|j|tjkr(|jr(tjddSrW)r>popr5CancelledErrorr?rBr;r.r.r2r<s  zTimerContext.__exit__cCs(|js$t|jD] }|qd|_dS)NT)r?rr>rArCr.r.r2rs zTimerContext.timeout)r[r\r]r}r5r3rr/r6rrr=rrr<rr.r.r.r2r0os  r0c@seZdZejdddZdS) CeilTimeoutrVcCsh|jdk rdt|jd|_|jdkr*td|j}|j}||}|dkrRt|}|j||j|_ |S)Nrr@r) r$rr%Z_taskrr rrZ _cancel_taskZ_cancel_handler)rYrdelayrr.r.r2r6s   zCeilTimeout.__enter__N)r[r\r] async_timeoutrr6r.r.r.r2rFsrFc@steZdZedddgZdZdZeZe ddddZ e e dd d Z e e e dd d Ze e edd dZdS) HeadersMixin _content_type _content_dict_stored_content_typeN)rawr-cCs2||_|dkrd|_i|_nt|\|_|_dS)Nzapplication/octet-stream)rLrJrKcgi parse_headerrYrMr.r.r2_parse_content_types z HeadersMixin._parse_content_typerVcCs(|jtj}|j|kr"|||jS)z7The value of content part for Content-Type HTTP header.)_headersrr CONTENT_TYPErLrQrJrPr.r.r2 content_types  zHeadersMixin.content_typecCs.|jtj}|j|kr"|||jdS)z7The value of charset part for Content-Type HTTP header.charset)rRrr rSrLrQrKrPr.r.r2rUs  zHeadersMixin.charsetcCs&|jtj}|dk rt|SdSdS)z(The value of Content-Length HTTP header.N)rRrr ZCONTENT_LENGTHr)rYcontent_lengthr.r.r2rVszHeadersMixin.content_length)r[r\r] frozensetZATTRSrJrKsentinelrLr~rQpropertyrTrrUrrVr.r.r.r2rIs rIzasyncio.Future[_T])futresultr-cCs|s||dSrW)r/ set_result)rZr[r.r.r2r\sr\)rZexcr-cCs|s||dSrW)r/ set_exception)rZr]r.r.r2r^sr^c@seZdZdZeeeefddddZddddZ eed d d Z deeed d dZ e dddZ eedddZeed ddZedddZedddZdS)r%)_mapsN)mapsr-cCst||_dSrW)tupler_)rYr`r.r.r2rszChainMapProxy.__init__rVcCstd|jdS)Nz4Inheritance class {} from ChainMapProxy is forbidden)ryrr[)rfr.r.r2__init_subclass__s zChainMapProxy.__init_subclass__)rr-c Cs<|jD](}z||WStk r,YqXqt|dSrW)r_r)rYrmappingr.r.r2 __getitem__s  zChainMapProxy.__getitem__)rrr-cCs||kr||S|SrWr.)rYrrr.r.r2rszChainMapProxy.getcCsttj|jSrW)lenrunionr_rXr.r.r2__len__szChainMapProxy.__len__cCs&i}t|jD]}||qt|SrW)reversedr_updateiter)rYdrcr.r.r2__iter__s zChainMapProxy.__iter__cstfdd|jDS)Nc3s|]}|kVqdSrWr.)r0mrr.r2rsz-ChainMapProxy.__contains__..anyr_)rYrr.rnr2 __contains__szChainMapProxy.__contains__cCs t|jSrWrorXr.r.r2__bool__szChainMapProxy.__bool__cCsdtt|j}d|dS)Nz, zChainMapProxy(rC)rmapreprr_)rYcontentr.r.r2__repr__ szChainMapProxy.__repr__)N)r[r\r] __slots__r rr~rrrbrdrrrgr rlobjectrrqrrrvr.r.r.r2r%sr%)N)N)N)N)T)r}r5rorsrNr functoolsrrrrresysr rr collectionsr contextlibrmathrpathlibrtypesrtypingrrr r r r r rrrrrrrrrr urllib.parserZurllib.requestrrHattrZ multidictrrZtyping_extensionsrZyarlrr^r logr!r"Ztypedefsr#__all__ version_infoZPY_36rZPY_38Zidna_sslZpatch_match_hostnamer* ImportErrorr3r7rr8r9rxrXrrrZ NO_EXTENSIONSrignore_environmentDEBUGrangeZCHARr<ZCTLZ SEPARATORSrrUr$rrsrr~rrrrr lru_cacherrrrrZreify_pyZ_helpersZreify_cZ _ipv4_patternZ _ipv6_patterncompileZ _ipv4_regex IGNORECASEZ _ipv6_regexrqZ _ipv4_regexbZ _ipv6_regexbrrpartialrrrrrrr r rrr r"r#r/r1r0rrFrIr\r=r^r%r.r.r.r2s0     L            =(   /     ( . ,,