B
    Kkd‚5  ã               @   s„   d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl	m
Z
 ddlmZ e e¡Ze d¡Zd	d
„ ZG dd„ deƒZdS )z7
The httplib2 algorithms ported for use with requests.
é    N)Úparsedate_tz)ÚCaseInsensitiveDicté   )Ú	DictCache)Ú
Serializerz9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?c             C   s0   t  | ¡ ¡ }|d |d |d |d |d fS )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   úD/tmp/pip-install-gxxfd9b7/pip/pip/_vendor/cachecontrol/controller.pyÚ	parse_uri   s    r   c               @   s\   e Zd ZdZddd„Zedd„ ƒZedd	„ ƒZd
d„ Zdd„ Z	dd„ Z
ddd„Zdd„ ZdS )ÚCacheControllerz9An interface to see if request should cached or not.
    NTc             C   s,   |pt ƒ | _|| _|ptƒ | _|p$d| _d S )N)éÈ   éË   i,  i-  )r   ÚcacheÚcache_etagsr   Ú
serializerÚcacheable_status_codes)Úselfr   r   r   Ústatus_codesr   r   r   Ú__init__"   s    zCacheController.__init__c       	      C   sh   t |ƒ\}}}}}|r|s&td| ƒ‚| ¡ }| ¡ }|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    zCacheController._urlnormc             C   s
   |   |¡S )N)r)   )r!   r   r   r   r   Ú	cache_url>   s    zCacheController.cache_urlc       
      C   s*  t dft dft dfddddddddt dfdœ}| d| dd¡¡}i }xÞ| d¡D ]Ð}| ¡ s`qR| d	d
¡}|d  ¡ }y|| \}}	W n" tk
rª   t d|¡ wRY nX |r´|	s¼d ||< |rRy||d
  ¡ ƒ||< W qR tk
rü   |	røt d|¡ Y qR tk
r    t d||j	¡ Y qRX qRW |S )NTF)NF)zmax-agez	max-stalez	min-freshzno-cachezno-storezno-transformzonly-if-cachedzmust-revalidateÚpublicÚprivatezproxy-revalidatezs-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   sP    
z#CacheController.parse_cache_controlc             C   s0  |   |j¡}t d|¡ |  |j¡}d|kr:t d¡ dS d|kr\|d dkr\t d¡ dS | j |¡}|dkr~t d	¡ dS | j 	||¡}|sžt 
d
¡ dS |jdkrºd}t |¡ |S t|jƒ}|rÐd|krüd|krît d¡ | j |¡ t d¡ dS t ¡ }t t|d ƒ¡}	td||	 ƒ}
t d|
¡ |  |¡}d}d|kr^|d }t d|¡ nDd|kr¢t|d ƒ}|dk	r¢t |¡|	 }td|ƒ}t d|¡ d|krÀ|d }t d|¡ d|kræ|d }|
|7 }
t d|
¡ ||
krt d¡ t d||
¡ |S d|kr,t d¡ | j |¡ dS )ze
        Return a cached response if it exists in the cache, otherwise
        return False.
        zLooking up "%s" in the cachezno-cachez-Request header has "no-cache", cache bypassedFzmax-ager   z1Request header has "max_age" as 0, cache bypassedNzNo cache entry availablez1Cache entry deserialization failed, entry ignoredi-  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: %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*   Úurlr5   r6   rC   r:   r   r1   r   ÚloadsÚwarningÚstatusr   ÚdeleteÚtimeÚcalendarÚtimegmr   Úmax)r   Úrequestr*   ÚccÚ
cache_dataÚrespÚmsgr:   ÚnowrD   Úcurrent_ageÚresp_ccÚfreshness_lifetimerF   Úexpire_timeÚ	min_freshr   r   r   Úcached_requestx   sv    




















zCacheController.cached_requestc             C   s`   |   |j¡}| j || j |¡¡}i }|r\t|jƒ}d|krH|d |d< d|kr\|d |d< |S )NrE   ÚETagzIf-None-Matchzlast-modifiedzLast-ModifiedzIf-Modified-Since)r*   rG   r   rH   r   r1   r   r:   )r   rP   r*   rS   Únew_headersr:   r   r   r   Úconditional_headersç   s    
z#CacheController.conditional_headersc             C   sä  |p| j }|j|kr(t d|j|¡ dS t|jƒ}|dk	rfd|krf|d  ¡ rft|d ƒt|ƒkrfdS |  	|j¡}|  	|¡}|  
|j¡}	t d|	¡ d}
d|kr®d}
t d¡ d|krÄd}
t d	¡ |
rê| j |	¡rêt d
¡ | j |	¡ |
ròdS | jr,d|kr,t d¡ | j |	| jj|||d¡ n´|jdkr\t d¡ | j |	| j ||¡¡ n„d|kràd|kr¦|d dkr¦t d¡ | j |	| jj|||d¡ n:d|krà|d ràt d¡ | j |	| jj|||d¡ dS )zc
        Algorithm for caching requests.

        This assumes a requests Response object.
        zStatus code %s not in %sNzcontent-lengthz&Updating cache with response from "%s"Fzno-storeTzResponse header has "no-store"zRequest header has "no-store"z0Purging existing cache entry to honor "no-store"rE   zCaching due to etag)Úbodyi-  zCaching permanant redirectrD   zmax-ager   z'Caching b/c date exists and max-age > 0rF   zCaching b/c of expires header)r   rJ   r5   r6   r   r:   Úisdigitr0   ÚlenrC   r*   rG   r   r1   rK   r   Úsetr   Údumps)r   rP   Úresponser_   r   r   Úresponse_headersÚcc_reqrQ   r*   Úno_storer   r   r   Úcache_response÷   sX    













zCacheController.cache_responsec                sv   |   |j¡}| j || j |¡¡}|s*|S dg‰ |j t‡ fdd„|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.
        zcontent-lengthc             3   s&   | ]\}}|  ¡ ˆ kr||fV  qd S )N)r   )Ú.0ÚkÚv)Úexcluded_headersr   r   ú	<genexpr>c  s   z9CacheController.update_cached_response.<locals>.<genexpr>r   )r*   rG   r   rH   r   r1   r:   ÚupdateÚdictÚitemsrJ   rb   rc   )r   rP   rd   r*   Úcached_responser   )rl   r   Úupdate_cached_responseI  s    	
z&CacheController.update_cached_response)NTNN)NN)r9   Ú
__module__Ú__qualname__Ú__doc__r   Úclassmethodr)   r*   rC   r[   r^   rh   rr   r   r   r   r   r      s   
6o
Rr   )ru   ÚloggingÚrerM   rL   Úemail.utilsr   Zpip._vendor.requests.structuresr   r   r   Ú	serializer   Ú	getLoggerr9   r5   Úcompiler   r   Úobjectr   r   r   r   r   Ú<module>   s   

	