B |b'@sdZddlmZddlZddlmZddlmZddlZddlm Z e e Z dZ Gdd d ejZGd d d ejZd d ZGdddeZdS)zTransport adapter for httplib2.)absolute_importN) exceptions) transport) http_client)readseektellc@s<eZdZdZddZeddZeddZedd Zd S) _Responsezhttplib2 transport response adapter. Args: response (httplib2.Response): The raw httplib2 response. data (bytes): The response body. cCs||_||_dS)N) _response_data)selfresponsedatarW/home/ankuromar296_gmail_com/.local/lib/python3.7/site-packages/google_auth_httplib2.py__init__(sz_Response.__init__cCs|jjS)zint: The HTTP status code.)r status)r rrrr,sz_Response.statuscCs t|jS)z-Mapping[str, str]: The HTTP response headers.)dictr )r rrrheaders1sz_Response.headerscCs|jS)zbytes: The response body.)r )r rrrr6sz_Response.dataN) __name__ __module__ __qualname____doc__rpropertyrrrrrrrr s   r c@s"eZdZdZddZdddZdS) 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. .. automethod:: __call__ cCs ||_dS)N)http)r rrrrrUszRequest.__init__GETNc Ks|dk rtdy8td|||jj|f|||d|\}}t||Stjtj fk r~} zt | Wdd} ~ XYnXdS)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) _LOGGERwarningdebugrrequestr httplib2Z HttpLib2Errorr HTTPExceptionrZTransportError) r urlrrrtimeoutkwargsr rexcrrr__call__Xs zRequest.__call__)rNNN)rrrrrr)rrrrr<srcCstS)z)Returns a default httplib2.Http instance.)r#ZHttprrrr_make_default_httpsr*c@seZdZdZdejejfddZddZddde j dfdd Z dd d Z e d d Zejdd Ze ddZejddZe ddZejddZe ddZejddZdS)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. NcCs6|dkrt}||_||_||_||_t|j|_dS)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)r r,rZrefresh_status_codesZmax_refresh_attemptsrrrrszAuthorizedHttp.__init__cCs|jdS)zCalls httplib2's Http.closeN)rclose)r rrrr0szAuthorizedHttp.closerc  s|dd}|dk r|ni} |j|j||| d} tfddtDrV} |jj ||f| ||d|\} } | j |j kr||j krt d| j |d|j |j|j| dk rȈ| |j ||f||||dd |S| | fS) z*Implementation of httplib2's Http.request._credential_refresh_attemptrNc3s|]}t|dVqdS)N)getattr).0Z stream_prop)rrr sz)AuthorizedHttp.request..)rr redirectionsconnection_typez;Refreshing credentials due to a %s response. Attempt %s/%s.)rrr5r6r1)popcopyr,Zbefore_requestr/all_STREAM_PROPERTIESrrr"rr-r.rinforefreshr) r urirrrr5r6r'r1Zrequest_headersZbody_stream_positionr contentr)rrr"sD     zAuthorizedHttp.requestcCs|jj||||ddS)z'Proxy to httplib2.Http.add_certificate.)passwordN)radd_certificate)r keycertdomainr@rrrrA szAuthorizedHttp.add_certificatecCs|jjS)z#Proxy to httplib2.Http.connections.)r connections)r rrrrE szAuthorizedHttp.connectionscCs ||j_dS)z#Proxy to httplib2.Http.connections.N)rrE)r valuerrrrEscCs|jjS)z(Proxy to httplib2.Http.follow_redirects.)rfollow_redirects)r rrrrGszAuthorizedHttp.follow_redirectscCs ||j_dS)z(Proxy to httplib2.Http.follow_redirects.N)rrG)r rFrrrrGscCs|jjS)zProxy to httplib2.Http.timeout.)rr&)r rrrr&!szAuthorizedHttp.timeoutcCs ||j_dS)zProxy to httplib2.Http.timeout.N)rr&)r rFrrrr&&scCs|jjS)z&Proxy to httplib2.Http.redirect_codes.)rredirect_codes)r rrrrH+szAuthorizedHttp.redirect_codescCs ||j_dS)z&Proxy to httplib2.Http.redirect_codes.N)rrH)r rFrrrrH0s)N)rrrrrZDEFAULT_REFRESH_STATUS_CODESZDEFAULT_MAX_REFRESH_ATTEMPTSrr0r#ZDEFAULT_MAX_REDIRECTSr"rArrEsetterrGr&rHrrrrr+s& C     r+)r __future__rloggingZ google.authrrr# six.movesr getLoggerrrr;Responser rr*objectr+rrrrs     E