۰jJSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJ r J r SSK J r J r JrJr SSKJr SSKJr SSKJrJrJr SSKJr SSKJr SS KJrJrJrJ r J!r!J"r" SSK#r#SS K#J$r$J%r% S S K&J'r'J(r( S S K)J*r*J+r+ S SK,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8 S SK9J:r: S SK;Jr> S SK(J?r?J@r@JArAJBrBJCrCJDrDJErEJFrF S SKGJHrH S SKIJJrJ \RS:aSSK JLrL O \!\M\NSS4rL\(aSSKOrO\ORrPOSSKOrO\ORrP\S"S15rT\S"SS15rU\S"SS15rV\U\T-rW\W\V-rXS\Rs=:*=(a S:Os =(d \RS:rYS rZ\(aS S!K[J\r\ S S"K;J]r] S S#K^J_r_ "S$S%5r`S&\a\ \RS'S4S(jrb"S)S*5rc"S+S,\c5rd"S-S.5re"S/S05rf"S1S25rgS3\hS'\P4S4jri\i"S55rj\i"S65rk"S7S8\f5rl"S9S:\f5rm"S;S<\f5rng!\Qa SrO\RrPGN f=f)=N) OrderedDict defaultdictdeque) AwaitableCallableIteratorSequence)suppress) HTTPStatus)chaincycleislice) monotonic) TracebackType) TYPE_CHECKINGAnyLiteralOptionalUnioncast) AddrInfoTypeSocketFactoryType)hdrshelpers)AbstractResolver ResolveResult) ClientConnectionErrorClientConnectorCertificateErrorClientConnectorDNSErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorInvalidUrlClientErrorServerFingerprintMismatchUnixClientConnectorError cert_errors ssl_errors)ResponseHandler) ClientRequest Fingerprint_merge_ssl_params) _SENTINEL ceil_timeoutis_canonical_ipv4_address is_ip_addressnoopsentinel set_exception set_result) client_logger)DefaultResolver )Bufferzmemoryview[int]zmemoryview[bytes]httphttpswswss)r9 r)r9rAr)r9r:) BaseConnector TCPConnector UnixConnectorNamedPipeConnectorrr) ClientTimeout) ConnectionKey)TracecH\rSrSrSrS\\SS4SjrS\4SjrS Sjr Sr g) _DeprecationWaitere _awaitable_awaited awaitablereturnNcXlSUlgNFrM)selfrPs N/home/mande/repo/quber/.venv/lib/python3.13/site-packages/aiohttp/connector.py__init___DeprecationWaiter.__init__hs# cDSUlURR5$)NT)rOrN __await__rTs rUrZ_DeprecationWaiter.__await__ls ((**rXc^UR(d[R"S[5 gg)NzDConnector.close() is a coroutine, please use await connector.close())rOwarningswarnDeprecationWarningr[s rU__del___DeprecationWaiter.__del__ps"}} MM5" rXrQN) __name__ __module__ __qualname____firstlineno__ __slots__rrrVrZra__static_attributes__rXrUrKrKes/*I)C.T+3+rXrKwaitersrQc# [R"USS06IShvN nUH1n[U[5(dM[R "SU5 M3 gN<7f)z'Wait for all waiters to finish closing.return_exceptionsTNz!Error while closing connector: %r)asynciogather isinstance Exceptionr6debug)rkresultsress rU_wait_for_closeruysINNGDtDDG c9 % %    CS IEsAAAAc R\rSrSrSrSSSSS\S\RS S4 S jrS \ 4S jr \ 4S \ S S4S jjr S \S4Sjr\S \R4Sj5r\S \R$S-4Sj5r\S \S-4Sj5rS\/S4S S4SjrSSjrSSjrSSjr\S \4Sj5rSrg) ConnectionN connectorrCkeyrHprotocollooprQcX lXlX@lX0l/UlUR 5(a0[ R"[R"S55Ul gg)Nr) _key _connector_loop _protocol _callbacks get_debug traceback extract_stacksys _getframe_source_traceback)rTryrzr{r|s rUrVConnection.__init__sM # 1946 >>  %.%<%)r~r[s rU__repr__Connection.__repr__sTYYKq))rX _warningscvURbSU0nUR"SU<3[40UD6 URR 5(agUR R URURSS9 USS.nURbURUS'URRU5 gg)NsourcezUnclosed connection T should_closezUnclosed connection)client_connectionmessagesource_traceback) rr_ResourceWarningr is_closedr_releaser~rcall_exception_handler)rTrkwargscontexts rUraConnection.__del__s >> %%F NN1$:O Vv Vzz##%% OO $ $TYYT $ R,0=RSG%%1.2.D.D*+ JJ - -g 6 &rXTcg)z9Force subclasses to not be falsy, to make checks simpler.Trjr[s rU__bool__Connection.__bool__srXcN[R"S[SS9 UR$)Nz%connector.loop property is deprecated stacklevel)r^r_r`rr[s rUr|Connection.loops# 35GTU zzrXcJURcgURR$N)r transportr[s rUrConnection.transports >> !~~'''rXcUR$r)rr[s rUr{Connection.protocols ~~rXcallbackcBUbURRU5 ggr)rappend)rTrs rU add_callbackConnection.add_callbacks   OO " "8 , rXcURSS/solUH"n[[5 U"5 SSS5 M$ g!,(df  M6=fr)rr rq)rT callbackscbs rU_notify_releaseConnection._notify_releases=%)__Q%7" ?B)$%$$$s A A cUR5 URb7URRURURSS9 SUlgg)NTrrrrrr~r[s rUcloseConnection.closesE  >> % OO $ $TYYT $ R!DN &rXcUR5 URb8URRURUR5 SUlggrrr[s rUreleaseConnection.releases@  >> % OO $ $TYY ?!DN &rXcjURSL=(d URR5(+$r)r is_connectedr[s rUclosedConnection.closeds&~~%JT^^-H-H-J)JJrX)rrr~rrrrc)rdrerfrgrr*rnAbstractEventLooprVstrrr^rrarrpropertyr| Transportrr{rrrrrboolrrirjrXrUrwrws-O"OO" O '' O  O *#*(0 7 7D 7'$-g// (7,,t3(( /D0-Xb$h%7-D-""KKKrXrwc"\rSrSrSrSSjrSrg)_ConnectTunnelConnectionaSpecial connection wrapper for CONNECT tunnels that must never be pooled. This connection wraps the proxy connection that will be upgraded with TLS. It must never be released to the pool because: 1. Its 'closed' future will never complete, causing session.close() to hang 2. It represents an intermediate state, not a reusable connection 3. The real connection (with TLS) will be created separately Ncg)a9Do nothing - don't pool or close the connection. These connections are an intermediate state during the CONNECT tunnel setup and will be cleaned up naturally after the TLS upgrade. If they were to be pooled, they would never be properly closed, causing session.close() to wait forever for their 'closed' future. Nrjr[s rUr _ConnectTunnelConnection.releaserXrjrc)rdrerfrg__doc__rrirjrXrUrrs  rXrcb\rSrSrSrSrS\R\S-SS4Sjr S Sjr S S jr Sr g) _TransportPlaceholderz.placeholder for BaseConnector.connect functionrr closed_futureNrQcXlSUlg)z)Initialize a placeholder for a transport.Nr)rTrs rUrV_TransportPlaceholder.__init__s# rXcg)zClose the placeholder.Nrjr[s rUr_TransportPlaceholder.closerrXcg)z%Abort the placeholder (does nothing).Nrjr[s rUabort_TransportPlaceholder.abortrrXrc) rdrerfrgrrhrnFuturerqrVrrrirjrXrUrrs58'IgnnY5E&F4 %4rXrc\rSrSrSrSrSrSr\r \ SSSSSS S .S \ S-\ -S \ S \S\S\ S\R S-S\ SS4Sjjr\4S\SS4SjjrS=SjrS\SS4SjrS=SjrS>S\\S-S\S-S\S-SS4Sjjr\S\ 4Sj5r\S\4Sj5r\S\4S j5rS?S!jr S?S"jr!SS#.S$\ S\"S4S%jjr#SS#.S$\ S\$\"\ 4S&jjr%\S\ 4S'j5r&S(S)S\4S*jr'S+\(S\(4S,jr)S+\(S-\$S.S/S0S\*4S1jr+S(S)S-\$S.SS4S2jr,S(S)S-\$S.S\*S-4S3jr-S?S4jr.S(S)S5\/SS4S6jr0SS7.S(S)S8\/S9\ SS4S:jjr1S+\(S-\$S.S/S0S\/4S;jr2S>  %.%<%Cg',OE))++0Cq0H e%67 %IKKM888SZZZ77>>yI(-5',$2&K ;;#*#9#9 '+'C'C $D  rXcRUR(aURR5 URHnUcMUR5 M /UlUR(d<[ R "USURURURS9Ulgg)znDouble confirmation for transport close. Some broken ssl servers may leave socket open without proper close. Nrr!) rr"rrrrr%_cleanup_closed_periodrr)rTrs rUrBaseConnector._cleanup_closeds  & &  ' ' . . 088I$!9+-',,*1*@*@!++ '+'C'C +D '-rX abort_sslr1cURUS9=n(d[[55$[U5n[R S:a [ R"X0RSS9nOURRU5n[U5$)zClose all opened transports. :param abort_ssl: If True, SSL connections will be aborted immediately without performing the shutdown handshake. This provides faster cleanup at the cost of less graceful disconnection. r0r8Tr| eager_start) rrKr2rurrrnTaskr create_task)rTr1rkcorotasks rUrBaseConnector.closesv ;;;;;;&df- -w'   w &<<::4HD::))$/D!$''rXc/nUR(aU$SUlURR5(aUURR 5 UR R 5 UR R5HnUHnUR5 M M UR R 5 SUl URR 5 SUl $UR(aURR5 UR(aURR5 URR5HnUHupgU(a>UR(a-URRS5bUR5 OUR5 UR =n(dMoUR#U5 M M UR H~nU(a>UR(a-URRS5bUR5 OUR5 UR =n(dMmUR#U5 M URHn U cMU R5 M UURR 5 UR R 5 UR R5HnUHnUR5 M M UR R 5 SUl URR 5 SUl $!URR 5 UR R 5 UR R5HnUHnUR5 M M UR R 5 SUl URR 5 SUl f=f)NT sslcontext)rrrrclearrrrr"rrrrget_extra_inforrrr) rTr1rk keyed_waiters keyed_waiterdatar*_rrs rUrBaseConnector._closes+- <<N 4 /zz##%%T KK    NN "!%!5!5!7 $1L '')%2"8 MM   !#'D  + + 1 1 3*.D '_##$$++-**++224 **, $HE!!OO!OO::<HT  !&-v-v.!%-66|DPKKMKKM"\\)6)NN6*("<< (OO%= KK    NN "!%!5!5!7 $1L '')%2"8 MM   !#'D  + + 1 1 3*.D ' KK    NN "!%!5!5!7 $1L '')%2"8 MM   !#'D  + + 1 1 3*.D 's& M/C MBM%%MMB2PcUR$)z+Is connector closed. A readonly property. )rr[s rUrBaseConnector.closed4s ||rXrzrHcSnUR(a*UR[UR5- =nS::aU$UR=n(a7URR U5=n(aU[U5-nX#:aU$U$)z Return number of available connections. The limit, limit_per_host and the connection key are taken into account. If it returns less than 1 means that there are no connections available. rr)rlenrrrget)rTrz total_remain host_remainacquireds rU_available_connections$BaseConnector._available_connections<s ;;DKK#dnn:M,MMLRSS .. .; .2266s;;x;s8}, )""rXreqc &URnUce0nURb URnUR[RU[R'[ [R UUURURURS9nURR[RS5nUbOUR5(dXQR[R'U$XTR[R'U$)znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)headersauthr|ssl)proxy proxy_headersrOrHOSTr+METH_GET proxy_authrrQpop AUTHORIZATIONr$PROXY_AUTHORIZATION)rTrMurlrO proxy_reqrPs rU-_update_proxy_auth_header_and_build_proxy_req;BaseConnector._update_proxy_auth_header_and_build_proxy_reqUsii"$    (''G [[3 ! MM     $$T%7%7>  ::<<8< D445?C!!$":":;rXtracesrIr'rGc# URnURXB5IShvN =nb$UR(aURU5 U$[ UR UR 5IShvN URU5S::ajURXB5IShvN URXB5IShvN =nb5UR(aURU5 UsSSS5IShvN $[[[UR55nURRU5 UR(aUR URU5 U(a!UHnUR#5IShvN M UR%XU5IShvN nU(a!UHnUR'5IShvN M UR((aUR+5 [-S5eSSS5IShvN URR3W5 URRW5 UR(a1UR Un U R3U5 U RU5 [5XXR65$GNwGN*GNGNGNGN%GN N![.a UR1XF5 ef=fN!,IShvN (df  N=f7f)z'Get from pool or create new connection.NrzConnector is closed.)connection_key_getrRr\r/connectceil_thresholdrK_wait_for_available_connectionrr*rrraddrrsend_connection_create_start_create_connectionsend_connection_create_endrrr BaseException_release_acquiredremoverwr) rTrMr^r'rzconn placeholdertracer*acquired_per_hosts rUrbBaseConnector.connectos\  ))C00 0D =yyBB3GK1G1GHH**3/1499#FFF"&))C"888DEyyJJ3O IHH!6t7O7O!PK NN  { +##'',00= H!'#@@BBB"("55c7KK!'#>>@@@"( <<KKM/0FGG =IHN k* 5!    $ 7 7 <   $ $[ 1  ! !% ($UJJ77i1IF8I*CKA  &&s8 5IHHHs!K-JAK-3J4K-7*K!J "K:J#;*K% K-1J&2K-7A-K%J1J)J1"J,##J1J/J1-K< K-KBK-K- K#K&K-)J1,J1/J11KKK-K*K  K*&K-c# SnURR5nURUnSXT'U(aURUSS9 U(a!UHnUR 5IShvN M UIShvN U(a!UHnUR 5IShvN M UR US5 URRUS5(d URU URU5S:agUS- nMNNNi!UR US5 URRUS5(dURU ff=f7f)z&Wait for an available connection slot.rTNFlastr) rrr move_to_endsend_connection_queued_startsend_connection_queued_endrWrGrK)rTrzr^attemptsfutr>rns rUrd,BaseConnector._wait_for_available_connections>(, (@(@(BC MM#.M!%M ))#E): +!'#@@BBB"( !'#>>@@@"( !!#t,}}((d33 c***3/!3 MH;CA!!#t,}}((d33 c*4sVAE D*D+ D8D9#DDD%AEDDDAE  Ec># URRU5=ncg[5nU(Ga9UR5upVUR 5(aXF- UR ::aU(d URU UR RU5 UR(aURURU5 U(a"UHnUR5IShvN M [XXPR5$URnUR!5 UR"(d,UR$(aUR&R)U5 U(aGM9URU gN![a URX5 ef=f7f)z^Get next reusable connection for the key or None. The connection will be marked as acquired. N)rrGrpopleftrrrrerrsend_connection_reuseconnrirjrwrrrrr$rr) rTrzr^rt1r*t0rnrs rUraBaseConnector._getsG[[__S) )E 2 [ IE!!##43J3J(J C(""5)''++C044U;!'""'"A"A"CCC"( "$UJJ??I KKM00SZZ//66yA3e8 KK D," 223>!"s7CFE=+E;,E=0A:F-F;E==FFcrUR(dg[UR5n[R"U5 UHtnUR U5S:aMURUnU(dM2UR SS9upEUR 5(dURS5 gU(aMBMv g)z Iterates over all waiters until one to be released is found. The one to be released is not finished and belongs to a host that has available connections. NrFrr)rlistrandomshufflerKpopitemdoner5)rTqueuesrzrkwaiterrAs rU_release_waiterBaseConnector._release_waiters}} dmm$vC**3/!3mmC(G'#OOO7 {{}}%%d+ ' rXr*c.UR(agURRU5 UR(aGURR U5=n(a%URU5 U(d URU UR 5 g)zRelease acquired connection.N)rrdiscardrrrGr)rTrzr*rs rUrjBaseConnector._release_acquiredsk <<  u%   d.E.E.I.I#.N%NU%N MM% ++C0 rXrr{rc2UR(agURX5 UR(dU(dUR(aZURnUR 5 UR (a,UR(dURRU5 gURURU[545 URc<[R"USURUR UR"S9Ul gg)Nr r!)rrjrrrrr$rrrrrrrr%rrr)rTrzr{rrs rUrBaseConnector._release%s <<  s-    0E0E **I NN zz$"?"?//66yA  C9; 78    '#*#9#9'' '+'C'C $D  (rXc# [5e7fr)NotImplementedError)rTrMr^r's rUrg BaseConnector._create_connectionEs"##s )rrrrrrrrrrrrrrrrrr)rQrC)NNNrc)4rdrerfrgrrrr.HIGH_LEVEL_SCHEMA_SETallowed_protocol_schema_setr3objectrrintrnrrVr^rrar rrtyperirrrrrrr rrrrrrrKr+r\rwrbrdrarr*rjrrgrirjrXrUrCrCs G!"7 4<!&+15()K"D=50K K  K  K $K''$.K!&K KZ(033D3*ST 04*..2 }%,!4'%t+   !T!!s$$$%N.*/($(9T?((+0</4</D69J4K</|/c2  498 98*.w-98BQ98 98v("(,0M( (T("(,0M( d (T4 _ _ QU $#  "    @$ $*.w-$BQ$ $rXrCc\rSrSrSS\S-S\SS4SjjrS\S\4Sjr S \ \ \4S \ \ SS4S jrS \ \ \4SS4S jrSS jrS \ \ \4S\ \ 4SjrS \ \ \4S\4SjrSrg)_DNSCacheTableiKNttlmax_sizerQcH[5Ul0UlXlX lgr)r _addrs_rr _timestamps_ttl _max_size)rTrrs rUrV_DNSCacheTable.__init__Ls$ M :< !rXhostcXR;$r)r)rTrs rU __contains___DNSCacheTable.__contains__Ts~~%%rXrzaddrscXR;aURRU5 [U5[U54URU'URb[ 5UR U'[UR5UR:a8URRSS9up4UR RUS5 gg)NFrr) rrtr rFrrrrrrW)rTrzr oldest_keyrAs rUre_DNSCacheTable.addWs .. NN & &s +$U|SZ8s 99 $-KD  S ! t~~  / NN222>MJ    T 2 0rXctURRUS5 URRUS5 gr)rrWrrTrzs rUrk_DNSCacheTable.removeds, 3% S$'rXclURR5 URR5 gr)rr<rr[s rUr<_DNSCacheTable.clearhs$   rXcURUup#[[X#55n[U5 URR U5 U$r)rrrnextrt)rTrzr|lengthrs rU next_addrs_DNSCacheTable.next_addrsls?~~c* VD)* T  ""3' rXclURcgURUUR-[5:$rS)rrrrs rUexpired_DNSCacheTable.expiredts0 99 $tyy09;>>rX)rrrr)Nrc)rdrerfrgrrrVrrrtuplerrrrerkr<rrrirjrXrUrrKs"EDL"3"$"&&D& 3uS#X 3tM/B 3t 3(%S/(d(!eCHo$}2E?5c??t?rXrverifiedc[cgU(a[R"5nO[R"[R5nU=R[R -slU=R[R -slSUl[RUl U=R[R-slUR5 URS5 U$)zCreate SSL context. This method is not async-friendly and should be called from a thread because it will load certificates from disk and do other blocking I/O. NF)zhttp/1.1) rQcreate_default_context SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONset_default_verify_pathsset_alpn_protocols)rr;s rU_make_ssl_contextr{s  {//1 ^^C$;$;< coo-coo-$) !!$ c333++-!!-0 rXTFc,^\rSrSrSr\\"S15-rSSSSS\RRSSSS\ SS S SSS S SS\ S .S\ S\ S-S\ S\S-S\S\RS\S-S\ \-\-S\\\4S-S\S-SS\-\-S\ S\S\S\ S\R.S-S\S\S-S \S-S!\S-S"\S-\-4*U4S#jjjrSS$.S%\ S&\\\4U4S'jjjrSS$.S%\ S&S4U4S(jjjr\S&\4S)j5r \S&\ 4S*j5r!SNS+\S-S,\S-S&S4S-jjr"SOS+\S,\S.\#S/S-S&\\$4S0jjr%S1\\\4S+\S,\S2\&S3S.\#S/S-S&\\$4 S4jr'S5\(S.\S/S6S7S&\)4S8jr*S5\(S&\S-4S9jr+S5\(S&\,S:4S;jr-\.S<.S=\/S>\\0S5\(S6S7S?\1\2S@\/S&\\Rf\)44SAjjr4\.S<.S=\/S5\(S6S7S?\1\2S@\/S&\\Rf\)44 SBjjr5SPSCjr6SQSDjr7S&\ 4SEjr8SF\RfS5\(S&S4SGjr9\.4SF\RfS5\(S6S7S?\1\2S&\\Rt\)44 SHjjr;SI\\$S&\\04SJjr<\.S<.S5\(S.\S/S6S7S?\1\2S&\\Rf\)44 SKjjr=S5\(S.\S/S6S7S&\\Rt\)44SLjr>SMr?U=r@$)RrDiu^TCP connector. verify_ssl - Set to True to check ssl certifications. fingerprint - Pass the binary sha256 digest of the expected certificate in DER format to verify that the certificate the server presents matches. See also https://en.wikipedia.org/wiki/HTTP_Public_Key_Pinning resolver - Enable DNS lookups and use this resolver use_dns_cache - Use memory cache for DNS lookups. ttl_dns_cache - Max seconds having cached a DNS entry, None forever. family - socket address family local_addr - local tuple of (host, port) to bind socket to keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. enable_cleanup_closed - Enables clean-up closed ssl transports. Disabled by default. happy_eyeballs_delay - This is the “Connection Attempt Delay” as defined in RFC 8305. To disable the happy eyeballs algorithm, set to None. interleave - “First Address Family Count” as defined in RFC 8305 loop - Optional event loop. socket_factory - A SocketFactoryType function that, if supplied, will be used to create sockets given an AddrInfoType. ssl_shutdown_timeout - DEPRECATED. Will be removed in aiohttp 4.0. Grace period for SSL shutdown handshake on TLS connections. Default is 0 seconds (immediate abort). This parameter allowed for a clean SSL shutdown by notifying the remote peer of connection closure, while avoiding excessive delays during connector cleanup. Note: Only takes effect on Python 3.11+. tcpTN rFrrrg?) verify_ssl fingerprint use_dns_cache ttl_dns_cachedns_cache_max_sizefamily ssl_contextrQ local_addrresolverrrrrrr|rhappy_eyeballs_delay interleavesocket_factoryssl_shutdown_timeoutrrrrrrrrQrrrrrrrr|rrrrrc P>[TU]U U U UUUUS9 [XXr5UlU U c [ UR S9UlSUlO XlSUlX0l[XES9Ul 0Ul X`l [R"U 5UlUUlUUl[%5UlUUlU U[*LaSUlg[.R0"S[2SS 9 [4R6S :a'Ub$US:wa[.R0"S US 3[8SS 9 UUlg) NrrTF)rrrzSThe ssl_shutdown_timeout parameter is deprecated and will be removed in aiohttp 4.0rrr9 zssl_shutdown_timeout=zd is ignored on Python < 3.11; only ssl_shutdown_timeout=0 is supported. The timeout will be ignored.)superrVr-_sslr7r _resolver_resolver_owner_use_dns_cacher _cached_hosts_throttle_dns_futures_familyaiohappyeyeballsaddr_to_addr_infos_local_addr_infos_happy_eyeballs_delay _interleaver_resolve_host_tasks_socket_factoryr3_ssl_shutdown_timeoutr^r_r`rrRuntimeWarning)rTrrrrrrrrQrrrrrrrr|rrrrr __class__s rUrVTCPConnector.__init__sC2 /#)"7#9  &c{P   ,$**=DN#'D %N#(D ++   " !1!D!DZ!P%9"%KN5 - 8 +)*D & MMe"    7*(4(A- +,@+AB]]"  *>D &rXr0r1rQc>[R"URR55HnUR 5 M [ TU]US9nURH$nUR 5 URU5 M& U$)zClose all ongoing DNS calls.r0) r from_iterablerrr"rrrr)rTr1rxrktrs rUrTCPConnector._closeso&&t'A'A'H'H'JKC JJLL'.9.5))A HHJ NN1 *rXc># [TU]U=(d URS:HS9IShvN UR(a#URR5IShvN ggN9N7f)a Close all opened transports. :param abort_ssl: If True, SSL connections will be aborted immediately without performing the shutdown handshake. If False (default), the behavior is determined by ssl_shutdown_timeout: - If ssl_shutdown_timeout=0: connections are aborted - If ssl_shutdown_timeout>0: graceful shutdown is performed rr0N)rrrrr)rTr1rs rUrTCPConnector.close"sZgmi&R43M3MQR3RmSSS   ..&&( ( (  T (s!'A(A$2A(A&A(&A(cUR$)zSocket family like AF_INET.)rr[s rUrTCPConnector.family1s||rXcUR$)z%True if local DNS caching is enabled.)rr[s rUrTCPConnector.use_dns_cache6s"""rXrportcUb UbURRX45 gUcUb [S5eURR5 g)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)rrkrr<)rTrrs rUclear_dns_cacheTCPConnector.clear_dns_cache;sL   0    % %tl 3  !1TU U    $ $ &rXr^rIc# [U5(a6SU;a[U5(d [US5eUUUURSSS./$UR(dU(a"UHnUR U5IShvN M UR (a [S5eURRXURS9IShvN nU(a"UHnURU5IShvN M U$X4nX`R;afURRU5(dFURRU5nU(a"UHnURU5IShvN M U$X`R;aURUnUR R#5n UR%U 5 U(a"UHnURU5IShvN M U IShvN UR'U 5 URRU5$[)5=URU'nUR+XaX(U5n [,R."5n [0R2S:a[,R4"XS S 9n OU R7U 5n U R95(d@UR:R%U 5 U R=UR:R&5 [,R>"U 5IShvN $GNGNDGN"GNGN<GN0!UR'U 5 f=fN,![,R@a S S jn U R=U 5 ef=f7f) z*Resolve host and return list of addresses.:zis not a canonical IPv4 addressr)hostnamerrrr*flagsNzConnector is closedrr8Tr3c[[[R5 UR 5 SSS5 g!,(df  g=fr)r rqrnCancelledErrorresult)rxs rUdrop_exception2TCPConnector._resolve_host..drop_exceptions(i)?)?@JJLA@@s 9 A)rxz#asyncio.Future[list[ResolveResult]]rQN)!r1r0r%rrsend_dns_resolvehost_startrrrresolvesend_dns_resolvehost_endrrrsend_dns_cache_hitrrrrerr_resolve_host_with_throttlernrrrr5r6rradd_done_callbackshieldr)rTrrr^rnrtrzrfuturesfuturer7r|resolved_host_taskrs rU _resolve_hostTCPConnector._resolve_hostDs   $'@'F'F+D2STT!%  "ll   ""#E::4@@@$||+,ABB..t$,,.OOC#E88>>>$Jl $$ $T-?-?-G-G-L-L''2237F#E224888$M ,, ,005G+/::+C+C+EF KK #E224888$ ( '%%005 558E9""3'' //4&Q'')   w &!(d4!P !%!1!1$!7 !&&((  $ $ ( (); <  0 01I1I1Q1Q R  (:;; ;AA P?9"9'.<%%  !  0 0 @  sA8M :L;A M L $M +L ,A7M #L$A3M LM !L&L'L+C=M )L1L/L1M  M  M M M LL,,M /L11,MM rzr zasyncio.Future[None]c# U(aDUHnURU5IShvN M UHnURU5IShvN M URRX#URS9IShvN nU(a"UHnUR U5IShvN M UR RX5 UHn[US5 M URRU5 UR RU5$NNNNu![an UHn[X5 M eSn A ff=f!URRU5 f=f7f)zResolve host and set result for all waiters. This method must be run in a task and shielded from cancellation to avoid cancelling the underlying lookup. Nr)send_dns_cache_missrrrrrrrer5rir4rrWr) rTrzrrr r^rnrrxes rUr (TCPConnector._resolve_host_with_throttles7 0#E33D999$$E::4@@@$..00DLL0QQE#E88>>>$    " "3 .3%  & & * *3 /!!,,S11/:AQ?  c%     & & * *3 /szE DD !DD /D6D7$DD8D6E D DDD D7D22D77D::EErMr'rGc# UR(aURXU5IShvN upEU$URXU5IShvN upEU$N&N 7f)zSCreate connection. Has same keyword arguments as BaseEventLoop.create_connection. N)rR_create_proxy_connection_create_direct_connection)rTrMr^r'rAr*s rUrgTCPConnector._create_connectionsS 99!::3PPHA ";;CQQHA QQs!'AAAA AAc>UR5(dg[c [S5eURn[U[R5(aU$USLa[ $UR n[U[R5(aU$USLa[ $[$)aLogic to get the correct SSL context 0. if req.ssl is false, return None 1. if ssl_context is specified in req, use it 2. if _ssl_context is specified in self, use it 3. otherwise: 1. if verify_ssl is not specified in req, use self.ssl_context (will generate a default context according to self.verify_ssl) 2. if verify_ssl is True in req, generate a default SSL context 3. if verify_ssl is False in req, generate a SSL context that won't verify NzSSL is not supported.T)r$rQ RuntimeErrorrpr_SSL_CONTEXT_UNVERIFIEDr_SSL_CONTEXT_VERIFIED)rTrMr;s rU_get_ssl_contextTCPConnector._get_ssl_contextszz|| ;67 7WW j#.. 1 1  T !* *YY j#.. 1 1  T !* *$$rXr,cURn[U[5(aU$URn[U[5(aU$gr)rQrpr,r)rTrMrets rU_get_fingerprintTCPConnector._get_fingerprints;gg c; ' 'Jii c; ' 'JrX client_errorargs addr_infosr$rc # [URURS9IShvN [R"UUR UR URURURS9IShvN nURS5(a4UR(a#[RS:aURUS'URR"U0UDSU0D6IShvN sSSS5IShvN $NNNN !,IShvN (df  g=f![an[!UR"U5UeSnAf[$an['UR"U5UeSnAf[(aFnUR*c [-U[.R05(aeU"UR"U5UeSnAff=f7f)Nrc)r&local_addr_infosrrr|rrQrrsock)r/ sock_connectrcrstart_connectionrrrrrrGrrrcreate_connectionr(rr`r)r"OSErrorerrnorprn TimeoutError) rTr&rMr'r$r%rr*r s rU_wrap_create_connection$TCPConnector._wrap_create_connections{ A#$$W5K5K.>>)%)%;%;)-)C)C#//#'#7#7 JJu%%22((G3595O5OF12!ZZ994U6UPTUU%V%& T1#2D2DcJPS S L)#*<*"D#DD#AD 9D:A1D +D,D / D#;D<D#F>D#D D D# D D  D D#F> D## F;-E F;E(( F;5AF66F;;F>c:# [URURS9IShvN URR"U0UD6IShvN sSSS5IShvN $N9NN !,IShvN (df  g=f![ an[ URU5UeSnAf[an[URU5UeSnAf[aFnURc [U[R5(aeU"URU5UeSnAff=f7fNr()r/r+rcrr-r(rr`r)r"r.r/rprnr0)rTrMr'r$r%rr s rU_wrap_existing_connection&TCPConnector._wrap_existing_connection.s A#$$W5K5K"ZZ994J6JJK T1#2D2DcJPS S L)#*<*)r$rRscheme_check_loop_for_start_tls)rTrM proxy_urls rU_fail_on_no_start_tls"TCPConnector._fail_on_no_start_tlsDsDzz|| II $$$   w &  &&(rXcnURR g![an[S5UeSnAff=f)NaAn HTTPS request is being sent through an HTTPS proxy. This needs support for TLS in TLS but it is not implemented in your runtime for the stdlib asyncio. Please upgrade to Python 3.11 or higher. For more details, please see: * https://bugs.python.org/issue37179 * https://github.com/python/cpython/pull/28073 * https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support * https://github.com/aio-libs/aiohttp/discussions/6044 )r start_tlsAttributeErrorr)rTattr_excs rUr9&TCPConnector._check_loop_for_start_tlsVs<  JJ   K   s 4 /4cFUR5 g![a gf=f)NTF)r9rr[s rU_loop_supports_start_tls%TCPConnector._loop_supports_start_tlsgs,   * * ,  s   underlying_transportcURRRS:wagURbURRS:wag[ U5R R S5(ag[RS:=(d [USS5nU(ag[R"S[USS 9 g) z6Issue a warning if the requested URL has HTTPS scheme.r>Nuvloopr_start_tls_compatibleFaAn HTTPS request is being sent through an HTTPS proxy. This support for TLS in TLS is known to be disabled in the stdlib asyncio (Python <3.11). This is why you'll probably see an error in the log below. It is possible to enable it via monkeypatching. For more details, see: * https://bugs.python.org/issue37179 * https://github.com/python/cpython/pull/28073 You can temporarily patch this as follows: * https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support * https://github.com/aio-libs/aiohttp/discussions/6044 r9)rr) request_inforZr8rRrre startswithrrgetattrr^r_r)rTrErMasyncio_supports_tls_in_tlss rU_warn_about_tls_in_tls#TCPConnector._warn_about_tls_in_tlsos      & &' 1  99  0 0G ;  $ % 0 0 ; ;H E E '*&6&6'&A' W # F # '   G ! rXc# UR5nURU5n[(aUce[URUR S9IShvN [ RS:arUR(aaURRUUUUR=(d URUR=(d SURS9IShvN nOVURRUUUUR=(d URUR=(d SS9IShvN n[#U[$R&5(a*UR)U5nU(aUR+U5 SSS5IShvN WcSn U"UR4[7U 55eUR9U5 Xu4$GNpNN![a3 URS:XaUR5 eUR!5 ef=f![,a> UR!5 UR.(dUR0R3U5 ef=fN!,IShvN (df  N=f![:an [=UR4U 5U eSn A f[>an [AUR4U 5U eSn A f[6aFn U RBc [#U [$RD5(aeU"UR4U 5U eSn A f[FaVn [ISUR<S URJS S URL<S URN=(d S SU <S3 5U eSn A ff=f7f)z$Wrap the raw TCP transport with TLS.Nr(r)server_hostnamessl_handshake_timeoutr)rPrQrz:Failed to start TLS (possibly caused by closing transport)z2Cannot initialize a TLS-in-TLS connection to host rdz4 through an underlying connection to an HTTPS proxy z ssl:defaultz [])(rrrr/r+rcrrrrr>rPrtotalrirrrprnrr!checkr&rrrr`r.connection_mader(rr)r"r/r0 TypeErrorrrrRrQ) rTrErMr'r$ tls_protor; tls_transportrmsgr type_errs rU_start_tls_connection"TCPConnector._start_tls_connections!MMO **3/ =) ))C #$$W5K5K''72t7Q7Q.2jj.B.B0%&,/,?,?,K38829--2G4151K1K /C/) /3jj.B.B0%&,/,?,?,K38829--2G4 /C/) mW->->??"&"7"7"H$$,44S9T  &*&B&BMM#")$3!-'C'! zz||  %%f-= 6= ' ''NcH Lyy ZW5I5I%J%J*#*<**>?  :::GWGWX 1 LLN8877>>vF"H*0*?*?*ID#//1H$66z8L sA9I4<EEEAI4"F>F?FI4"G%3 I4E F AFFI4FG"4"GI4G""I4% I1/A6I,%I4,I11I4c $# URU5 UR5nURU5nURU/U[S9IShvN upgUR 5(GaU(aUR Xa5 [RUl URUl URRSSSS9n[XXpR5n URU 5IShvN n U R n U ceU R#UUR$S9 U R'U 5IShvN n SU lU R(S:wacU R*n U c[-U R(5R.n [1U R2U R4U R(U U R6S9eU(d.UR9SSS9nUc [;S5eUR=5nU(dURA5 U(dQURCU5nUREURFUUWURHUS 9IShvN U RA5 $URKUUUS 9IShvN U RA5 $Xg4$GN5GNGNV![>a URA5 ef=f!U(dURA5 ff=fNN^![>a" U RA5 U RA5 ef=f!U RA5 f=f7f) Nr#)rRrVproxy_headers_hash)read_until_eofr)statusrrOra)rSz)Transport does not expose socket instance)r'rQr*rPrM)rMr')&r;rCr\rr$r$rMr METH_CONNECTmethodrZr`_replacerrsendrset_response_paramsrstartr{reasonr phraser#rIhistoryrOr=rduprirrr5rrr])rTrMr^r'runtime_has_start_tlsr[rr*rzrl proxy_respr{resprrawsockr;s rUr%TCPConnector._create_proxy_connectionVs ""3' $ = = ?FFsK "&!?!? r71K"@"    ::<<$++I; $00I GGIM$$--t.C,DujjID(~~d33JD #>>+++ ,,#8+/+G+G-(--d33 "&*{{c)"&++"?&0&=&D&DG2&33 LL#';;$+$(LL 1"+":":8T":"R"?". K##*++-1!),!%!6!6s!;J!%!?!? '&$(+ "@""  ""77# 8  "} .446%OO% 1!)1 a!   "  p  "sA LJBL.J/L4?K 3J 4K 8K;B(J (AK;KK;LK;+K ,K;/LL K J((J++KK; K; ,K88K;;L  L) rrrrrrrrrrrrr)NNr)rMr+rQNrc)Ardrerfrgrr frozensetrra AddressFamily AF_UNSPECr3rbytesrrr,rrrrrrnrrr.rVrrrrrrrrr rrrr r+r*rgrrr!r!rrrrqrr1r5r;r9rCrM BaseTransportr]rirrri __classcell__rs@rUrDrDsq$L#8)UG:L"L  $("$&"&'-';';'E'E)-/3-1,03;!&+15()-1!%379A/P>P>T\ P>  P> Tz P> P>$$P> $&P>K * ,P>#s(Od*P>#T)P> %<&0P>P>P> !P>" $#P>$''$.%P>&!&'P>($dl)P>*$J+P>,*D0-P>.($.6/P>P>d+0 4 D69J4K  05 ) ) ) )#t##'C$J'S4Z'SW'HLaa"a,4W,=,Da m aF'2 38_'2'2 '2 +, '2 !D( '2 m '2R   *.w- BQ   %M%j46G%BMh}6M)= $A$A&$A $A ! $A 9o $A$A w  /1 2$AV)= AAA! A 9o A  A w  /1 2A,)$"$/ %/// /   / l)= T(%//T(T(! T( 9o T( w$$o5 6 T(l-( l 6)= I IW I! I 9o I w  /1 2IVf  f *.w-f BQf w$$o5 6f f rXrDc^\rSrSrSr\\"S15-rS\SSS4S\ S \ S \ \ -S-S \ S \ S \RS-SS4U4Sjjjr\S\ 4Sj5rS\S\SSSS\4SjrSrU=r$)rEiaaUnix socket connector. path - Unix socket path. keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. loop - Optional event loop. unixFrrNpathrrrrr|rQc4>[TU]UUUUUS9 Xlg)Nrrrrr|)rrV_pathrTrrrrrr|rs rUrVUnixConnector.__init__s- #/)   rXcUR$)zPath to unix socket.rr[s rUrUnixConnector.pathzzrXrMr^rIr'rGc# [URURS9IShvN URR UR UR 5IShvN upESSS5IShvN U$NPNN !,IShvN (df  W$=f![aTnURc [U[R5(ae[URURU5UeSnAff=f7fr4)r/r+rcrcreate_unix_connectionrrr.r/rprnr0r'rr`rTrMr^r'rAr*r s rUrg UnixConnector._create_connections X#$$W5K5K"&!B!BMM4::"   Xyy ZW5I5I%J%J*499c6H6H#NTW W XsC9"BA7B4A=A9A=% B0A;1B5C97B9A=;B=BB  BBC9B C6"AC11C66C9rrdrerfrgrrrrr3rrrrrrnrrVrrr+rr*rgrirrs@rUrErEs #8)VH:M"M "3;15"E>D0     ''$. $c *.w-BQ rXrEc^\rSrSrSr\\"S15-rS\SSS4S\ S \ S \ \ -S-S \ S \ S \RS-SS4U4Sjjjr\S\ 4Sj5rS\S\SSSS\4SjrSrU=r$)rFiaNamed pipe connector. Only supported by the proactor event loop. See also: https://docs.python.org/3/library/asyncio-eventloop.html path - Windows named pipe path. keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. loop - Optional event loop. npipeFrrNrrrrrr|rQc>[TU]UUUUUS9 [UR[R 5(d [ S5eXlg)Nrz9Named Pipes only available in proactor loop under windows)rrVrprrnProactorEventLooprrrs rUrVNamedPipeConnector.__init__s^ #/)   JJ  % %  K  rXcUR$)zPath to the named pipe.rr[s rUrNamedPipeConnector.path rrXrMr^rIr'rGc:# [URURS9IShvN URR UR UR 5IShvN upE[R"S5IShvN SSS5IShvN [[ W5$N|NFN(N!,IShvN (df  N/=f![aInURc [U[R5(ae[URU5UeSnAff=f7f)Nr(r)r/r+rcrcreate_pipe_connectionrrrnsleepr.r/rpr0r!r`rr*rs rUrg%NamedPipeConnector._create_connection%s I#$$W5K5K"&!B!BMM4::"mmA&&&$OU++%' Iyy ZW5I5I%J%J&s'9'93?S H IsD"CB#C4B+B%B+>B'?B+ CB)CD#C%B+'B+)C+C1B4 2 C>CDC DADDDrrrs@rUrFrFs #8)WI:N"N "3;15"E>D0     ''$. 2c, ,*.w-,BQ, ,,rXrF)ornrrrarrr^ collectionsrrrcollections.abcrrrr contextlibr r=r itertoolsr r rtimertypesrtypingrrrrrrrrrr<rrabcrrclient_exceptionsrrr r!r"r#r$r%r&r'r(r) client_protor* client_reqrepr+r,r-r.r/r0r1r2r3r4r5logr6rr7rr;r bytearrayrQr ImportErrorrrEMPTY_SCHEMA_SETHTTP_SCHEMA_SET WS_SCHEMA_SETHTTP_AND_EMPTY_SCHEMA_SETrr__all__clientrGrHtracingrIrKrrurwrrrCrrrrrrDrErFrjrXrUrs. 77CC**EE<0    *HH   %w& 5)%68KK LFJ^^ bT?VW-.4-( +.>>1MA!S%5%59#  "  %,(J4 &(9#:JtJUKUKp z (44"J $J $Z-?-?`6*$/+E2b  =b  J4M4nE,E,k5  sH H"!H"