mxi'dZddlmZddlZddlZddlmZddlmZddl Z eje Z dZ GddejZGd d ej Zd ZGd d eZy)zTransport adapter for httplib2.)absolute_importN) exceptions) transport)readseektellcFeZdZdZdZedZedZedZy) _Responsezhttplib2 transport response adapter. Args: response (httplib2.Response): The raw httplib2 response. data (bytes): The response body. c ||_||_yN) _response_data)selfresponsedatas K/home/htdocs/ttos/venv/lib/python3.12/site-packages/google_auth_httplib2.py__init__z_Response.__init__(s! c.|jjS)zint: The HTTP status code.)r statusrs rrz_Response.status,s~~$$$rc,t|jS)z-Mapping[str, str]: The HTTP response headers.)dictr rs rheadersz_Response.headers1sDNN##rc|jS)zbytes: The response body.)rrs rrz_Response.data6szzrN) __name__ __module__ __qualname____doc__rpropertyrrrrrr r sH%%$$rr c eZdZdZdZ ddZy)Requestahttplib2 request adapter. This class is used internally for making requests using various transports in a consistent way. If you use :class:`AuthorizedHttp` 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_httplib2 import httplib2 http = httplib2.Http() request = google_auth_httplib2.Request(http) credentials.refresh(request) Args: http (httplib2.Http): The underlying http object to use to make requests. c||_yr )http)rr%s rrzRequest.__init__Ss  rNc T|tjd tjd|||jj|f|||d|\}}t ||S#t jtjjf$r} tj| d} ~ wwxYw)a3Make an HTTP request using httplib2. Args: url (str): The URI to be requested. method (str): The HTTP method to use for the request. Defaults to 'GET'. body (bytes): The payload / body in HTTP request. headers (Mapping[str, str]): Request headers. timeout (Optional[int]): The number of seconds to wait for a response from the server. This is ignored by httplib2 and will issue a warning. kwargs: Additional arguments passed throught to the underlying :meth:`httplib2.Http.request` method. Returns: google.auth.transport.Response: The HTTP response. Raises: google.auth.exceptions.TransportError: If any exception occurred. Nzvhttplib2 transport does not support per-request timeout. Set the timeout when constructing the httplib2.Http instance.zMaking request: %s %s)methodbodyr) _LOGGERwarningdebugr%requestr httplib2 HttpLib2Errorclient HTTPExceptionrTransportError) rurlr'r(rtimeoutkwargsrrexcs r__call__zRequest.__call__Vs.   OOP  1 MM163 ?.TYY.."wBHNHdXt, ,&& (A(AB 1++C0 0 1sAA -B' B""B')GETNNN)rrrrrr6r!rrr#r#<s,CG&1rr#c*tjS)z)Returns a default httplib2.Http instance.)r-Httpr!rr_make_default_httpr:s ==?rcJeZdZdZdej ej fdZdZddde jdfdZ ddZ e dZejd Ze d Zejd Ze d Zejd Ze dZejdZy)AuthorizedHttpaA httplib2 HTTP class with credentials. This class is used to perform requests to API endpoints that require authorization:: from google.auth.transport._httplib2 import AuthorizedHttp authed_http = AuthorizedHttp(credentials) response = authed_http.request( 'https://www.googleapis.com/storage/v1/b') This class implements :meth:`request` in the same way as :class:`httplib2.Http` and can usually be used just like any other instance of :class:`httplib2.Http`. The underlying :meth:`request` implementation handles adding the credentials' headers to the request and refreshing credentials as needed. Nc| t}||_||_||_||_t |j|_y)a Args: credentials (google.auth.credentials.Credentials): The credentials to add to the request. http (httplib2.Http): The underlying HTTP object to use to make requests. If not specified, a :class:`httplib2.Http` instance will be constructed. 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. N)r:r% credentials_refresh_status_codes_max_refresh_attemptsr#_request)rr>r%refresh_status_codesmax_refresh_attemptss rrzAuthorizedHttp.__init__sB* <%'D &%9"%9"  * rc8|jjy)zCalls httplib2's Http.closeN)r%closers rrEzAuthorizedHttp.closes rr7c |jdd}||jni} |jj|j||| d} t fdt Drj} |jj||f| ||d|\} } | j|jvr||jkrtjd| j|dz|j|jj|j| j!| |j||f||||dzd|S| | fS) z*Implementation of httplib2's Http.request._credential_refresh_attemptrNc38K|]}t|dywr )getattr).0 stream_propr(s r z)AuthorizedHttp.request..sVKwt[$/Vs)r(r redirectionsconnection_typez;Refreshing credentials due to a %s response. Attempt %s/%s.)r(rrMrNrG)popcopyr>before_requestrAall_STREAM_PROPERTIESrr%r,rr?r@r)inforefreshr) rurir'r(rrMrNr4rGrequest_headersbody_stream_positionrcontents ` rr,zAuthorizedHttp.requestsr'-jj1NPQ&R#-4,?',,.R '' vsOT $ VCUV V#'99; .DII--   #%+   ' OOt99 9+d.H.HH LLM+a/**      $ $T]] 3$/ ./ 4<< ) /,G!,K     rcB|jj||||y)z'Proxy to httplib2.Http.add_certificate.)passwordN)r%add_certificate)rkeycertdomainr\s rr]zAuthorizedHttp.add_certificates !!#tVh!Grc.|jjS)#Proxy to httplib2.Http.connections.r% connectionsrs rrdzAuthorizedHttp.connections syy$$$rc&||j_y)rbNrcrvalues rrdzAuthorizedHttp.connectionss!& rc.|jjS)(Proxy to httplib2.Http.follow_redirects.r%follow_redirectsrs rrkzAuthorizedHttp.follow_redirectssyy)))rc&||j_y)riNrjrfs rrkzAuthorizedHttp.follow_redirectss&+ "rc.|jjS)Proxy to httplib2.Http.timeout.r%r3rs rr3zAuthorizedHttp.timeoutsyy   rc&||j_y)rnNrorfs rr3zAuthorizedHttp.timeout#s" rc.|jjS)&Proxy to httplib2.Http.redirect_codes.r%redirect_codesrs rrtzAuthorizedHttp.redirect_codes(syy'''rc&||j_y)rrNrsrfs rrtzAuthorizedHttp.redirect_codes-s$)  rr )rrrrrDEFAULT_REFRESH_STATUS_CODESDEFAULT_MAX_REFRESH_ATTEMPTSrrEr-DEFAULT_MAX_REDIRECTSr,r]r rdsetterrkr3rtr!rrr<r<s.&CC&CC +@ 33G!RH%%&&**++!! ^^""(())rr<)r __future__r http.clientr%logging google.authrrr- getLoggerrr)rTResponser r#r:objectr<r!rrrsp&&"! '  H %- ""8@1i@1F l)Vl)r