dZddlZddlZddlZddlZddlZddlZddlZGddZda ej Z dZ dS)z Unified Cache Manager for the Milionar addon. Handles both metadata (JSON) and binary assets (images) with: - In-memory caching for speed - Atomic writes for safety - Automatic garbage collection NceZdZdZdZdZdZddZddZddZ d Z d Z d Z d Z d ZdZddZddZddZddZdZedZdZdS) CacheManagerz Centralized cache manager for metadata and generated assets. Thread-safe with atomic writes and automatic cleanup. dzcache_metadata.jsonNc2|r||_ntjd|_tj|jstj|ji|_d|_tj|_ | d|_ dS)z Initialize the cache manager. Args: cache_dir: Base directory for cache files. Defaults to addon_data folder. z9special://profile/addon_data/plugin.video.milionar/cache/FrN) _cache_dirxbmcvfs translatePathexistsmkdirs _metadata_metadata_dirty threadingLock_metadata_lock_load_metadata _last_cleanup)self cache_dirs Y/Users/chudy/Library/Application Support/Kodi/addons/plugin.video.milionar/wcs/caching.py__init__zCacheManager.__init__s  'DOO%3KDO ~do.. , N4? + + +$'n.. c@|j5|j|}||cdddSd|vr:|dtjkr|j|=d|_|cdddS|d|cdddS#1swxYwYdS)z Get a value from the metadata cache. Args: key: Cache key string default: Default value if key not found Returns: Cached value or default NexpiresTdata)rr gettimer)rkeydefaultentrys rrzCacheManager.get?s( . .N&&s++E} . . . . . . . . E!!eI&6&D&DN3''+$ . . . . . . . .99VW-- . . . . . . . . . . . . . . . . . .sB1B1BBBc|j5|tjd}|rtj|z|d<||j|<d|_ddddS#1swxYwYdS)z Set a value in the metadata cache. Args: key: Cache key string data: Data to cache (must be JSON serializable) ttl_seconds: Optional time-to-live in seconds )r timestamprTN)rrr r)rrr ttl_secondsr s rsetzCacheManager.setXs  ( (! <g|]}||S) startswith).0kprefixs r z.CacheManager.delete_prefix..rs*PPPA1<<;O;OPaPPPrTNr&)rr.keys_to_deleters ` r delete_prefixzCacheManager.delete_prefixos   , ,PPPPPPPN% ( (N3'' ,'+$  , , , , , , , , , , , , , , , , , ,s*AAAc|j5|js ddddS|ddddS#1swxYwYdS)z+Force save metadata to disk (atomic write).N)rr_save_metadata_locked)rs rflushzCacheManager.flushxs   ) )'  ) ) ) ) ) ) ) )  & & ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s ??AAc(tj|j|j} t j|rt j|d}|}| |rRtj ||_ tjdt|j dtjdSdSdS#t"$r4}tjd|tji|_ Yd}~dSd}~wwxYw)z$Load metadata from disk into memory.rz[CacheManager] Loaded z cached entriesz'[CacheManager] Error loading metadata: N)ospathjoinrMETADATA_FILENAMEr r Filereadclosejsonloadsr xbmcloglenLOGINFO Exception LOGWARNING)r metadata_pathfcontentes rrzCacheManager._load_metadatas T_d6LMM  ~m,, jL44&&(( j%)Z%8%8DNHZc$.6I6IZZZ\`\hiiiii  j jjj   HBqBBDO T T TDNNNNNNN sB!C D)D  Dcptj|j|j}|dz} t j|jd}tj |d}| || tj |rtj |tj||d|_dS#t $r[}t#jd|t"jtj |rtj |Yd}~dSYd}~dSd}~wwxYw)z Save metadata to disk with atomic write (must hold lock). Uses temp file + rename pattern to prevent corruption. .tmpF) ensure_asciiwz&[CacheManager] Error saving metadata: N)r7r8r9rr:r>dumpsr r r;writer=r r'renamerrDr@rALOGERROR)rrF temp_pathrHrGrIs rr3z"CacheManager._save_metadata_lockedsE  T_d6LMM !F*  *jeDDDG Y,,A GGG    GGIII~m,, .}--- N9m 4 4 4#(D  * * * HAaAA4= Q Q Q~i(( *y))))))))) * * * * * * *sBC D5A D00D5c||}tj|j|}t j|r|SdS)z Get the filesystem path for a cached asset. Args: cache_key: Unique identifier for the asset Returns: Absolute path to the cached file, or None if not cached N)_asset_filenamer7r8r9rr r )r cache_keyfilenamefilepaths rget_asset_pathzCacheManager.get_asset_pathsJ'' 227<<:: >( # # Otr.jpgcH|||}tj|j|}|dz} t j|d}|||t j |rt j |t j |||S#t$rX}tjd|d|tjt j |rt j |Yd}~dSd}~wwxYw)a( Save binary asset to cache. Args: cache_key: Unique identifier for the asset data: Binary data (bytes) to save extension: File extension (default .jpg) Returns: Absolute path to the saved file rKwbz"[CacheManager] Error saving asset : N)rTr7r8r9rr r;rOr=r r'rPrDr@rArQ) rrUr extensionrVrWrRrGrIs r save_assetzCacheManager.save_assets'' 9==7<<::v%   Y--A GGDMMM GGIII~h'' )x((( N9h / / /O    HJ)JJqJJDM Z Z Z~i(( *y)))44444  sAz2CacheManager._maintenance_worker..Qs adr)rz[CacheManager] Deleted z old cache filesz"[CacheManager] Maintenance error: )rrr itemsappendrr@rArBrCr listdirrr:endswithr7r8r9Statst_sizest_mtimer'sortr4rDrQ)rr~rnowmax_age_secondsmax_size_bytes expired_keysrr age files_info total_size deleted_countdirsfilesrVrWstatsizemtimerIs rrzz CacheManager._maintenance_workersD N)++C*R/$6O(4/$6N$ s s! "&."6"6"8"855JC E))eI.>.D.D$++C0000$--!E+$6600(//444',,Cs++s+/D(Hcs<7H7Hccceieqrrr s s s s s s s s s s s s s s s$JJM!/$/::KD%!  t5559J9J69R9R57<<BB "<11D<<>>D MMOOEe 66x000%* "))8T5*ABBB"d* DN**NN333-7'')HdE!^33N8,,,$&J!Q&MMq  R=RRRTXT`aaa JJLLLLL N N N H=!==t} M M M M M M M M M NsV*I7B8C0$ I70C44I77C48A/I7(Az(CacheManager.make_key..os(11SC111111r)r9)rws rmake_keyzCacheManager.make_keygs%xx11D111111rcR|j5i|_d|_dddn #1swxYwYtj|j\}}|D];}t j|j|}tj |>H N8 $ $ $ $ />>>>>s #''r)rY)r_)NNF)__name__ __module__ __qualname____doc__r{r|r:rrr$r'r1r4rr3rXr^rjrTrrz staticmethodrrr*rrrrsZ -B....2(((( ,,,,,,)))    ***>"    D.....2FNFNFNX22\2 ? ? ? ? ?rrct4t5ttadddn #1swxYwYtS)zk Get the global CacheManager instance (singleton). Returns: CacheManager instance N) _instance_instance_lockrr*rrget_cache_managerrs|  + + (NN  + + + + + + + + + + + + + + + s 155) rr7r>rrprr@r rrrrrr*rrrs  k?k?k?k?k?k?k?k?^  !!     r