Update admin_routes.py

admin_routes.py

@@ -16,6 +16,11 @@ from pydantic import BaseModel, Field
 import httpx
 
 from config_provider import ConfigProvider
+from logger import log_info, log_error, log_warning, log_debug
+from exceptions import (
+    RaceConditionError, ValidationError, ResourceNotFoundError,
+    AuthenticationError, AuthorizationError
+)
 
 # ===================== Constants & Config =====================
 security = HTTPBearer()
@@ -148,7 +153,7 @@ async def login(request: LoginRequest):
     # Create token
     token = create_token(request.username)
     
-    log(f"✅ User '{request.username}' logged in successfully")
+    log_info(f"✅ User '{request.username}' logged in successfully")
     return LoginResponse(token=token, username=request.username)
 
 @router.post("/change-password")
@@ -179,7 +184,7 @@ async def change_password(
     # Save configuration
     cfg.save()
     
-    log(f"✅ Password changed for user '{username}'")
+    log_info(f"✅ Password changed for user '{username}'")
     return {"success": True}
 
 # ===================== Locales Endpoints =====================
@@ -340,7 +345,7 @@ async def update_environment(
     username: str = Depends(verify_token)
 ):
     """Update environment configuration with provider validation"""
-    log(f"📝 Updating environment config by {username}")
+    log_info(f"📝 Updating environment config by {username}")
     
     cfg = ConfigProvider.get()
     
@@ -374,7 +379,7 @@ async def update_environment(
     # Update via ConfigProvider
     ConfigProvider.update_environment(update.model_dump(), username)
     
-    log(f"✅ Environment updated to LLM: {update.llm_provider.name}, TTS: {update.tts_provider.name}, STT: {update.stt_provider.name} by {username}")
+    log_info(f"✅ Environment updated to LLM: {update.llm_provider.name}, TTS: {update.tts_provider.name}, STT: {update.stt_provider.name} by {username}")
     return {"success": True}
 
 # ===================== Project Endpoints =====================
@@ -439,7 +444,7 @@ async def create_project(
     # Create project via ConfigProvider
     new_project = ConfigProvider.create_project(project.model_dump(), username)
     
-    log(f"✅ Project '{project.name}' created by {username}")
+    log_info(f"✅ Project '{project.name}' created by {username}")
     return new_project.model_dump()
 
 @router.put("/projects/{project_id}")
@@ -464,7 +469,7 @@ async def update_project(
     # Update via ConfigProvider
     updated_project = ConfigProvider.update_project(project_id, update.model_dump(), username)
     
-    log(f"✅ Project '{updated_project.name}' updated by {username}")
+    log_info(f"✅ Project '{updated_project.name}' updated by {username}")
     return updated_project.model_dump()
 
 @router.delete("/projects/{project_id}")
@@ -472,7 +477,7 @@ async def delete_project(project_id: int, username: str = Depends(verify_token))
     """Delete project (soft delete)"""
     ConfigProvider.delete_project(project_id, username)
     
-    log(f"✅ Project deleted by {username}")
+    log_info(f"✅ Project deleted by {username}")
     return {"success": True}
 
 @router.patch("/projects/{project_id}/toggle")
@@ -480,7 +485,7 @@ async def toggle_project(project_id: int, username: str = Depends(verify_token))
     """Toggle project enabled status"""
     enabled = ConfigProvider.toggle_project(project_id, username)
     
-    log(f"✅ Project {'enabled' if enabled else 'disabled'} by {username}")
+    log_info(f"✅ Project {'enabled' if enabled else 'disabled'} by {username}")
     return {"enabled": enabled}
 
 # ===================== Version Endpoints =====================
@@ -512,7 +517,7 @@ async def create_version(
     """Create new version"""
     new_version = ConfigProvider.create_version(project_id, version_data.model_dump(), username)
     
-    log(f"✅ Version created for project {project_id} by {username}")
+    log_info(f"✅ Version created for project {project_id} by {username}")
     return new_version.model_dump()
 
 @router.put("/projects/{project_id}/versions/{version_id}")
@@ -525,7 +530,7 @@ async def update_version(
     """Update version"""
     updated_version = ConfigProvider.update_version(project_id, version_id, update.model_dump(), username)
     
-    log(f"✅ Version {version_id} updated for project {project_id} by {username}")
+    log_info(f"✅ Version {version_id} updated for project {project_id} by {username}")
     return updated_version.model_dump()
 
 @router.post("/projects/{project_id}/versions/{version_id}/publish")
@@ -537,7 +542,7 @@ async def publish_version(
     """Publish version"""
     project, version = ConfigProvider.publish_version(project_id, version_id, username)
     
-    log(f"✅ Version {version_id} published for project '{project.name}' by {username}")
+    log_info(f"✅ Version {version_id} published for project '{project.name}' by {username}")
 
     # Notify LLM provider if project is enabled and provider requires repo info
     cfg = ConfigProvider.get()
@@ -547,7 +552,7 @@ async def publish_version(
         try:
             await notify_llm_startup(project, version)
         except Exception as e:
-            log(f"⚠️ Failed to notify LLM provider: {e}")
+            log_error(f"⚠️ Failed to notify LLM provider", e)
             # Don't fail the publish 
 
     return {"success": True}
@@ -561,7 +566,7 @@ async def delete_version(
     """Delete version (soft delete)"""
     ConfigProvider.delete_version(project_id, version_id, username)
     
-    log(f"✅ Version {version_id} deleted for project {project_id} by {username}")
+    log_info(f"✅ Version {version_id} deleted for project {project_id} by {username}")
     return {"success": True}
 
 @router.get("/projects/{project_name}/versions")
@@ -618,7 +623,7 @@ async def create_api(api: APICreate, username: str = Depends(verify_token)):
     """Create new API"""
     new_api = ConfigProvider.create_api(api.model_dump(), username)
     
-    log(f"✅ API '{api.name}' created by {username}")
+    log_info(f"✅ API '{api.name}' created by {username}")
     return new_api.model_dump()
 
 @router.put("/apis/{api_name}")
@@ -630,7 +635,7 @@ async def update_api(
     """Update API"""
     updated_api = ConfigProvider.update_api(api_name, update.model_dump(), username)
     
-    log(f"✅ API '{api_name}' updated by {username}")
+    log_info(f"✅ API '{api_name}' updated by {username}")
     return updated_api.model_dump()
 
 @router.delete("/apis/{api_name}")
@@ -638,7 +643,7 @@ async def delete_api(api_name: str, username: str = Depends(verify_token)):
     """Delete API (soft delete)"""
     ConfigProvider.delete_api(api_name, username)
     
-    log(f"✅ API '{api_name}' deleted by {username}")
+    log_info(f"✅ API '{api_name}' deleted by {username}")
     return {"success": True}
 
 @router.post("/validate/regex")
@@ -677,7 +682,7 @@ async def run_all_tests(
     username: str = Depends(verify_token)
 ):
     """Run all tests"""
-    log(f"🧪 Running {request.test_type} tests requested by {username}")
+    log_info(f"🧪 Running {request.test_type} tests requested by {username}")
     
     # TODO: Implement test runner
     # For now, return mock results
@@ -755,7 +760,7 @@ async def generate_tts(
                 headers={"X-TTS-Status": "disabled"}
             )
         
-        log(f"🎤 TTS request: '{request.text[:50]}...' with provider: {tts_provider.get_provider_name()}")
+        log_info(f"🎤 TTS request: '{request.text[:50]}...' with provider: {tts_provider.get_provider_name()}")
         
         # Preprocess text if needed
         preprocessor = TTSPreprocessor(language=request.language)
@@ -781,7 +786,7 @@ async def generate_tts(
         )
         
     except Exception as e:
-        log(f"❌ TTS generation error: {e}")
+        log_error("❌ TTS generation error", e)
         raise HTTPException(status_code=500, detail=str(e))
 
 @router.get("/tts/voices")
@@ -806,7 +811,7 @@ async def get_tts_voices(username: str = Depends(verify_token)):
         return {"voices": voice_list}
         
     except Exception as e:
-        log(f"❌ Error getting TTS voices: {e}")
+        log_error("❌ Error getting TTS voices", e)
         return {"voices": []}
 
 # ===================== Helper Functions =====================
@@ -829,12 +834,12 @@ async def notify_llm_startup(project, version):
         
         success = await llm_provider.startup(project_config)
         if success:
-            log(f"✅ LLM provider notified for project '{project.name}'")
+            log_info(f"✅ LLM provider notified for project '{project.name}'")
         else:
-            log(f"⚠️ LLM provider notification failed for project '{project.name}'")
+            log_info(f"⚠️ LLM provider notification failed for project '{project.name}'")
             
     except Exception as e:
-        log(f"❌ Error notifying LLM provider: {e}")
+        log_error("❌ Error notifying LLM provider", e)
         raise
 
 # ===================== Cleanup Task =====================
@@ -856,11 +861,11 @@ def cleanup_activity_log():
             
             if len(cfg.activity_log) < original_count:
                 removed = original_count - len(cfg.activity_log)
-                log(f"🧹 Cleaned up {removed} old activity log entries")
+                log_info(f"🧹 Cleaned up {removed} old activity log entries")
                 cfg.save()
                 
         except Exception as e:
-            log(f"❌ Activity log cleanup error: {e}")
+            log_error("❌ Activity log cleanup error", e)
         
         # Run every hour
         time.sleep(3600)
@@ -869,4 +874,4 @@ def start_cleanup_task():
     """Start the cleanup task in background"""
     thread = threading.Thread(target=cleanup_activity_log, daemon=True)
     thread.start()
-    log("🧹 Activity log cleanup task started")
+    log_info("🧹 Activity log cleanup task started")