8?j+HdZddlZddlZddlmZmZmZmZmZ ddl Z n#e $rZ e de dZ [ wwxYwddl m Z mZddlm ZddlmZerddl mZn ddl mZn#e ef$rdZYnwxYwejeZGd d ejZGd d ejZdS) zBTransport adapter for Asynchronous HTTP Requests based on aiohttp.N) TYPE_CHECKINGAsyncGeneratorMappingOptionalUnionzjThe aiohttp library is not installed from please install the aiohttp package to use the aiohttp transport.)_helpers exceptions)r) transport) ClientTimeoutceZdZdZdejfdZeej e j de fdZ eej e j deeeffdZej e j d de deed ffd Zej e j defd Zej e j d Zd S)Responseaz Represents an HTTP response and its data. It is returned by ``google.auth.aio.transport.sessions.AsyncAuthorizedSession``. Args: response (aiohttp.ClientResponse): An instance of aiohttp.ClientResponse. Attributes: status_code (int): The HTTP status code of the response. headers (Mapping[str, str]): The HTTP headers of the response. responsec||_dSN) _response)selfrs RC:\Projects\Historical\venv\Lib\site-packages\google/auth/aio/transport/aiohttp.py__init__zResponse.__init__8s !returnc|jjSr)rstatusrs r status_codezResponse.status_code;s~$$rcRd|jjDS)Nci|]\}}|| Sr).0keyvalues r z$Response.headers..CsLLLzsEULLLr)rheadersitemsrs rr"zResponse.headers@s*MLT^-C-I-I-K-KLLLLr chunk_sizeNcK |jj|23d{V}|WV 6dS#tj$r}t jd|d}~wwxYw)Nz'Failed to read from the payload stream.)rcontent iter_chunkedaiohttpClientPayloadErrorr ResponseError)rr%chunkexcs rr'zResponse.contentEs #~5BB         e    )   *9  s303AAAcK |jd{VS#tj$r}t jd|d}~wwxYw)Nz!Failed to read the response body.)rreadr)ClientResponseErrorr r+)rr-s rr/z Response.readQsm Y,,........ .* Y Y Y*+NOOUX X Ys#A AA c<K|jdSr)rclosers rr2zResponse.closeXs  r)r$)__name__ __module__ __qualname____doc__r)ClientResponserpropertyrcopy_docstringr r intrrstrr"rbytesr'r/r2rrrr r ,s  "!7""""XY/00%S%%%10X%XY/00Mc*MMM10XMXY/00   ~eTk7R   10 XY/00YEYYY10Y XY/0010rr c eZdZdZddeejfdZdddej fde de dee d ee e e fd e eefd ejf d Zdd ZddZdS)RequestaAsynchronous Requests request adapter. This class is used internally for making requests using aiohttp in a consistent way. If you use :class:`google.auth.aio.transport.sessions.AsyncAuthorizedSession` you do not need to construct or use this class directly. This class can be useful if you want to configure a Request callable with a custom ``aiohttp.ClientSession`` in :class:`AuthorizedSession` or if you want to manually refresh a :class:`~google.auth.aio.credentials.Credentials` instance:: import aiohttp import google.auth.aio.transport.aiohttp # Default example: request = google.auth.aio.transport.aiohttp.Request() await credentials.refresh(request) # Custom aiohttp Session Example: session = session=aiohttp.ClientSession(auto_decompress=False) request = google.auth.aio.transport.aiohttp.Request(session=session) auth_session = google.auth.aio.transport.sessions.AsyncAuthorizedSession(auth_request=request) Args: session (aiohttp.ClientSession): An instance :class:`aiohttp.ClientSession` used to make HTTP requests. If not specified, a session will be created. .. automethod:: __call__ Nsessionc"||_d|_dS)NF)_session_closed)rr?s rrzRequest.__init__{s  rGETurlmethodbodyr"timeoutrcK |jrtjd|jst j|_t |tjr|}nt j|}tj t|||||jj ||f|||d|d{V}tj t|d{Vt|S#tj$r } tjd|d} | | d} ~ wt j$rD} t |tjr|j} n|} tjd| d} | | d} ~ wwxYw) a Make an HTTP request using aiohttp. Args: url (str): The URL to be requested. method (Optional[str]): The HTTP method to use for the request. Defaults to 'GET'. body (Optional[bytes]): The payload or body in HTTP request. headers (Optional[Mapping[str, str]]): Request headers. timeout (float): The number of seconds to wait for a response from the server. If not specified or if None, the requests default timeout will be used. kwargs: Additional arguments passed through to the underlying aiohttp :meth:`aiohttp.Session.request` method. Returns: google.auth.aio.transport.Response: The HTTP response. Raises: - google.auth.exceptions.TransportError: If the request fails or if the session is closed. - google.auth.exceptions.TimeoutError: If the request times out. zsession is closed.)total)datar"rGNzFailed to send request to .zRequest timed out after z seconds.)rBr TransportErrorrAr) ClientSession isinstancer r request_log_LOGGERrequest_helpers_asyncresponse_log_asyncr ClientErrorasyncio TimeoutErrorrI) rrDrErFr"rGkwargsclient_timeoutr caught_exc client_exctimeout_seconds timeout_excs r__call__zRequest.__call__sD# .| F /0DEEE= 8 ' 5 7 7 '7#899 F!(!(!6W!E!E!E  &#tW E E E2T]2&   H!3GXFF F F F F F F FH%% %" - - -#23VPS3V3V3VWWJ* ,# . . .'7#899 *")-")$1E?EEEK: - .s$CCE)DE?EEcrK|js&|jr|jd{Vd|_dS)zY Close the underlying aiohttp session to release the acquired resources. NT)rBrAr2rs rr2z Request.closesL| (  (-%%'' ' ' ' ' ' ' ' rc >|jrtjd|js&t jdd}t |Sdt|jddd}t|jdd}|r6|js.t|tj rkt j t|d dt|d d t|d d t|ddtj ||d<nttddrot|ttdrLt|dd}|r8t j |t|d d t|dd|d<n$tjdt|t|jdd}|rt||d<dD]"\}}t|j|d}||||<#t t jdi|S)aCreates an independent copy of this request adapter. Clones the connection settings, trace configurations, and session defaults (headers, cookies, basic auth, and timeouts). Only standard `aiohttp.TCPConnector` and `aiohttp.UnixConnector` connectors are supported. The DNS resolver is not copied to avoid closing shared resolver resources. Returns: google.auth.aio.transport.aiohttp.Request: A new request adapter. Raises: google.auth.exceptions.TransportError: If the transport is closed, or if the session uses an unsupported connector. z Cannot clone a closed transport.FT)auto_decompress trust_env)r? _trust_env _connectorN_ssl_limitd_limit_per_hostr _force_close)ssllimitlimit_per_host force_close local_addr connector UnixConnector_path)pathrjrlz(Unsupported connector type for cloning: _trace_configs trace_configs))_default_headersr") _cookie_jar cookie_jar) _default_authauth)_timeoutrG)_json_serializejson_serializer)rBr rLrAr)rMr>getattrclosedrN TCPConnectorrR_get_local_addrrotypelist) r new_sessionsession_kwargsorig_connectorrqrs attr_name kwarg_namevals r_clonezRequest._clonesl" < P+,NOO O} 0!/ %K;/// / %  dCC   ! dCC  ."7 .'*>?? /6.B==!.(C@@#*>;La#P#P ' N N-=nMM ///{++/488 Z A A>> ~w==292G!%nhDD$+NNE$R$R333N;/ !/UtN?S?SUU   /?FF  B.2=.A.AN? +& 1 1 !Iz$-D99C-0z*w4FF~FFGGGGrr)rN)rr>)r3r4r5r6rr)rMrr _DEFAULT_TIMEOUT_SECONDSr;r<rrfloatr r r]r2rrrrr>r>]s :)> ? $/3/8/Q E.E. E.E.uo E. '#s(+, E. um+, E.  E.E.E.E.NNHNHNHNHNHNHrr>)r6rUloggingtypingrrrrrr) ImportErrorrY google.authrr google.auth.aiorRr r AttributeError getLoggerr3rPr r>rrrrsIHJJJJJJJJJJJJJJNNNN +t    -,,,,,,,666666%%%%%%%%%%%%%)))))))  (  ' H % %.....y!...bHHHHHiHHHHHs"5 05A A)(A)