U
��.e�5 � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
Z
ddl m Z e�
e�Ze�d�Zd d
� ZG d d � d e�ZdS )
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 )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 �G/usr/lib/python3.8/site-packages/pip/_vendor/cachecontrol/controller.py� parse_uri s r c @ s\ e Zd ZdZddd�Zedd� �Zedd � �Zd
d � Zd d
� Z dd� Z
ddd�Z dd� Z dS )�CacheControllerz9An interface to see if request should cached or not.
NTc C s, |pt � | _|| _|pt� | _|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 ZschemeZ authority�pathZqueryZfragmentZ request_uriZ
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-revalidateZpublicZprivatezproxy-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 �headersZknown_directivesZ
cc_headersZretvalZ cc_directive�partsZ directive�typZrequiredr 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� ||�}|s�t�
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| k�r^| d } t�d| � nDd|k�r�t|d �}
|
dk �r�t�|
�| }td|�} 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�
|� 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& �urlr3 r4 r; r8 r r/ r �loadsZwarning�statusr �delete�time�calendarZtimegmr �max)r �requestr& �ccZ
cache_data�resp�msgr8 Znowr< Z current_ageZresp_ccZfreshness_lifetimer> Z expire_timeZ 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 )Nr= ZETagz
If-None-Matchz
last-modifiedz
Last-ModifiedzIf-Modified-Since)r& r? r r@ r r/ r r8 )r rF r& rH Z new_headersr8 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 | j�r,d |k�r,t�d � | j �| | jj|||d
�� n�|jdk�r\t�d� | j �| | j�||�� n�d|k�r�d|k�r�|d dk�r�t�d� | j �| | jj|||d
�� n:d|k�r�|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"Fr* Tz Response header has "no-store"z Request header has "no-store"z0Purging existing cache entry to honor "no-store"r= zCaching due to etag)�bodyr zCaching permanant redirectr< r' r z'Caching b/c date exists and max-age > 0r> z Caching b/c of expires header)r rA r3 r4 r r8 �isdigitr. �lenr; r& r? r r/ rB r �setr �dumps) r rF �responserM r r Zresponse_headersZcc_reqrG r& Zno_storer r r �cache_response� sr
�
��
��
�
�
�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.
rL c 3 s& | ] \}}|� � � kr||fV qd S r% )r )�.0�k�v�Zexcluded_headersr r � b s �z9CacheController.update_cached_response..r )
r& r? r r@ r r/ r8 �update�dict�itemsrA rP rQ )r rF rR r& Zcached_responser rW r �update_cached_responseI s �� z&CacheController.update_cached_response)NTNN)NN)
r7 �
__module__� __qualname__�__doc__r � classmethodr$ r& r; rJ rK rS r\ r r r r r s �
6o
Rr )r_ Zlogging�rerD rC Z email.utilsr Z pip._vendor.requests.structuresr r r Z serializer Z getLoggerr7 r3 �compiler r �objectr r r r r � s