}Dj{J0dZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lmZmZmZd d lmZmZd dlmZmZmZd dlmZmZeeZ GddeZ!GddeZ"Gdde"Z#GddeZ$ddee%de%fdZ&y)zFilesystem cache backend. For usage details, see :ref:`Backends: Filesystem `. .. automodsumm:: requests_cache.backends.filesystem :classes-only: :nosignatures: )contextmanager) getLogger)makedirs)Path) PickleError)rmtree)RLock)time_ns)AnyIteratorOptional)SerializerTypejson_serializer) BaseCache BaseStorage StrOrPath) SQLiteDictget_cache_pathc eZdZdZ d dedededeeffd Ze de fdZ e de fd Z dee fd Zd Zfd ZxZS) FileCachea[Filesystem cache backend. Args: cache_name: Base directory for cache files use_cache_dir: Store database in a user cache directory (e.g., `~/.cache/`) use_temp: Store cache files in a temp directory (e.g., ``/tmp/http_cache/``). Note: if ``cache_name`` is an absolute path, this option will be ignored. decode_content: Decode JSON or text response body into a human-readable format extension: Extension for cache files. If not specified, the serializer default extension will be used. max_cache_bytes: Enable LRU caching, and set the maximum total size (in bytes) of cached responses on the file system. max_file_bytes: The maximum size of a single file. By default, this is the same as ``max_cache_bytes``. Only used if ``max_cache_bytes`` is set. block_bytes: The size of a block of data on the file system, which will be used when computing total file size on disk. Only used if ``max_cache_bytes`` is set. sync_index: On startup, sync LRU metadata with any changes on disk since last use. Use this if you intend to modify cache files outside of requests-cache. Leave off to reduce startup time for larger caches. Only used if ``max_cache_bytes`` is set. lock: Replace the default :class:`threading.RLock` object without your own. Use this if you want to share the lock between multiple cache instances, and/or use a different lock type (such as :py:class:`multiprocessing.RLock` or :py:class:`filelock.FileLock`). cache_nameuse_tempdecode_content serializerc t|ddt|i||rd|i|n|}d|vrtnt|f||d||_|j 5t|jdz dfddi||_ dddy#1swYyxYw)Nrrmax_cache_bytes)rrzredirects.sqlite redirects) super__init__str LRUFileDictFileDict responseslockr cache_dirr)selfrrrrkwargsskwargs __class__s n/var/www/html/Astrologybackend/backend/venv/lib/python3.12/site-packages/requests_cache/backends/filesystem.pyr"zFileCache.__init__3s >C O>v>:D<6v6&$\3D3NKT\ $ !).$ LS$ YY )3!33[*MQ*U[*DN   s "A<<Breturnc.|jjSzThe lock used by the cache.)r&r'r)s r-r'zFileCache.lockEs~~"""c@t|jjS)zBase directory for cache files)rr&r(r1s r-r(zFileCache.cache_dirJsDNN,,--r2c6|jjS)/Get absolute file paths to all cached responses)r&pathsr1s r-r6zFileCache.pathsOs~~##%%r2c|j5|jj|jj dddy#1swYyxYw)zClear the cacheN)r'r&clearrinit_dbr1s r-r8zFileCache.clearSs@YY % NN " NN " " $ % % %s 5A  Acf|j5t||i|cdddS#1swYyxYwN)r'r!deleter)argsr*r,s r-r<zFileCache.deleteZs0 YY 37>4262 3 3 3s'0) http_cacheFTN)__name__ __module__ __qualname____doc__rboolr rr"propertyr r'rr(r r6r8r< __classcell__r,s@r-rrs6!-#/3   ^, $#e##.4..&x~&%33r2rceZdZdZdddedfdedededeedee d ee f fd Z e d e fd Z edd eedefdZd ed efdZd efdZdZdZd efdZd eefdZd efdZddZdZd eefdZd efdZxZS)r%zA dictionary-like interface to files on the local filesystem. The cache directory will be created if it doesn't already exist. FNrr use_cache_dir extensionrr'c t|dd|i|t||||_t ||j |_t|j dd|_||n t|_ t|jdy)Nr)rIr is_binaryFT)exist_okr ) r!r"rr(_get_extensionrrJgetattrrLr _lockr) r)rrrIrJrr'r*r,s r-r"zFileDict.__init__eso 9J9&9' -Zbc' 4??C +uE!-T57 $/r2r.c|jSr0)rPr1s r-r'z FileDict.lockvszzr2key ignore_errorsc#K |j5ddddy#1swYyxYw#ttttf$r}|st d|d|Yd}~yd}~wwxYww)zPAttempt an I/O operation, and either ignore errors or re-raise them as KeyErrorsNz File for key z not found.)rPEOFErrorIOErrorOSErrorrKeyError)r)rRrSes r-_try_iozFileDict._try_io{sb J    '7K8 J sg[ABI! JsDA" **A"'*A"*AAA"AA"c<|j||jz Sr;)r(rJr)rRs r- _key2pathzFileDict._key2paths~~3%'7 888r2c0|jrdnd}|j|5|j|j|5}|j ||j cdddcdddS#1swYnxYw dddy#1swYyxYw)Nrbr)rLrZr]open deserializeread)r)rRmodefs r- __getitem__zFileDict.__getitem__s~~t3 \\#  7$))$/ 71''QVVX6 7 7 7 7 7 7 7 7 7 7s#!B  A6# B 6A? ;B  Bc|j|5|j|jdddy#1swYyxYwr;)rZr]unlinkr\s r- __delitem__zFileDict.__delitem__s8 \\#  ) NN3  & & ( ) ) )s ;Ac|j|5|j|j|jrdnd5}|j |j |ddddddy#1swYxYw#1swYyxYw)Nwbw)rd)rZr]rarLwrite serialize)r)rRvalueres r- __setitem__zFileDict.__setitem__sw \\#  /$))t~~t3)O /STu-. / / / / / / /s#0B!A4#B4A= 9BB c|j5|j|jcdddS#1swYyxYwr;)rPr]existsr\s r- __contains__zFileDict.__contains__s3 ZZ 0>>#&--/ 0 0 0s6?c#@K|jEd{y7wr;)keysr1s r-__iter__zFileDict.__iter__s99;s cBtd|jDS)Nc3 K|]}dyw)rNr ).0_s r- z#FileDict.__len__..s+1+s )sumr6r1s r-__len__zFileDict.__len__s+djjl+++r2c|jd5t|jd|jjdddy#1swYyxYw)zEmpty the cache directory.T)rSN)rZrr(mkdirr1s r-r8zFileDict.clearsC \\\ - # 4>> 6 NN " # # #s 2AAc\|jDcgc]}|jc}Scc}wr;)r6stem)r)paths r-ruz FileDict.keyss &*jjl3d 333s)c|j5|jjd|jcdddS#1swYyxYw)r5*N)rPr(globrJr1s r-r6zFileDict.pathss< ZZ =>>&&4>>*:';< = = =s (?Ac|j5td|jDcdddS#1swYyxYw))Return the size of the database, in bytesc3PK|]}|jj ywr;)statst_size)ryrs r-r{z FileDict.size..sDttyy{**Ds$&N)rPr|r6r1s r-sizez FileDict.sizes6 ZZ EDtzz|DD E E Es 7A)NF)r.N)r@rArBrCrrrDr r#rr r"rEr'rrZrr]rfrirprsr rvintr}r8rur6rrFrGs@r-r%r%_s###'/> $000 0 C= 0 ^, 0uo0"eJ8C=JJJ9S9T97s7 )/ 040(3-,,# 4=x~= EcEr2r%c eZdZdZddddddeded eed effd Zfd Zd e de ddffd Z fdZ defdZ dZdedefdZfdZdefdZxZS)r$aQA size-restricted version of FileDict, using LRU eviction. Args: block_bytes: The size of a block of data on the file system. File sizes will be aligned with this. max_cache_bytes: The maximum total size of all files in the cache. max_file_bytes: The maximum size of a single file. By default, this is the same as ``max_cache_bytes``. sync_index: Check for filesystem changes since last use. Use this if you intend to modify cache files outside of requests-cache. Leave off to reduce startup time for larger caches. ri@NF) block_bytesrmax_file_bytes sync_indexrrrrct||i|||_||_|xs||_|j|jkDrt d|d|j|jkDrt d|d|jdkrt d|t |jdz dfi||_|st|jdk(r|jyy) Nzr*r,s r-r"zLRUFileDict.__init__s $)&).&,?   !5!5 5NN__`a    d11 1PQ_P``abc c   a G }UV V (!:ELVL T^^,1  "2r2c0t||} |jj||S#t$r]|j |}|j r8|j|jj}||j|<Y|SwxYw)z7Get a value and update its access time in the LRU index) r!rfrupdate_access_timerXr]rr_get_size_on_diskrr)r)rRro file_path file_sizer,s r-rfzLRUFileDict.__getitem__s#C( 0 NN - -c 2  0s+I! 229>>3C3K3KL &/s#  0s/A"BBrRror.c|j|}t|tr|jdn|}~|j t |}||j kDr'tjd|d|j dy|j|5 t|-||j|t|9||||j|<dddy#t$rYDwxYw#1swYyxYw)NzUTF-8z Not caching z because it is larger than z bytes.)rn isinstancer#encoderrrloggerdebugrZr!rirX_evictrpr)r)rRrocontentdatarr,s r-rpzLRUFileDict.__setitem__s..'*4Wc*Bw~~g& **3t95 t** * LLsg%@ATAT@UU\]   \\#  , #C( KK " G U +#,DNN3  , ,   , ,s0C1C")0C1" C.+C1-C..C11C:c^ |j|=t| |y#t$rYwxYw)z.Delete a file and remove it from the LRU indexN)rrXr!ri)r)rRr,s r-rizLRUFileDict.__delitem__s7 s# C    s ,,desired_free_bytesc|jj}||z|jz }|dkry|jj|}|D]} ||=y#t$rYwxYw)zMake space in the cache to fit the given number of bytes, if needed. This starts deleting the least recently used entries first. rN)r total_sizerget_lrurX)r)r current_size space_needed keys_to_evictrRs r-rzLRUFileDict._evicts| ~~002 #&884;O;OO 1  ..|<   C I   sA A&%A&c*|j5|jj|jD]D}|j}|j |j j|j|<F dddy#1swYyxYw)z(Rebuild the LRU index from files on diskN)rPrr8r6rrrr)r)rrRs r-rzLRUFileDict._sync_lru_index#sw ZZ R NN "  Rii&*&<&?  KK@@QQ^_  KKA$//ARRXY Z KK-doo->?  KK00AA^_ ` KK..2oo->?!!% 12 OO,-   KK..2oo->?!!% 12 OO,-   KK..2oo->?))-(9:!OO,-  W5 5 5 s EE33E<c|jd5}|jd|jd|f}dddjsty#1swYxYw)NTrz DELETE FROM z WHERE key=?)rrrrowcountrX)r)rRrcurs r-rizLRUDict.__delitem__s\ __D_ ) TS++ T__,=\JSFSC T||N T Ts "AAr.c|j5}|jd|jd|dj}|s t ||dcdddS#1swYyxYw)NzSELECT size FROM z WHERE key=''r)rrrfetchonerX)r)rRrrows r-rfzLRUDict.__getitem__sf __  #++ 1$//1B,seSTUV__aCsm#q6    s AAA&rRrctt}|jd5}|jd|jd|||fdddy#1swYyxYw)zESave a value (file size), and update access time and total cache sizeTrz INSERT INTO z (key, access_time, size) VALUES (?, ?, ?) ON CONFLICT(key) DO UPDATE SET access_time = excluded.access_time, size = excluded.size N)rr rrr)r)rRr timestamprs r-rpzLRUDict.__setitem__se N __D_ ) S KK!__-. i&    s $AAct||jd5}|jd|jddddy#1swYyxYw)NTrUPDATE z_size SET total_size = 0)r!r8rrr)r)rr,s r-r8z LRUDict.clearsP   __D_ ) MS KK'$//!22JK L M M Ms A  Ac|j5}|jd|jjdcdddS#1swYyxYw)NzSELECT COUNT(key) FROM rrrrr)r)r>r*rs r-countz LRUDict.countsO __  Z#;;!88IJKTTVWXY Z Z Zs /A  Arc|j5}|jd|jd|f}|j}|j |Dcgc]}|d c}cdddScc}w#1swYyxYw)zCGet the least recently used keys with a combined size >= total_sizez WITH ordered AS ( SELECT key, size, access_time, SUM(size) OVER (ORDER BY access_time) AS running_total FROM z ) SELECT * FROM ordered WHERE running_total - size < ? ORDER BY access_time; rN)rrrfetchallr)r)rrrrowsrs r-rzLRUDict.get_lrus__  ,#++//*+  C<<>D IIK&*+sCF+ , ,, , ,sAA4 A/#A4/A44A=reversedlimitc +K|dvrtd||rdnd}|rd|nd}|j5}|jd|jd|d |d |D] }|d   d d d y #1swYy xYww) zFGet LRU entries in sorted order, by either ``access_time`` or ``size``) access_timerrRzInvalid sort key: DESCASCzLIMIT zSELECT key FROM z ORDER BY  rN)rrrr) r)rRrrr* direction limit_exprrrs r-sortedzLRUDict.sorteds 4 41#78 8&FE ).veW%B __  #{{"4??"3:cU!I;aPZ|\ !f     s2A>4A2) A>2A;7A>c|j5}|jd|jdj}|r|dndcdddS#1swYyxYw)NzSELECT total_size FROM _sizerr)r)rrs r-rzLRUDict.total_sizesT __  (#++ 77HNOXXZC 3q6a ( ( (s 6AActt}|jd5}|jd|jd||f}dddj s t |y#1swY!xYw)zUpdate the given key with the current timestamp Raises: KeyError: If the key doesn't exist in the LRU index Trrz" SET access_time = ? WHERE key = ?N)rr rrrrrX)r)rRrrrs r-rzLRUDict.update_access_timest  N __D_ ) S++$//**LMC C  ||3-    s #A))A2)rFN)r@rArBrCr"r9rirrfr#rpr8rrrDr r rrrrFrGs@r-rr=s *7r # s # M Z,#,*!#  }  # ((C(  c  r2rNrJr.c|rd|Sdddddd}|r=|jx}r/|jD]\}}|j||}d|Sy)zQUse either the provided file extension, or get the serializer's default extension.bsonpkljson)r safe_picklepickleorjsonujsonz.dat)nameitemsreplace)rJrsubsrkvs r-rNrNsr9+  Dz.t.JJL &DAq<<1%D &4&z r2)NN)'rC contextlibrloggingrosrpathlibrrrshutilr threadingr timer typingr r r serializersrrrrrrsqliterrr@rrr%r$rr#rNr r2r-rs&**9//. 8 C3 C3LSE{SElE+(E+Pn jn bhsmr2