U Sd'@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||_||_dSN) _response_data)selfresponsedatar8/tmp/pip-unpacked-wheel-h6l5luug/google_auth_httplib2.py__init__(sz_Response.__init__cCs|jjS)zint: The HTTP status code.)r statusr rrrr,sz_Response.statuscCs t|jS)z-Mapping[str, str]: The HTTP response headers.)dictr rrrrheaders1sz_Response.headerscCs|jS)zbytes: The response body.)r rrrrr6sz_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 ||_dSr )http)r rrrrrUszRequest.__init__GETNc Ks|dk rtdz:td|||jj|f|||d|\}}t||WStjtj fk r} zt | W5d} ~ 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 urlrr rtimeoutkwargsrrexcrrr__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)rcloserrrrr2szAuthorizedHttp.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|dVqdSr )getattr).0Z stream_propr rr sz)AuthorizedHttp.request..)r r redirectionsconnection_typez;Refreshing credentials due to a %s response. Attempt %s/%s.)r rr8r9r3)popcopyr.Zbefore_requestr1all_STREAM_PROPERTIESrrr$rr/r0r!infoZrefreshr) r urirr rr8r9r)r3Zrequest_headersZbody_stream_positionrcontentrr6rr$sV     zAuthorizedHttp.requestcCs|jj||||ddS)z'Proxy to httplib2.Http.add_certificate.)passwordN)radd_certificate)r keycertdomainrBrrrrC szAuthorizedHttp.add_certificatecCs|jjS)#Proxy to httplib2.Http.connections.r connectionsrrrrrI szAuthorizedHttp.connectionscCs ||j_dS)rGNrHr valuerrrrIscCs|jjS)(Proxy to httplib2.Http.follow_redirects.rfollow_redirectsrrrrrNszAuthorizedHttp.follow_redirectscCs ||j_dS)rLNrMrJrrrrNscCs|jjS)Proxy to httplib2.Http.timeout.rr(rrrrr(!szAuthorizedHttp.timeoutcCs ||j_dS)rONrPrJrrrr(&scCs|jjS)&Proxy to httplib2.Http.redirect_codes.rredirect_codesrrrrrS+szAuthorizedHttp.redirect_codescCs ||j_dS)rQNrRrJrrrrS0s)N)rrrrrZDEFAULT_REFRESH_STATUS_CODESZDEFAULT_MAX_REFRESH_ATTEMPTSrr2r%ZDEFAULT_MAX_REDIRECTSr$rCrrIsetterrNr(rSrrrrr-s:  J        r-)r __future__rloggingZ google.authrrr%Z six.movesr getLoggerrr!r>Responser rr,objectr-rrrrs     E