Update admin_routes.py

admin_routes.py

@@ -13,15 +13,54 @@ import bcrypt
 from datetime import datetime, timedelta
 from typing import Dict, List, Optional, Any
 from pathlib import Path
-
 from fastapi import APIRouter, HTTPException, Depends, Header
 from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
 from pydantic import BaseModel, Field
 import jwt
-
 from utils import log
 from config_provider import ConfigProvider
 
+# Activity log retention policy (keep last 30 days)
+ACTIVITY_LOG_RETENTION_DAYS = 30
+ACTIVITY_LOG_MAX_ENTRIES = 10000
+
+async def cleanup_activity_log():
+    """Cleanup old activity log entries"""
+    while True:
+        try:
+            config = load_config()
+            
+            if "activity_log" in config:
+                # Calculate cutoff date
+                cutoff_date = datetime.utcnow() - timedelta(days=ACTIVITY_LOG_RETENTION_DAYS)
+                
+                # Filter recent entries
+                original_count = len(config["activity_log"])
+                config["activity_log"] = [
+                    log for log in config["activity_log"]
+                    if datetime.fromisoformat(log["timestamp"].replace("Z", "+00:00")) > cutoff_date
+                ]
+                
+                # Also limit by max entries
+                if len(config["activity_log"]) > ACTIVITY_LOG_MAX_ENTRIES:
+                    config["activity_log"] = config["activity_log"][-ACTIVITY_LOG_MAX_ENTRIES:]
+                
+                # Save if anything was removed
+                removed_count = original_count - len(config["activity_log"])
+                if removed_count > 0:
+                    save_config(config)
+                    log(f"🧹 Cleaned up {removed_count} old activity log entries")
+            
+        except Exception as e:
+            log(f"❌ Activity log cleanup error: {e}")
+        
+        # Run cleanup once per day
+        await asyncio.sleep(86400)  # 24 hours
+
+# Start cleanup task when module loads
+def start_cleanup_task():
+    asyncio.create_task(cleanup_activity_log())
+
 # ===================== Dynamic Config Loading =====================
 def get_jwt_config():
     """Get JWT configuration based on work_mode"""