Update cache_manager.py

cache_manager.py

@@ -24,19 +24,22 @@ class CacheManager:
         
         # Inicjalizacja pliku metadanych
         self.metadata_file = self.cache_dir / "metadata.json"
-        asyncio.create_task(self._init_metadata())
-        
-    async def _init_metadata(self):
-        """Inicjalizuje lub wczytuje metadane cache"""
-        if not self.metadata_file.exists():
-            await self._save_metadata({
-                'entries': {},
-                'total_size': 0,
-                'last_cleanup': time.time()
-            })
+        self._initialized = False
+
+    async def _ensure_initialized(self):
+        """Zapewnia, że cache jest zainicjalizowany przed użyciem"""
+        if not self._initialized:
+            if not self.metadata_file.exists():
+                await self._save_metadata({
+                    'entries': {},
+                    'total_size': 0,
+                    'last_cleanup': time.time()
+                })
+            self._initialized = True
 
     async def _load_metadata(self) -> Dict:
         """Wczytuje metadane cache"""
+        await self._ensure_initialized()
         try:
             if not self.metadata_file.exists():
                 return {'entries': {}, 'total_size': 0, 'last_cleanup': time.time()}
@@ -49,6 +52,7 @@ class CacheManager:
 
     async def _save_metadata(self, metadata: Dict):
         """Zapisuje metadane cache"""
+        await self._ensure_initialized()
         async with aiofiles.open(self.metadata_file, 'w') as f:
             await f.write(json.dumps(metadata, indent=2))
 
@@ -61,6 +65,7 @@ class CacheManager:
 
     async def get(self, key: str) -> Optional[Dict]:
         """Pobiera wartość z cache jeśli istnieje i nie wygasła."""
+        await self._ensure_initialized()
         try:
             metadata = await self._load_metadata()
             entry_meta = metadata['entries'].get(key)
@@ -86,6 +91,7 @@ class CacheManager:
 
     async def set(self, key: str, value: Dict):
         """Zapisuje wartość do cache."""
+        await self._ensure_initialized()
         try:
             cache_file = self.cache_dir / f"{key}.json"
             data_str = json.dumps(value)
@@ -113,6 +119,7 @@ class CacheManager:
 
     async def invalidate(self, key: str):
         """Usuwa wpis z cache."""
+        await self._ensure_initialized()
         try:
             cache_file = self.cache_dir / f"{key}.json"
             if cache_file.exists():
@@ -131,6 +138,7 @@ class CacheManager:
 
     async def invalidate_all(self):
         """Czyści cały cache."""
+        await self._ensure_initialized()
         try:
             metadata = await self._load_metadata()
             # Usuń wszystkie pliki cache
@@ -153,9 +161,9 @@ class CacheManager:
 
     async def _cleanup_old_entries(self):
         """Usuwa najstarsze wpisy gdy cache przekroczy limit rozmiaru."""
+        await self._ensure_initialized()
         try:
             metadata = await self._load_metadata()
-            
             sorted_entries = sorted(
                 metadata['entries'].items(),
                 key=lambda x: x[1]['timestamp']
@@ -170,32 +178,4 @@ class CacheManager:
                 metadata = await self._load_metadata()
 
         except Exception as e:
-            self.logger.error(f"Błąd podczas czyszczenia cache: {str(e)}")
-
-def cache_result(ttl: int = 3600):
-    """
-    Dekorator do cache'owania wyników funkcji.
-    """
-    def decorator(func):
-        @wraps(func)
-        async def wrapper(*args, **kwargs):
-            if not args or not hasattr(args[0], 'cache'):
-                return await func(*args, **kwargs)
-                
-            cache = args[0].cache
-            cache_key = cache._compute_key(
-                func.__name__,
-                *args[1:],
-                **kwargs
-            )
-            
-            result = await cache.get(cache_key)
-            if result is not None:
-                return result
-            
-            result = await func(*args, **kwargs)
-            await cache.set(cache_key, result)
-            return result
-            
-        return wrapper
-    return decorator
+            self.logger.error(f"Błąd podczas czyszczenia cache: {str(e)}")