XlĔ d Z ddlmZ ddlZddlZddlZddlZddlZddlm Z ddl
m Z m Z m
Z
ddlmZ ddlmZmZ ddlmZ e rdd l
mZ dd
lmZ dd lmZ dd lmZ ej e Z ej d
Z dZ ddZ! G d d Z"dS )z7
The httplib2 algorithms ported for use with requests.
) annotationsN) parsedate_tz)
TYPE_CHECKING
CollectionMapping)CaseInsensitiveDict) DictCacheSeparateBodyBaseCache)
Serializer)Literal)PreparedRequest) HTTPResponse) BaseCachez9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?)- 4 uristrreturn tuple[str, str, str, str, str]c t | }|J | }|d |d |d |d |d fS )zParses a URI using the regex given in Appendix B of RFC 3986.
(scheme, authority, path, query, fragment) = parse_uri(uri)
N )URImatchgroups)r r r s u/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/pip/_vendor/cachecontrol/controller.py parse_urir ' sQ
IIcNNE
\\^^F 1Ivay&)VAYq BB c e Zd ZdZ d+d,d Zed-d Zed-d Zd.dZd/dZ d0dZ
d1d Z d2d3d&Z d2d4d)Z
d5d*ZdS )6CacheControllerz4An interface to see if request should cached or not.NTcacheBaseCache | None cache_etagsbool
serializerSerializer | None status_codesCollection[int] | Nonec ~ |t n|| _ || _ |p
t | _ |pd| _ d S )N) i, r r )r r$ r& r r( cacheable_status_codes)selfr$ r& r( r* s r __init__zCacheController.__init__5 sC %*MY[[[u
&$4
&2&O6O###r! r r r c t | \ }}}}}|r|st d|z | }| }|sd}|rd ||g p|}|dz |z |z }|S )z4Normalize the URL to create a safe key for the cachez(Only absolute URIs are allowed. uri = %s/?z://)r Exceptionlowerjoin) clsr scheme authoritypathqueryfragment request_uri
defrag_uris r _urlnormzCacheController._urlnormA s 6?s^^2D% NY N F LMM M OO%% D 7$ 7 7?4 e^i/+=
r! c , | | S )N)r@ )r8 r s r cache_urlzCacheController.cache_urlU s ||C r! headersMapping[str, str]dict[str, int | None]c
t dft dft dfddddddddt dfd }| d| dd }i }| d D ]
}| s| d d
}|d } || \ }} n+# t $ r t
d | Y |w xY w|r| sd ||< |r ||d
||< # t $ r | rt
d
| Y t $ r% t
d||j Y w xY w|S )NTF)NF) max-agez max-stale min-freshno-cacheno-storez no-transformzonly-if-cachedzmust-revalidatepublicprivatezproxy-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)
intgetsplitstripKeyErrorloggerdebug
IndexError
ValueError__name__)
r0 rC known_directives
cc_headersretval cc_directiveparts directivetyprequireds
r parse_cache_controlz#CacheController.parse_cache_controlY s T{ u t%% ) + ,#$ - d
[[ '++or2R2RSS
(* & , ,S 1 1 L %%''
&&sA..E a((I
0 ;
XX
KYWWW
)h
)$(y!
(+E!HNN,<,<(=(=F9%%! N % " LLU!
s* 6 C%C*)C*9&D 'E7 *E76E7requestr
HTTPResponse | Nonec d|j v rdS |j }|J | j | }| t d dS t
| j t r| j | }nd}| j
||| }|t d |S )zO
Load a cached response, or return None if it's not available.
RangeNzNo cache entry availablez1Cache entry deserialization failed, entry ignored) rC urlr$ rQ rU rV
isinstancer
get_bodyr( loadswarning)r0 rc rB
cache_data body_fileresults r _load_from_cachez CacheController._load_from_cache s go % %4K $$$Z^^I..
LL3 4 4 44 dj"7 8 8
++I66II I &&w
IFF > NNN O O O
r! HTTPResponse | Literal[False]c |j J | |j }t d| | |j }d|v r t d dS d|v r(|d dk r t d dS | | }|sdS t |j t v r d }t | |S t |j }|rd
|vrTd |vr4t d | j | t d
dS t j
}t |d
}|J t j |dd } t# d|| z
}
t d|
| | } d} | d }
|
|
} t d| ned|v rat |d }|Jt j |dd | z
}t# d| } t d| | d }
|
|
} t d| | d }| |
|z
}
t d|
| |
k r8t d t d| |
|S d |vr4t d | j | dS )ze
Return a cached response if it exists in the cache, otherwise
return False.
Nz Looking up "%s" in the cacherI z-Request header has "no-cache", cache bypassedFrG r z1Request 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 dater z Current age based on date: %iz#Freshness lifetime from max-age: %iexpiresz#Freshness lifetime from expires: %iz+Freshness lifetime from request max-age: %irH z'Adjusted current age from min-fresh: %iz2The response is "fresh", returning cached responsez%i > %iz4The cached response is "stale" with no etag, purging)rg rB rU rV rb rC ro rP statusPERMANENT_REDIRECT_STATUSESr r$ deletetimer calendartimegmmaxrQ )r0 rc rB ccrespmsgrC now
time_tuplerr current_ageresp_ccfreshness_lifetimemax_agert expire_time min_freshs r cached_requestz CacheController.cached_request s~
{&&&NN7;// 3Y???
%
%go
6
6 LLH I I I5 ??r)} 1 1 LLL M M M5 $$W-- 5 t{ : : :7
LL K,? ,M,M &//W$$ GHHH
!!),,, LL< = = =5ikk!'&/22
%%%z"1"~..!S4Z(( 4kBBB **733 ++i(( !( LL>@R S S S S '
!
!"79#566G" &ogbqbk : :T A %(K%8%8" BDVWWW &&## !( LL=?Q
FF;'' 9 $K LLBK P P P + + LLM N N N LL$6 D D DK LLO P P P J i ( ( ( ur! dict[str, str]c | | }i }|r2t |j }d|v r |d |d< d|v r |d |d< |S )Nrs ETagz
If-None-Matchz
last-modifiedz
Last-ModifiedzIf-Modified-Since)ro r rC )r0 rc r} new_headersrC s r conditional_headersz#CacheController.conditional_headers sl $$W-- L0CDL0Q0QG /6v O, '))3:?3K /0r! rB responser body bytes | None expires_time
int | NoneNonec X t | j t rX| j || j ||d | | | j || dS dS | j || j ||| | dS )z.
Store the data in the cache.
r! )rt N)rh r$ r
setr( dumpsset_body)r0 rB rc r r r s r
_cache_setzCacheController._cache_set& s dj"7 8 8
JNN%%gx==$
##It44444
JNN%%gx>>$
r! response_or_ref2HTTPResponse | weakref.ReferenceType[HTTPResponse]c t |t j r | }|dS n|}|p| j }|j |vr#t
d|j | dS t |j }d|v r6t |d }|J t j |dd } nd} |Fd|v rB|d r(t |d t | k rdS | |j }
| | } |j J | |j } t
d| d}
d | v r d
}
t
d d |
v r d
}
t
d |
rN| j | r4t
d
| j | |
rdS d| dd v r t
d dS | j rd|v rd}| d r6t |d }| t j |dd | z
}t- |d }t
d| d t
d | | |||| dS t |j t0 v r4t
d | | ||d dS d|v rt |d }|J t j |dd } | d }|=|dk r7t
d |}| | |||| dS d|v r|d rt |d }| t j |dd | z
}nd}t
d | | | |||| dS dS dS dS ) zc
Algorithm for caching requests.
This assumes a requests Response object.
NzStatus code %s not in %srr r r content-lengthz&Updating cache with response from "%s"FrJ Tz Response header has "no-store"z Request header has "no-store"z0Purging existing cache entry to honor "no-store"*varyrM z Response header has "Vary: *"rs rt i u zetag object cached for z secondszCaching due to etagzCaching permanent redirectr! rG z'Caching b/c date exists and max-age > 0z4Caching b/c of expires header. expires in {} seconds)rh weakref
ReferenceTyper/ ru rU rV r rC r ry rz isdigitrP lenrb rg rB r$ rQ rw r& r{ r rv format)r0 rc r r r* r r/ response_headersr rr cc_reqr| rB no_storer rt r s r cache_responsez CacheController.cache_responseD s ow'< = = '&((H 'H ".!L1L ?"8 8 8 LL*HO=S
F5H 6
6
% % %%&6v&>??J )))?:bqb>22DDD
$444 !12::<< 5$%56773t99DD F))'/::
%
%&6
7
7{&&&NN7;// =yIII H LL9 : : : H LL8 9 9 9 )
y11 ) LLK L L L J i ( ( ( F "&&vr22 2 2 LL8 9 9 9 F < *: : : L ##I..
G&'7 'BCC&#+?72A2;#?#?$#FL |Z88L LLI<III J J J LL. / / / OOIw$ M M M M M
!
!%@
@
@ LL5 6 6 6 OOIw# > > > > >
'
'
'%&6v&>??J )))?:bqb>22DffY''G"w{{ FGGG & ...#I. *+;I+F G GG *'/wrr{'C'Cd'J '+ LLNUU (
OO! $ A (
'& /. r! c < |j J | |j }| | }|s|S dg|j fd|j D d|_ | ||| |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.
Nr c H i | ] \ }}| v|| S )r6 ).0kvexcluded_headerss r
z:CacheController.update_cached_response.. s=
Aq7799$444 1444r! r- )rg rB ro rC updateitemsru r )r0 rc r rB cached_responser s @r update_cached_responsez&CacheController.update_cached_response s {&&&NN7;// //88 O -- &&
$ , 2 2 4 4
"%
7O<<< r! )NTNN)r$ r% r& r' r( r) r* r+ )r r r r )rC rD r rE )rc r
r rd )rc r
r rp )rc r
r r )NN) rB r rc r
r r r r r r r r )
rc r
r r r r r* r+ r r )rc r
r r r r )rY
__module__ __qualname____doc__r1 classmethodr@ rB rb ro r r r r r r r! r r# r# 2 s9 >> #' (,/3
P
P
P
P
P [& ! ! ! [!4 4 4 4l 4l l l l\
( "#'
D "/3 Q Q Q Q Qf( ( ( ( ( ( r! r# )r r r r )#r
__future__r ry loggingrerx r email.utilsr typingr r r pip._vendor.requests.structuresr pip._vendor.cachecontrol.cacher r
"pip._vendor.cachecontrol.serializer r pip._vendor.requestsr
pip._vendor.urllib3r r getLoggerrY rU compiler rv r r# r r! r r s
# " " " " " $ $ $ $ $ $ 5 5 5 5 5 5 5 5 5 5 ? ? ? ? ? ? K K K K K K K K 9 9 9 9 9 9 9 444444000000888888 8 $ $bjMNN ( C C C CM M M M M M M M M M r!