o 4j@sRddlZddlZddlZddlZddlZddlZddlZddlmZm 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 mLZLne!eMeNddfZLerddlOZOeOjPZPnz ddlOZOeOjPZPWneQydZOeRZPYnweSdhZTeSddhZUeSddhZVeUeTBZWeWeVBZXdejKko&dknp.ejKdkZYd ZZerFd d!l[m\Z\d d"l;m]Z]d d#l^m_Z_Gd$d%d%Z`d&eae eRd'dfd(d)ZbGd*d+d+ZcGd,d-d-ecZdGd.d/d/ZeGd0d1d1ZfGd2d3d3Zgd4ehd'ePfd5d6Zieid7Zjeid8ZkGd9d:d:efZlGd;d<dd>efZndS)?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)r8 r)r8r@r)r8r9) BaseConnector TCPConnector UnixConnectorNamedPipeConnectorrr) ClientTimeout) ConnectionKey)Tracec@s>eZdZdZdeeddfddZdefddZd d d ZdS) _DeprecationWaiter _awaitable_awaited awaitablereturnNcCs||_d|_dSNFrJ)selfrMrQN/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/aiohttp/connector.py__init__h z_DeprecationWaiter.__init__cCsd|_|jS)NT)rLrK __await__rPrQrQrRrUlrTz_DeprecationWaiter.__await__cCs|js tdtdSdS)NzDConnector.close() is a coroutine, please use await connector.close())rLwarningswarnDeprecationWarningrVrQrQrR__del__ps z_DeprecationWaiter.__del__rNN) __name__ __module__ __qualname__ __slots__rrrSrUrZrQrQrQrRrIes rIwaitersrNcs<tj|ddiIdH}|D] }t|trtd|qdS)z'Wait for all waiters to finish closing.return_exceptionsTNz!Error while closing connector: %r)asynciogather isinstance Exceptionr5debug)r`resultsresrQrQrR_wait_for_closeys  ric @seZdZdZdddddedejddf d d Zdefd d Z e fd e ddfddZ de dfddZedejfddZedejdBfddZededBfddZdegdfddfddZd$ddZd$ddZd$d d!Zedefd"d#ZdS)% ConnectionN connectorrBkeyrGprotocollooprNcCs@||_||_||_||_g|_|rtt d|_ dSdS)Nr) _key _connector_loop _protocol _callbacks get_debug traceback extract_stacksys _getframe_source_traceback)rPrkrlrmrnrQrQrRrSszConnection.__init__cCsd|jdS)Nz Connection<>)rorVrQrQrR__repr__szConnection.__repr__ _warningscCs|jdur?d|i}|jd|tfi||jrdS|jj|j|jdd|dd}|jdur7|j|d<|j |dSdS)NsourcezUnclosed connection T should_closezUnclosed connection)client_connectionmessagesource_traceback) rrrXResourceWarningrq is_closedrp_releaserorycall_exception_handler)rPr|kwargscontextrQrQrRrZs     zConnection.__del__TcCdS)z9Force subclasses to not be falsy, to make checks simpler.TrQrVrQrQrR__bool__szConnection.__bool__cCstjdtdd|jS)Nz%connector.loop property is deprecated stacklevel)rWrXrYrqrVrQrQrRrnszConnection.loopcCs|jdurdS|jjSN)rr transportrVrQrQrRrs zConnection.transportcC|jSr)rrrVrQrQrRrmszConnection.protocolcallbackcCs|dur |j|dSdSr)rsappend)rPrrQrQrR add_callbackszConnection.add_callbackc CsR|jddg}|_|D]}tt |Wdn1s!wYq dSr)rsr re)rP callbackscbrQrQrR_notify_releases zConnection._notify_releasecCs6||jdur|jj|j|jddd|_dSdS)NTr~rrrrprrorVrQrQrRcloses   zConnection.closecCs2||jdur|j|j|jd|_dSdSrrrVrQrQrRreleases   zConnection.releasecCs|jdup |j Sr)rr is_connectedrVrQrQrRclosedszConnection.closedr[)r\r]r^ryr)rbAbstractEventLooprSstrr{rWrrZrrpropertyrn TransportrrmrrrrrboolrrQrQrQrRrjs8    rjc@seZdZdZdddZdS)_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 rNNcCr)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. NrQrVrQrQrRrz _ConnectTunnelConnection.releaser[)r\r]r^__doc__rrQrQrQrRrs rc@sDeZdZdZdZdejedBddfddZd dd Z d d d Z dS) _TransportPlaceholderz.placeholder for BaseConnector.connect functionrr closed_futureNrNcCs||_d|_dS)z)Initialize a placeholder for a transport.Nr)rPrrQrQrRrSs z_TransportPlaceholder.__init__cCr)zClose the placeholder.NrQrVrQrQrRrrz_TransportPlaceholder.closecCr)z%Abort the placeholder (does nothing).NrQrVrQrQrRabortrz_TransportPlaceholder.abortr[) r\r]r^rr_rbFuturererSrrrQrQrQrRrs  rc@sHeZdZdZdZdZdZeZe ddddddd d e dBe Bd e d e d e de dejdBde ddfddZefdeddfddZdRddZdeddfddZdRddZ   dSdeedBdedBd edBddfd!d"Zede fd#d$Zede fd%d&Zede fd'd(ZdTd)d*ZdTd+d,Z dd-d.e de!dfd/d0Z"dd-d.e de#e!e fd1d2Z$ede fd3d4Z%d5d6de fd7d8Z&d9e'de'fd:d;Z(d9e'dd?de)fd@dAZ*d5d6dd?de.fdPdQZ1dS)UrBa\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_closedrntimeout_ceil_thresholdrrrrrrnrrNcCs|r|dur|turtdn|turd}|pt}||_d|_|r.tt d|_ t t |_||_||_t|_t t|_tt||_||_t t|_||_tjt|d|_d|_d|_ |rst!sst"j#dt j$t%ddd}| |_&g|_'|(|_)|j)*d|+dS) Nz6keepalive_timeout cannot be set if force_close is Trueg.@Frrnzoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version rr),r2 ValueErrorrbget_running_loop_timeout_ceil_threshold_closedrtrurvrwrxryrr_conns_limit_limit_per_hostset _acquired_acquired_per_hostrfloat_keepalive_timeout _force_closer_waitersrq functoolspartialr)_factory_cleanup_handle_cleanup_closed_handleNEEDS_CLEANUP_CLOSEDrWrX version_inforY_cleanup_closed_disabled_cleanup_closed_transports create_future_placeholder_futurer4_cleanup_closed)rPrrrrrrnrrQrQrRrSsV     zBaseConnector.__init__r|cCs|jrdS|js dSdd|jD}|d|i}|jd|tfi|||dd}|jdur9|j|d<|j|dS)NcSsg|]}t|qSrQ)repr).0crQrQrR hsz)BaseConnector.__del__..r}zUnclosed connector zUnclosed connector)rk connectionsrr) rrvalues_closerXrryrqr)rPr|connsrrrQrQrRrZbs  zBaseConnector.__del__cCstdt|S)NzH"with Connector():" is deprecated, use "async with Connector():" instead)rWrXrYrVrQrQrR __enter__ws zBaseConnector.__enter__exccGs |dSr)r)rPrrQrQrR__exit__s zBaseConnector.__exit__cs|SrrQrVrQrQrR __aenter__szBaseConnector.__aenter__exc_type exc_value exc_tracebackcs|IdHdSr)r)rPrrrrQrQrR __aexit__szBaseConnector.__aexit__cCr)z1Ultimately close connection on releasing if True.)rrVrQrQrRrzBaseConnector.force_closecCr)zThe total number for simultaneous connections. If limit is 0 the connector has no limit. The default limit size is 100. )rrVrQrQrRrzBaseConnector.limitcCr)zThe limit for simultaneous connections to the same endpoint. Endpoints are the same if they are have equal (host, port, is_ssl) triple. )rrVrQrQrRrrzBaseConnector.limit_per_hostc Cs|jr |jd|_t}|j}|jr^tt}||}|jD]9\}}t}|D])\}} |r@| |dkr@| || fq*|j } | |j sS|j rS|j | q*|rZ|||<q!||_|jrptj|d||j|jd|_dSdS)zCleanup unused transports.Nr_cleanupr)rcancelrrrrritemsrrrrris_sslrrweakref_handlerqr) rPnowtimeoutrdeadlinerlraliveprotouse_timerrQrQrRrs@     zBaseConnector._cleanupcCs\|jr|j|jD] }|dur|q g|_|js,tj|d|j|j|j d|_dSdS)z~Double confirmation for transport close. Some broken ssl servers may leave socket open without proper close. Nrr) rrrrrrr_cleanup_closed_periodrqr)rPrrQrQrRrs    zBaseConnector._cleanup_closed abort_sslrcCsZ|j|d}s ttSt|}tjdkr#tj||jdd}t|S|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. rr7Trn eager_start) rrIr1rirwrrbTaskrq create_task)rPrr`corotaskrQrQrRrs   zBaseConnector.closec Csg}|jr|Sd|_z|jr>|W|j|j|jD] }|D]}|q%q!|jd|_ |j d|_ S|j rF|j |j rN|j |jD])}|D]$\}}|rm|j rm|j ddurm|n||j}r{||qWqS|jD]"}|r|j r|j ddur|n||j}r||q|j D] } | dur| q|W|j|j|jD] }|D]}|qq|jd|_ |j d|_ S|j|j|jD] }|D]}|qq|jd|_ |j d|_ w)NT sslcontext)rrqrrclearrrrrrrrrget_extra_inforrrr) rPrr` keyed_waiters keyed_waiterdatar_rrrQrQrRrs  *                        zBaseConnector._closecCr)z;Is connector closed. A readonly property. )rrVrQrQrRr4szBaseConnector.closedrlrGcCs\d}|jr|jt|j}dkr|S|j}r,|j|}r&|t|8}||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)rPrl total_remain host_remainacquiredrQrQrR_available_connections<s   z$BaseConnector._available_connectionsreqcCs|j}|dus Ji}|jdur|j}|jtj|tj<ttj|||j|j|j d}|j tj d}|durH| sB||jtj <|S||jtj <|S)znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)headersauthrnssl)proxy proxy_headersrrHOSTr*METH_GET proxy_authrqrpop AUTHORIZATIONrPROXY_AUTHORIZATION)rPrurlr proxy_reqrrQrQrR-_update_proxy_auth_header_and_build_proxy_reqUs*    z;BaseConnector._update_proxy_auth_header_and_build_proxy_reqtracesrHrrFc s|j}|||IdH}dur|jr|||St|j|j4IdH||dkrX|||IdH|||IdH}durX|jrL|||WdIdHSt t t |j }|j ||jrq|j||z(|r|D] }|IdHqv||||IdH}|r|D] }|IdHqWnty|||w|jr|tdWdIdHn 1IdHswY|j ||j ||jr|j|} | || |t||||jS)z'Get from pool or create new connection.NrzConnector is closed.)connection_key_getrrr.connectceil_thresholdr_wait_for_available_connectionrr)rrraddrrsend_connection_create_start_create_connectionsend_connection_create_end BaseException_release_acquiredrrrremoverjrq) rPrrrrlconn placeholdertraceracquired_per_hostrQrQrRrosX       ( '    zBaseConnector.connectc sd} |j}|j|}d||<|r|j|ddz4|r*|D] }|IdHq |IdH|r=|D] }|IdHq3W||d|j|dsO|j|=n||d|j|dsa|j|=w||dkrkdS|d7}q)z&Wait for an available connection slot.rTNFlastr) rqrr move_to_endsend_connection_queued_startsend_connection_queued_endr rr)rPrlrattemptsfutrrrQrQrRrs8       z,BaseConnector._wait_for_available_connectionc s|j|}dur dSt}|ru|\}}|r`|||jkr`|s)|j|=|j||jr:|j |||rX|D]}z | IdHWq>t yW| ||wt ||||jS|j}||jss|jrs|j||s|j|=dS)znGet next reusable connection for the key or None. The connection will be marked as acquired. N)rrrpopleftrrrrrrsend_connection_reuseconnrrrjrqrrrrrr) rPrlrrt1rt0rrrQrQrRrs8      zBaseConnector._getcCsv|jsdSt|j}t||D]'}||dkrq|j|}|r8|jdd\}}|s6|ddS|s"qdS)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. NrFr!)rlistrandomshufflerpopitemdoner4)rPqueuesrlr`waiterrrQrQrR_release_waiters     zBaseConnector._release_waiterrcCsN|jrdS|j||jr!|j|}r!|||s!|j|=|dS)zRelease acquired connection.N)rrdiscardrrrr3)rPrlrrrQrQrRrs   zBaseConnector._release_acquiredr~rmrcCs|jrdS||||js|s|jr(|j}||jr&|js&|j |dS|j | |t f|j durHt j|d|j|j|jd|_ dSdS)Nrr)rrrrrrrrrrrrrrrrrqr)rPrlrmrrrQrQrRr%s&     zBaseConnector._releasecstr)NotImplementedError)rPrrrrQrQrRrEsz BaseConnector._create_connection)rNrB)NNNr[)2r\r]r^rrryrHIGH_LEVEL_SCHEMA_SETallowed_protocol_schema_setr2objectrrintrbrrSrWrrZrrrtyperrrrrrrrrrrr,rrrr*rrjrrrr3r)rrrrQrQrQrRrBs   M      ' >  ; * *  rBc@seZdZddedBdeddfddZdedefd d Zd e e efd e e ddfd dZ d e e efddfddZdddZd e e efde e fddZd e e efdefddZdS)_DNSCacheTableNttlmax_sizerNcCst|_i|_||_||_dSr)r _addrs_rr _timestamps_ttl _max_size)rPr=r>rQrQrRrSLs  z_DNSCacheTable.__init__hostcCs ||jvSr)r?)rPrCrQrQrR __contains__Ts z_DNSCacheTable.__contains__rladdrscCsz||jvr |j|t|t|f|j|<|jdur!t|j|<t|j|jkr;|jjdd\}}|j |ddSdS)NFr!) r?r#r rrArr@rBr/r )rPrlrE oldest_keyrrQrQrRrWs    z_DNSCacheTable.addcCs |j|d|j|ddSr)r?r r@rPrlrQrQrRrdsz_DNSCacheTable.removecCs|j|jdSr)r?rr@rVrQrQrRrhs z_DNSCacheTable.clearcCs4|j|\}}tt||}t||j||Sr)r?r,r nextr#)rPrlrnlengthrErQrQrR next_addrsls  z_DNSCacheTable.next_addrscCs$|jdurdS|j||jtkSrO)rAr@rrGrQrQrRexpiredts z_DNSCacheTable.expired)Nr<r[)r\r]r^rr9rSr8rrDtuplerr,rrrrrJrKrQrQrQrRr;Ks" r;verifiedcCsztdurdS|r t}n)ttj}|jtjO_|jtjO_d|_tj|_ |jtj O_| | 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) rcreate_default_context SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONset_default_verify_pathsset_alpn_protocols)rMrrQrQrR_make_ssl_context{s   rZTFc,seZdZdZeedhBZdddddejj dddde ddd ddd d dde d d e de dBde de dBde dejdedBde eBeBdeee fdBdedBddeBeBde de de de dejdBdededBde dBd edBd!edBeBf*fd"d#Zdd$d%e d&eeeffd'd(Zdd$d%e d&dffd)d*Zed&e fd+d,Zed&e fd-d.Z dbd/edBd0e dBd&dfd1d2Z! dcd/ed0e d3e"d4dBd&ee#fd5d6Z$d7eee fd/ed0e d8e%d9d3e"d4dBd&ee#f d:d;Z&dd&e(fd?d@Z)ddIe0e1dJe.d&eej2e(ffdKdLZ3e-dFdGe.ddIe0e1dJe.d&eej2e(ff dMdNZ4dddPdQZ5dedRdSZ6d&e fdTdUZ7dVej2ddIe0e1d&eej9e(ff dYdZZ:d[ee#d&ee/fd\d]Z;e-dFddIe0e1d&eej2e(ff d^d_Zd&eej9e(ffd`daZ=Z>S)frCuTCP 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 r<Frrrg?) verify_ssl fingerprint use_dns_cache ttl_dns_cachedns_cache_max_sizefamily ssl_contextr local_addrresolverrrrrrrnrhappy_eyeballs_delay interleavesocket_factoryssl_shutdown_timeoutr]r^r_r`rarbrcrrdrerrrrrrnrrfrgrhric stj| | | ||||dt|||||_|| dur&t|jd|_d|_n| |_d|_||_t ||d|_ i|_ ||_ t | |_||_||_t|_||_||turZd|_dStjdtdd tjd kr{|dur{|dkr{tjd |d tdd ||_dS) NrrTF)r=r>rzSThe ssl_shutdown_timeout parameter is deprecated and will be removed in aiohttp 4.0rrr8 zssl_shutdown_timeout=zd is ignored on Python < 3.11; only ssl_shutdown_timeout=0 is supported. The timeout will be ignored.)superrSr,_sslr6rq _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_factoryr2_ssl_shutdown_timeoutrWrXrYrwrRuntimeWarning)rPr]r^r_r`rarbrcrrdrerrrrrrnrrfrgrhri __class__rQrRrSsZ      zTCPConnector.__init__rrrNcsNt|jD]}|qtj|d}|jD] }|||q|S)zClose all ongoing DNS calls.r) r from_iterablerrrrrlrryr)rPrr'r`tr}rQrRrs   zTCPConnector._closecs>tj|p |jdkdIdH|jr|jIdHdSdS)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)rlrr{rorn)rPrr}rQrRr"s  zTCPConnector.closecCr)zSocket family like AF_INET.)rsrVrQrQrRrb1rzTCPConnector.familycCr)z%True if local DNS caching is enabled.)rprVrQrQrRr_6rzTCPConnector.use_dns_cacherCportcCsJ|dur|dur|j||fdS|dus|durtd|jdS)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)rqrrr)rPrCrrQrQrRclear_dns_cache;s zTCPConnector.clear_dns_cacherrHc st|rd|vrt|st|d||||jdddgS|jsT|r/|D] }||IdHq$|jr6td|jj |||jdIdH}|rR|D] }| |IdHqG|S||f}||j vrz|j |sz|j |}|rx|D] }||IdHqm|S||jvr|j|}|j} || |r|D] }||IdHqz | IdHW|| n|| w|j |St|j|<}||||||} t} tjdkrtj| | d d } n| | } | s|j| | |jjz t| IdHWStj y ddd} | | w)z*Resolve host and return list of addresses.:zis not a canonical IPv4 addressr)hostnamerCrrbrflagsNzConnector is closedrbr7Trr'#asyncio.Future[list[ResolveResult]]rNcSs:tttj |WddS1swYdSr)r rerbCancelledErrorresult)r'rQrQrRdrop_exceptions "z2TCPConnector._resolve_host..drop_exception)r'rrNN)!r0r/r$rsrpsend_dns_resolvehost_startrrrnresolvesend_dns_resolvehost_endrqrKrJsend_dns_cache_hitrrrqrrr4r_resolve_host_with_throttlerbrrwrrrr0ryadd_done_callbackshieldr)rPrCrrrrhrlrfuturesfuturerrnresolved_host_taskrrQrQrR _resolve_hostDsr             zTCPConnector._resolve_hostrlrzasyncio.Future[None]c szkzK|r|D] }||IdHq|D] }||IdHq|jj|||jdIdH}|r;|D] }||IdHq0|j|||D]}t|dqDWnt yd} z |D]}t || qWd} ~ wwW|j |n|j |w|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_missrrnrrsrrqrr4rr3rrr rJ) rPrlrCrrrrrEr'erQrQrRrs0    z(TCPConnector._resolve_host_with_throttlerrrFcs@|jr||||IdH\}}|S||||IdH\}}|S)zcCreate connection. Has same keyword arguments as BaseEventLoop.create_connection. N)r_create_proxy_connection_create_direct_connection)rPrrrrrrQrQrRrs zTCPConnector._create_connectioncCsd|sdStdurtd|j}t|tjr|S|durtS|j}t|tjr*|S|dur0tStS)a*Logic 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)rr RuntimeErrorrdrO_SSL_CONTEXT_UNVERIFIEDrm_SSL_CONTEXT_VERIFIED)rPrrrQrQrR_get_ssl_contexts  zTCPConnector._get_ssl_contextr+cCs,|j}t|tr |S|j}t|tr|SdSr)rrdr+rm)rPrretrQrQrR_get_fingerprints  zTCPConnector._get_fingerprint client_errorargs addr_infosrrc s@z[t|j|jd4IdHAtj||j|j|j|j|j dIdH}| dr4|j r4t j dkr4|j |d<|jj|i|d|iIdHWdIdHWS1IdHsUwYWdStyo}zt|j||d}~wty}zt|j||d}~wty}z|jdurt|tjr||j||d}~ww)Nr)rlocal_addr_infosrfrgrnrhrrjrisock)r. sock_connectrrtstart_connectionrvrwrxrqrzrr{rwrcreate_connectionr'rrr(r!OSErrorerrnordrb TimeoutError) rPrrrrrrrrrQrQrR_wrap_create_connectionsB     4z$TCPConnector._wrap_create_connectionc sz2t|j|jd4IdH|jj|i|IdHWdIdHWS1IdHs,wYWdStyF}zt|j||d}~wtyX}zt |j||d}~wt yv}z|j durkt |t jrk||j||d}~wwNr)r.rrrqrr'rrr(r!rrrdrbr)rPrrrrrrrQrQrR_wrap_existing_connection.s&4z&TCPConnector._wrap_existing_connectionr*cCs8|sdS|j}|dusJ|jdkrdS|dS)zRaise a :py:exc:`RuntimeError` on missing ``start_tls()``. It is necessary for TLS-in-TLS so that it is possible to send HTTPS queries through HTTPS proxies. This doesn't affect regular HTTP requests, though. Nr=)rrscheme_check_loop_for_start_tls)rPr proxy_urlrQrQrR_fail_on_no_start_tlsDs   z"TCPConnector._fail_on_no_start_tlsc Cs2z|jjWdSty}ztd|d}~ww)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 )rq start_tlsAttributeErrorr)rPattr_excrQrQrRrVs z&TCPConnector._check_loop_for_start_tlscCs$z|WdStyYdSw)NFT)rrrVrQrQrR_loop_supports_start_tlsgs   z%TCPConnector._loop_supports_start_tlsunderlying_transportcCst|jjjdkr dS|jdus|jjdkrdSt|jdr dStjdkp*t |dd}|r/dSt j dt |dd dS) z6Issue a warning if the requested URL has HTTPS scheme.r=Nuvlooprj_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 r8)r}r) request_infor rrr:r] startswithrwrgetattrrWrXr|)rPrrasyncio_supports_tls_in_tlsrQrQrR_warn_about_tls_in_tlsos&   z#TCPConnector._warn_about_tls_in_tlsc sf|}||}tr|dusJzt|j|jd4IdHz7tjdkrA|jrA|j j ||||j p4|j |j p8d|jdIdH}n|j j ||||j pL|j |j pPddIdH}Wntym|jdkrh||wt|tjr||}|rz||Wnty||js|j|wWdIdHn 1IdHswYWnlty} zt|j| | d} ~ wty} zt|j| | d} ~ wty} z| j durt| tj!r||j| | d} ~ wt"y} zt#d|j d|j$d d |j%d |j&p d d | d | d} ~ ww|dur*d} ||jt| |'|||fS)z$Wrap the raw TCP transport with TLS.Nrrj)server_hostnamessl_handshake_timeoutri)rrrz2Cannot initialize a TLS-in-TLS connection to host rdz4 through an underlying connection to an HTTPS proxy z ssl:defaultz []z:Failed to start TLS (possibly caused by closing transport))(rrrr.rrrwrr{rqrrrCtotalrrrrdrbrrcheckr%rrrr'rrr(r!rrr TypeErrorrrrrconnection_made) rPrrrr tls_protor tls_transportr^rtype_errmsgrQrQrR_start_tls_connections           ()  z"TCPConnector._start_tls_connectionhostscCs|g}|D]7}|d}d|v}|rtjntj}|jr|j|krq|r)||dddfn||df}||tjtjd|fq|S)zConverts the list of hosts to a list of addr_infos. The list of hosts is the result of a DNS lookup. The list of addr_infos is the result of a call to `socket.getaddrinfo()`. rCrrrr;)socketAF_INET6AF_INETrsr SOCK_STREAM IPPROTO_TCP)rPrrhinforCis_ipv6rbaddrrQrQrR_convert_hosts_to_addr_infoss z)TCPConnector._convert_hosts_to_addr_infosc s||}||}|jj}|dusJ|dr!|dd}|j}|dus*Jz |j|||dIdH} WntyV} z| j durKt | t j rKt |j| | d} ~ wwd} || } | r|rj|jpf|dnd} z|j|j||| | ||dIdH\}}Wntt j fy} z| } t| |jWYd} ~ q^d} ~ ww|r|rz ||W||fSty} z$||js|j|| } |d}|}t | |WYd} ~ q^d} ~ ww||fS| dusJ| )Nz...)r)rrrrrrr)!rrr raw_hostendswithrstriprrrrrdrbrrrrrrrr rtpop_addr_infos_interleaverxrrr%rrrrr getpeernameremove_addr_infos)rPrrrrrr^rCrrrlast_excrrtransprrbad_peerrQrQrRr sp                z&TCPConnector._create_direct_connectioncs|||}||}|j|g|tdIdH\}}|r|r)|||tj|_ |j |_ |j j dddd}t ||||j} || IdH} zz| j} | dusUJ| j||jd| | IdH} Wntyv| | wd| _zKz6| jdkr| j} | durt| jj} t| j| j| j| | jd|s|jddd}|durtd| }Wn ty|wW|s|n|s|ww|s|!|}|j"|j#||||j$|d IdHW| S|j%|||d IdHW| S| w||fS) Nr)rr proxy_headers_hash)read_until_eofr)statusrrr)rz)Transport does not expose socket instance)rrrrr)rr)&rrrrr#rrr METH_CONNECTmethodr r_replacerrqsendrrset_response_paramsrstartrrrreasonr phraser"rhistoryrrrduprrrrCr)rPrrrruntime_has_start_tlsrrrrlr proxy_resprmresprrawsockrrQrQrRrVs             z%TCPConnector._create_proxy_connection)NNr)rr*rNNr[)?r\r]r^rr6 frozensetr7r AddressFamily AF_UNSPECr2rbytesr9rOr+rLrrrr8rbrrr-rSr,rrrrrbr_rrrrrrr*r)rrrrr rrr:rerrrrrrr BaseTransportrrrr __classcell__rQrQr}rRrCst&      $R     c   ) !  +    6  V   K rCceZdZdZeedhBZdedddfdede d e e BdBd e d e d e jdBd dffdd Zed efddZdededddd efddZZS)rDaUnix 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. unixFrrNpathrrrrrnrNcs tj|||||d||_dS)Nrrrrrn)rlrS_pathrPrrrrrrnr}rQrRrSs  zUnixConnector.__init__cCr)zPath to unix socket.rrVrQrQrRrrzUnixConnector.pathrrrHrrFc sz5t|j|jd4IdH|j|j|jIdH\}}WdIdHW|S1IdHs/wYW|StyW}z|jdurJt |t j rJt |j |j||d}~wwr)r.rrrqcreate_unix_connectionrrrrrdrbrr&rrrPrrrrrrrQrQrRrs$  z UnixConnector._create_connectionr\r]r^rr6rr7r2rrr8rr9rbrrSrrr*r,r)rrrQrQr}rRrDsD  rDcr)rEaNamed 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. npipeFrrNrrrrrrnrNcs6tj|||||dt|jtjstd||_dS)Nrz9Named Pipes only available in proactor loop under windows)rlrSrdrqrbProactorEventLooprrrr}rQrRrSs  zNamedPipeConnector.__init__cCr)zPath to the named pipe.rrVrQrQrRr rzNamedPipeConnector.pathrrrHrrFc sz:t|j|jd4IdH!|j|j|jIdH\}}tdIdHWdIdHn 1IdHs5wYWnt yZ}z|j durOt |tj rOt |j||d}~wwtt|S)Nrr)r.rrrqcreate_pipe_connectionrrrbsleeprrrdrr rrr)rrQrQrRr%s$(  z%NamedPipeConnector._create_connectionrrQrQr}rRrEsD rE)orbrr-rrwrurW collectionsrrrcollections.abcrrrr contextlibr r<r itertoolsr r r timertypesrtypingrrrrrrrtrrr;rrabcrrclient_exceptionsrrrr r!r"r#r$r%r&r'r( client_protor) client_reqrepr*r+r,r-r.r/r0r1r2r3r4logr5rer6rr:r bytearrayrrO ImportErrorr8rEMPTY_SCHEMA_SETHTTP_SCHEMA_SET WS_SCHEMA_SETHTTP_AND_EMPTY_SCHEMA_SETr6r__all__clientrFrGtracingrHrIr,rirjrrrBr;rrZrrrCrDrErQrQrQrRs     8 (          XQ0+7