NBh9HSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r SSKJ r SSKJ r SSK J r SSKJr \R "\5rSr"S S \ R(5r"S S \ R(5r"S S\ R.5r"SS\R05rg)zTransport adapter for Async HTTP (aiohttp). NOTE: This async support is experimental and marked internal. This surface may change in minor releases. )absolute_importN)_helpers) exceptions) transport)requestsc`\rSrSrSrSrSr\S5r\S5r \S5r Sr S r S r g ) _CombinedResponse,a In order to more closely resemble the `requests` interface, where a raw and deflated content could be accessed at once, this class lazily reads the stream in `transport.Response` so both return forms can be used. The gzip and deflate transfer-encodings are automatically decoded for you because the default parameter for autodecompress into the ClientSession is set to False, and therefore we add this class to act as a wrapper for a user to be able to access both the raw and decoded response bodies - mirroring the sync implementation. cXlSUlgN) _response _raw_contentselfresponses lC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\google/auth/transport/_aiohttp_requests.py__init___CombinedResponse.__init__9s! ctURRnSU;=(a USS:H=(d USS:H$)NContent-Encodinggzipdeflaterheaders)rrs r_is_compressed _CombinedResponse._is_compressed=sD..((!W, & '6 1 8)*i7 rc.URR$r rstatusrs rr!_CombinedResponse.statusD~~$$$rc.URR$r rr"s rr_CombinedResponse.headersH~~%%%rc.URR$r rcontentr"s rdata_CombinedResponse.dataLr'rc# URc1URRR5IShvN UlUR$N7fr )rrr*readr"s r raw_content_CombinedResponse.raw_contentPsA    $&*nn&<&<&A&A&C CD    !Ds5AA Ac&# UR5IShvN UR5(aS[RR UR R S5nURUR5nU$UR$Nx7f)Nr) r/rurllib3r MultiDecoderrr decompressr)rdecoder decompresseds rr*_CombinedResponse.contentUs~      &&33&&'9:G#--d.?.?@L     !sBBA9B)rrN)__name__ __module__ __qualname____firstlineno____doc__rrpropertyr!rr+r/r*__static_attributes__rrr r ,sW ! %%&&&&! !rr cN\rSrSrSrSr\S5r\S5r\S5r Sr g) _Responsebzj Requests transport response adapter. Args: response (requests.Response): The raw Requests response. cXlgr rrs rr_Response.__init__js!rc.URR$r r r"s rr!_Response.statusmr$rc.URR$r rr"s rr_Response.headersqr'rc.URR$r r)r"s rr+_Response.dataur'rrDN) r8r9r:r;r<rr=r!rr+r>r?rrrArAbsH"%%&&&&rrAc4\rSrSrSrSSjrSSS\4SjrSrg) RequestzaRequests request adapter. This class is used internally for making requests using asyncio transports in a consistent way. If you use :class:`AuthorizedSession` you do not need to construct or use this class directly. This class can be useful if you want to manually refresh a :class:`~google.auth.credentials.Credentials` instance:: import google.auth.transport.aiohttp_requests request = google.auth.transport.aiohttp_requests.Request() credentials.refresh(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__ NcdUb'UR(a[R"S5eXlg)Nzr?rrrMrMzs,  3*rrMc|^\rSrSrSr\R \RSSS4U4SjjrSSS\ S4U4Sjjr Sr U=r $)AuthorizedSessionaThis is an async implementation of the Authorized Session class. We utilize an aiohttp transport instance, and the interface mirrors the google.auth.transport.requests Authorized Session class, except for the change in the transport used in the async use case. A Requests Session class with credentials. This class is used to perform requests to API endpoints that require authorization:: from google.auth.transport import aiohttp_requests async with aiohttp_requests.AuthorizedSession(credentials) as authed_session: response = await authed_session.request( 'GET', 'https://www.googleapis.com/storage/v1/b') The underlying :meth:`request` implementation handles adding the credentials' headers to the request and refreshing credentials as needed. Args: credentials (google.auth._credentials_async.Credentials): The credentials to add to the request. refresh_status_codes (Sequence[int]): Which HTTP status codes indicate that credentials should be refreshed and the request should be retried. max_refresh_attempts (int): The maximum number of times to attempt to refresh the credentials and retry the request. refresh_timeout (Optional[int]): The timeout value in seconds for credential refresh HTTP requests. auth_request (google.auth.transport.aiohttp_requests.Request): (Optional) An instance of :class:`~google.auth.transport.aiohttp_requests.Request` used when refreshing credentials. If not passed, an instance of :class:`~google.auth.transport.aiohttp_requests.Request` is created. kwargs: Additional arguments passed through to the underlying ClientSession :meth:`aiohttp.ClientSession` object. NFc >[[U] "S0UD6 XlX lX0lX@lSUlXPlSUl [R"5Ul [R"5UlX`lg)NFr?)superrnr credentials_refresh_status_codes_max_refresh_attempts_refresh_timeout_is_mtls _auth_request_auth_request_sessionrbget_event_loop_loopLock _refresh_lockrP) rrrrefresh_status_codesmax_refresh_attemptsrefresh_timeout auth_requestrVrg __class__s rrAuthorizedSession.__init__si /9&9&%9"%9" / )%)"++- $\\^ /rc :># U(aBUR5H.n [XI5[LdMXIRS5XI'M0 [R "UR URSS5S9IShvN Ul[UR5n Xl URSS5n UbUR5O0n Uc URO[R"URUS9n Un [R "U ["R$5nUR&R)XX,5IShvN SSS5 [R "U ["R$5n[*[,U]^"UU4UU US .UD6IShvN nSSS5 WR0n WR2UR4;GaEXR6:Ga5[R8R;S UR2U S -UR65 Uc URO[R"URUS9n [R "U ["R$5nUR<IShvN UR>RASUR&RBU 5IShvN SSS5IShvN SSS5 UR0n UR."UU4UUU UU S -S .UD6IShvN sSSS5IShvN $SSS5IShvN U$GNGN!,(df  GN=fGN!,(df  GN=fNNN!,IShvN (df  N=f!,(df  N=fNNwNh!,IShvN (df  W$=f7f) a*Implementation of Authorized Session aiohttp request. Args: method (str): The http request method used (e.g. GET, PUT, DELETE) url (str): The url at which the http request is sent. data (Optional[dict]): Dictionary, list of tuples, bytes, or file-like object to send in the body of the Request. headers (Optional[dict]): Dictionary of HTTP Headers to send with the Request. timeout (Optional[Union[float, aiohttp.ClientTimeout]]): The amount of time in seconds to wait for the server response with each individual request. Can also be passed as an ``aiohttp.ClientTimeout`` object. max_allowed_time (Optional[float]): If the method runs longer than this, a ``Timeout`` exception is automatically raised. Unlike the ``timeout`` parameter, this value applies to the total method execution time, even if multiple requests are made under the hood. Mind that it is not guaranteed that the timeout error is raised at ``max_allowed_time``. It might take longer, for example, if an underlying request takes a lot of time, but the request itself does not timeout, e.g. if a large file is being transmitted. The timout error will be raised after such request completes. zutf-8 trust_envF)rVrN_credential_refresh_attemptr)rXrWz;Refreshing credentials due to a %s response. Attempt %s/%s.)r+rmax_allowed_timerXr)"keystypebytesdecoderYrZrPgetrxrMrwpopcopy functoolspartialr TimeoutGuardrbrcrrbefore_requestrqrnr]remaining_timeoutr!rsrtr\infor|rzrun_in_executorrefresh)rrerdr+rrrXrVrgkeyrrrequest_headersremaining_timeguardrrs rr]AuthorizedSession.request sGV ||~ %.#*<#6#6w#?GL&(( 11jje4   '"4#=#=>L!- +1**5RTU*V '180CgllnO ?""&&t'9'97K  .N&&~w7K7KLPU&&55 #M &&~w7K7KLPU!&'8$!G"+# "  "M#44N4#=#==/2L2LL  %%QOO/!3.. &&"**4+=+=wO **"G$8$8#111"jj88 $"2"2":":L 21"'!8!8!\\ #%3#0Ka0O   O     de 2ML MLF 2 2111 O    ds3-NA NLNBN! L"LL"-N3L7L4L7C N!M)2M 3M)65M+M ,M0 M);M <M)4N4M:5N8 NM<NM>NL"" L1 ,N4L77 M N M) M M)M& M M& "M)) M7 3N<N>NNN  NN) rwrxrPrvrzrtr|rsrurr) r8r9r:r;r<rDEFAULT_REFRESH_STATUS_CODESDEFAULT_MAX_REFRESH_ATTEMPTSrrlr]r> __classcell__)rs@rrnrnsH$R'CC&CC04 BBrrn)r< __future__rrbrloggingrYr2 google.authrrrgoogle.auth.aior^google.auth.transportr getLoggerr8r\rlResponser rArMrZrnr?rrrs ' "!6*   H %3! **3!l& ""&0R*iR*j--r