|
|
|
|
|
"""
|
|
|
Configuration API Router
|
|
|
========================
|
|
|
API endpoints for configuration management and hot reload
|
|
|
"""
|
|
|
|
|
|
from fastapi import APIRouter, HTTPException, Query
|
|
|
from fastapi.responses import JSONResponse
|
|
|
from typing import Optional, Dict, Any
|
|
|
import logging
|
|
|
|
|
|
from backend.services.config_manager import get_config_manager
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
router = APIRouter(
|
|
|
prefix="/api/config",
|
|
|
tags=["Configuration"]
|
|
|
)
|
|
|
|
|
|
|
|
|
config_manager = get_config_manager()
|
|
|
|
|
|
|
|
|
@router.post("/reload")
|
|
|
async def reload_config(config_name: Optional[str] = Query(None, description="Specific config to reload (reloads all if omitted)")) -> JSONResponse:
|
|
|
"""
|
|
|
Manually reload configuration files.
|
|
|
|
|
|
Reloads a specific configuration file or all configuration files.
|
|
|
|
|
|
Args:
|
|
|
config_name: Optional specific config name to reload
|
|
|
|
|
|
Returns:
|
|
|
JSON response with reload status
|
|
|
"""
|
|
|
try:
|
|
|
result = config_manager.manual_reload(config_name)
|
|
|
|
|
|
if result["success"]:
|
|
|
return JSONResponse(
|
|
|
status_code=200,
|
|
|
content={
|
|
|
"success": True,
|
|
|
"message": result["message"],
|
|
|
"data": result
|
|
|
}
|
|
|
)
|
|
|
else:
|
|
|
raise HTTPException(status_code=404, detail=result["message"])
|
|
|
|
|
|
except Exception as e:
|
|
|
logger.error(f"Error reloading config: {e}", exc_info=True)
|
|
|
raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
|
|
|
|
|
|
|
|
|
@router.get("/status")
|
|
|
async def get_config_status() -> JSONResponse:
|
|
|
"""
|
|
|
Get configuration status.
|
|
|
|
|
|
Returns the status of all loaded configurations.
|
|
|
|
|
|
Returns:
|
|
|
JSON response with config status
|
|
|
"""
|
|
|
try:
|
|
|
all_configs = config_manager.get_all_configs()
|
|
|
|
|
|
status = {
|
|
|
"loaded_configs": list(all_configs.keys()),
|
|
|
"config_count": len(all_configs),
|
|
|
"configs": {}
|
|
|
}
|
|
|
|
|
|
for config_name, config_data in all_configs.items():
|
|
|
status["configs"][config_name] = {
|
|
|
"version": config_data.get("version", "unknown"),
|
|
|
"last_updated": config_data.get("last_updated", "unknown"),
|
|
|
"keys": list(config_data.keys())
|
|
|
}
|
|
|
|
|
|
return JSONResponse(
|
|
|
status_code=200,
|
|
|
content={
|
|
|
"success": True,
|
|
|
"data": status
|
|
|
}
|
|
|
)
|
|
|
|
|
|
except Exception as e:
|
|
|
logger.error(f"Error getting config status: {e}", exc_info=True)
|
|
|
raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
|
|
|
|
|
|
|
|
|
@router.get("/{config_name}")
|
|
|
async def get_config(config_name: str) -> JSONResponse:
|
|
|
"""
|
|
|
Get a specific configuration.
|
|
|
|
|
|
Retrieves the current configuration for a specific config name.
|
|
|
|
|
|
Args:
|
|
|
config_name: Name of the config to retrieve
|
|
|
|
|
|
Returns:
|
|
|
JSON response with configuration data
|
|
|
"""
|
|
|
try:
|
|
|
config = config_manager.get_config(config_name)
|
|
|
|
|
|
if config is None:
|
|
|
raise HTTPException(status_code=404, detail=f"Config '{config_name}' not found")
|
|
|
|
|
|
return JSONResponse(
|
|
|
status_code=200,
|
|
|
content={
|
|
|
"success": True,
|
|
|
"config_name": config_name,
|
|
|
"data": config
|
|
|
}
|
|
|
)
|
|
|
|
|
|
except HTTPException:
|
|
|
raise
|
|
|
except Exception as e:
|
|
|
logger.error(f"Error getting config: {e}", exc_info=True)
|
|
|
raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
|
|
|
|
|
|
|
