p[iPdZddlZddlZddlmZmZmZmZmZ ddl Z ddl m Z ddl mZddlm ZddlmZerddl mZn ddl mZej(eZGd d ej.ZGd d ej0Zy#e $rZ e de dZ [ wwxYw#e ef$rdZY^wxYw) zBTransport adapter for Asynchronous HTTP Requests based on aiohttp.N)AsyncGeneratorMappingOptional TYPE_CHECKINGUnionzjThe aiohttp library is not installed from please install the aiohttp package to use the aiohttp transport.)_helpers) exceptions) transport) ClientTimeoutceZdZdZdej fdZeeje jde fdZ eeje jdeeeffdZeje jd de deedffd Zeje jdefd Zeje jd Zy) 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||_yN) _response)selfrs Z/mnt/data/GridWatch/venv/lib/python3.12/site-packages/google/auth/aio/transport/aiohttp.py__init__zResponse.__init__9s !returnc.|jjSr)rstatusrs r status_codezResponse.status_code<s~~$$$rc~|jjjDcic]\}}|| c}}Scc}}wr)rheadersitems)rkeyvalues rrzResponse.headersAs3.2^^-C-C-I-I-KLzsEU LLLs 9 chunk_sizeNcK |jjj|23d{}|7 6y#tj$r}t j d|d}~wwxYww)Nz'Failed to read from the payload stream.)rcontent iter_chunkedaiohttpClientPayloadErrorr ResponseError)rr chunkexcs rr"zResponse.contentFst #~~55BB   e   )) **9  s=A-%<:8:<:<A-A*A%%A**A-cK |jjd{S7#tj$r}t j d|d}~wwxYww)Nz!Failed to read the response body.)rreadr$ClientResponseErrorr r&)rr(s rr*z Response.readRsQ Y,,.. ..** Y**+NOUX X Ys0A(&(A(AAAAc@K|jjywr)rclosers rr-zResponse.closeYs s)i)__name__ __module__ __qualname____doc__r$ClientResponserpropertyrcopy_docstringr r intrrstrrrbytesr"r*r-rrr r -s' "!7!7"XY//0%S%1%XY//0Mc*M1MXY//0  ~eTk7R 1 XY//0YEY1Y XY//01rr c eZdZdZddeej fdZdddejfde de dee d ee e e fd e eefd ej f d Zdd Zy)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|_y)NF)_session_closed)rr;s rrzRequest.__init__|s  rGETurlmethodbodyrtimeoutrcK |jrtjd|jst j |_t |tjr|}nt j|}tjt|||||jj||f|||d|d{}tjt|d{t|S717#tj$r!} tjd|d} | | d} ~ wt j"$rJ} t |tjr |j$} n|} tj"d| d} | | d} ~ wwxYww) 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)datarrCNzFailed to send request to .zRequest timed out after z seconds.)r>r TransportErrorr=r$ ClientSession isinstancer r request_log_LOGGERrequest_helpers_asyncresponse_log_asyncr ClientErrorasyncio TimeoutErrorrE) rr@rArBrrCkwargsclient_timeoutr caught_exc client_exctimeout_seconds timeout_excs r__call__zRequest.__call__spD# .|| //0DEE== ' 5 5 7 '7#8#89!(!(!6!6W!E  &#tW E2T]]22&   H!33GXF F FH% % G"" -#225OPSuTU3VWJ* ,## .'7#8#89")--")$11*?*;9EK: - .sZFB;C5?C1!C5!C3"C50F1C53C55FD$$F:AE??FFcK|js.|jr"|jjd{d|_y7 w)zY Close the underlying aiohttp session to release the acquired resources. NT)r>r=r-rs rr-z Request.closes7|| --%%' ' '  (s6AA Ar)rN)r.r/r0r1rr$rIrr _DEFAULT_TIMEOUT_SECONDSr6r7rrfloatr r rYr-r8rrr:r:^s:)>)> ? $/3/8/Q/Q E. E.E.uo E. '#s(+, E. um+, E.   E.Nrr:)r1rQloggingtypingrrrrrr$ ImportErrorrU google.authrr google.auth.aiorNr r AttributeError getLoggerr.rLr r:r8rrrdsIJJ !"6%%) '  H %.y!!.boioO t    ( s)BBB BB B%$B%