File: //usr/local/lib/python3.7/site-packages/pip/_vendor/cachecontrol/__pycache__/adapter.cpython-37.pyc
B
L��g� � @ s� d dl mZ d dlZd dlZd dlZd dlmZmZmZm Z d dl
m Z d dl m
Z
d dlmZmZ d dlmZ er�d dlmZmZ d d lmZ d d
l mZ d d lmZ d d lm Z G d
d� de �Z dS )� )� annotationsN)�
TYPE_CHECKING�Any�
Collection�Mapping)� HTTPAdapter)� DictCache)�PERMANENT_REDIRECT_STATUSES�CacheController)�CallbackFileWrapper)�PreparedRequest�Response)� HTTPResponse)� BaseCache)�
BaseHeuristic)�
Serializerc s� e Zd ZdddhZd"dddd d
d d d d
d� � fdd�
Zd#ddddddd dd�� fdd�
Zd$dddd dd �� fd d �
Zd
d �� fd d!� Z� ZS )%�CacheControlAdapter�PUT�PATCH�DELETENTzBaseCache | None�boolz type[CacheController] | NonezSerializer | NonezBaseHeuristic | NonezCollection[str] | Noner �None) �cache� cache_etags�controller_class�
serializer� heuristic�cacheable_methods�args�kw�returnc
sP t � j||� |d kr t� n|| _|| _|p.d| _|p8t} | | j||d�| _d S )N)�GET)r r )�super�__init__r r r r r
�
controller)
�selfr r r r r r r r �controller_factory)� __class__� �D/tmp/pip-unpacked-wheel-hv55ucu3/pip/_vendor/cachecontrol/adapter.pyr# s
z CacheControlAdapter.__init__Fr z7None | float | tuple[float, float] | tuple[float, None]z
bool | strz4None | bytes | str | tuple[bytes | str, bytes | str]zMapping[str, str] | Noner
)�request�stream�timeout�verify�cert�proxiesr r c s� |p| j }|j|krhy| j�|�} W n tjk
r> d} Y nX | rT| j|| dd�S |j�| j� |�� t
� � ||||||�}
|
S )z�
Send a request. Use the request information to see if it
exists in the cache and cache the response if we need to and can.
NT)�
from_cache) r �methodr$ �cached_request�zlib�error�build_response�headers�update�conditional_headersr" �send) r% r* r+ r, r- r. r/ r � cacheable�cached_response�resp)r' r( r) r9 2 s
zCacheControlAdapter.sendr )r* �responser0 r r c
s( |p| j }|s�|j|kr�| jr*| j�|�}|jdkrh| j�||�}||k rNd}|jdd� |�� |}nht |j�t
kr�| j� ||� nJt |j
t�| jj ||��|_
|jr�|j� ddd�� fdd � }t�||�|_t� �||�}|j| jk�r |j�r |jd
k �st�| j�|j�} | j� | � ||_ |S ) z�
Build a response by making a request or using the cache.
This will end up calling send and returning a potentially
cached response
i0 TF)�decode_contentr r )r% r c s � � | j dkr| j�� d S )Nr )�
chunk_left�_fp�_close)r% )�super_update_chunk_lengthr( r) �_update_chunk_length� s
z@CacheControlAdapter.build_response.<locals>._update_chunk_lengthN) r r1 r �apply�statusr$ �update_cached_response�read� release_conn�intr �cache_responser r@ � functools�partial�chunkedrC �types�
MethodTyper" r5 �invalidating_methods�ok�url�AssertionError� cache_urlr �deleter0 )
r% r* r= r0 r r: r; rC r< rT )r' )rB r) r5 P s<
z"CacheControlAdapter.build_response)r c s | j �� t� �� d S )N)r �closer" )r% )r' r( r) rV � s
zCacheControlAdapter.close)NTNNNN)FNTNNN)FN) �__name__�
__module__� __qualname__rP r# r9 r5 rV �
__classcell__r( r( )r' r) r s
$ " Jr ) �
__future__r rK rN r3 �typingr r r r Z pip._vendor.requests.adaptersr Z pip._vendor.cachecontrol.cacher Z#pip._vendor.cachecontrol.controllerr r
Z$pip._vendor.cachecontrol.filewrapperr Zpip._vendor.requestsr r
Zpip._vendor.urllib3r r Z#pip._vendor.cachecontrol.heuristicsr Z"pip._vendor.cachecontrol.serializer r r( r( r( r) �<module> s