}Dj<pdZddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z mZmZmZmZmZmZmZdd lmZdd lmZdd lmZmZd d lmZmZd dlm Z m!Z!d dl"m#Z#m$Z$m%Z%d dl&m'Z'm(Z(e)e*e e+e,fZ-e e.Z/GddZ0edZ1edZ2Gddee1e2feZ3Gddee3Z4y)zwBase classes for all cache backends .. automodsumm:: requests_cache.backends.base :classes-only: :nosignatures: ) annotations)ABC)UserDict)datetime) getLogger) PickleError) TYPE_CHECKINGIterableIteratorListMutableMappingOptionalTypeVarUnion)warn)Path)RequestResponse) create_keyredact_response) AnyRequestCachedResponse)DEFAULT_CACHE_NAME CacheSettingsExpirationTime)SerializerTypeinit_serializerc$eZdZdZefddZeddZdddZ d ddZ dZ dZ d dd Z d d d Z d d dddd d  d!dZdZ d" d#dZdZdd$dZdd$dZd%dZd&dZdZdZy)' BaseCacheaBase class for cache backends. Can be used as a non-persistent, in-memory cache. This manages higher-level cache operations, including: * Saving and retrieving responses * Managing redirect history * Convenience methods for general cache info * Dict-like wrapper methods around the underlying storage Notes: * Lower-level storage operations are handled by :py:class:`.BaseStorage`. * To extend this with your own custom backend, see :ref:`custom-backends`. Args: cache_name: Cache prefix or namespace, depending on backend serializer: Serializer name or instance kwargs: Additional backend-specific keyword arguments c l||_t|_t|_t |_yN) cache_name DictStorage responses redirectsr _settings)selfr#kwargss h/var/www/html/Astrologybackend/backend/venv/lib/python3.12/site-packages/requests_cache/backends/base.py__init__zBaseCache.__init__6s$$;F=0; &ct)zPath to the cache database file. Raises: NotImplementedError: For backends that do not use a file-based database. )NotImplementedErrorr(s r*db_pathzBaseCache.db_path<s "!r,Nc |jj|}||j|j|}|S#ttf$r|cYSwxYw)zRetrieve a response from the cache, if it exists Args: key: Cache key for the response default: Value to return if `key` is not in the cache )r%getr&AttributeErrorKeyError)r(keydefaultresponses r* get_responsezBaseCache.get_responseHsV ~~))#.H>>$..*=>O) N s:=AAct|xs|j|j}tj||}t ||j j }||j|<|jrG|js:|jD]*}||j|j|j<,yyy)zSave a response to the cache Args: cache_key: Cache key for this response; will otherwise be generated based on request response: Response to save expires: Absolute expiration time for this response )expiresN) rrequestr from_responserr'ignored_parametersr%history revalidatedr&)r(r7 cache_keyr:cached_responsers r* save_responsezBaseCache.save_responseWsB1A1A!B (66xQ)/4>>;\;\]$3y!   O$?$?%% G=Ftqyy9: G%@ r,ctjd|jj|jjy)zDelete all items from the cachez!Clearing all items from the cacheN)loggerinfor%clearr&r/s r*rGzBaseCache.clearns/ 78  r,ctjd|jj|jjy)"Close any open backend connectionszClosing backend connectionsN)rEdebugr%closer&r/s r*rKzBaseCache.closets/ 23  r,c *|jj|jjnt}|d||jj|jj|xs|jj |j jd|S)z3Create a normalized cache key from a request object)r;r=content_root_key match_headers serializer)r'key_fnrr=rMrNr%rO)r(r;rNr)rQs r*rzBaseCache.create_keyzs}+/..*?*?*K&&Q[ #~~@@!^^<<'G4>>+G+G~~00     r,Tc|r td|}|r|s|j||}||jvxs||jvS)acCheck if the specified request is cached Args: key: Check for a specific cache key request: Check for a matching request, according to current request matching settings url: Check for a matching GET request with the specified URL verify: Check for requests with or without SSL verification GETverify)rrr%r&)r(r5r;urlrUs r*containszBaseCache.containssG eS)G 3//'&/9Cdnn$=t~~(==r,F)expiredinvalid older_thanrequestsurlsrUcX|r t|ng}|r8t|xsg|D cgc]} td| jc} z}|r$||D cgc]} |j| |c} z }|j d|||D]} |j | j tjdt|dt|dk(r |j|d=n|jj||jy cc} wcc} w#t$rY&wxYw) aRemove responses from the cache according one or more conditions. Args: keys: Remove responses with these cache keys expired: Remove all expired responses invalid: Remove all invalid responses (that can't be deserialized with current settings) older_than: Remove responses older than this value, relative to ``response.created_at`` requests: Remove matching responses, according to current request matching settings urls: Remove matching GET requests for the specified URL(s) verify: Set to ``False`` to remove responses without SSL verification rSrTF)validrXrYrZzDeleting up to z responsesrN)listrpreparerfilterappendr@rErJlenr%r4 bulk_delete_prune_redirects) r(rXrYrZr[r\rUkeys delete_keysrVr;r7s r*deletezBaseCache.deletes"*04d HN+X\.]QTwuc/B/J/J/L.]]H  S[\DOOGFOC\ \K 'j$  3H   x11 2 3  s;'7&8 CD { q  NN;q>2 NN & &{ 3 %/^\  s!DDD D)(D)c|jjDcgc]\}}||jvs|}}}|jj|ycc}}w)zARemove any redirects that no longer point to an existing responseN)r&itemsr%re)r(kvinvalid_redirectss r*rfzBaseCache._prune_redirectssK+/>>+?+?+A]41aQdnnE\Q]] ""#45^s AAc#4Kt||||gsy|jjD]g}|j|}|r|t d}||_|0|3|r |j r#|r |j s|sR|j|sd|iyw)aGet responses from the cache, with optional filters for which responses to include: Args: valid: Include valid and unexpired responses; set to ``False`` to get **only** expired/invalid/old responses expired: Include expired responses invalid: Include invalid responses (as an empty ``CachedResponse``) older_than: Get responses older than this value, relative to ``response.created_at`` Ni) status_code)anyr%rgr8rr@ is_expired is_older_than)r(r^rXrYrZr5r7s r*rbzBaseCache.filters E7GZ89 >>&&( C((-H8+)c:%("%x22 3 38#9#9*#E sAB B?BBcntjdt|jj }|D]x}|j|}|j j dk(rd|j _|j|j }||k7s]||j|<|j|=zy)z7Recreate cache keys for all previously cached responseszRecreating all cache keyssNoner,N)rErJr`r%rgr;bodyr)r(old_keys old_cache_keyr7 new_cache_keys r* recreate_keyszBaseCache.recreate_keyss 01++-.% 2M~~m4H$$/(+  % OOH,<,<=M -08}-NN=1 2r,cttdtd|r|j||jddy)NzQremove_expired_responses() is deprecated; please use delete(expired=True) insteadr) stacklevelT)rXrY)rDeprecationWarningreset_expirationri)r( expire_afters r*remove_expired_responsesz"BaseCache.remove_expired_responsess6 _    ! !, / D$ /r,ctjd||jD],}|j|||j|j <.y)zSet a new expiration value to set on existing cache items Args: expire_after: New expiration value, **relative to the current time** zResetting expiration with: N)rErFrbr}r%r@)r(r~r7s r*r}zBaseCache.reset_expirationsO  1,@A  :H  % %l 319DNN8-- . :r,c tjdt|jdt |dt ||jj |j|j j |j y)z4Update this cache with the contents of another cachezCopying z responses from z to N)rErJrdr%reprupdater&)r(others r*rzBaseCache.updatese xEOO 455Ed5k]RVW[\`WaVbcd eoo. eoo.r,c rt|jdi|Dchc]}|jc}Scc}w)zVGet all unique cached URLs. Optionally takes keyword arguments for :py:meth:`.filter`.rP)sortedrbrV)r(r)r7s r*r\zBaseCache.urls s-KDKK4I&4IJx||JKKJs4cPd|jjd|jdS)N) __class____name__r#r/s r*__str__zBaseCache.__str__$s'4>>**+6$//1B"EEr,ct|Sr")strr/s r*__repr__zBaseCache.__repr__'s 4yr,)r#r)returnzUnion[str, Path]r")r5rrzOptional[CachedResponse])NN)r7rr@ Optional[str]r:zOptional[datetime])r;rrNOptional[Iterable[str]]rr)NNNT)r5rr;zOptional[AnyRequest]rVrrUbool)rgrrXrrYrrZrr[zOptional[Iterable[AnyRequest]]r\rrUr)TTFN) r^rrXrrYrrZrrzIterator[CachedResponse])r~r)rz 'BaseCache')rz List[str])r __module__ __qualname____doc__rr+propertyr0r8rCrGrKrrWrirfrbryrr}rr\rrrPr,r*r r !s(*<) "" $$(&* GG!G$ G. 26  /  ,"(,! > >&> >  >0%)37(,) ) )  ) # ) 1 ) &) ) V6%)   #  " B 2"0 :/ LFr,r KTVTcHeZdZdZ d d dZd dZdZd dZd dZdZ y) BaseStorageaBase class for client-agnostic storage implementations. Notes: * This provides a common dictionary-like interface for the underlying storage operations (create, read, update, delete). * One ``BaseStorage`` instance corresponds to a single table/hash/collection, or whatever the backend-specific equivalent may be. * ``BaseStorage`` subclasses contain no behavior specific to ``requests``, which are handled by :py:class:`.BaseCache` subclasses. * ``BaseStorage`` also contains a serializer object (defaulting to :py:mod:`pickle`), which determines how :py:class:`.CachedResponse` objects are saved internally. See :ref:`serializers` for details. Args: serializer: Custom serializer that provides ``loads`` and ``dumps`` methods. If not provided, values will be written as-is. decode_content: Decode response body JSON or text into a human-readable format kwargs: Additional backend-specific keyword arguments Nc t|||_tjdt |j d|jy)Nz Initialized z with serializer: )rrOrErJtyper)r(rOdecode_contentr)s r*r+zBaseStorage.__init__Cs< **nE |DJ$7$7#88J4??J[\]r,c8|D]} ||=y#t$rYwxYw)zDelete multiple keys from the cache, without raising errors for missing keys. This is a naive, generic implementation that subclasses should override with a more efficient backend-specific implementation, if possible. N)r4)r(rgrls r*rezBaseStorage.bulk_deleteLs3  A G   s   cy)rINrPr/s r*rKzBaseStorage.closeXsr,ctrt|jdsJ|jr|jj|S|S)z/Serialize a value, if a serializer is availabledumps)r hasattrrOr)r(values r* serializezBaseStorage.serialize[s9 4??G4 44/3t$$U+IEIr,cb|js|Strt|jdsJ |jj|} ||_|S#t $rY|SwxYw#t $rB}tjdt|tj|dYd}~yd}~wwxYw)zDeserialize a value, if a serializer is available. If deserialization fails (usually due to a value saved in an older requests-cache version), ``None`` will be returned. loadsz Unable to deserialize response: T)exc_infoN) rOr rrr@r3DESERIALIZE_ERRORSrEerrorrrJ)r(r5robjes r* deserializezBaseStorage.deserializeas L 4??G4 44 //''.C  # J" J "  LL;CF8D E LLTL * s;A# AA# A A#A  A## B.,8B))B.cFtt|jSr")rr`rgr/s r*rzBaseStorage.__str__ys4 $%%r,)NF)rOzOptional[SerializerType]rr)rgz Iterable[KT])rr) rrrrr+rerKrrrrPr,r*rr/sC*04$^,^^ 1J 0&r,rc,eZdZdZfdZfdZxZS)r$a7A basic dict wrapper class for non-persistent, in-memory storage .. note:: This is mostly a placeholder for when no other backends are available. For in-memory caching, either :py:class:`.SQLiteCache` (with `use_memory=True`) or :py:class:`.RedisCache` is recommended instead. c2t||i|d|_yr")superr+rO)r(argsr)rs r*r+zDictStorage.__init__s $)&)r,ct||}t|ddr|jj  ||_|S#t $rY|SwxYw)aAn additional step is needed here for response data. The original response object is still in memory, and hasn't gone through a serialize/deserialize loop. So, the file-like response body has already been read, and needs to be reset. rawN)r __getitem__getattrrresetr@r3)r(r5itemrs r*rzDictStorage.__getitem__sZ w"3' 4 % HHNN   DN     sA AA)rrrrr+r __classcell__)rs@r*r$r$}s  r,r$N)5r __future__rabcr collectionsrrloggingrpicklertypingr r r r r rrrwarningsrpathlibrr[rr cache_keysrrmodelsrrpolicyrrr serializersrrr3 ImportError TypeError ValueErrorrrrEr rrrr$rPr,r*rs# ddd&4/FF9%k; :V 8 GGT T] T]K&.R(#K&\(Kr,