o ޭj'@sdZddlmZddlZddlZddlmZmZddl Z e e Z dZ GdddejZGdd d ejZd d ZGd d d eZdS)zTransport adapter for httplib2.)absolute_importN) exceptions transport)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)selfresponsedatarQ/var/www/html/CropPilot/venv/lib/python3.10/site-packages/google_auth_httplib2.py__init__&s z_Response.__init__cC|jjS)zint: The HTTP status code.)r statusr rrrr*z_Response.statuscCs t|jS)z-Mapping[str, str]: The HTTP response headers.)dictr rrrrheaders/s z_Response.headerscCs|jS)zbytes: The response body.)r rrrrr4sz_Response.dataN) __name__ __module__ __qualname____doc__rpropertyrrrrrrrrs  rc@s$eZdZdZddZ dddZdS) 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. cCs ||_dSr )http)r rrrrrQs zRequest.__init__GETNc Ksz|dur tdztd|||jj|f|||d|\}}t||WStjtjj fy<} zt | d} ~ ww)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) _LOGGERwarningdebugrrequestrhttplib2 HttpLib2Errorclient HTTPExceptionrTransportError) r urlr r!rtimeoutkwargsr rexcrrr__call__Ts$  zRequest.__call__)rNNN)rrrrrr/rrrrr:s rcCstS)z)Returns a default httplib2.Http instance.)r&Httprrrr_make_default_http}sr1c@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|durt}||_||_||_||_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)r1r credentials_refresh_status_codes_max_refresh_attemptsr_request)r r3rrefresh_status_codesmax_refresh_attemptsrrrrszAuthorizedHttp.__init__cCs|jdS)zCalls httplib2's Http.closeN)rcloserrrrr9szAuthorizedHttp.closerc  s|dd}|dur|ni} |j|j||| d} tfddtDr+} |jj ||f| ||d|\} } | j |j vrv||j krvt d| j |d|j |j|j| durd| |j ||f||||dd |S| | fS) z*Implementation of httplib2's Http.request._credential_refresh_attemptrNc3s|] }t|dVqdSr )getattr).0 stream_propr!rr sz)AuthorizedHttp.request..)r!r redirectionsconnection_typez;Refreshing credentials due to a %s response. Attempt %s/%s.)r!rr@rAr:)popcopyr3before_requestr6all_STREAM_PROPERTIESrrr%rr4r5r"inforefreshr) r urir r!rr@rAr-r:request_headersbody_stream_positionr contentrr>rr%sR     zAuthorizedHttp.requestcCs|jj||||ddS)z'Proxy to httplib2.Http.add_certificate.)passwordN)radd_certificate)r keycertdomainrNrrrrOszAuthorizedHttp.add_certificatecCr)#Proxy to httplib2.Http.connections.r connectionsrrrrrUrzAuthorizedHttp.connectionscC ||j_dS)rSNrTr valuerrrrU  cCr)(Proxy to httplib2.Http.follow_redirects.rfollow_redirectsrrrrr\rzAuthorizedHttp.follow_redirectscCrV)rZNr[rWrrrr\rYcCr)Proxy to httplib2.Http.timeout.rr,rrrrr,rzAuthorizedHttp.timeoutcCrV)r]Nr^rWrrrr,!rYcCr)&Proxy to httplib2.Http.redirect_codes.rredirect_codesrrrrra&rzAuthorizedHttp.redirect_codescCrV)r_Nr`rWrrrra+rYr )rrrrrDEFAULT_REFRESH_STATUS_CODESDEFAULT_MAX_REFRESH_ATTEMPTSrr9r&DEFAULT_MAX_REDIRECTSr%rOrrUsetterr\r,rarrrrr2s<   I       r2)r __future__r http.clientrlogging google.authrrr& getLoggerrr"rGResponserrr1objectr2rrrrs  C