OwlCyberSecurity - MANAGER
Edit File: controller.cpython-38.pyc
U ʗRe @ � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m Z 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�SeparateBodyBaseCache)� 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 ��/builddir/build/BUILDROOT/alt-python38-pip-22.2.1-2.el8.x86_64/opt/alt/python38/lib/python3.8/site-packages/pip/_vendor/cachecontrol/controller.py� parse_uri s r c @ sf e Zd ZdZddd�Zedd� �Zedd � �Zd d � Zd d � Z dd� Z ddd�Z ddd�Z dd� Z dS )�CacheControllerz4An interface to see if request should cached or not.NTc C s4 |d krt � n|| _|| _|p"t� | _|p,d| _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|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 �_urlnorm/ s zCacheController._urlnormc C s | � |�S �N)r, )r$ r r r r � cache_urlC 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-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_controlG sV � �� z#CacheController.parse_cache_controlc C sX | � |j�}t�d|� | �|j�}d|kr:t�d� dS d|kr\|d dkr\t�d� dS | j�|�}|dkr~t�d � dS t| jt �r�| j� |�}nd}| j � |||�}|s�t� d � dS t|j�tkr�d }t�|� |S t|j�}|r�d |k�r$d |k�rt�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�r4t�d� t�d| | � |S d |k�rTt�d� | j�|� dS )ze Return a cached response if it exists in the cache, otherwise return False. z Looking up "%s" in the cacher1 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: %ir0 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> rK rB r r9 � isinstancer �get_bodyr �loads�warningr8 �status�PERMANENT_REDIRECT_STATUSESr �delete�time�calendar�timegmr �max)r �requestr. �cc� cache_data� body_file�resp�msgrB �nowrL � current_age�resp_cc�freshness_lifetimerN � expire_time� min_freshr r r �cached_request} s� � � z CacheController.cached_requestc C s` | � |j�}| j�|| j�|��}i }|r\t|j�}d|krH|d |d< d|kr\|d |d< |S )NrM �ETagz If-None-Matchz last-modifiedz Last-ModifiedzIf-Modified-Since)r. rO r rR r r9 r rB )r r[ r. r_ � new_headersrB r r r �conditional_headers� s z#CacheController.conditional_headersc C s\ t | jt�r:| jj|| j�||d�|d� | j�||� n | jj|| j�|||�|d� dS )z. Store the data in the cache. � )rN N)rP r r �setr �dumps�set_body)r r. r[ �response�body� expires_timer r r � _cache_set s ��zCacheController._cache_setc C s� |p| j }|j|kr(t�d|j|� dS t|j�}d|krNt�t|d ��}nd}|dk r�d|kr�|d � � r�t |d �t |�kr�dS | � |j�}| � |�} | � |j�} t�d| � d} d| kr�d } t�d � d|kr�d } t�d � | �r| j�| ��rt�d � | j�| � | �rdS d |�dd�k�r8t�d� dS | j�r�d|k�r�d} |�d��r~t|d �} | dk �r~t�| �| } t| d�} t�d�| �� t�d� | �| |||| � n�t |j�tk�r�t�d� | �| ||d� n�d|k�r�t�t|d ��}d| k�r<| d dk�r<t�d� | d } | �| |||| � n`d|k�r�|d �r�t|d �} | dk �rvt�| �| } nd} t�d�| �� | �| |||| � dS )zc Algorithm for caching requests. This assumes a requests Response object. zStatus code %s not in %sNrL r �content-lengthz&Updating cache with response from "%s"Fr2 Tz Response header has "no-store"z Request header has "no-store"z0Purging existing cache entry to honor "no-store"�*�varyr5 z Response header has "Vary: *"rM rN i u z"etag object cached for {0} secondszCaching due to etagzCaching permanent redirectrk r/ z'Caching b/c date exists and max-age > 0z5Caching b/c of expires header. expires in {0} seconds)r rT r= r> r rB rX rY r �isdigitr8 �lenrK r. rO r r9 rV r rZ �formatrr rU )r r[ ro rp r r �response_headersrL �cc_reqr\ r. �no_storerq rN r r r �cache_response s� � �� �� � ���z CacheController.cache_responsec sl | � |j�}| j�|| j�|��}|s*|S dg� |j�t� 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. rs c 3 s& | ] \}}|� � � kr||fV qd S r- )r" )�.0�k�v��excluded_headersr r � <genexpr>� s �z9CacheController.update_cached_response.<locals>.<genexpr>r ) r. rO r rR r r9 rB �update�dict�itemsrT rr )r r[ ro r. �cached_responser r� r �update_cached_response� s �� z&CacheController.update_cached_response)NTNN)NN)NN)rA � __module__� __qualname__�__doc__r � classmethodr, r. rK rg rj rr r| r� r r r r r $ s � 6u {r )r� �logging�rerX rW � email.utilsr Z pip._vendor.requests.structuresr r r r � serializer � getLoggerrA r= �compiler rU r �objectr r r r r �<module> s