File: //lib/python3/dist-packages/pip/_vendor/cachecontrol/__pycache__/controller.cpython-310.pyc
o
@%Ne = � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
Z
ddl m Z e�
e�Ze�d�Zd Zd
d � ZG d d
� d
e�ZdS )z7
The httplib2 algorithms ported for use with requests.
� N)� parsedate_tz)�CaseInsensitiveDict� )� DictCache)�
Serializerz9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?)�- �4 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 �E/usr/lib/python3/dist-packages/pip/_vendor/cachecontrol/controller.py� parse_uri s "r c @ s^ e Zd ZdZ ddd�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 s4 |d u rt � n|| _|| _|pt� | _|pd| _d S )N)�� �� i, r r )r �cache� cache_etagsr �
serializer�cacheable_status_codes)�selfr r r � status_codesr r r �__init__( s zCacheController.__init__c C sh t |�\}}}}}|r
|std| ��|�� }|�� }|s d}|r(d�||g�p)|}|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 �_urlnorm0 s zCacheController._urlnormc C s
| � |�S �N)r+ )r# r r r r � cache_urlD s
zCacheController.cache_urlc
C s t dft dft dfddddddddt dfd� }|�d|�dd��}i }|�d�D ]c}|�� s/q(|�d d
�}|d �� }z|| \}} W n tyR t�d |� Y q(w |rW| s[d ||< |r�z ||d
�� �||< W q( tyz | rxt�d
|� Y q( ty� t�d||j � Y q(w q(|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_controlH s^ � � �� ���z#CacheController.parse_cache_controlc C s* | � |j�}t�d|� | �|j�}d|v r t�d� dS d|v r.|d dkr.t�d� dS | j�|�}|du r?t�d � dS | j� ||�}|sOt�
d
� dS t |j �t
v r_d }t�|� |S t|j�}|rjd |vr�d
|vryt�d� | j�|� t�d� dS t�� }t�t|d ��} td|| �}
t�d|
� | �|�} d} d| v r�| d } t�d| � n d|v r�t|d �}
|
dur�t�|
�| }td|�} t�d| � d|v r�|d } t�d| � d|v r�|d }|
|7 }
t�d|
� | |
k�rt�d� t�d| |
� |S d
|v�rt�d� | j�|� dS )ze
Return a cached response if it exists in the cache, otherwise
return False.
z Looking up "%s" in the cacher0 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 ignoredzQReturning cached permanent redirect 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= rJ rA r r8 r �loads�warningr7 �status�PERMANENT_REDIRECT_STATUSESr �delete�time�calendar�timegmr �max)r �requestr- �cc�
cache_data�resp�msgrA �nowrK � current_age�resp_cc�freshness_lifetimerM � expire_time� min_freshr r r �cached_request~ sz
�
�
z CacheController.cached_requestc C s` | � |j�}| j�|| j�|��}i }|r.t|j�}d|v r$|d |d< d|v r.|d |d< |S )NrL �ETagz
If-None-Matchz
last-modifiedz
Last-ModifiedzIf-Modified-Since)r- rN r rO r r8 r rA )r rX r- r[ � new_headersrA r r r �conditional_headers� s
z#CacheController.conditional_headersc C s� |p| j }|j|vrt�d|j|� dS t|j�}d|v r't�t|d ��}nd}|durCd|v rC|d � � rCt
|d �t |�krCdS | � |j�}| � |�} | �
|j�}
t�d|
� d} d| v rgd } t�d
� d|v rrd } t�d � | r�| j�|
�r�t�d � | j�|
� | r�dS d
|�dd�v r�t�d� dS | jr�d|v r�d} |�d�r�t|d �}
|
dur�t�|
�| } t| d�} t�d�| �� t�d� | jj|
| j�|||�| d� dS t
|j�tv r�t�d� | j�|
| j�||d�� dS d|v �rbt�t|d ��}d| v �r)| d dk�r)t�d� | d } | jj|
| j�|||�| d� dS d|v �rd|d �rft|d �}
|
du�rFt�|
�| } nd} t�d�| �� | jj|
| jj|||d �| d� dS dS dS dS ) zc
Algorithm for caching requests.
This assumes a requests Response object.
zStatus code %s not in %sNrK r �content-lengthz&Updating cache with response from "%s"Fr1 Tz Response header has "no-store"z Request header has "no-store"z0Purging existing cache entry to honor "no-store"�*�varyr4 z Response header has "Vary: *"rL rM i u z"etag object cached for {0} secondszCaching due to etag)rM zCaching permanent redirect� r. z'Caching b/c date exists and max-age > 0z5Caching b/c of expires header. expires in {0} seconds)�body)r rQ r< r= r rA rU rV r �isdigitr7 �lenrJ r- rN r r8 rS r rW �format�setr �dumpsrR )r rX �responserk r r �response_headersrK �cc_reqrY r- �no_store� expires_timerM r r r �cache_response� s�
�
�
�
�
��
��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.
rg c 3 s( � | ]\}}|� � � vr||fV qd S r, )r! )�.0�k�v��excluded_headersr r � <genexpr>� s � ��z9CacheController.update_cached_response.<locals>.<genexpr>r )
r- rN r rO r r8 rA �update�dict�itemsrQ ro rp )r rX rq r- �cached_responser rz r �update_cached_responsey s �� z&CacheController.update_cached_response)NTNN)NN)
r@ �
__module__� __qualname__�__doc__r � classmethodr+ r- rJ rc rf rv r� r r r r r $ s
�
6p
{r )r� �logging�rerU rT � email.utilsr � pip._vendor.requests.structuresr r r � serializer � getLoggerr@ r< �compiler
rR r �objectr r r r r �<module> s