B žHe @ã@sŒdZddlZddlZddlZddlZddlmZddlmZddl m Z m Z ddl m Z e e¡Ze d¡Zd Zd d „ZGd d „d eƒZdS)z7 The httplib2 algorithms ported for use with requests. éN)Ú parsedate_tz)ÚCaseInsensitiveDicté)Ú DictCacheÚSeparateBodyBaseCache)Ú Serializerz9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?)i-i4cCs0t |¡ ¡}|d|d|d|d|dfS)zƒParses a URI using the regex given in Appendix B of RFC 3986. (scheme, authority, path, query, fragment) = parse_uri(uri) réééé)ÚURIÚmatchÚgroups)Úurir©rúw/var/www/downstreamdata.science/rtclock/rtclock-venv/lib/python3.7/site-packages/pip/_vendor/cachecontrol/controller.pyÚ parse_urisrc@sfeZdZdZddd„Zedd„ƒZedd „ƒZd d „Zd d „Z dd„Z ddd„Z ddd„Z dd„Z dS)ÚCacheControllerz4An interface to see if request should cached or not.NTcCs4|dkrtƒn||_||_|p"tƒ|_|p,d|_dS)N)éÈéËi,i-i4)rÚcacheÚ cache_etagsrÚ serializerÚcacheable_status_codes)ÚselfrrrÚ status_codesrrrÚ__init__'s zCacheController.__init__c Csht|ƒ\}}}}}|r|s&td|ƒ‚| ¡}| ¡}|s>d}|rPd ||g¡pR|}|d||}|S)z4Normalize the URL to create a safe key for the cachez(Only absolute URIs are allowed. uri = %sú/ú?z://)rÚ ExceptionÚlowerÚjoin) ÚclsrÚschemeÚ authorityÚpathÚqueryÚfragmentÚ request_uriÚ defrag_urirrrÚ_urlnorm/s zCacheController._urlnormcCs | |¡S)N)r*)r"rrrrÚ cache_urlCszCacheController.cache_urlc Cs*tdftdftdfddddddddtdfdœ }| d| dd¡¡}i}xÞ| d¡D]Ð}| ¡s`qR| d d ¡}|d  ¡}y||\}} Wn"tk rªt d |¡wRYnX|r´| s¼d||<|rRy||d  ¡ƒ||<WqRtk rü| røt d |¡YqRtk r t d||j ¡YqRXqRW|S)NTF)NF) zmax-agez max-stalez min-freshzno-cachezno-storez no-transformzonly-if-cachedzmust-revalidateÚpublicÚprivatezproxy-revalidatezs-maxagez cache-controlz Cache-ControlÚú,ú=rrz,Ignoring unknown cache-control directive: %sz-Missing value for cache-control directive: %sz8Invalid value for cache-control directive %s, must be %s) ÚintÚgetÚsplitÚstripÚKeyErrorÚloggerÚdebugÚ IndexErrorÚ ValueErrorÚ__name__) rÚheadersÚknown_directivesÚ cc_headersÚretvalÚ cc_directiveÚpartsÚ directiveÚtypÚrequiredrrrÚparse_cache_controlGsP     z#CacheController.parse_cache_controlcCsX| |j¡}t d|¡| |j¡}d|kr:t d¡dSd|kr\|ddkr\t d¡dS|j |¡}|dkr~t d ¡dSt|jt ƒr˜|j  |¡}nd}|j   |||¡}|s¾t  d ¡dSt|jƒtkrÞd }t |¡|St|jƒ}|röd |kr$d |krt d¡|j |¡t d¡dSt ¡} t t|d ƒ¡} td| | ƒ} t d| ¡| |¡} d} d| kr†| d} t d| ¡nDd|krÊt|dƒ}|dk rÊt |¡| }td|ƒ} t d| ¡d|krè|d} t d| ¡d|kr|d}| |7} t d| ¡| | kr4t d¡t d| | ¡|Sd |krTt d¡|j |¡dS)ze Return a cached response if it exists in the cache, otherwise return False. zLooking up "%s" in the cachezno-cachez-Request header has "no-cache", cache bypassedFzmax-agerz1Request header has "max_age" as 0, cache bypassedNzNo cache entry availablez1Cache entry deserialization failed, entry ignoredzQReturning cached permanent redirect response (ignoring date and etag information)ÚdateÚetagz(Purging cached response: no date or etagz!Ignoring cached response: no datezCurrent age based on date: %iz#Freshness lifetime from max-age: %iÚexpiresz#Freshness lifetime from expires: %iz+Freshness lifetime from request max-age: %iz min-freshz'Adjusted current age from min-fresh: %iz2The response is "fresh", returning cached responsez%i > %iz4The cached response is "stale" with no etag, purging)r+Úurlr6r7rDr;rr2Ú isinstancerÚget_bodyrÚloadsÚwarningr1ÚstatusÚPERMANENT_REDIRECT_STATUSESrÚdeleteÚtimeÚcalendarÚtimegmrÚmax)rÚrequestr+ÚccÚ cache_dataÚ body_fileÚrespÚmsgr;ÚnowrEÚ current_ageÚresp_ccÚfreshness_lifetimerGÚ expire_timeÚ min_freshrrrÚcached_request}s|                                zCacheController.cached_requestcCs`| |j¡}|j ||j |¡¡}i}|r\t|jƒ}d|krH|d|d<d|kr\|d|d<|S)NrFÚETagz If-None-Matchz last-modifiedz Last-ModifiedzIf-Modified-Since)r+rHrrKrr2rr;)rrTr+rXÚ new_headersr;rrrÚconditional_headersòs    z#CacheController.conditional_headerscCs\t|jtƒr:|jj||j ||d¡|d|j ||¡n|jj||j |||¡|ddS)z. Store the data in the cache. ó)rGN)rIrrÚsetrÚdumpsÚset_body)rr+rTÚresponseÚbodyÚ expires_timerrrÚ _cache_sets zCacheController._cache_setcCs |p|j}|j|kr(t d|j|¡dSt|jƒ}d|krNt t|dƒ¡}nd}|dk r†d|kr†|d  ¡r†t |dƒt |ƒkr†dS|  |j¡}|  |¡} |  |j¡} t d| ¡d} d| krÎd } t d ¡d|kräd } t d ¡| r|j | ¡rt d ¡|j | ¡| rdSd | dd¡kr8t d¡dS|jr¶d|kr¶d} | d¡r~t|dƒ} | dk r~t | ¡|} t| dƒ} t d | ¡¡t d¡| | |||| ¡næt |jƒtkrât d¡| | ||d¡nºd|krœt t|dƒ¡}d| kr<| ddkr 0z5Caching b/c of expires header. expires in {0} seconds)rrMr6r7rr;rQrRrÚisdigitr1ÚlenrDr+rHrr2rOrrSÚformatrkrN)rrTrhrirrÚresponse_headersrEÚcc_reqrUr+Úno_storerjrGrrrÚcache_responses                          zCacheController.cache_responsecsl| |j¡}|j ||j |¡¡}|s*|Sdg‰|j t‡fdd„|j  ¡Dƒƒ¡d|_ |  |||¡|S)zéOn a 304 we will get a new set of headers that we want to update our cached value with, assuming we have one. This should only ever be called when we've sent an ETag and gotten a 304 as the response. zcontent-lengthc3s&|]\}}| ¡ˆkr||fVqdS)N)r )Ú.0ÚkÚv)Úexcluded_headersrrú «sz9CacheController.update_cached_response..r) r+rHrrKrr2r;ÚupdateÚdictÚitemsrMrk)rrTrhr+Úcached_responser)rxrÚupdate_cached_response‘s   z&CacheController.update_cached_response)NTNN)NN)NN)r:Ú __module__Ú __qualname__Ú__doc__rÚ classmethodr*r+rDr`rcrkrtr~rrrrr$s   6u  {r)rÚloggingÚrerQrPÚ email.utilsrZpip._vendor.requests.structuresrrrrÚ serializerÚ getLoggerr:r6Úcompiler rNrÚobjectrrrrrÚs