8 iCdZddlZddlZddlmZmZmZ ddlZn#e$rZ ede dZ [ wwxYwddl m Z ddl m Z ddl m Zddl mZejeZGdd ejZGd 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) transportceZdZdZdejfdZeej 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)selfr s Y/srv/django_bis/venv311/lib/python3.11/site-packages/google/auth/aio/transport/aiohttp.py__init__zResponse.__init__1s !returnc|jjSr )rstatusrs r status_codezResponse.status_code4s~$$rcRd|jjDS)Nci|]\}}|| Sr).0keyvalues r z$Response.headers..<sLLLzsEULLLr)rheadersitemsrs rrzResponse.headers9s*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.content>s #~5BB         e    )   *9  s303AAAcK |jd{VS#tj$r}t jd|d}~wwxYw)Nz!Failed to read the response body.)rreadr&ClientResponseErrorrr()rr*s rr,z Response.readJsm Y,,........ .* Y Y Y*+NOOUX X Ys#A AA c<K|jdSr )rclosers rr/zResponse.closeQs  r)r!)__name__ __module__ __qualname____doc__r&ClientResponserpropertyrcopy_docstringrr intrrstrrrbytesr$r,r/rrrr r %s  "!7""""XY/00%S%%%10X%XY/00Mc*MMM10XMXY/00   ~eTk7R   10 XY/00YEYYY10Y XY/0010rr c eZdZdZddejfdZdddejfde de de e d e e e e fd e d ejf d Zdd 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__ Nsessionc"||_d|_dS)NF)_session_closed)rr<s rrzRequest.__init__ts  rGETurlmethodbodyrtimeoutrc8K |jrtjd|jst j|_t j|}tjt|||||jj ||f|||d|d{V}tj t|d{Vt|S#tj$r } tjd|d} | | d} ~ wtj$r } 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)datarrDNzFailed to send request to .zRequest timed out after z seconds.)r?rTransportErrorr>r& ClientSession ClientTimeoutr request_log_LOGGERrequest_helpers_asyncresponse_log_asyncr ClientErrorasyncio TimeoutError) rrArBrCrrDkwargsclient_timeoutr caught_exc client_exc timeout_excs r__call__zRequest.__call__xsD .| F /0DEEE= 8 ' 5 7 7 $2AAAN  &#tW E E E2T]2&   H!3GXFF F F F F F F FH%% %" - - -#23VPS3V3V3VWWJ* ,# . . .$1=7===K: -  .s$B8B==D C''D9DDcrK|js&|jr|jd{Vd|_dS)zY Close the underlying aiohttp session to release the acquired resources. NT)r?r>r/rs rr/z Request.closesL| (  (-%%'' ' ' ' ' ' ' ' rr )rN)r0r1r2r3r&rJrr_DEFAULT_TIMEOUT_SECONDSr8rr9rfloatr rYr/rrrr;r;Vs: 5 $/3"; >.>. >.>.uo >. '#s(+, >.  >.  >.>.>.>.@rr;)r3rRloggingtypingrrrr& ImportErrorrV google.authrrgoogle.auth.aiorOr getLoggerr0rMr r;rrrrcsU4444444444NNNN +t    ! """"""666666%%%%%% ' H % %.....y!...bhhhhhihhhhhs1 ,1