!ddlZddlZddlZddlmZddlmZejeZ dZ ejfZ Gdde ZdZdZd Zd Zd Zd Zd Zej,eZy)N) http_client) _to_bytes)readseektellc(eZdZdZdZdZdZdZy) MemoryCachez8httplib2 Cache implementation which only caches locally.ci|_yNcache)selfs )lib/third_party/oauth2client/transport.py__init__zMemoryCache.__init__#s  c8|jj|Sr )r getrkeys rrzMemoryCache.get&szz~~c""rc"||j|<yr r )rrvalues rsetzMemoryCache.set)s 3rc<|jj|dyr )r poprs rdeletezMemoryCache.delete,s sD!rN)__name__ __module__ __qualname____doc__rrrrrrr r sB# "rr ctS)aReturn an HTTP object which caches results returned. This is intended to be used in methods like oauth2client.client.verify_id_token(), which calls to the same URI to retrieve certs. Returns: httplib2.Http, an HTTP object with a MemoryCache ) _CACHED_HTTPr rrget_cached_httpr#0s  rc*tjS)zSReturn a new HTTP object. Returns: httplib2.Http, an HTTP object. )httplib2Httpr rrget_http_objectr'=s ==?rc |iSt|S)zCreates a copy of the headers. Args: headers: dict, request headers to copy. Returns: dict, the copied headers or a new dictionary if the headers were None. )dict)headerss r_initialize_headersr+Fs23d7m3rc<|d|vr|dz|dz|d<|S||d<|S)a,Adds a user-agent to the headers. Args: headers: dict, request headers to add / modify user agent within. user_agent: str, the user agent to add. Returns: dict, the original headers passed in, but modified if the user agent is not None. z user-agent r )r* user_agents r_apply_user_agentr/SsC 7 "%/#%5 8M%MGL ! N%/GL ! NrcDi} tj|D]f\}}t|tjs t |}t|tjs t |}t ||t |<h |S#t $rddlm}|dwxYw)aForces header keys and values to be strings, i.e not unicode. The httplib module just concats the header keys and values in a way that may make the message header a unicode string, which, if it then tries to contatenate to a binary request body may result in a unicode decode error. Args: headers: dict, A dictionary of headers. Returns: The same dictionary but with all the keys converted to strings. r)NonAsciiHeaderErrorz: ) six iteritems isinstance binary_typestrrUnicodeEncodeErroroauth2client.clientr1)r*cleankvr1s r clean_headersr<hs E .MM'*DAqa1Fa1F"+A,E)A,  + L .;!!T1--.s A>BBc|jdddtjdffd }||_t|jdy)aPrepares an HTTP object's request method for auth. Wraps HTTP requests with logic to catch auth failures (typically identified via a 401 status code). In the event of failure, tries to refresh the token used and then retry the original request. Args: credentials: Credentials, the credentials used to identify the authenticated user. http: httplib2.Http, an http object to be used to make auth requests. GETNc  js&tjd j t |} j |t | jd}tfdtDrj} ||t|||\}}d} t| D]} |jtvr||fStjd|j| dz|  j  j ||j| ||t|||\}}||fS)Nz1Attempting refresh to obtain initial access_tokenc38K|]}t|dywr )getattr).0 stream_propbodys r z:wrap_http_for_auth..new_request..s##!5@wt[$/!sz&Refreshing due to a %s (attempt %s/%s)) access_token_LOGGERinfo_refreshr+applyr/r.all_STREAM_PROPERTIESrr<rangestatusREFRESH_STATUS_CODESr) urimethodrDr* redirectionsconnection_typebody_stream_positionrespcontentmax_refresh_attemptsrefresh_attempt credentialsorig_request_methods ` r new_requestz'wrap_http_for_auth..new_requestsW'' LL0 1  !4 5&g.'"';#9#9:# #!# ##'99; +C,9',B,8/K g !$%9:O{{"66W} LLAo&9- /  !4 5   g &#/ .//VT0=g0F0Nc`d jvr6 j jr jd ||||||St |}t | j |jddd} jd|i\}}d|z|d< |||t|||S)Naud?rGrzBearer Authorization) _kwargsrHaccess_token_expiredrefreshr+r/r.split _create_tokenr<) rRrSrDr*rTrUuri_roottoken unused_expiryauthenticated_request_methodr[r\s rr]z-wrap_http_for_jwt_access..new_requests K'' '((044##D)/VT070?A A *'2G g{'='= >yya(+H#.#<#rxs !+ '  H %-$002 "& "  4*6@6F,^x}}[]+ r