sync: 193 file da Baida98/AI@bd00f054 (2026-08-28 06:05 UTC) [deploy-all]

api/performance_rum.py

@@ -25,6 +25,7 @@ from pydantic import BaseModel, ConfigDict, Field, field_validator
 from .auth_guard import AuthRole, require_role
 
 router = APIRouter(prefix="/api/performance", tags=["performance"])
+debug_router = APIRouter(prefix="/api/debug", tags=["debug"])
 admin_dependency = Depends(require_role(AuthRole.ADMIN))
 
 _RELEASE_RE = re.compile(r"^[0-9a-f]{7,40}$")
@@ -189,6 +190,52 @@ async def ingest_metric(
     return {"accepted": True}
 
 
+@debug_router.get("/db-check", include_in_schema=False)
+async def debug_db_check(role: AuthRole = Depends(require_role(AuthRole.MACHINE))) -> dict[str, Any]:
+    """Temporary internal DB probe; remove after diagnosing Supabase connectivity."""
+    started = time.perf_counter()
+    try:
+        rows = await asyncio.to_thread(_execute, "select now() as db_now", {}, fetch=True)
+        elapsed_ms = round((time.perf_counter() - started) * 1000, 1)
+        return {
+            "ok": True,
+            "db_now": rows[0].get("db_now") if rows else None,
+            "latency_ms": elapsed_ms,
+            "tls_required": True,
+            "connect_timeout_s": 5,
+            "statement_timeout_ms": 5000,
+        }
+    except Exception as exc:
+        elapsed_ms = round((time.perf_counter() - started) * 1000, 1)
+        name = type(exc).__name__
+        lowered = name.lower()
+        if "timeout" in lowered or "cancel" in lowered:
+            category = "timeout"
+        elif "ssl" in lowered or "certificate" in lowered:
+            category = "tls"
+        elif "auth" in lowered or "password" in lowered:
+            category = "authentication"
+        elif "operational" in lowered or "connection" in lowered:
+            category = "connectivity"
+        else:
+            category = "database"
+        pgcode = getattr(exc, "pgcode", None)
+        _logger.error("RUM db probe failed type=%s category=%s elapsed_ms=%s", name, category, elapsed_ms)
+        return {
+            "ok": False,
+            "error_category": category,
+            "exception_type": name,
+            "sqlstate": pgcode[:5] if isinstance(pgcode, str) else None,
+            "latency_ms": elapsed_ms,
+            "tls_required": True,
+            "connect_timeout_s": 5,
+            "statement_timeout_ms": 5000,
+        }
+
+
+extra_routers = (debug_router,)
+
+
 @router.get("/admin/summary", dependencies=[admin_dependency])
 async def performance_summary(
     from_time: datetime,

main.py

@@ -189,6 +189,8 @@ for prefix, module_name in _ROUTER_MAP.items():
         module = importlib.import_module(f"api.{module_name}")
         if hasattr(module, "router"):
             app.include_router(module.router)
+            for extra_router in getattr(module, "extra_routers", ()):
+                app.include_router(extra_router)
             _logger.info(f"✅ Route montata: /api/{prefix} (da api.{module_name})")
         else:
             _logger.warning(f"⚠️ Modulo api.{module_name} non ha un attributo 'router'")