/usr/local/lib/python3.9/site-packages/pip/_vendor/cachecontrol/__pycache__
a ���h�J � @ s� d Z ddlmZ ddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlmZ ddlmZmZ ddlmZ e r�dd l mZ dd lmZ dd lmZ dd lmZ e�e �Z e� d �Z dZ ddd�dd�Z!G dd� d�Z"dS )z7 The httplib2 algorithms ported for use with requests. � )� annotationsN)� parsedate_tz)� TYPE_CHECKING� Collection�Mapping)�CaseInsensitiveDict)� DictCache�SeparateBodyBaseCache)� Serializer)�Literal)�PreparedRequest)� HTTPResponse)� BaseCachez9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?)�- �4 �strz tuple[str, str, str, str, str]��uri�returnc C s@ t �| �}|dusJ �|�� }|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) N� � � � � )�URI�match�groups)r r r � r �M/usr/local/lib/python3.9/site-packages/pip/_vendor/cachecontrol/controller.py� parse_uri' s r c @ s� e Zd ZdZd/ddddd�d d �Zed d d �d d��Zed d d �dd��Zddd�dd�Zddd�dd�Z ddd�d d �Z dd d�d d �Z d0d dd!d"d#d$d%�d&d'�Z d1dd(d"dd$d)�d*d+�Z dd!d!d,�d-d.�ZdS )2�CacheControllerz4An interface to see if request should cached or not.NTzBaseCache | None�boolzSerializer | NonezCollection[int] | None)�cache� cache_etags� serializer� status_codesc C s4 |d u rt � n|| _|| _|p"t� | _|p,d| _d S )N)�� �� i, r r )r r" r# r r$ �cacheable_status_codes)�selfr" r# r$ r% r r r �__init__5 s zCacheController.__init__r r 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 �_urlnormA s zCacheController._urlnormc C s | � |�S )N)r8 )r0 r r r r � cache_urlU s zCacheController.cache_urlzMapping[str, str]zdict[str, int | None])�headersr c C s" t dft dft dfddddddddt dfd� }|�d|�dd��}i }|�d�D ]�}|�� s^qP|�d d �}|d �� }z|| \}} W n" ty� t�d |� Y qPY n0 |r�| s�d ||< |rPz||d �� �||< W qP ty� | r�t�d |� Y qP t�y t�d||j � Y qP0 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) r: �known_directives� cc_headers�retval� cc_directive�parts� directive�typ�requiredr r r �parse_cache_controlY sV � �� z#CacheController.parse_cache_controlr zHTTPResponse | None)�requestr c C s� d|j v rdS |j}|dus J �| j�|�}|du rBt�d� dS t| jt�r\| j�|�}nd}| j � |||�}|du r�t� d� |S )zO Load a cached response, or return None if it's not available. �RangeNzNo cache entry availablez1Cache entry deserialization failed, entry ignored) r: �urlr" rE rI rJ � isinstancer �get_bodyr$ �loads�warning)r) rW r9 � cache_dataZ body_file�resultr r r �_load_from_cache� s z CacheController._load_from_cachez HTTPResponse | Literal[False]c C s@ |j dusJ �| �|j �}t�d|� | �|j�}d|v rHt�d� dS d|v rj|d dkrjt�d� dS | �|�}|s|dS t|j�t v r�d }t�|� |S t |j�}|r�d |vr�d |vr�t�d � | j � |� t�d � dS t � � }t|d �}|dus�J �t�|dd� �} td|| �} t�d| � | �|�} d} | �d�} | du�r^| } t�d| � nLd|v �r�t|d �}|du�r�t�|dd� �| }td|�} t�d| � |�d�} | du�r�| } t�d| � |�d�}|du�r�| |7 } t�d| � | | k�r t�d� t�d| | � |S d |v�r<t�d� | j � |� dS )ze Return a cached response if it exists in the cache, otherwise return False. Nz Looking up "%s" in the cacher= z-Request header has "no-cache", cache bypassedFr; r z1Request header has "max_age" as 0, cache bypassedzQReturning cached permanent redirect response (ignoring date and etag information)�date�etagz(Purging cached response: no date or etagz!Ignoring cached response: no dater z 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)rY r9 rI rJ rV r: r` rD �status�PERMANENT_REDIRECT_STATUSESr r" �delete�timer �calendar�timegm�maxrE )r) rW r9 �cc�resp�msgr: �now� time_tuplera � current_age�resp_cc�freshness_lifetime�max_agerc � expire_time� min_freshr r r �cached_request� sz � � z CacheController.cached_requestzdict[str, str]c C sH | � |�}i }|rDt|j�}d|v r0|d |d< d|v rD|d |d< |S )Nrb �ETagz If-None-Matchz last-modifiedz Last-ModifiedzIf-Modified-Since)r` r r: )r) rW rl � new_headersr: r r r �conditional_headers s z#CacheController.conditional_headersr z bytes | Nonez int | None�None)r9 rW �response�body� expires_timer c C sd t | jt�rB| jj|| j�||d�|d� |dur`| j�||� n | jj|| j�|||�|d� dS )z. Store the data in the cache. � )rc N)rZ r" r �setr$ �dumpsZset_body)r) r9 rW r{ r| r} r r r � _cache_set& s ��zCacheController._cache_setz2HTTPResponse | weakref.ReferenceType[HTTPResponse])rW �response_or_refr| r% r c C s t |tj�r |� }|du r$dS n|}|p,| j}|j|vrLt�d|j|� dS t|j�}d|v r�t |d �}|dusvJ �t � |dd� �} nd} |dur�d|v r�|d � � r�t |d �t|�kr�dS | �|j�} | �|�} |jdus�J �| �|j�} t�d| � d} d | v �rd } t�d � d | v �r2d } t�d � | �r\| j�| ��r\t�d � | j�| � | �rfdS d|�dd�v �r�t�d� dS | j�rd|v �rd}|�d��r�t |d �}|du�r�t � |dd� �| }t|d�}t�d|� d�� t�d� | �| ||||� �n t |j�tv �r<t�d� | �| ||d� n�d|v �rt |d �}|du�s`J �t � |dd� �} | �d�}|du�r�|dk�r�t�d� |}| �| ||||� nhd|v �r|d �rt |d �}|du�r�t � |dd� �| }nd}t�d �|�� | �| ||||� dS ) zc Algorithm for caching requests. This assumes a requests Response object. NzStatus code %s not in %sra r r �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"�*�varyrA z Response header has "Vary: *"rb rc i u zetag object cached for z secondszCaching due to etagzCaching permanent redirectr~ r; z'Caching b/c date exists and max-age > 0z4Caching b/c of expires header. expires in {} seconds)rZ �weakref� ReferenceTyper( rd rI rJ r r: r rh ri �isdigitrD �lenrV rY r9 r" rE rf r# rj r� re �format)r) rW r� r| r% r{ r( �response_headersro ra �cc_reqrk r9 �no_storer} rc rs r r r �cache_responseD s� �� �� �� � ���z CacheController.cache_response)rW r{ r c sj |j dusJ �| �|j �}| �|�}|s,|S dg� |j�� 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. Nr� c s" i | ]\}}|� � � vr||�qS r )r. )�.0�k�v��excluded_headersr r � <dictcomp>� s �z:CacheController.update_cached_response.<locals>.<dictcomp>r& )rY r9 r` r: �update�itemsrd r� )r) rW r{ r9 �cached_responser r� r �update_cached_response� s �� z&CacheController.update_cached_response)NTNN)NN)NN)rM � __module__� __qualname__�__doc__r* � classmethodr8 r9 rV r` rv ry r� r� r� r r r r r 2 s, � 6n �" � r )#r� � __future__r rh �logging�rerg r� � email.utilsr �typingr r r Z pip._vendor.requests.structuresr Z pip._vendor.cachecontrol.cacher r Z"pip._vendor.cachecontrol.serializer r Zpip._vendor.requestsr Zpip._vendor.urllib3r r � getLoggerrM rI �compiler re r r r r r r �<module> s*
.
Edit
..
Edit
__init__.cpython-39.pyc
Edit
_cmd.cpython-39.pyc
Edit
adapter.cpython-39.pyc
Edit
cache.cpython-39.pyc
Edit
controller.cpython-39.pyc
Edit
filewrapper.cpython-39.pyc
Edit
heuristics.cpython-39.pyc
Edit
serialize.cpython-39.pyc
Edit
wrapper.cpython-39.pyc
Edit