iwd UdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lm Z m!Z!dd l"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/m0Z0m1Z1m2Z2m3Z3m4Z4dd l5m6Z6ddl7m8Z8m9Z9ddl:Z:ddl;mZ>ddl?m@ZAddlBmCZCddlDmEZEddlFmGZGe jdk\rddlZInddlIZIdZJe jdk(ZLe jdk(ZMe jdk\ZNe jdk\ZOe1dZPe1dZQejddZSeSjZTeUe jjdZXeYdd geZd!d"Z[eEjZ]e jjxs:e jj xr!eUe jjd#ZaeZdd$Dchc] }eb| c}ZceZdd%Dchc] }eb| c}ebd&hzZdd'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8ebd9hZeecedz eez ZfGd:d;ZgGd<d=ed=gd>Zhd?eCd@e/eCe-ehffdAZid@e-e jfdBZje:jdCdCdCDGdEdFZldGe-e jdHemd@ehfdIZnd@e&emelffdJZod?eCd@e/eCe-ehffdKZpe:jdCdCdCDGdLdMZqejdNOdPemd@eqfdQZsGdRdSeZtejdNOdTemd@e/eme ememfffdUZuddVe#dWe-emd@e-emfdXZve jdYZxeZd%d&Dchc] }eb| c}dZhzZyd[emd@emfd\Zz dd]emd^eUd_emd`emd@emf daZ{dHe-emd@eUfdbZ|da}e-e~edc<ddad@emfdeZddfZ ddgedhemdiedjej dked@e-ej f dlZ ddme$ge#fdiedjej dked@e-ej f dnZdoediedped@efdqZGdrdsZGdtdue%duZGdvdweZGdxdyeZ ddze-ed{ed@eIjfd|ZGd}d~ZdddePd@dfdZeZGdde.Zefdddeded@dfdZej,Gdde(ePZGdde,e2emee#fe#fZdZe jeZdedZe jeZe jd'edZdZe:jdCdCdCDGddZdemd@dfdZde-emd@e-ej fdZejdemde~d@eUfdZdemde~d@eUfdZycc}wcc}wcc}w)zVarious helper functionsN) namedtuple)suppress) EmailMessage) HeaderParser)HTTP) parsedateceil)Path)MappingProxyType TracebackType)AnyCallableContextManagerDict GeneratorGenericIterableIteratorListMappingOptionalProtocolTupleTypeTypeVarUnionget_argsoverload)quote) getproxies proxy_bypass) MultiDictMultiDictProxy MultiMapping)under_cached_property)URL)hdrs) client_logger ) BasicAuth ChainMapProxyETagreifyDarwinWindows)r, _T_S _SENTINELsentinelAIOHTTP_NO_EXTENSIONSi0dPYTHONASYNCIODEBUG ()<>@,;:\"/[]?={} ceZdZdedfdZy)noopreturn)NNNc#KdywNselfs J/var/www/html/binance/venv/lib/python3.12/site-packages/aiohttp/helpers.py __await__znoop.__await__xs  sN)__name__ __module__ __qualname__rr]rYr\rUrUws9%56rarUc eZdZdZ ddedededdffd Zeddededdfd Zedd d edede dfd Z defd Z xZ S)r.z!Http basic authentication helper.latin1loginpasswordencodingrVcz| td| tdd|vr tdt| ||||S)Nz"None is not allowed as login valuez%None is not allowed as password valuerHz5A ":" is not allowed in login (RFC 1945#section-11.1)) ValueErrorsuper__new__)clsrdrerf __class__s r\rjzBasicAuth.__new__sP =AB B  DE E %<TU UwsE8X>>ra auth_headerc |jdd\}}|jdk7rtd|z tj|j ddj |} |jd d\}}|||| S#t$r tdwxYw#tj$r td wxYw#t$r td wxYw) z->sA-F *I* ??  '>JK K 9&&#**73dfX   5 ")sA!6 Hh8X99- FDE E F~~ 978 8 9 534 4 5s"B5B'/C B$'C Crrurlct|ts td|j |jy||j xsd|j xsd|S)zCreate BasicAuth from url.zurl should be yarl.URL instanceNrr) isinstancer' TypeErrorraw_user raw_passworduserre)rkrrfs r\from_urlzBasicAuth.from_urlsT#s#=> > << C$4$4$<388>r3<<#52IIrac|jd|jj|j}dt j |j |jzS)zEncode credentials.rHzBasic %s)rdrerwrfru b64encoderx)r[credss r\rwzBasicAuth.encodesNJJF ? ?#& ?7: ?  ?:::;::83;J3JSJ@UJJJJrar.)rdrerfrrVc|j|j|dfS|jdt|jxsd|j xsdfS)zIRemove user and password from URL if present and return BasicAuth object.Nr)rr with_userr.rre)rs r\strip_auth_from_urlrsO || 0 0 8Dy ==  #((.b#,,:L" M MMracztjjd}| t|}n" tj}|trdndz } tjt|S#t $r }t jd|Yd}~yd}~wwxYw#tj$r }t jd|Yd}~yd}~wt$re}d}tjt5|j!}dddn #1swYnxYw|s|rt jd|Yd}~yd}~wwxYw) zLoad netrc from file. Attempt to load it 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. NETRCNzHCould not resolve home directory when trying to look for .netrc file: %s_netrcz.netrczCould not parse .netrc file: %sFzCould not read .netrc file: %s)osenvirongetr home RuntimeErrorr*debug IS_WINDOWSnetrcrNetrcParseErrorwarningOSError contextlibris_file) netrc_env netrc_pathhome_dire netrc_existss r\netrc_from_envrs w'I)_  yy{HZXF  G{{3z?++    5     D?CC  G   ) 0%--/L 0 0 0    ! !"BA F GsSA/B/ B8BBD:.C  D:D50D  D5 D !D55D:T) auto_attribsfrozenslotsc(eZdZUeed<eeed<y) ProxyInfoproxy proxy_authN)r^r_r`r'__annotations__rr.rYrar\rrs J##rar netrc_objhostc| td|j|}|td|d|\}}}|s||n|}|d}t||S)z Return :py:class:`~aiohttp.BasicAuth` credentials for ``host`` from ``netrc_obj``. :raises LookupError: if ``netrc_obj`` is :py:data:`None` or if no entry is found for the ``host``. zNo .netrc file foundz No entry for z found in the `.netrc` file.r) LookupErrorauthenticatorsr.)rrauth_from_netrcrdaccountrer~s r\basicauth_from_netrcrsv011..t4OM$1MNOO.E7H '/uH Xx ((racBtjDcic]\}}|dvr |t|}}}t}|jDcic]\}}|t |}}}i}|jD]~\}}|\}} |j dvr0t jd|j j|I|r%| #|j t||j} t|| ||<|Scc}}wcc}}w#t$rd} Y,wxYw)N)httphttpswswss)rrz)%s proxies %s are not supported, ignoring) r!itemsr'rrschemer*rupperrrrr) kv proxy_urlsrstrippedretprotovalrauths r\proxies_from_envrs3L&&( Aq . . 3q6 J  I6@6F6F6HIda&q))IHI Cnn& , s t <<+ +  ! !;U\\=O=O=QSX   zz% / 5::FDud+E  , J- J# D sDD D DDc|j.t|jrtd|jdt} ||j}|j |j fS#t$rtd|dwxYw)z5Get a permitted proxy for the given URL from the env.zProxying is disallowed for ``zNo proxies found for `z ` in the env)rr"rrrrrKeyError)rproxies_in_env proxy_infos r\get_env_proxy_for_urlr,s xx SXX 68 AFGG%'N7#CJJ/ !6!666 H23'FGGHs A--Bc6eZdZUeed<eed<eed<ded<y)MimeTypetypesubtypesuffixzMultiDictProxy[str] parametersN)r^r_r`rrrYrar\rr:s I L K%%rar8)maxsizemimetypec |s tdddttS|jd}t}|ddD]W}|s|j d\}}}|j |j j|jdY|djj }|d k(rd }|j d \}}} | j d \} }} t|| | t|S) 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)rrrrrGr(NrOz "r*z*/*rK+)rr$r#rs partitionaddrtstrip) rpartsparamsitemkey_valuefulltypemtypestypers r\parse_mimetyperBs R~ik7R   NN3 E&[Fab ; s+ Q 399;$$& D(9: ; Qx~~%%'H3((-OE1es+E1f  E&^F=S rac,eZdZdfd ZdefdZxZS)EnsureOctetStreamrVcDt||jdyNzapplication/octet-stream)ri__init__set_default_type)r[rls r\rzEnsureOctetStream.__init__ks  89rac|jddj}|jd\}}}|j}|j ddk7r|j S|S)aRe-implementation from Message Returns application/octet-stream in place of plain/text when value is wrong. The way this class is used guarantees that content-type will be present so simplify the checks wrt to the base implementation. z content-typerrGrKr()rrtrrcountget_default_type)r[rctypers r\get_content_typez"EnsureOctetStream.get_content_typepsc,224ooc* q!  ;;s q ((* * rarVN)r^r_r`rrrrrs@r\rrjs: #rarrawctttjd|}|j }|j d}t |dd}|t|fS)zParse Content-Type header. Returns a tuple of the parsed content type and a MappingProxyType of parameters. The default returned value is `application/octet-stream` )policyzContent-Type: rYr(N)rrrparsestrr get_paramsdictr )rmsg content_typer content_dicts r\parse_content_typersb ( 6 ? ?.QTPU@V WC'')L ^^B Fqr #L ),7 77raobjdefaultct|dd}|r5t|tr%|ddk7r|ddk7rt|jS|S)NnamerrCrD)getattrrrr r)rrrs r\guess_filenamersC 3 %D 4%$q'S.T"X_Dz Nraz[^\041\043-\133\135-\176] contentcptt|kDstd|tj d|S)aReturn 7-bit content as quoted-string. Format content into a quoted-string as defined in RFC5322 for Internet Message Format. Notice that this is not the 8-bit HTTP format, but the 7-bit email format. Content must be in usascii or a ValueError is raised. zbad content for quoted-string c*d|jdzS)NrIr)group)xs r\zquoted_string..sdQWWQZ&7ra)QCONTENTsetrh not_qtext_resub)rs r\ quoted_stringrs7 s7| #9'EFF   7 AAradisptype quote_fields_charsetrc |rtt|kDstd||}|rg}|jD]\}}|rtt|kDstd|d||r[|j dk(r%t |d|}|j |d|zfe t|}|j |d|zf|jd d jd d }|j |d|zfdjd|D} dj|| f}|S#t$r:dj|dt |d|f}|j |d z|fY1wxYw)akSets ``Content-Disposition`` header for MIME. This is the MIME payload Content-Disposition header from RFC 2183 and RFC 7579 section 4.2, not the HTTP Content-Disposition from RFC 6266. disptype is a disposition type: inline, attachment, form-data. Should be valid extension token (see RFC 2183) quote_fields performs value quoting to 7-bit MIME headers according to RFC 7578. Set to quote_fields to False if recipient can take 8-bit file names and field values. _charset specifies the charset to use when quote_fields is True. params is a dict with disposition params. zbad content disposition type z"bad content disposition parameter rOfilenamerrrz"%s"z''rrIz\\rJz\"z; c3>K|]}dj|yw)rON)join).0pairs r\ z-content_disposition_header..s?tCHHTN?s) TOKENrrhrrtr appendrrreplace) rrrrrlparamsrrqvalsparamss r\content_disposition_headerr"su( ECM18 EFF E   5HCus3x/ #EcWAcW!UVV99;*, b8|jrtjdy)z7Raise TimeoutError if timer has already been cancelled.N)rr TimeoutErrorrZs r\rzTimerContext.assert_timeouts ??&&D 0 rac tj|j}| tdtj dk\r|j |_|jrtjd|jj||S)N)rSz4Timeout context manager should be used inside a taskr+) r current_taskrfrsys version_info cancellingrrrrrr[tasks r\rzTimerContext.__enter__sr##4 <UV V   w & $0D  ??&&D 0 4  rarrrcd}|jr|jj}|tjurR|jrF|Jt j dk\r|j|jkDrytj|y)Nr+) rpoprCancelledErrorrrruncancelrr)r[rrr enter_tasks r\rzTimerContext.__exit__s} 37 ;;*J w-- -$//) ))7*&&(4+;+;;&&G 3rac|js2t|jD]}|jd|_yyNT)rrrcancelrs r\rRzTimerContext.timeouts8DKK(   #DO rar)r^r_r`rr~rrrrr}rrrrr boolrrRrYrar\rwrws}0@IW664 1 +"4 ./-('  $ 0#rarwdelayric||dkrtjdStj}|j }||z}||kDr t |}tj |SrV) async_timeoutrRrget_running_loopr=r timeout_at)rrirSr@rYs r\ ceil_timeoutrsd } $$T**  # # %D ))+C ;D ~Dz  # #D ))raceZdZUdZegdZeeed<dZ e eed<dZ e e eefed<e Zeedefed<de ed dfd Zed efd Zed e efd Zed e efd Zy) HeadersMixinzMixin for handling headers.) _content_type _content_dict_stored_content_type_headersNrrrrrVc||_|d|_i|_yt|\}}||_|j |_yr)rrrrcopy)r[rrcontent_mapping_proxys r\_parse_content_typez HeadersMixin._parse_content_typesH$'! ;!;D !#D 2DS2I /L/!-D !6!;!;!=D rac|jjtj}|j|k7r|j ||j J|j S)z7The value of content part for Content-Type HTTP header.)rrr) CONTENT_TYPErrrr[rs r\rzHeadersMixin.content_typesXmm 1 12  $ $ +  $ $S )!!---!!!rac|jjtj}|j|k7r|j ||j J|j jdS)z7The value of charset part for Content-Type HTTP header.charset)rrr)rrrrrs r\rzHeadersMixin.charsetscmm 1 12  $ $ +  $ $S )!!---!!%%i00racr|jjtj}|dSt |S)z(The value of Content-Length HTTP header.N)rrr)CONTENT_LENGTHr<)r[content_lengths r\rzHeadersMixin.content_length s3**4+>+>?%-tF3~3FFra)r^r_r`r frozensetATTRSr%rrrrrrr8rrr7rpropertyrrr<rrYrar\rrs% P QE3#'M8C='.2M8DcN+28@%T9 45@ >x} > >"c""1#11G GGrarfutzasyncio.Future[_T]resultcH|js|j|yyrX)done set_result)rrs r\rrs 88: v rac$eZdZ ddededdfdZy)ErrorableProtocolexc exc_causerVNcyrXrY)r[rrs r\ set_exceptionzErrorableProtocol.set_exceptionsra.)r^r_r`rrrYrar\rrs($' !  rarz&asyncio.Future[_T] | ErrorableProtocolrrctj|r|jry|tu}||u}|s |s||_|j |y)zSet future exception. If the future is marked as complete, this function is a no-op. :param exc_cause: An exception that is a direct cause of ``exc``. Only set if provided. N)risfuturer _EXC_SENTINEL __cause__r)rrrexc_is_sentinelexc_causes_itselfs r\rr!sM=0Oy( #4! crac`eZdZUdZdZeeed<d dede ee fdZ ded e fd Z d efd Zy) AppKeyz.Keys for static typing support in Application.)_name_t__orig_class__rNrtctj}|r8|jjdk(r|jd}n|j }|r8dz|z|_||_y)Nzr^r$)inspect currentframef_codeco_name f_globalsf_backrr)r[rrframemodules r\rzAppKey.__init__Cs]$$&||##z1#ooj9LLE  c\D( raotherrVcVt|tr|j|jkSyr)rrr)r[rs r\__lt__z AppKey.__lt__Os" eV $:: + +racl|j}|0tt5t|jd}ddd|d}nSt |t r8|jdk(r |j}n'|jd|j}n t|}d|jd|dS#1swYtxYw)Nrz <>builtinsr$z) rrAttributeErrorrrrrr_r`reprr)r[rt_reprs r\__repr__zAppKey.__repr__Ts GG 9.) 5T001!4 5 9"F 4 ||z)LL>1>>*:;!WF$**WVHB77 5 5s B**B3rX)r^r_r`rr~robjectrrrr5rrrrrYrar\rr8sQ81I L  S Xd2h%7 Ft 8#8rarc eZdZdZdeeeeee fe fddfdZ ddZ e dee de fdZe dede fd Zdeeee fde fd Ze dee d edee effd Ze ddee d ddee fd Ze dded e de fdZddeeee fd e de fdZdefdZdeeeee ffdZdedefdZdefdZdefdZy)r/)_mapsmapsrVNc$t||_yrX)tupler)r[rs r\rzChainMapProxy.__init__js 4[ racJtdj|j)Nz4Inheritance class {} from ChainMapProxy is forbidden)rformatr^)rks r\__init_subclass__zChainMapProxy.__init_subclass__ms" !6#,,/  rarcyrXrYr[rs r\ __getitem__zChainMapProxy.__getitem__ss25racyrXrYrs r\rzChainMapProxy.__getitem__vs,/racf|jD] } ||cSt|#t$rY"wxYwrX)rr)r[rmappings r\rzChainMapProxy.__getitem__ysDzz G s|#  sm  s $ 00rcyrXrYr[rrs r\rzChainMapProxy.getsBEracyrXrYrs r\rzChainMapProxy.getsILracyrXrYrs r\rzChainMapProxy.gets8;rac0 ||S#t$r|cYSwxYwrX)rrs r\rzChainMapProxy.gets% 9  N s  cVttj|jSrX)lenrunionrrZs r\__len__zChainMapProxy.__len__s;35;; +,,racri}t|jD]}|j|t|SrX)reversedrupdateiter)r[drs r\__iter__zChainMapProxy.__iter__s602 + G HHW  Awrac@tfd|jDS)Nc3&K|]}|v ywrXrY)rmrs r\rz-ChainMapProxy.__contains__..s03!80sanyrrs `r\ __contains__zChainMapProxy.__contains__s0TZZ000rac,t|jSrXr rZs r\__bool__zChainMapProxy.__bool__s4::rac`djtt|j}d|dS)Nz, zChainMapProxy(rB)rmaprr)r[rs r\rzChainMapProxy.__repr__s*))Cdjj12y**rarrrX)r^r_r`r~rrrrrrrrrr5rr6rrr<rrr rrrrrrYrar\r/r/gs}I!XgeC4D.Es.J&KL!QU! 5vbz5b55 /s/s//uS&*_5#EvbzEBE5R=EE LvbzLDL8B<LL ;s;S;3;;uS&*_-s --(5fSk)9#:;1141$+#+rar/z[!\x23-\x7E\x80-\xff]+z(W/)?"(z)"z)(?:\s*,\s*|$)|(.)rc&eZdZUeed<dZeed<y)r0rFis_weakN)r^r_r`rrrrrYrar\r0r0s JGTrar0rc`|tk7r%tj|std|dyy)NzValue z, is not a valid etag. Maybe it contains '"'?)ETAG_ANY _ETAGC_RE fullmatchrh)rs r\validate_etag_valuers9 !4!4U!;UIJ K  "<radate_strc|Vt|}|Itt5tj|dddtjj icdddSy#1swYyxYw)z/Process a date string, return a datetime objectNtzinfo)rrrhdatetimetimezoneutc)r timetuples r\parse_http_dater#sdh'  *% W(()BQ-V@Q@Q@U@UV W W  W s 0AA#methodcodecr|tvxs.|tvxs$d|cxkxrdkncxr|tjvS)z-Check if a request must return an empty body.r<,)EMPTY_BODY_STATUS_CODESEMPTY_BODY_METHODSr)METH_CONNECT_ALLr$r%s r\must_be_empty_bodyr,sD '' C ' ' C 4 #  A&D,A,A"Arac^|tvxs$d|cxkxrdkncxr|tjvS)zrCheck if a Content-Length header should be removed. This should always be a subset of must_be_empty_body r<r')r(r)r*r+s r\should_remove_content_lengthr.s4 * *  tc=f(=(==rarX)Tzutf-8)rNzTuple[weakref.ref[object], str]rVNr{)rrruryrrenum functoolsrrrplatformrerr=rX collectionsrr email.messager email.parserr email.policyr email.utilsrmathr pathlibr typesr r typingrrrrrrrrrrrrrrrrrr urllib.parser urllib.requestr!r"attr multidictr#r$r% propcache.apir&r1yarlr'rr)logr*rr__all__systemIS_MACOSrPY_310PY_311r5r6Enumr7r8rrr NO_EXTENSIONSrranger( METH_HEAD_ALLr)flagsdev_modeignore_environmentDEBUGchrCHARCTL SEPARATORSrrUr.rrsrrrrrr lru_cacherrrrcompilerr rr"r&r'r<rr?rKrQrrrrrZr^r]rcr}rxrwTimeoutrrrrrrrtotal_orderingrr/_ETAGCr _QUOTED_ETAGQUOTED_ETAG_RELIST_QUOTED_ETAG_RErr0rr#r,r.)is0r\r^s    "&%!1(3 ==8w# 9 8??  ( X__ ) +  W $  W $ T] T] DIIk: .   RZZ^^$;<= $S#$@c3$@A''   $$$Sbjjnn=Q.R)S a &1A&Q|$!s1v$H(F' * s Z <J ;(IJ<J~NSNU30C+C%DN(-(VT$d3$$4$ )HU[[$9))):$sI~.4 7s 7uS(92E-E'F 7T$d3&&4&R $S$X$!$N 2R  8C 8E#/?S/I*I$J 8! 8hsmx}rzz67 !$- .qCF .$ 7 B3 B3 B?F00!%08;0QT00f : :$ :+/(3-.%&s%&P %&       # #  "  g!!" (%& "S "  "  # # "" " g!!" "     %  1 1 h?~&89?   >##>#D56 * E? *,1 * *,G,G^("   - 1  . +8WR[+8+8\<+GE#vc{"23S89<+@ # BJJv  &$ L) bjjAl^3E!FG T$d34  s t hsm9J9J0K s#$  C D m'$| /sV#V(V-