U
|
H=®dE7 ã @ s d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
|
Z
|
ddl m Z e e¡Ze d¡Zd d
|
ZG d d d eZdS ) z7
|
The httplib2 algorithms ported for use with requests.
|
é N)Ú parsedate_tz)ÚCaseInsensitiveDicté )Ú DictCache)Ú
|
Serializerz9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?c C s0 t | ¡ ¡ }|d |d |d |d |d fS )zParses 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 úZD:\z\workplace\VsCode\pyvenv\venv\Lib\site-packages\pip/_vendor/cachecontrol/controller.pyÚ parse_uri s r c @ s\ e Zd ZdZdddZedd Zedd Zd
|
d Zd d Z dd Z
|
dddZ dd Z dS )ÚCacheControllerz9An interface to see if request should cached or not.
|
NTc C s4 |d krt n|| _|| _|p"t | _|p,d| _d S )N)éÈ éË i, é- )r ÚcacheÚ cache_etagsr Ú
|
serializerÚcacheable_status_codes)Úselfr r r Ú status_codesr r r Ú__init__" s zCacheController.__init__c C sh t |\}}}}}|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_urir r r Ú_urlnorm* s zCacheController._urlnormc C s
|
| |¡S ©N)r* )r" r r r r Ú cache_url> s zCacheController.cache_urlc
|
C s( t dft dft dfddddddddt dfd }| d| dd¡¡}i }| d¡D ]Ò}| ¡ s^qP| d d
|
¡}|d ¡ }z|| \}} W n$ tk
|
rª t d |¡ Y qPY nX |r´| s¼d ||< |rPz||d
|
¡ ||< W qP tk
|
rü | røt d |¡ Y qP tk
|
r t d||j ¡ Y qPX qP|S )NTF)NF) úmax-agez max-staleú min-freshúno-cacheúno-storez no-transformzonly-if-cachedzmust-revalidateÚpublicÚprivatezproxy-revalidatezs-maxagez cache-controlz Cache-ControlÚ ú,ú=r r z,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Úrequiredr r r Úparse_cache_controlB sV ó
|
þý z#CacheController.parse_cache_controlc C s0 | |j¡}t d|¡ | |j¡}d|kr:t d¡ dS d|kr\|d dkr\t d¡ dS | j |¡}|dkr~t d ¡ dS | j ||¡}|st
|
d
|
¡ dS |j d krºd }t |¡ |S t |j}|rÐd |krüd|krît d¡ | j |¡ t d¡ dS t ¡ }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|
|
¡ | |
|
kr t d¡ t d| |
|
¡ |S d|kr,t d¡ | j |¡ dS )ze
|
Return a cached response if it exists in the cache, otherwise
|
return False.
|
z Looking up "%s" in the cacher/ z-Request header has "no-cache", cache bypassedFr- r z1Request header has "max_age" as 0, cache bypassedNzNo cache entry availablez1Cache entry deserialization failed, entry ignoredr zVReturning cached "301 Moved Permanently" response (ignoring date and etag information)ÚdateÚetagz(Purging cached response: no date or etagz!Ignoring cached response: no datez Current age based on date: %iz#Freshness lifetime from max-age: %iÚexpiresz#Freshness lifetime from expires: %iz+Freshness lifetime from request max-age: %ir. z'Adjusted current age from min-fresh: %iz2The response is "fresh", returning cached responsez%i > %iz4The cached response is "stale" with no etag, purging)r, Úurlr; r< rI r@ r r7 r ÚloadsÚwarningÚstatusr ÚdeleteÚtimeÚcalendarÚtimegmr Úmax)r Úrequestr, ÚccÚ
|
cache_dataÚrespÚmsgr@ ÚnowrJ Ú current_ageÚresp_ccÚfreshness_lifetimerL Ú expire_timeÚ min_freshr r r Úcached_requestx s|
|
|
|
|
|
|
ÿ
|
|
|
|
|
|
|
|
|
|
ÿ
|
|
|
|
|
z CacheController.cached_requestc C s` | |j¡}| j || j |¡¡}i }|r\t|j}d|krH|d |d< d|kr\|d |d< |S )NrK ÚETagz If-None-Matchz last-modifiedz Last-ModifiedzIf-Modified-Since)r, rM r rN r r7 r r@ )r rV r, rY Ú new_headersr@ r r r Úconditional_headersç s
|
z#CacheController.conditional_headersc C s |p| j }|j|kr(t d|j|¡ dS t|j}|dk rfd|krf|d ¡ rft|d t|krfdS | |j¡}| |¡}|
|
|j ¡} t d| ¡ d}
|
d|kr®d}
|
t d¡ d|krÄd}
|
t d ¡ |
|
rê| j | ¡rêt d
|
¡ | j | ¡ |
|
ròdS d | d d ¡krt d¡ dS | jrLd|krLt d¡ | j | | jj|||d¡ n´|jdkr|t d¡ | j | | j ||¡¡ nd|kr d|krÆ|d dkrÆt d¡ | j | | jj|||d¡ n:d|kr |d r t d¡ | j | | jj|||d¡ dS )zc
|
Algorithm for caching requests.
|
|
This assumes a requests Response object.
|
zStatus code %s not in %sNúcontent-lengthz&Updating cache with response from "%s"Fr0 Tz Response header has "no-store"z Request header has "no-store"z0Purging existing cache entry to honor "no-store"Ú*Úvaryr3 z Response header has "Vary: *"rK zCaching due to etag)Úbodyr zCaching permanant redirectrJ r- r z'Caching b/c date exists and max-age > 0rL z Caching b/c of expires header)r rP r; r< r r@ Úisdigitr6 ÚlenrI r, rM r r7 rQ r Úsetr Údumps) r rV Úresponserh r r Úresponse_headersÚcc_reqrW r, Úno_storer r r Úcache_response÷ sx
|
|
ÿ
|
ÿþ
|
ýü
|
|
|
|
|
|
ÿ
|
|
|
ÿ
|
|
|
ÿz CacheController.cache_responsec sv | |j¡}| j || j |¡¡}|s*|S dg |j t fdd|j ¡ D ¡ d|_
|
| j || j ||¡¡ |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.
|
re c 3 s& | ] \}}| ¡ kr||fV qd S r+ )r )Ú.0ÚkÚv©Úexcluded_headersr r Ú <genexpr>k s þz9CacheController.update_cached_response.<locals>.<genexpr>r ) r, rM r rN r r7 r@ ÚupdateÚdictÚitemsrP rk rl )r rV rm r, Úcached_responser ru r Úupdate_cached_responseR s þÿ z&CacheController.update_cached_response)NTNN)NN) r? Ú
|
__module__Ú __qualname__Ú__doc__r Ú classmethodr* r, rI ra rd rq r| r r r r r s ÿ
|
|
|
6o
|
[r )r ÚloggingÚrerS rR Ú email.utilsr Z pip._vendor.requests.structuresr r r Ú serializer Ú getLoggerr? r; Úcompiler r Úobjectr r r r r Ú<module> s
|
|
|
