관리-도구
편집 파일: adapter.cpython-38.pyc
U &?�f� � @ 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__� �N/opt/hc_python/lib/python3.8/site-packages/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|krhz| 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/ r0 r � cacheable�cached_response�respr' r) r* r: 2 s zCacheControlAdapter.sendr )r+ �responser1 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 r2 r �apply�statusr$ �update_cached_response�read� release_conn�intr �cache_responser rA � functools�partial�chunkedrF �types� MethodTyper" r6 �invalidating_methods�ok�url�AssertionError� cache_urlr �deleter1 ) r% r+ r> r1 r r; r< rF r= rW r' rD r* r6 P sL � �� � z"CacheControlAdapter.build_response)r c s | j �� t� �� d S )N)r �closer" rC r' r) r* rY � s zCacheControlAdapter.close)NTNNNN)FNTNNN)FN) �__name__� __module__� __qualname__rS r# r: r6 rY � __classcell__r) r) r' r* r s& �$ �"" � Or ) � __future__r rN rQ r4 �typingr r r r Z pip._vendor.requests.adaptersr � pip._vendor.cachecontrol.cacher �#pip._vendor.cachecontrol.controllerr r �$pip._vendor.cachecontrol.filewrapperr Zpip._vendor.requestsr r Zpip._vendor.urllib3r r Z#pip._vendor.cachecontrol.heuristicsr �"pip._vendor.cachecontrol.serializer r r) r) r) r* �<module> s