o ҷhJ@sdZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZe rZdd l mZdd lmZdd lmZdd lmZeeZed ZdZ dddZ!GdddZ"dS)z7 The httplib2 algorithms ported for use with requests. ) annotationsN) parsedate_tz) TYPE_CHECKING CollectionMapping)CaseInsensitiveDict) DictCacheSeparateBodyBaseCache) Serializer)Literal)PreparedRequest) HTTPResponse) BaseCachez9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?)-4uristrreturntuple[str, str, str, str, str]cCs@t|}|dus J|}|d|d|d|d|dfS)zParses a URI using the regex given in Appendix B of RFC 3986. (scheme, authority, path, query, fragment) = parse_uri(uri) N)URImatchgroups)rrrrV/var/www/html/venv/lib/python3.10/site-packages/pip/_vendor/cachecontrol/controller.py parse_uri's  "rc@seZdZdZ    d5d6d d Zed7ddZed7ddZd8ddZd9ddZ d:d d!Z d;d#d$Z  dd1d2Z d?d3d4ZdS)@CacheControllerz4An interface to see if request should cached or not.NTcacheBaseCache | None cache_etagsbool serializerSerializer | None status_codesCollection[int] | NonecCs4|durtn||_||_|pt|_|pd|_dS)N)i,rr)rr!r#r r%cacheable_status_codes)selfr!r#r%r'rrr__init__5s zCacheController.__init__rrrc Csht|\}}}}}|r |std||}|}|sd}|r(d||gp)|}|d||}|S)z4Normalize the URL to create a safe key for the cachez(Only absolute URIs are allowed. uri = %s/?z://)r Exceptionlowerjoin) clsrscheme authoritypathqueryfragment request_uri defrag_urirrr_urlnormAs zCacheController._urlnormcCs ||S)N)r;)r3rrrr cache_urlUs zCacheController.cache_urlheadersMapping[str, str]dict[str, int | None]c Cstdftdftdfddddddddtdfd }|d|dd}i}|dD]c}|s/q(|d d }|d }z||\}} WntyRtd |Yq(w|rW| s[d||<|rz ||d ||<Wq(tyz| rxtd |Yq(tytd||j Yq(wq(|S)NTF)NF) max-agez max-stale min-freshno-cacheno-storez no-transformzonly-if-cachedzmust-revalidatepublicprivatezproxy-revalidatezs-maxagez cache-controlz Cache-Control,=rrz,Ignoring unknown cache-control directive: %sz-Missing value for cache-control directive: %sz8Invalid value for cache-control directive %s, must be %s) intgetsplitstripKeyErrorloggerdebug IndexError ValueError__name__) r,r=known_directives cc_headersretval cc_directiveparts directivetyprequiredrrrparse_cache_controlYs^      z#CacheController.parse_cache_controlrequestr HTTPResponse | NonecCsd|jvrdS|j}|dusJ|j|}|dur!tddSt|jtr.|j|}nd}|j |||}|durAt 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!rJrNrO isinstancer get_bodyr%loadswarning)r,r\r< cache_data body_fileresultrrr_load_from_caches      z CacheController._load_from_cacheHTTPResponse | Literal[False]cCs6|jdusJ||j}td|||j}d|vr$tddSd|vr5|ddkr5tddS||}|s>dSt|jt vrNd }t||St |j}|rYd |vrod |vrhtd |j |td dSt }t|d }|dusJt|dd} td|| } td| ||} d} | d} | dur| } td| n$d|vrt|d}|durt|dd| }td|} td| |d} | dur| } td| |d}|dur| |7} td| | | kr tdtd| | |Sd |vrtd|j |dS)ze Return a cached response if it exists in the cache, otherwise return False. NzLooking up "%s" in the cacherBz-Request header has "no-cache", cache bypassedFr@rz1Request header has "max_age" as 0, cache bypassedzQReturning cached permanent redirect response (ignoring date and etag information)dateetagz(Purging cached response: no date or etagz!Ignoring cached response: no daterzCurrent age based on date: %iz#Freshness lifetime from max-age: %iexpiresz#Freshness lifetime from expires: %iz+Freshness lifetime from request max-age: %irAz'Adjusted current age from min-fresh: %iz2The response is "fresh", returning cached responsez%i > %iz4The cached response is "stale" with no etag, purging)r_r<rNrOr[r=rgrIstatusPERMANENT_REDIRECT_STATUSESrr!deletetimercalendartimegmmaxrJ)r,r\r<ccrespmsgr=now time_tupleri current_ageresp_ccfreshness_lifetimemax_agerk expire_time min_freshrrrcached_requestsz                             zCacheController.cached_requestdict[str, str]cCsH||}i}|r"t|j}d|vr|d|d<d|vr"|d|d<|S)NrjETagz If-None-Matchz last-modifiedz Last-ModifiedzIf-Modified-Since)rgrr=)r,r\rt new_headersr=rrrconditional_headerss    z#CacheController.conditional_headersr<responser body bytes | None expires_time int | NoneNonecCsjt|jtr$|jj||j||d|d|dur"|j||dSdS|jj||j||||ddS)z. Store the data in the cache. )rkN)r`r!r setr%dumpsset_body)r,r<r\rrrrrr _cache_set&s  zCacheController._cache_setresponse_or_ref2HTTPResponse | weakref.ReferenceType[HTTPResponse]cCst|tjr|}|durdSn|}|p|j}|j|vr&td|j|dSt|j}d|vrEt |d}|dus;Jt |dd} nd} |durad|vra|d rat |dt|kradS||j} ||} |jdussJ||j} td| d} d | vrd } td d | vrd } td | r|j| rtd |j| | rdSd|ddvrtddS|jrd|vrd}|drt |d}|durt |dd| }t|d}td|dtd|| ||||dSt |jtvrtd|| ||ddSd|vrt |d}|dus'Jt |dd} | d}|durQ|dkrQtd|}|| ||||dSd|vr|drt |d}|durrt |dd| }nd}td||| ||||dSdSdSdS)zc Algorithm for caching requests. This assumes a requests Response object. NzStatus code %s not in %srirrcontent-lengthz&Updating cache with response from "%s"FrCTzResponse header has "no-store"zRequest header has "no-store"z0Purging existing cache entry to honor "no-store"*varyrFzResponse header has "Vary: *"rjrkiuzetag object cached for z secondszCaching due to etagzCaching permanent redirectrr@z'Caching b/c date exists and max-age > 0z4Caching b/c of expires header. expires in {} seconds)r`weakref ReferenceTyper+rlrNrOrr=rrprqisdigitrIlenr[r_r<r!rJrnr#rrrrmformat)r,r\rrr'rr+response_headersrwricc_reqrsr<no_storerrkr{rrrcache_responseDs                           zCacheController.cache_responsecsj|jdusJ||j}||}|s|Sdg|jfdd|jDd|_|||||S)zOn 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. Nrcs"i|] \}}|vr||qSr)r1).0kvexcluded_headersrr s  z:CacheController.update_cached_response..r))r_r<rgr=updateitemsrlr)r,r\rr<cached_responserrrupdate_cached_responses     z&CacheController.update_cached_response)NTNN)r!r"r#r$r%r&r'r()rrrr)r=r>rr?)r\r rr])r\r rrh)r\r rr)NN) r<rr\r rr rrrrrr) r\r rrrrr'r(rr)r\r rr rr )rR __module__ __qualname____doc__r- classmethodr;r<r[rgr~rrrrrrrrr 2s.     6  n " r )rrrr)#r __future__rrploggingreror email.utilsrtypingrrrpip._vendor.requests.structuresrpip._vendor.cachecontrol.cacherr "pip._vendor.cachecontrol.serializer r pip._vendor.requestsr pip._vendor.urllib3r r getLoggerrRrNcompilerrmrr rrrrs,