(phC SrSSKrSSKrSSKJrJrJr SSKrSSK J r SSK J r SSK J r SSK Jr \R "\5r"SS \R&5r"S S \R(5rg!\ar \"S5\ eSr C ff=f) 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\rSrSrSrS\R 4Sjr\\ R"\ R5S\ 4Sj55r\\ R"\ R5S\\\44Sj55r\ R"\ R5SS\ S\\S 44S jj5r\ R"\ R5S\4S j5r\ R"\ R5S 5rS rg )Response%a^ 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. responsecXlgN _response)selfr s T/var/www/html/venv/lib/python3.13/site-packages/google/auth/aio/transport/aiohttp.py__init__Response.__init__1s!returnc.URR$r)rstatusrs r status_codeResponse.status_code4s~~$$$rcURRR5VVs0sHupX_M snn$s snnfr)rheadersitems)rkeyvalues rrResponse.headers9s5.2^^-C-C-I-I-KL-Kzs -KLLLs: chunk_sizeNc# URRRU5ShvN nU7v MN g![Ran[ R "S5UeSnAff=f7f)Nz'Failed to read from the payload stream.)rcontent iter_chunkedaiohttpClientPayloadErrorr ResponseError)rr"chunkexcs rr$Response.content>sm #~~55BB  e   )) **9  s=A0%=;9;=;=A0A-A((A--A0c# URR5IShvN $N![Ran[R "S5UeSnAff=f7f)Nz!Failed to read the response body.)rreadr&ClientResponseErrorrr()rr*s rr- Response.readJsP Y,,.. ..** Y**+NOUX X Ys0A(&(A(AAAAc@# URR5 g7fr)rclosers rr1Response.closeQs sr)i)__name__ __module__ __qualname____firstlineno____doc__r&ClientResponserpropertyrcopy_docstringrr intrrstrrrbytesr$r-r1__static_attributes__rrr r %s "!7!7" Y//0%S%1% Y//0Mc*M1MY//0  ~eTk7R 1 Y//0YEY1Y Y//01rr c \rSrSrSrSS\R 4SjjrSSS\R4S\ S\ S \ \ S \ \ \ \ 4S \S \R4 S jjrSSjrSrg)RequestVaAsynchronous 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__ NsessioncXlSUlg)NF)_session_closed)rrCs rrRequest.__init__ts  rGETurlmethodbodyrtimeoutrc# UR(a[R"S5eUR(d[R "5Ul[R "US9n[R"[X!X45 URR"UU4UUUS.UD6IShvN n[R"[U5IShvN [U5$N2N![Ra!n [R"SUS35n XeSn A f[R a!n [R "SUS35n XeSn A ff=f7f) aW 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)datarrLNzFailed to send request to .zRequest timed out after z seconds.)rFrTransportErrorrEr& ClientSession ClientTimeoutr request_log_LOGGERrequest_helpers_asyncresponse_log_asyncr ClientErrorasyncio TimeoutError) rrIrJrKrrLkwargsclient_timeoutr caught_exc client_exc timeout_excs r__call__Request.__call__xs0D .|| //0DEE== ' 5 5 7 $22AN  &t E!]]22&   H!33GXF F FH% % G"" -#225OPSuTU3VWJ ,## .$11*7)9=K -  .sYE B'C"+C,"C"C C"E C" C""E 6DE )EE  E c# UR(d3UR(a"URR5IShvN SUlgN 7f)zI Close the underlying aiohttp session to release the acquired resources. NT)rFrEr1rs rr1 Request.closes6|| --%%' ' '  (sAAA A)rFrEr)rN)r3r4r5r6r7r&rRrr_DEFAULT_TIMEOUT_SECONDSr<rr=rfloatr rar1r>r?rrrArAVs: 5 5 $/3";; >. >.>.uo >. '#s(+, >.  >.   >.@rrA)r7rZloggingtypingrrrr& ImportErrorr^ google.authrrgoogle.auth.aiorWr getLoggerr3rUr rAr?rrrms44 !"6%   H %.y!!.bhih} t  sA//B5 A>>B