o BvgI @sdZddlZddlmZmZmZzddlZWney'ZzededZ[wwddl m Z ddl m Z ddl m Z Gdd d e jZGd d d e jZdS) zCTransport adapter for Asynchronous HTTP Requests based on aiohttp. N)AsyncGeneratorMappingOptionalzjThe aiohttp library is not installed from please install the aiohttp package to use the aiohttp transport.)_helpers) exceptions) transportc@seZdZdZdejfddZee e j de fddZ ee e j deeeffdd Ze e j dd e deed ffd dZe e j defddZe e j ddZd 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. responsecCs ||_dSN) _response)selfr r ^/var/www/html/portfolio/venv/lib/python3.10/site-packages/google/auth/aio/transport/aiohttp.py__init__-s zResponse.__init__returncCs|jjSr )r statusr r r r status_code0szResponse.status_codecCsdd|jjDS)NcSsi|]\}}||qSr r ).0keyvaluer r r 8sz$Response.headers..)r headersitemsrr r rr5szResponse.headers chunk_sizeNc CsTz|jj|2z 3dHW}|Vq 6WdStjy)}ztd|d}~ww)Nz'Failed to read from the payload stream.)r content iter_chunkedaiohttpClientPayloadErrorr ResponseError)r rchunkexcr r rr:szResponse.contentc s<z |jIdHWStjy}ztd|d}~ww)Nz!Failed to read the response body.)r readrClientResponseErrorrr )r r"r r rr#Fs z Response.readcs|jdSr )r closerr r rr%MszResponse.close)r)__name__ __module__ __qualname____doc__rClientResponserpropertyrcopy_docstringrrintrrstrrrbytesrr#r%r r r rr!s      rc @sleZdZdZddejfddZdddejfde de d e e d e e e e fd e d ejf d dZdddZdS)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_sesion = 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__ NsessioncCs||_d|_dS)NF)_session_closed)r r1r r rrps zRequest.__init__GETurlmethodbodyrtimeoutrc sz-|jr td|jst|_tj|d}|jj||f|||d|IdH}t|WStj yG} z td|d} | | d} ~ wt j y_} z t d|d} | | d} ~ ww) 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)datarr8NzFailed to send request to .zRequest timed out after z seconds.) r3rTransportErrorr2r ClientSession ClientTimeoutrequestr ClientErrorasyncio TimeoutError) r r5r6r7rr8kwargsclient_timeoutr caught_exc client_exc timeout_excr r r__call__ts:"     zRequest.__call__cs(|js|jr|jIdHd|_dS)zY Close the underlying aiohttp session to release the acquired resources. NT)r3r2r%rr r rr%s  z Request.closer )rN)r&r'r(r)rr=rr_DEFAULT_TIMEOUT_SECONDSr.rr/rfloatrrHr%r r r rr0Rs* >r0)r)rAtypingrrrr ImportErrorrE google.authrrgoogle.auth.aiorrr0r r r rs$    1