OjaSrSSKJr SSKrSSKJr SSKrSSKrSSK r SSK J r SSK r SSKr SSKr SSKJr SSKJr SSKJr SS KJr SS KJr SSKrSS KJr \R:"\5rS r "S S\RB5r""SS\#5r$"SS\RJ5r%"SS\ RLRN5r("SS\ RLRN5r)"SS\ RT5r+g!\ ar\ "S5\eSrCff=f)zTransport adapter for Requests.)absolute_importN)OptionalzmThe requests library is not installed from please install the requests package to use the requests transport.)create_urllib3_context)_helpers) exceptions) transport) _mtls_helper)service_accountxcN\rSrSrSrSr\S5r\S5r\S5r Sr g) _Response2ziRequests transport response adapter. Args: response (requests.Response): The raw Requests response. cXlgN _response)selfresponses `/var/www/html/leaf-doctor-v1/venv/lib/python3.13/site-packages/google/auth/transport/requests.py__init___Response.__init__9s!c.URR$r)r status_coders rstatus_Response.status<s~~)))rc.URR$r)rheadersrs rr_Response.headers@~~%%%rc.URR$r)rcontentrs rdata_Response.dataDr!rrN) __name__ __module__ __qualname____firstlineno____doc__rpropertyrrr$__static_attributes__rrr r 2sH "**&&&&rr cX\rSrSrSr\R R4SjrSr Sr Sr g) TimeoutGuardIa-A context manager raising an error if the suite execution took too long. Args: timeout (Union[None, Union[float, Tuple[float, float]]]): The maximum number of seconds a suite can run without the context manager raising a timeout exception on exit. If passed as a tuple, the smaller of the values is taken as a timeout. If ``None``, a timeout error is never raised. timeout_error_type (Optional[Exception]): The type of the error to raise on timeout. Defaults to :class:`requests.exceptions.Timeout`. c(XlXlX lgr)_timeoutremaining_timeout_timeout_error_type)rtimeouttimeout_error_types rrTimeoutGuard.__init__Ws !(#5 rc:[R"5UlU$r)time_startrs r __enter__TimeoutGuard.__enter__\siik  rc^U(agURcg[R"5UR- mSn[UR[R 5(a$URT- UlUR S:*nO<[U4SjUR55Ul[UR 5S:*nU(aUR5eg)NFrc3,># UH oT- v M g7frr-).0xelapseds r (TimeoutGuard.__exit__..ns*N 1w; s) r2r9r: isinstancenumbersNumberr3tupleminr4)rexc_type exc_value traceback deadline_hitrAs @r__exit__TimeoutGuard.__exit__`s   == ))+ + dmmW^^ 4 4%)]]W%SSKnSSKn[5nURUR 5S9 [5nURUR 5S9 [ R "X5unnn [U [5(aU RS5OU n URUUU S9 URUUU S9 SSS5 XPlX`l[*[,U]_5 g!,(df  N-=f!UR[[[[[ 4an ["R$"S5U eSn A ff=f)Nrcafilezutf-8)certfilekeyfilepasswordz8Failed to configure client certificate and key for mTLS.)certifisslrload_verify_locationswherer secure_cert_key_pathsrDbytesdecodeload_cert_chainSSLErrorOSErrorIOError ValueError RuntimeErrorr\rMutualTLSChannelError_ctx_poolmanager_ctx_proxymanagersuperrrr) rcertkeyrzr{ctx_poolmanagerctx_proxymanager cert_pathkey_path passphraseryexc __class__s rr_MutualTlsAdapter.__init__s=02--W]]_-E13..gmmo.F 33D>C"*e44%%g.#  //&$%0 !00&$%1?@!0!1 /1G?>* LL       22J  s7C6/AC%>C6% C3/C63C66*D< D77D<cL>URUS'[[U]"U0UD6 gN ssl_context)rrrrinit_poolmanagerrargsrkrs rr"_MutualTlsAdapter.init_poolmanagers( $ 5 5} 7HHrcJ>URUS'[[U]"U0UD6$r)rrrrproxy_manager_forrs rr#_MutualTlsAdapter.proxy_manager_fors+ $ 6 6}&?PPPr)rr r&r'r(r)r*rrrr, __classcell__rs@rrrrrs  .2`IQQrrrcD^\rSrSrSrU4SjrU4SjrU4SjrSrU=r $)_MutualTlsOffloadAdapteri aF A TransportAdapter that enables mutual TLS and offloads the client side signing operation to the signing library. Args: enterprise_cert_file_path (str): the path to a enterprise cert JSON file. The file should contain the following field: { "libs": { "signer_library": "...", "offload_library": "..." } } Raises: ImportError: if certifi is not installed google.auth.exceptions.MutualTLSChannelError: If mutual TLS channel creation failed for any reason. c>SSKnSSKJn URU5UlURR 5 [ 5nURUR5S9 URRU5 X@l [ 5nURUR5S9 URRU5 XPl [[U];5 g)Nr)_custom_tls_signerru)rzgoogle.auth.transportrCustomTlsSignersignerload_librariesrr|r}attach_to_ssl_contextrrrrr)renterprise_cert_file_pathrzr poolmanager proxymanagerrs rr!_MutualTlsOffloadAdapter.__init__"s<(889RS  ""$,. )))A ))+6 +-/ **'--/*B )),7!- &68rcL>URUS'[[U]"U0UD6 gr)rrrrrs rr)_MutualTlsOffloadAdapter.init_poolmanager5s( $ 5 5} &>OOrcJ>URUS'[[U]"U0UD6$r)rrrrrs rr*_MutualTlsOffloadAdapter.proxy_manager_for9s, $ 6 6}-tFWPVWWr)rrrrrs@rrr s*9&PXXrrc^\rSrSrSr\R \RSSS4U4SjjrS Sjr SSS\ 4U4Sjjr \ S5r U4SjrS rU=r$) AuthorizedSessioni>a A Requests Session class with credentials. This class is used to perform requests to API endpoints that require authorization:: from google.auth.transport.requests import AuthorizedSession authed_session = AuthorizedSession(credentials) response = 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. This class also supports mutual TLS via :meth:`configure_mtls_channel` method. In order to use this method, the `GOOGLE_API_USE_CLIENT_CERTIFICATE` environment variable must be explicitly set to ``true``, otherwise it does nothing. Assume the environment is set to ``true``, the method behaves in the following manner: If client_cert_callback is provided, client certificate and private key are loaded using the callback; if client_cert_callback is None, application default SSL credentials will be used. Exceptions are raised if there are problems with the certificate, private key, or the loading process, so it should be called within a try/except block. First we set the environment variable to ``true``, then create an :class:`AuthorizedSession` instance and specify the endpoints:: regular_endpoint = 'https://pubsub.googleapis.com/v1/projects/{my_project_id}/topics' mtls_endpoint = 'https://pubsub.mtls.googleapis.com/v1/projects/{my_project_id}/topics' authed_session = AuthorizedSession(credentials) Now we can pass a callback to :meth:`configure_mtls_channel`:: def my_cert_callback(): # some code to load client cert bytes and private key bytes, both in # PEM format. some_code_to_load_client_cert_and_key() if loaded: return cert, key raise MyClientCertFailureException() # Always call configure_mtls_channel within a try/except block. try: authed_session.configure_mtls_channel(my_cert_callback) except: # handle exceptions. if authed_session.is_mtls: response = authed_session.request('GET', mtls_endpoint) else: response = authed_session.request('GET', regular_endpoint) You can alternatively use application default SSL credentials like this:: try: authed_session.configure_mtls_channel() except: # handle exceptions. Args: credentials (google.auth.credentials.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.requests.Request): (Optional) An instance of :class:`~google.auth.transport.requests.Request` used when refreshing credentials. If not passed, an instance of :class:`~google.auth.transport.requests.Request` is created. default_host (Optional[str]): A host like "pubsub.googleapis.com". This is used when a self-signed JWT is created from service account credentials. NcH>[[U] 5 XlX lX0lX@lSUlX`lUci[R"5Ul [RRSS9nURRSU5 [UR5nOSUl XPl[#UR[$R&5(aHURR)UR(aSR+UR5OS5 gg)NF) max_retrieshttps://z https://{}/)rrr credentials_refresh_status_codes_max_refresh_attempts_refresh_timeout_is_mtls _default_hostrOrW_auth_request_sessionadapters HTTPAdaptermountrR _auth_requestrDr Credentials_create_self_signed_jwtformat) rrrefresh_status_codesmax_refresh_attemptsrefresh_timeout auth_request default_host retry_adapterrs rrAuthorizedSession.__init__s /1&%9"%9" / )  )1)9)9);D & %--99a9HM  & & , ,Z G#4#=#=>L)-D &* d&&(C(C D D    4 4<@^^URSS5nUbUR5O0n Uc URO[R"URUS9n Un [ U 5n UR RXX)5 SSS5 W Rn [ U 5n [R"[XX45 [[U]:"UU4UU US.UD6n SSS5 U Rn W RUR ;Ga`XR":GaPU R[$R&:Xa}UR((al[*R,"UR.5ummnnX:wa-[R1S5 UR3UU4Sj5 O[R1S 5 [R1S U RUS -UR"5 Uc URO[R"URUS9n [ U 5n UR R=U 5 SSS5 U Rn UR"UU4UUU UUS -S .UD6$U $!,(df  GN=f!,(df  GN=f![4a2n[R7SU5 [8R:"S 5UeSnAff=f!,(df  N=f)aImplementation of Requests' request. Args: timeout (Optional[Union[float, Tuple[float, float]]]): The amount of time in seconds to wait for the server response with each individual request. Can also be passed as a tuple ``(connect_timeout, read_timeout)``. See :meth:`requests.Session.request` documentation for details. 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 timeout error will be raised after such request completes. Raises: google.auth.exceptions.MutualTLSChannelError: If mutual TLS channel creation fails for any reason. ValueError: If the client certificate is invalid. _credential_refresh_attemptrN)r5raz;Client certificate has changed, reconfiguring mTLS channel.c >TT4$rr-)call_cert_bytescall_key_bytessr+AuthorizedSession.request..\s .(Irz&Failed to reconfigure mTLS channel: %sz"Failed to reconfigure mTLS channelzXSkipping reconfiguration of mTLS channel because the client certificate has not changed.z;Refreshing credentials due to a %s response. Attempt %s/%s.)r$rmax_allowed_timer5r)popcopyr functoolspartialr/rbefore_requestr3rrbrcrrrdrrr http_client UNAUTHORIZEDrr *check_parameters_for_unauthorized_responserinfor Exceptionerrorrrrefresh)rrirhr$rrr5rkrrequest_headersrremaining_timeguardrcached_fingerprintcurrent_cert_fingerprinterrrs @@rrdAuthorizedSession.requestsT'-jj1NPQ&R#-4,?',,.R    ""4#5#5wG  * . )U    + +L# W*00 . )U  &t E.='   H*00  D$>$> >+.H.HH##{'?'??<< %OO)) '&*0*E %#LL!+!77 I < LLM$$+a/**  ?""&&t'9'97K  n-  ((6."44N<< !/,G!,K   o* )* )R )%#MM*RTUV","B"B D##$%%2.-s<&I*"7I<2+JK * I9< J  K -KK  KcUR$)z3Indicates if the created SSL channel is mutual TLS.)rrs rrAuthorizedSession.is_mtlss}}rcx>URbURR5 [[U]5 gr)rr[rr)rrs rr[AuthorizedSession.closes/  % % 1  & & , , . ,.r) rrrrrrrrrr)r&r'r(r)r*rDEFAULT_REFRESH_STATUS_CODESDEFAULT_MAX_REFRESH_ATTEMPTSrrrprdr+rr[r,rrs@rrr>sfTr'CC&CC)V5&v Qf//rr),r* __future__rr http.clientclientrloggingrEr9typingrrOrrlrequests.adaptersrequests.exceptions#requests.packages.urllib3.util.ssl_r google.authrrrrr "google.auth.transport._mtls_helperr google.oauth2r getLoggerr&rcrpResponser objectr/rRrrrrrrWrr-rrr s&&!  !"!.))   H %& ""&.)-6)-XN*iN*bCQ))55CQL/Xx00<</XdT/((T/E  w  sC77D = DD