Update metrics_core.py

metrics_core.py

@@ -1,35 +1,45 @@
+# core/metrics_core.py
+
 import json
 import os
 from datetime import datetime
 
+from core.alerters import ConsoleAlerter, FileAlerter
+from core.alert_manager import AlertManager
+from core.failsafe_core import failsafe
+
+# Настройка алертов — FailSafe будет сообщать о сбоях
+alert_manager = AlertManager([
+    ConsoleAlerter(),
+    FileAlerter("failsafe_errors.log")
+])
+
 METRICS_FILE = "metrics_log.json"
 
+@failsafe(alert_manager)
 def save_metrics(metrics: dict):
     """
     Сохраняет метрики в локальный JSON-файл.
+    Если произойдет ошибка, она будет автоматически залогирована, и функция не упадёт.
     """
-    # Добавляем timestamp
     metrics["timestamp"] = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
 
-    # Если файла нет — создаём новый список
     if not os.path.exists(METRICS_FILE):
         with open(METRICS_FILE, "w", encoding="utf-8") as f:
             json.dump([], f, ensure_ascii=False, indent=2)
 
-    # Загружаем старые метрики
     with open(METRICS_FILE, "r", encoding="utf-8") as f:
         data = json.load(f)
 
-    # Добавляем новые
     data.append(metrics)
 
-    # Сохраняем обратно
     with open(METRICS_FILE, "w", encoding="utf-8") as f:
         json.dump(data, f, ensure_ascii=False, indent=2)
 
+@failsafe(alert_manager)
 def read_metrics():
     """
-    Возвращает все сохранённые метрики.
+    Возвращает все сохранённые метрики. Ошибки логируются и не ломают систему.
     """
     if not os.path.exists(METRICS_FILE):
         return []