}DjhIddlmZmZddlmZmZddlmZmZmZm Z m Z m Z m Z ddl mZmZddlmZmZddlmZddlmZdd lmZdd lmZd d lmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%d d l&m'Z'erddlm(Z(m)Z)gdZ*ee+Z,edGddeZ-dede'de.fdZ/de e0e0fde e0e0fdee0fdZ1de0defdZ2y) )datetime timedelta)DEBUG getLogger) TYPE_CHECKINGDictListMappingMutableMappingOptionalUnion)definefield)PreparedRequestResponse)CaseInsensitiveDict)coalesce)normalize_headers) RichMixin) DO_NOT_CACHEEXPIRE_IMMEDIATELY NEVER_EXPIRECacheDirectivesExpirationTime KeyCallbackget_expiration_datetimeget_expiration_secondsget_url_expirationutcnow) CacheSettings) CachedRequestCachedResponse)zX-HTTP-Method-Overridez X-HTTP-MethodzX-Method-OverrideF)reprc .eZdZUdZeddZeed<edZe ed<edZ e ed<edZ e ed <edZ e ed <edZe ed <edZe ed <edZe ed <edZeeed<eddZeed<eddZeed<eddZe ed<eddZe ed<eddZeed<eddZee e fed<eddZee e fed<eedZe eefed<e! d0dededeefdZ"e#dee$fdZ%d1dedde fd Z& d0dedd!ee'fd"Z(d#e)fd$Z*dedefd%Z+d#e)ddddfd&Z,d'efd(Z-d2d)Z.ddd!e'de fd*Z/d+d,de fd-Z0d.e1edee1ee ffd/Z2y)3 CacheActionsaTranslates cache settings and headers into specific actions to take for a given cache item. The resulting actions are then handled in :py:meth:`CachedSession.send`. .. rubric:: Notes * See :ref:`precedence` for behavior if multiple sources provide an expiration * See :ref:`headers` for more details about header behavior * The following arguments/properties are the outputs of this class: Args: cache_key: The cache key created based on the initial request error_504: Indicates the request cannot be fulfilled based on cache settings expire_after: User or header-provided expiration value send_request: Send a new request resend_request: Send a new request to refresh a stale cache item resend_async: Return a stale cache item, and send a non-blocking request to refresh it skip_read: Skip reading from the cache skip_write: Skip writing to the cache NF)defaultr% cache_key)r( error_504 expire_after send_requestresend_request resend_async skip_read skip_writevary_cache_key _directives _settings_only_if_cached_refresh_request_stale_if_error_stale_while_revalidate)factoryr%_validation_headersrequestsettingsc |xs t}tj|j}tj d|t |jt|j|j|j}|jxs |tk(}|jxs |j}|j xs |j }|jt"k(xs |j$} |j&xs |j&} |j(xs |j(} |j*t-|| ||d} t/d| |||||| ||t1| j3|j| |  } | S)aiInitialize from request info and cache settings. Note on refreshing: `must-revalidate` isn't a standard request header, but is used here to indicate a user-requested refresh. Typically that's only used in response headers, and `max-age=0` would be used by a client to request a refresh. However, this would conflict with the `expire_after` option provided in :py:meth:`.CachedSession.request`. Args: cache_key: The cache key created based on the initial request request: The outgoing request settings: Session-level cache settings z'Cache directives from request headers: )disabled cachedisabled methodzdisabled by headers or refreshdisabled by expirationread) r) directivesr+only_if_cachedrefreshr;r<r/r0stale_if_errorstale_while_revalidate)r"r from_headersheadersloggerdebugrmax_ager urlurls_expire_afterr+actual_no_cacherno_cacheno_storerCrmust_revalidaterErFdisabled_is_method_allowed_log_cache_criteriaanyvalues)clsr)r;r<rBr+rNkinda_no_cacherCrDrErF read_criteriaactionss i/var/www/html/Astrologybackend/backend/venv/lib/python3.12/site-packages/requests_cache/policy/actions.py from_requestzCacheActions.from_requestTso&.}$11'//B  >zlKL    w{{H,F,F G  ! ! %44T 8T#,,C 0C0C!00MJ4M4M$$(::Xj>X>X!00MJ4M4M  + + Pz/P/P  '//#5gx#HH.<&5  FM2!%)-..01!**)#9  returnc,t|jS)zConvert the user/header-provided expiration value to a datetime. Applies to new cached responses, and previously cached responses that are being revalidated. )rr+)selfs r[expireszCacheActions.expiress 't'8'899r]cached_responser$errorc|y|j*|jr|jdus|r|jdury|r,|jr t t |j}nR|jr,|jr t t |j}n|j j}t|j|zkS)zDetermine whether a given cached response is "fresh enough" to satisfy the request, based on: * min-fresh * max-stale * stale-if-error (if an error has occurred) * stale-while-revalidate FT)seconds) ra is_expiredr8r7rrr2get_expire_offsetr!)r`rbrcoffsets r[ is_usablezCacheActions.is_usables  "  # # +**t/K/Kt/S$..$6 t++'=d>R>R'STF  ' 'D,H,H'=d>Z>Z'[\F%%779Fx/11F:::r] create_keyc |j|}|j|d}|s|jr |sd|_na|d|_nW|r|j||fi|sd|_n9|s|jr|sd|_n!|j r|r|jrd|_||js|j|tjd|y)aDetermine if we can reuse a cached response, or set headers for a conditional request if possible. Used after fetching a cached response, but before potentially sending a new request. Args: cached_response: Cached response to examine create_key: Cache key function, used for validating ``Vary`` headers key_kwargs: Additional keyword arguments for ``create_key``. T)rcNzPost-read cache actions: ) rir4r*r,_validate_varyr-rfr8r._update_validation_headersrIrJ)r`rbrj key_kwargsusable_responseusable_if_errors r[update_from_cached_responsez(CacheActions.update_from_cached_responses ..9...E4#7#7!DN  $ $D   3 3 3OZ ^S] ^ $D  $*>*>?"&D   ' 'O@\@\ $D   &t/C/C  + +O < 078r]responsectj|j}|jjr|j ||j tk(xr |j }|j tk(}|jj}|duxr || }|jjt|j|j |j|jjv||j |xs||jj"d}t%|j'|_t)d|y)zUpdate expiration + actions based on headers and other details from a new response. Used after receiving a new response, but before saving it to the cache. N)r>r?zdisabled statuszdisabled by filterzdisabled by headersr@zdisabled by read-onlywrite)rrGrHr3 cache_control_update_from_response_headersr+r has_validatorr filter_fnrRrSr; status_codeallowable_codesr0 read_onlyrUrVrT)r`rrrB skip_stale do_not_cachecallback filtered_outwrite_criterias r[update_from_responsez!CacheActions.update_from_responses %11(2B2BC >> ' '  . .z :&&*<<]ZE]E]A] ((L8 >>++t+FHX4F0F #nn55#5h6F6F#WW'334>>;Y;YY".#'??&2&@j%)^^%=%= n3356G^4r]cP|jj|j|S)z:Apply validation headers (if any) before sending a request)rHupdater:)r`r;s r[update_requestzCacheActions.update_requestst778r]cdtjd|jjdt fd|j j D}|jjk7}|jjxs.|jjxs|jj}|xs|xs| |_ |j_j j|j dj vrdj vr j d=d_S)zGAfter revalidation, update the cached response's expiration and headerszResponse for URL z has not been modifiedc3`K|]%\}}jj||k7'ywN)rHget).0kvrbs r[ z;CacheActions.update_revalidated_response.. s0 48AqO # # ' ' *a / s+.zContent-LengthzTransfer-EncodingT)rIrJr;rLrUrHitemsrar3r{rRr2rPr0r revalidated)r`rrrbheaders_changedexpiration_changedpermanent_skips ` r[update_revalidated_responsez(CacheActions.update_revalidated_responses  ()9)9)=)=(>>TUV  '>>''(89&*#r]rBc@tjd||jxs |j|_|jr t |_n0t|j|j|j |_|jxs |j|_ y)z@Check response headers for expiration and other cache directivesz(Cache directives from response headers: N) rIrJr7rE immutablerr+rrKrar0rP)r`rBs r[rvz*CacheActions._update_from_response_headers"s ? |LM#33Pz7P7P    ,D  (""""!!!D  //@Z-@-@r]ctj|j}|jxr2|jxs$|j xs|j j}|j jxr|jxs |j}|s|rY|jr|j|jd<|jr|j|jd<d|_d|_yy)zIf needed, get validation headers based on a cached response. Revalidation may be triggered by a stale response, request headers, or cached response headers. z If-None-MatchzIf-Modified-SinceFTN)rrGrHrwrfr5r3always_revalidaterurOrQetagr: last_modifiedr,r-)r`rbrB revalidate cc_revalidates r[rmz'CacheActions._update_validation_headers1s%11/2I2IJ --  & & [$-- [4>>;[;[ 44    =:#=#=  .is !U!t}}'<'<".normalize_cookiessJ3:=b2G2G2IJ$!QaS!:JKJ99VK01 1KsA_cookiesN)r r strrgetattrr6)r`rrcached_cookiesrequest_cookiess r[rzCacheActions._cookies_matchsN 2x'8 2S 2+>+A+AB+GDMM:t,TU.00r] vary_headersc |jj}|dury|s|Stt||Dcgc]}|j c}zScc}w)z}Merge Vary headers with user-configured match_headers to build a complete set of headers for the secondary cache key.T)r3rrrr)r`r user_headersrs r[rz!CacheActions._merge_match_headerssP~~33 4  c,\)J!''))JJKLL)JsAr)F)rbr$)3__name__ __module__ __qualname____doc__rr)r__annotations__r*boolr+rr,r-r.r/r0r1r r2rr3r"r4r5r6rr7r r8dictr:r classmethodr\propertyrrarirrqrrrrrvrmrlrr rr]r[r'r''s*4e4Is4E*It*#(#6L.6u-L$- /ND/u-L$-E*It*U+J+$)$$7NHSM7$)E#BKB$T>I}>"%e.s(RQq}@h&@&@!@@Rs!)rHrMETHOD_OVERRIDE_HEADERSrmethodrU)r;r<rHrmethodss ` r[rSrSsXoo6!4!6G'>?!w{{1~?G? G R'R RR@sA  headers_1 headers_2rctjtkDryt|}t|}|Dcgc](}|j ||j |k7s'|*}}tj ddj |ycc}w)z:Log which specific headers specified by Vary did not matchNz)Failed Vary check. Non-matching headers: , )rIlevelrrrrJr)rrrr nonmatchings r[rrsw ||e!),I!),I"KimmA&6)--:J&J1KKK LLrs($VVV.3*   $6 8 UjM9jMjMZ SS=STS Wc3h' Wc3h' W s) W<3<$