~tjPddlZddlZddlZddlZddlZddlZddlZddlmZm Z m Z ddl m Z m Z mZmZddlmZddlmZddlmZmZmZddlmZddlmZdd lmZmZmZm Z m!Z!m"Z"ddl#Z#dd l#m$Z$m%Z%d d l&m'Z'm(Z(d d l)m*Z*m+Z+d dl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8d dl9m:Z:d dl;mZ>d dl(m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFd dlGmHZHd dlImJZJejKdkrddl mLZLn e!eMeNddfZLer ddlOZOeOjPZPn ddlOZOeOjPZPn#eQ$rdZOeRZPYnwxYweSdhZTeSddhZUeSddhZVeUeTzZWeWeVzZXdejKcxkodkncp ejKdkZYd ZZerd d!l[m\Z\d d"l;m]Z]d d#l^m_Z_Gd$d%Z`d&eae eRd'dfd(ZbGd)d*ZcGd+d,ecZdGd-d.ZeGd/d0ZfGd1d2Zgd3ehd'ePfd4Zieid5Zjeid6ZkGd7d8efZlGd9d:efZmGd;d>   O%.%)rwrYs rT__repr__zConnection.__repr__s)TY))))rV _warningsc2|jd|i}|jd|tfi||jrdS|j|j|jd|dd}|j |j|d<|j |dSdS)NsourcezUnclosed connection T should_closezUnclosed connection)client_connectionmessagesource_traceback) rzr\ResourceWarningry is_closedrx_releaserwrcall_exception_handler)rSrkwargscontexts rTr^zConnection.__del__s > %%F IN:$::O V Vv V V Vz##%%  O $ $TYT $ R R R,0=RSSG%1.2.D*+ J - -g 6 6 6 6 6 & %rVTcdS)z9Force subclasses to not be falsy, to make checks simpler.TrdrYs rT__bool__zConnection.__bool__strVcHtjdtd|jS)Nz%connector.loop property is deprecated stacklevel)r[r\r]ryrYs rTruzConnection.loops. 35GTU    zrVc,|jdS|jjSN)rz transportrYs rTrzConnection.transports > !4~''rVc|jSr)rzrYs rTrtzConnection.protocols ~rVcallbackcB||j|dSdSr)r{append)rSrs rT add_callbackzConnection.add_callbacks,   O " "8 , , , , , rVc|jddgc}|_|D]8}tt5|dddn #1swxYwY9dSr)r{r rk)rS callbackscbs rT_notify_releasezConnection._notify_releases%)_QQQ%7" 4?  B)$$                   s AA A c||j0|j|j|jdd|_dSdS)NTrrrzrxrrwrYs rTclosezConnection.closesP  > % O $ $TYT $ R R R!DNNN & %rVc||j.|j|j|jd|_dSdSrrrYs rTreleasezConnection.releasesK  > % O $ $TY ? ? ?!DNNN & %rVcH|jdup|j Sr)rz is_connectedrYs rTclosedzConnection.closeds%~%JT^-H-H-J-J)JJrVr_)r`rarbrr*rhAbstractEventLooprUstrrr[rr^rrpropertyru TransportrrtrrrrrboolrrdrVrTrqrqsO"OO" O ' O  OOOO *#****(0 7 7 7D 7 7 7 7'$-g/X (7,t3(((X( /D0X-Xb$h%7-D----""""""""KKKKXKKKrVrqceZdZdZddZdS)_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 rPNcdS)aaDo 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. NrdrYs rTrz _ConnectTunnelConnection.releaserVr_)r`rarb__doc__rrdrVrTrrs2      rVrcReZdZdZdZdejedzddfdZd dZ d dZ dS) _TransportPlaceholderz.placeholder for BaseConnector.connect functionrr closed_futureNrPc"||_d|_dS)z)Initialize a placeholder for a transport.Nr)rSrs rTrUz_TransportPlaceholder.__init__s# rVcdS)zClose the placeholder.NrdrYs rTrz_TransportPlaceholder.closerrVcdS)z%Abort the placeholder (does nothing).NrdrYs rTabortz_TransportPlaceholder.abortrrVr_) r`rarbrrcrhFuturerkrUrrrdrVrTrrsu88'IgnY5E&F4 %%%%444444rVrceZdZdZdZdZdZeZe ddddddd d e dze zd e d e d e de dejdzde ddfdZefdeddfdZd;dZdeddfdZd;dZ drCa\Base connector class. 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. timeout_ceil_threshold - Trigger ceiling of timeout values when it's above timeout_ceil_threshold. loop - Optional event loop. TNg@Fdrkeepalive_timeout force_closelimitlimit_per_hostenable_cleanup_closedrutimeout_ceil_thresholdrrrrrrurrPc|r||turtdn |turd}|ptj}||_d|_|r+tjtj d|_ tt|_||_||_t#|_tt"|_t)t*||_||_tt0|_||_t7jt:||_d|_d|_ |r2tBs+tEj#dtj$tJdd}| |_&g|_'|(|_)|j)*d|+dS) Nz6keepalive_timeout cannot be set if force_close is Trueg.@Frruzoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version rr),r3 ValueErrorrhget_running_loop_timeout_ceil_threshold_closedr|r}r~rrrrr_conns_limit_limit_per_hostset _acquired_acquired_per_hostrfloat_keepalive_timeout _force_closer_waitersry functoolspartialr*_factory_cleanup_handle_cleanup_closed_handleNEEDS_CLEANUP_CLOSEDr[r\ version_infor]_cleanup_closed_disabled_cleanup_closed_transports create_future_placeholder_futurer5_cleanup_closed)rSrrrrrrurs rTrUzBaseConnector.__init__s  ) ,1B(1R1R L!H,,$(!1w/11'=$ >>   O%.%z)BaseConnector.__del__..hs777Qa777rVrzUnclosed connector zUnclosed connector)rr connectionsrr) rrvalues_closer\rrryr)rSrconnsrrs rTr^zBaseConnector.__del__bs <  F{  F77$+"4"4"6"6777 D! 5T55QQ&QQQ +    ! -*.*@G& ' ))'22222rVc:tjdt|S)NzH"with Connector():" is deprecated, use "async with Connector():" instead)r[r\r]rYs rT __enter__zBaseConnector.__enter__ws%  4     rVexcc.|dSr)r)rSrs rT__exit__zBaseConnector.__exit__s rVc K|SrrdrYs rT __aenter__zBaseConnector.__aenter__s  rVexc_type exc_value exc_tracebackc>K|d{VdSr)r)rSrrrs rT __aexit__zBaseConnector.__aexit__s. jjllrVc|jS)z1Ultimately close connection on releasing if True.)rrYs rTrzBaseConnector.force_closes   rVc|jS)zThe total number for simultaneous connections. If limit is 0 the connector has no limit. The default limit size is 100. )rrYs rTrzBaseConnector.limits {rVc|jS)zThe limit for simultaneous connections to the same endpoint. Endpoints are the same if they are have equal (host, port, is_ssl) triple. )rrYs rTrzBaseConnector.limit_per_hosts ##rVc|jr |jd|_t}|j}|jrt t }||z }|jD]\}}t }|D]}\}} |r!| |z dkr| || f:|j } | |j s!|j r|j | ~|r|||<||_|jr*tj|d||j|j|_dSdS)zCleanup unused transports.Nr_cleanupr)rcancelrrrrritemsrrrrris_sslrrweakref_handleryr) rSnowtimeoutrdeadlinersraliveprotouse_timers rTrzBaseConnector._cleanups}   (  ' ' ) ) )$(D kk) ; &%e,,KW}H"k//11 - - U>Cgg',JJOE8))++!80Cq0H0H eX%6777 %IKKMMM8JSZJ7>>yIII-',K$%DK ; #*#9 '+'C $$$D   rVc|jr|j|jD]}||g|_|js/t j|d|j|j|j |_dSdS)z~Double confirmation for transport close. Some broken ssl servers may leave socket open without proper close. Nrr) rrrrrrr_cleanup_closed_periodryr)rSrs rTrzBaseConnector._cleanup_closeds  & 1  ' . . 0 0 08 " "I$!!!*,', *1*@!+ '+'C +++D ' ' '  rV abort_sslrc2||x}sttSt|}tjdkrt j||jd}n|j |}t|S)aClose 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. rr8Tru eager_start) rrKr2rorrrhTaskry create_task)rSrrecorotasks rTrzBaseConnector.closes ;;;;;; .&dff-- -w''  w & &<4:4HHHDD:))$//D!$'''rVcg}|jr|Sd|_ |jr||j|j|jD]}|D]}||jd|_ |j d|_ S|j r|j |j r|j |jD]t}|D]o\}}|r6|j r/|j d|n||jx}r||pu|jD]l}|r6|j r/|j d|n||jx}r||m|j D]} | | ||j|j|jD]}|D]}||jd|_ |j d|_ S#|j|j|jD]}|D]}||jd|_ |j d|_ wxYw)NT sslcontext)rryrrclearrrrrrrrrget_extra_inforrrr) rSrre keyed_waiters keyed_waiterdatar _rrs rTrzBaseConnector._closes+- < N 4 /z##%% T K      N " " "!%!5!5!7!7 * * $1**L ''))))* M   ! ! !#'D  + 1 1 3 3 3*.D ' '_# .$++---* 5+22444 **,, / / $ / /HE1!&!O&"O::<HHT  !&-v/v... / + +""66|DDPKKMMMMKKMMM"\)6+NN6***!< & & (OO%%% K      N " " "!%!5!5!7!7 * * $1**L ''))))* M   ! ! !#'D  + 1 1 3 3 3*.D ' ' K      N " " "!%!5!5!7!7 * * $1**L ''))))* M   ! ! !#'D  + 1 1 3 3 3*.D ' . . . .sK!E#K!!B)N c|jS)z;Is connector closed. A readonly property. )rrYs rTrzBaseConnector.closed4s |rVrsrHcd}|jr$|jt|jz x}dkr|S|jx}r6|j|x}r|t|z}||kr|S|S)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)rSrs total_remain host_remainacquireds rT_available_connectionsz$BaseConnector._available_connections<s ; DK#dn:M:M,MMLRSSS . .; #266s;;;x -s8}}, k))""rVreqc|j}|Ji}|j|j}|jtj|tj<t tj|||j|j|j }|j tj d}|=| s||jtj <n||jtj <|S)znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)headersauthrussl)proxy proxy_headersr)rHOSTr+METH_GET proxy_authryr+pop AUTHORIZATIONrPROXY_AUTHORIZATION)rSr'urlr) proxy_reqr*s rT-_update_proxy_auth_header_and_build_proxy_reqz;BaseConnector._update_proxy_auth_header_and_build_proxy_reqUsi"$   ('G [3 ! M      $$T%7>>  ::<< C8< D455>B !$":;rVtracesrIrrGc^K|j}|||d{Vx}|jr|||St |j|j4d{V||dkrj|||d{V|||d{Vx}0|jr|||cdddd{VSttt|j }|j ||jr |j|| |r|D]}|d{V||||d{V}|r|D]}|d{V|jr#|t-dn%#t.$r|||wxYw dddd{Vn#1d{VswxYwY|j ||j ||jr7|j|} | || |t5||||jS)z'Get from pool or create new connection.NrzConnector is closed.)connection_key_getr,r6r/connectceil_thresholdr&_wait_for_available_connectionrr*rrraddrrsend_connection_create_start_create_connectionsend_connection_create_endrrr BaseException_release_acquiredremoverqry) rSr'r7rrsconn placeholdertracer acquired_per_hosts rTr;zBaseConnector.connectos/ ))C00000000 0D =y HBB3GGGK1GHH H H H H H H H H**3//14499#vFFFFFFFFF"&))C"8"88888888DEyPJJ3OOO H H H H H H H H H H H H H H!6t7O!P!PK N  { + + +# >',00=== HC!'CC#@@BBBBBBBBBB"55c67KKKKKKKKA!'AA#>>@@@@@@@@@@ <HKKMMM/0FGGGH !   &&sK888 H= H H H H H H H H H H H H H H H H H H H H H H H H H H HN k*** 5!!!   ) $ 7 <   $ $[ 1 1 1  ! !% ( ( ($UDJ777s3&A1H*A(HAG2+H"G??H H"Hc^Kd} |j}|j|}d||<|r||d |r|D]}|d{V|d{V|r|D]}|d{V||d|j|ds|j|=n>#||d|j|ds|j|=wxYw||dkrdS|dz }))z&Wait for an available connection slot.rTNFlastr) ryrr move_to_endsend_connection_queued_startsend_connection_queued_endr1r"r&)rSrsr7attemptsfutrrGs rTr=z,BaseConnector._wait_for_available_connections (, (@(@(B(BC M#.M!%M#  ;))#E)::: +C!'CC#@@BBBBBBBBBB A!'AA#>>@@@@@@@@@@!!#t,,,}((d33+ c*!!#t,,,}((d33+ c*******3//!33 MH; s A C;D cK|j|x}dSt}|r(|\}}|r||z |jkr|s|j|=|j||jr |j |||rE|D]B} | d{V#t$r| ||wxYwt||||jS|j}||js!|jr|j||(|j|=dS)znGet next reusable connection for the key or None. The connection will be marked as acquired. N)rr"rpopleftrrrr>rrsend_connection_reuseconnrBrCrqryrrrrrr) rSrsr7rt1r t0rGrs rTr:zBaseConnector._gets[__S)) )E 24 [[ B IE2!!## @R43J(J(J) C(""5)))'<+C044U;;;"!'""""'"A"A"C"CCCCCCCCC,""" 223>>>!""$UDJ???I KKMMM0 BSZ B/66yAAA3 B8 K ts =C"C:cR|jsdSt|j}tj||D]r}||dkr|j|}|rG|d\}}|s|ddS|GsdS)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. NrFrJ)rlistrandomshuffler&popitemdoner5)rSqueuesrsrewaiterrs rT_release_waiterzBaseConnector._release_waiters}  Fdm$$v  C**3//!33mC(G #OOO77 {{}}%%d+++FF    rVr c|jrdS|j||jr;|j|x}r|||s|j|=|dS)zRelease acquired connection.N)rrdiscardrrr"r^)rSrsr rs rTrCzBaseConnector._release_acquireds <  F u%%%   1d.E.I.I#.N.N%NU 1 MM%  1+C0 rVrrtrc|jrdS||||js |s|jrE|j}||jr!|js|j |dS|j | |tf|j /tj|d|j|j|j|_ dSdS)Nrr)rrCrrrrrrrrrrrrrrryr)rSrsrtrrs rTrzBaseConnector._release%s <  F sH---     0E  *I NN   z B$"? B/66yAAA F C9;; 7888   '#*#9' '+'C $$$D  ( 'rVc"Ktr)NotImplementedError)rSr'r7rs rTr@z BaseConnector._create_connectionEs"###rV)rPrC)NNNr_)2r`rarbrrrr HIGH_LEVEL_SCHEMA_SETallowed_protocol_schema_setr3objectrrintrhrrUr[rr^rrrtyperBrrrrrrrrrrrWrrr&r+r6rqr;r=r:r^r*rCrr@rdrVrTrCrCs  G!"7 4<!&+15()KKK"D=50K K  K  K $K'$.K!&K KKKKZ(0333D3333*ST 04*..2 }%,!4'%t+   !T!!!X!sX$$$$X$%%%%N.*/((($(9T?(((((+0</</</4</D69J4K</</</</|X/c2  498 98*.w-98BQ98 98989898v("(,0M( ((((T("(,0M( d ((((T4 _ _ QU    $#  "    @$ $*.w-$BQ$ $$$$$$rVrCceZdZddedzdeddfdZdedefdZd e e efd e e ddfd Z d e e efddfd Zdd Zd e e efde e fdZd e e efdefdZdS)_DNSCacheTableNttlmax_sizerPcVt|_i|_||_||_dSr)r _addrs_rr _timestamps_ttl _max_size)rSrlrms rTrUz_DNSCacheTable.__init__Ls. MM :< !rVhostc||jvSr)ro)rSrss rT __contains__z_DNSCacheTable.__contains__Tst~%%rVrsaddrsc||jvr|j|t|t|f|j|<|jt |j|<t|j|jkr;|jd\}}|j |ddSdS)NFrJ) rorLr r!rqrrprrrZr1)rSrsrv oldest_keyrs rTr>z_DNSCacheTable.addWs $. N & &s + + +$U||SZZ8s 9 $-KKD S ! t~   / / N222>>MJ   T 2 2 2 2 2 0 /rVcr|j|d|j|ddSr)ror1rprSrss rTrDz_DNSCacheTable.removeds9 3%%% S$'''''rVcj|j|jdSr)rorrprYs rTrz_DNSCacheTable.clearhs1       rVc|j|\}}tt||}t||j||Sr)rorWrnextrL)rSrsrulengthrvs rT next_addrsz_DNSCacheTable.next_addrslsO~c* fVD&))** T  ""3''' rVc^|jdS|j||jztkSrR)rqrprrzs rTexpiredz_DNSCacheTable.expiredts- 9 5$ty09;;>>rV)Nrkr_)r`rarbrrgrUrfrrutuplerrWrr>rDrrrrdrVrTrjrjKs5""EDL"3"$""""&&D&&&& 3uS#X 3tM/B 3t 3 3 3 3(%S/(d((((!!!!eCHo$}2E?5c??t??????rVrjverifiedctdS|rtj}ntjtj}|xjtjzc_|xjtjzc_d|_tj|_ |xjtj zc_| | d|S)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) r+create_default_context SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONset_default_verify_pathsset_alpn_protocols)rrs rT_make_ssl_contextr{s  {t ./11 ^C$;<< co-co-$) !!$ c33++---!!-000 rVTFc,eZdZdZeedhzZdddddejj dddde ddd ddd d dde d d e de dzde de dzde dejdedzde ezezdeee fdzdedzddezezde de de de dejdzdededzde dzd edzd!edzezf*fd"Zdd#d$e d%eeeffd&Zdd#d$e d%dffd'Zed%e fd(Zed%e fd)Z dMd*edzd+e dzd%dfd,Z! dNd*ed+e d-e"d.dzd%ee#fd/Z$d0eee fd*ed+e d1e%d2d-e"d.dzd%ee#f d3Z&d4e'd-ed.d5d6d%e(fd7Z)d4e'd%edzfd8Z*d4e'd%e+d9fd:Z,e-d;de0e1d?e.d%eej2e(ffd@Z3e-d;de0e1d?e.d%eej2e(ff dAZ4dOdCZ5dPdDZ6d%e fdEZ7dFej2d4e'd%dfdGZ8e-fdFej2d4e'd5d6d>e0e1d%eej9e(ff dHZ:dIee#d%ee/fdJZ;e-d;d4e'd-ed.d5d6d>e0e1d%eej2e(ff dKZS)QrDuTCP 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 rkFrrrg?) verify_ssl fingerprint use_dns_cache ttl_dns_cachedns_cache_max_sizefamily ssl_contextr+ local_addrresolverrrrrrrurhappy_eyeballs_delay interleavesocket_factoryssl_shutdown_timeoutrrrrrrrr+rrrrrrrrurrrrrc t| | | ||||t|||||_|| "t |j|_d|_n| |_d|_||_t|||_ i|_ ||_ tj| |_||_||_t%|_||_||t*ur d|_dSt/jdt2d t4jd kr(|&|dkr t/jd |d t8d ||_dS) NrrTF)rlrmrzSThe 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.)superrUr-_sslr7ry _resolver_resolver_owner_use_dns_cacherj _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)rSrrrrrrrr+rrrrrrrrurrrrr __class__s rTrUzTCPConnector.__init__s2 /#)"7#9    &c:{KPP  (  ,$*===DN#'D %DN#(D ++(:     " !1!DZ!P!P%9"%KN55 - 0 8 + +)*D & & & Me"      7**(4(A-- ],@]]]"  *>D & & &rVrrrPc6tj|jD]}|t |}|jD]+}|||,|S)zClose all ongoing DNS calls.r) r from_iterablerrrrrrr)rSrrPretrs rTrzTCPConnector._closes&t'A'H'H'J'JKK  C JJLLLL''..9.55)  A HHJJJ NN1    rVcKt|p |jdkd{V|jr!|jd{VdSdS)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 rrN)rrrrr)rSrrs rTrzTCPConnector.close"sggmmi&R43MQR3RmSSSSSSSSS   ).&&(( ( ( ( ( ( ( ( ( ( ) )rVc|jS)zSocket family like AF_INET.)rrYs rTrzTCPConnector.family1s |rVc|jS)z%True if local DNS caching is enabled.)rrYs rTrzTCPConnector.use_dns_cache6s ""rVrsportc| ||j||fdS||td|jdS)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)rrDrr)rSrsrs rTclear_dns_cachezTCPConnector.clear_dns_cache;sc   0   % %tTl 3 3 3 3 3  !1TUU U   $ $ & & & & &rVr7rIcKt|r2d|vrt|st|d||||jdddgS|js|r |D]}||d{V|jrtd|j |||jd{V}|r |D]}| |d{V|S||f}||j vrX|j |s>|j |}|r |D]}||d{V|S||jvr|j|}|j} || |r |D]}||d{V | d{V|| n#|| wxYw|j |St)x|j|<}||||||} t-j} t0jdkrt-j| | d } n| | } | s9|j| | |jj t-j| d{VS#t,j $rdd} | | wxYw)z*Resolve host and return list of addresses.:zis not a canonical IPv4 addressr)hostnamersrrr flagsNzConnector is closedrr8TrrP#asyncio.Future[list[ResolveResult]]rPctttj5|ddddS#1swxYwYdSr)r rkrhCancelledErrorresult)rPs rTdrop_exceptionz2TCPConnector._resolve_host..drop_exceptionsi)?@@!!JJLLL!!!!!!!!!!!!!!!!!!sAA A)rPrrPN)!r1r0r%rrsend_dns_resolvehost_startrrrresolvesend_dns_resolvehost_endrrrsend_dns_cache_hitrryrr>r`r_resolve_host_with_throttlerhrrrrrr[radd_done_callbackshieldr)rSrsrr7rGrnrsrfuturesfuturerruresolved_host_taskrs rT _resolve_hostzTCPConnector._resolve_hostDs    $'@'F'F+D2STTT!%  "l   "  A#AAE::4@@@@@@@@@@| C+,ABBB..tT$,.OOOOOOOOC ?#??E88>>>>>>>>>>JTl $$ $ $T-?-G-G-L-L $'22377F 9#99E2248888888888M $, , ,05G+/:+C+C+E+EF KK    9#99E2248888888888 ( ''''''''%0055 558EE9"3'' //T4&QQ'))  w & &!(d4!P!P!P  !%!1!1$!7!7 !&&(( S  $ ( (); < < <  0 01I1Q R R R  (:;;;;;;;; ;%    ! ! ! !  0 0 @ @ @  sF99G<K*Lrsrzasyncio.Future[None]c|K |r@|D]}||d{V|D]}||d{V|j|||jd{V}|r |D]}||d{V|j|||D]}t|dn(#t$r} |D]}t|| d} ~ wwxYw |j |n#|j |wxYw|j |S)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_missrrrrrrr>r5rBr4rr1r) rSrsrsrrr7rGrvrPes rTrz(TCPConnector._resolve_host_with_throttles 0 A#::E33D9999999999#AAE::4@@@@@@@@@@.00tDL0QQQQQQQQE ?#??E88>>>>>>>>>>   " "3 . . . & &3%%%% &    & &c1%%%%    &  & * *3 / / / /D & * *3 / / / /!,,S111s*B)%)%;)-)C#/#'#7 JJu%%P2P(G33595OF129TZ94U6UUPTUUUUUUUUU% V V V V V V V V V V V V V V V V V V V V V V V V V V V V V V& T T T1#2DcJJPS S L L L)#*)rr,scheme_check_loop_for_start_tls)rSr' proxy_urls rT_fail_on_no_start_tlsz"TCPConnector._fail_on_no_start_tlsDsWzz||  FI $$$  w & & F &&(((((rVcd |jjdS#t$r}td|d}~wwxYw)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 )ry start_tlsAttributeErrorr)rSattr_excs rTrz&TCPConnector._check_loop_for_start_tlsVsT  J     K    s  /*/cR |dS#t$rYdSwxYw)NTF)rrrYs rT_loop_supports_start_tlsz%TCPConnector._loop_supports_start_tlsgsD   * * , , ,4   55 s  &&underlying_transportc<|jjjdkrdS|j|jjdkrdSt |jdrdStjdkpt|dd}|rdStj dt|d dS) 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_infor4rr,rhra startswithrrgetattrr[r\r)rSrr'asyncio_supports_tls_in_tlss rT_warn_about_tls_in_tlsz#TCPConnector._warn_about_tls_in_tlsos    &' 1 1 F 9  0G ; ; F $ % % 0 ; ;H E E  F'*&6'&A' W # F F # '  F  G !      rVcK|}||}tr|J t|j|j4d{V t jdkrF|jr?|j ||||j p|j |j pd|jd{V}n8|j ||||j p|j |j pdd{V}nC#t$r6|jdkr|n|wxYwt#|t$jrr||}|r[ ||nD#t,$r7||js|j|wxYwdddd{Vn#1d{VswxYwY| d} ||jt7| ||n#t:$r} t=|j| | d} ~ wt>$r} tA|j| | d} ~ wt6$r9} | j!t#| t$j"r||j| | d} ~ wtF$r<} tId|j d |j%d d |j&d |j'pd d| d | d} ~ wwxYw||fS)z$Wrap the raw TCP transport with TLS.Nrr)server_hostnamessl_handshake_timeoutr)r r rz: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/rr<rrrryrr rstotalrBrrrjrhrrcheckr&rrrr9rconnection_mader(rr)r"rr TypeErrorrrr,r+) rSrr'rr tls_protor tls_transportrmsgrtype_errs rT_start_tls_connectionz"TCPConnector._start_tls_connectionsMMOO **3//  *)))C #$W5K( "( "( "( "( "( "( "( "'722t7Q2.2j.B.B0%&,/,?,K3829-2G4151K /C//)))))) /3j.B.B0%&,/,?,K3829-2G4 /C//)))))) %1Q66,224444,22444mW->?? ""&"7"7"<"HQ$,44S999T  &*&B&BM#")$3!-'C''!!!!!! )'*>?    ::tGWXXX  zz||   %%f----0   LLNNN8G7>>vFFF"H*0*?*?*I*ID#//11H$6z8LLLHHHH 5= '''NsI6B C8CC*EFE<<FF11 H;;A5H66H;c(K|||}||}||g|td{V\}}|r|r|||tj|_ |j |_ |j ddd}t||||j} || d{V} | j} | J| ||j| | d{V} d| _ | jdkrJ| j} | t-| jj} t1| j| j| j| | j|s<|dd}|t;d|}n##t>$r| wxYw|s| n#|s| wwxYw|sU|!|}|"|j#||||j$| d{V | S|%||| d{V | S#t>$r*| | wxYw#| wxYw||fS) Nr)r,r0proxy_headers_hash)read_until_eofr)statusrr)r)r z)Transport does not expose socket instance)rr+rr r')r'r)&rrr6rr$rrr METH_CONNECTmethodr4r9_replacerrysendrzset_response_paramsrstartr2reasonr phraser#rhistoryr)rrduprBrrrrrsr)rSr'r7rruntime_has_start_tlsr5rr rsrE proxy_resprtresprrawsockrs rTrz%TCPConnector._create_proxy_connectionVs  ""3''' $ = = ? ?FFsKK "&!?!? r71K"@" "        5 ::<<X #$ <++Is;;; $0I GIM$--t.C,D#udjIID(~~d33333333JD #>+++ ,,#8+/+G-(--d33333333 "&*{c))"&+"?&0&=&=&DG2&3 L#';$+$(L 10"+":":8T":"R"R"?". K###*++--$OO%%% 1*!)))1*!))))*- !%!6!6s!;!;J!%!?!? '&$(+ "@"""  """""77# 8  """"q!     """  p  """"%sQAKK7 BG H HHK7H33AK7 K74K44K77L )NNr)r'r+rPNr_)?r`rarbrrd frozensetrer AddressFamily AF_UNSPECr3rbytesrgrr,rrrrrfrhrrr.rUrWrrrrrrrr rrrrr+r*r@rrrr!rrrhrkrrrrrrr BaseTransportrr"rr __classcell__rs@rTrDrDs#$$L#8))UG:L:L"L  $("$&"&'-';'E)-/3-1,03;!&+15()-1!%379A/P>P>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>P>P>P>P>d+0   4 D69J4K      05 ) ) ) ) ) ) ) ) ) )X#t###X#''C$J'S4Z'SW''''HLaaa"a,4W,=,Da m aaaaF'2 38_'2'2 '2 +, '2 !D( '2 m '2'2'2'2R   *.w- BQ      %M%j46G%%%%BMh}6M)= $A$A$A$A&$A $A ! $A 9o $A$A w /1 2$A$A$A$AV)= AAAAA! A 9o A  A w /1 2AAAA,))))$"$/ %// /   / / / / l)= T(T(%/T(T(! T( 9o T( w$o5 6 T(T(T(T(l-( l 6)= III IW I! I 9o I w /1 2IIIIVf  f *.w-f BQf w$o5 6f f f f f f f f rVrDceZdZdZeedhzZdedddfdede d e e zdzd e d e d e jdzd dffd Zed efdZdededddd efdZxZS)rEaUnix 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. unixFrrNpathrrrrrurPcbt|||||||_dS)Nrrrrru)rrU_pathrSrJrrrrrurs rTrUzUnixConnector.__init__sB #/)     rVc|jS)zPath to unix socket.rMrYs rTrJzUnixConnector.path zrVr'r7rIrrGcK t|j|j4d{V|j|j|jd{V\}}dddd{Vn#1d{VswxYwYnP#t$rC}|jt|tj rt|j |j||d}~wwxYw|Sr)r/rr<rycreate_unix_connectionrrMrrrjrhrr'rJr9rSr'r7rrr rs rTr@z UnixConnector._create_connections X#$W5K        "&!B!BM4:""5                             X X Xy ZW5I%J%J *49c6H#NNTW W X  s:!A8/A&A8& A00A83A04A88 C>CCr`rarbrrdrArer3rrrfrrgrhrrUrrJr+rWr*r@rFrGs@rTrErEs*  #8))VH:M:M"M "3;15"E>D0     '$. $cX *.w-BQ rVrEceZdZdZeedhzZdedddfdede d e e zdzd e d e d e jdzd dffd Zed efdZdededddd efdZxZS)rFaNamed 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. npipeFrrNrJrrrrrurPct|||||t|jtjst d||_dS)NrLz9Named Pipes only available in proactor loop under windows)rrUrjryrhProactorEventLooprrMrNs rTrUzNamedPipeConnector.__init__sx #/)     J  %   K  rVc|jS)zPath to the named pipe.rPrYs rTrJzNamedPipeConnector.path rQrVr'r7rIrrGcK t|j|j4d{V|j|j|jd{V\}}tjdd{Vdddd{Vn#1d{VswxYwYnJ#t$r=}|j t|tj rt|j||d}~wwxYwtt |S)Nrr)r/rr<rycreate_pipe_connectionrrMrhsleeprrrjrr!r9rr*rTs rTr@z%NamedPipeConnector._create_connection%s I#$W5K ' ' ' ' ' ' ' '"&!B!BM4:""5mA&&&&&&&&& ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' I I Iy ZW5I%J%J &s'93??S H I OU+++s;!BA B.B B  B B B C8CCrUrGs@rTrFrFs*  #8))WI:N:N"N "3;15"E>D0     '$. 2cX, ,*.w-,BQ, ,,,,,,,,rVrF)orhrrXrrr}r[ 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;rD bytearrayr+r ImportErrorrfrAEMPTY_SCHEMA_SETHTTP_SCHEMA_SET WS_SCHEMA_SETHTTP_AND_EMPTY_SCHEMA_SETrdr__all__clientrGrHtracingrIrKrWrorqrrrCrjrrrrrDrErFrdrVrTrssT 7777777777CCCCCCCCCCCC**********EEEEEEEEEEEEEEEE<<<<<<<<00000000                            *)))))HHHHHHHHHH                    %%%%%%w&&&&&&& 5)%68KK LF JJJJJ ^  9bT??)VW-.. 4-(( +.>>1MA!S%59#  "  %%%%%%,,,,,,(J4 &(9#:JtJJJJUKUKUKUKUKUKUKUKp     z   (44444444"J $J $J $J $J $J $J $J $Z-?-?-?-?-?-?-?-?`6*)$//++E22b  b  b  b  b  =b  b  b  J44444M444nE,E,E,E,E,E,E,E,E,E,s: D DD