a
    ¦Oc @  ã                   @   sŒ   d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl	m
Z
mZ ddlmZ e e¡Ze d¡Zd	Zd
d„ ZG dd„ deƒZdS )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 fS )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   ú[/var/www/html/megastudio/lib/python3.9/site-packages/pip/_vendor/cachecontrol/controller.pyÚ	parse_uri   s    r   c                   @   sf   e Zd ZdZddd„Zedd„ ƒZedd	„ ƒZd
d„ Zdd„ Z	dd„ Z
ddd„Zddd„Zdd„ ZdS )ÚCacheControllerz4An interface to see if request should cached or not.NTc                 C   s4   |d u rt ƒ 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    zCacheController.__init__c           	      C   sh   t |ƒ\}}}}}|r|s&td| ƒ‚| ¡ }| ¡ }|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_uriZ
defrag_urir   r   r   Ú_urlnorm/   s    zCacheController._urlnormc                 C   s
   |   |¡S ©N)r+   )r$   r   r   r   r   Ú	cache_urlC   s    zCacheController.cache_urlc           
      C   s"  t dft dft dfddddddddt dfdœ}| d| dd¡¡}i }| d¡D ]Ì}| ¡ s^qP| d	d
¡}|d  ¡ }z|| \}}	W n" ty¨   t d|¡ Y qPY n0 |r²|	sºd ||< |rPz||d
  ¡ ƒ||< W qP tyø   |	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-transformzonly-if-cachedzmust-revalidateÚpublicÚprivatezproxy-revalidatezs-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   ÚheadersZknown_directivesZ
cc_headersÚretvalZcc_directiveÚpartsZ	directiveÚtypÚrequiredr   r   r   Úparse_cache_controlG   sV    ó
þýz#CacheController.parse_cache_controlc                 C   sX  |   |j¡}t d|¡ |  |j¡}d|v r:t d¡ dS d|v r\|d dkr\t d¡ dS | j |¡}|du r~t d	¡ dS t| jt	ƒr˜| j 
|¡}nd}| j |||¡}|s¾t d
¡ dS t|jƒtv rÞd}t |¡ |S t|jƒ}|röd|vr$d|vrt d¡ | j |¡ t d¡ dS t ¡ }	t t|d ƒ¡}
td|	|
 ƒ}t d|¡ |  |¡}d}d|v r†|d }t d|¡ nDd|v rÊt|d ƒ}|durÊt |¡|
 }td|ƒ}t d|¡ d|v rè|d }t d|¡ d|v r|d }||7 }t d|¡ ||kr4t d¡ t d||¡ |S d|vrTt d¡ | j |¡ dS )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 bypassedNzNo 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=   rF   rA   r   r8   Ú
isinstancer   Úget_bodyr   ÚloadsÚwarningr7   ÚstatusÚPERMANENT_REDIRECT_STATUSESr   ÚdeleteÚtimeÚcalendarÚtimegmr   Úmax)r   Úrequestr-   ÚccZ
cache_dataZ	body_fileÚrespÚmsgrA   ÚnowrG   Zcurrent_ageZresp_ccZfreshness_lifetimerI   Zexpire_timeZ	min_freshr   r   r   Úcached_request}   s€    



ÿ










ÿ




zCacheController.cached_requestc                 C   s`   |   |j¡}| j || j |¡¡}i }|r\t|jƒ}d|v rH|d |d< d|v r\|d |d< |S )NrH   ZETagzIf-None-Matchzlast-modifiedzLast-ModifiedzIf-Modified-Since)r-   rJ   r   rM   r   r8   r   rA   )r   rV   r-   rX   Znew_headersrA   r   r   r   Úconditional_headersò   s    
z#CacheController.conditional_headersc                 C   s\   t | jtƒr:| jj|| j ||d¡|d | j ||¡ n| jj|| j |||¡|d dS )z.
        Store the data in the cache.
        ó    )rI   N)rK   r   r   Úsetr   ÚdumpsZset_body)r   r-   rV   ÚresponseÚbodyÚexpires_timer   r   r   Ú
_cache_set  s    ýýzCacheController._cache_setc                 C   s   |p| j }|j|vr(t d|j|¡ dS t|jƒ}d|v rNt t|d ƒ¡}nd}|dur†d|v r†|d  	¡ r†t
|d ƒt|ƒkr†dS |  |j¡}|  |¡}	|  |j¡}
t d|
¡ d}d|	v rÎd	}t d
¡ d|v räd	}t d¡ |r| j |
¡rt d¡ | j |
¡ |rdS d| dd¡v r8t d¡ dS | jr¶d|v r¶d}| d¡r~t|d ƒ}|dur~t |¡| }t|dƒ}t d |¡¡ t d¡ |  |
||||¡ næt
|jƒtv rât d¡ |  |
||d¡ nºd|v rœt t|d ƒ¡}d|	v r<|	d dkr<t d¡ |	d }|  |
||||¡ n`d|v rœ|d rœt|d ƒ}|durvt |¡| }nd}t d |¡¡ |  |
||||¡ dS )zc
        Algorithm for caching requests.

        This assumes a requests Response object.
        zStatus code %s not in %sNrG   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"Ú*Zvaryr4   zResponse header has "Vary: *"rH   rI   i u z"etag object cached for {0} secondszCaching due to etagzCaching permanent redirectr]   r.   z'Caching b/c date exists and max-age > 0z5Caching b/c of expires header. expires in {0} seconds)r   rO   r<   r=   r   rA   rS   rT   r   Úisdigitr7   ÚlenrF   r-   rJ   r   r8   rQ   r   rU   Úformatrc   rP   )r   rV   r`   ra   r   r   Zresponse_headersrG   Zcc_reqrW   r-   Zno_storerb   rI   r   r   r   Úcache_response  s¢    

ÿ
ÿþ
ýü










û



ÿÿûzCacheController.cache_responsec                    sl   |   |j¡}| j || j |¡¡}|s*|S dg‰ |j t‡ fdd„|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.
        rd   c                 3   s&   | ]\}}|  ¡ ˆ vr||fV  qd S r,   )r"   )Ú.0ÚkÚv©Zexcluded_headersr   r   Ú	<genexpr>ª  s   þz9CacheController.update_cached_response.<locals>.<genexpr>r   )r-   rJ   r   rM   r   r8   rA   ÚupdateÚdictÚitemsrO   rc   )r   rV   r`   r-   Úcached_responser   rm   r   Úupdate_cached_response‘  s    	þÿ	z&CacheController.update_cached_response)NTNN)NN)NN)r@   Ú
__module__Ú__qualname__Ú__doc__r   Úclassmethodr+   r-   rF   r[   r\   rc   ri   rs   r   r   r   r   r   $   s    ÿ


6u

{r   )rv   ÚloggingÚrerS   rR   Úemail.utilsr   Úpip._vendor.requests.structuresr   r   r   r   Ú	serializer   Ú	getLoggerr@   r<   Úcompiler   rP   r   Úobjectr   r   r   r   r   Ú<module>   s   

	