U #FZhC @sdZddlZddlZddlmZmZmZz ddlZWn,ek r`Z zede W5dZ [ XYnXddl m Z ddl m Z ddl m Zddl mZeeZGdd d ejZGd d d ejZdS) 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@seZdZdZejdddZee e j e dddZ ee e j eeefddd Ze e j de eed fd d dZe e j edddZe 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 h/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/google/auth/aio/transport/aiohttp.py__init__1szResponse.__init__returncCs|jjSr )r statusr r r r status_code4szResponse.status_codecCsdd|jjDS)NcSsi|]\}}||qSr r ).0keyvaluer r r <sz$Response.headers..)r headersitemsrr r rr9szResponse.headersN) chunk_sizerc Cs^z(|jj|2z3dHW}|Vq6Wn0tjk rX}ztd|W5d}~XYnXdS)Nz'Failed to read from the payload stream.)r contentZ iter_chunkedaiohttpZClientPayloadErrorr ResponseError)r rchunkexcr r rr>szResponse.contentc sHz|jIdHWStjk rB}ztd|W5d}~XYnXdS)Nz!Failed to read the response body.)r readrZClientResponseErrorrr)r r!r r rr"Jsz Response.readcs|jdSr )r closerr r rr#QszResponse.close)r)__name__ __module__ __qualname____doc__rZClientResponserpropertyrZcopy_docstringrrintrrstrrrbytesrr"r#r r r rr%s      rc@sfeZdZdZd ejdddZdddejfe e e e e e e e fe ejddd Zdd d d ZdS)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__ N)sessioncCs||_d|_dS)NF)_session_closed)r r-r r rrtszRequest.__init__GET)urlmethodbodyrtimeoutrc sz~|jrtd|js"t|_tj|d}tt |||||jj ||f|||d|IdH}t t |IdHt |WStjk r} ztd|d} | | W5d} ~ XYn<tjk r} ztd|d} | | W5d} ~ XYnXdS) 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)datarr4NzFailed to send request to .zRequest timed out after z seconds.)r/rZTransportErrorr.r ClientSessionZ ClientTimeoutrZ request_log_LOGGERrequest_helpers_asyncZresponse_log_asyncrZ ClientErrorasyncio TimeoutError) r r1r2r3rr4kwargsZclient_timeoutr caught_excZ client_excZ timeout_excr r r__call__xs6"      zRequest.__call__rcs&|js|jr|jIdHd|_dS)zY Close the underlying aiohttp session to release the acquired resources. NT)r/r.r#rr r rr#s z Request.close)N)r$r%r&r'rr8rrZ_DEFAULT_TIMEOUT_SECONDSr*rr+rfloatrr@r#r r r rr,Vs @r,)r'r<loggingtypingrrrr ImportErrorr?Z google.authrrZgoogle.auth.aior;r getLoggerr$r9rr,r r r rs$      1