sync: 193 file da Baida98/AI@52f96f4f (2026-08-28 09:13 UTC) [deploy-all] (#135)

- sync: 193 file da Baida98/AI@52f96f4f (2026-08-28 09:13 UTC) [deploy-all] (6819abe673c768afa4e5c3a7e8d6160ed15746bf)

api/performance_rum.py

@@ -18,7 +18,6 @@ import re
 import time
 from datetime import datetime, timezone
 from typing import Annotated, Any
-from urllib.parse import parse_qs, urlsplit
 
 from fastapi import APIRouter, Depends, Header, HTTPException, Request, status
 from pydantic import BaseModel, ConfigDict, Field, field_validator
@@ -26,7 +25,6 @@ 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}$")
@@ -124,28 +122,6 @@ def _db_url() -> str:
     return value
 
 
-def _db_target_metadata() -> dict[str, Any]:
-    """Return only non-secret connection metadata for the temporary probe."""
-    raw = _db_url()
-    parsed = urlsplit(raw)
-    host = (parsed.hostname or "").lower()
-    port = parsed.port or 5432
-    query = parse_qs(parsed.query)
-    sslmode = query.get("sslmode", [None])[0]
-    if "pooler" in host or port in {6543, 6544}:
-        target = "pooler"
-    else:
-        target = "direct"
-    return {
-        "scheme": parsed.scheme,
-        "target": target,
-        "port": port,
-        "sslmode_in_url": sslmode or "not_explicit",
-        "has_database": bool(parsed.path and parsed.path != "/"),
-        "has_username": bool(parsed.username),
-        "has_password": bool(parsed.password),
-    }
-
 
 def _execute(sql: str, params: dict[str, Any], *, fetch: bool = False) -> list[dict[str, Any]]:
     import psycopg2
@@ -214,58 +190,6 @@ 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,
-            "connection": _db_target_metadata(),
-            "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)
-        metadata: dict[str, Any]
-        try:
-            metadata = _db_target_metadata()
-        except Exception:
-            metadata = {"configuration": "invalid_or_unavailable"}
-        return {
-            "ok": False,
-            "error_category": category,
-            "exception_type": name,
-            "connection": metadata,
-            "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(

main.py

@@ -189,8 +189,6 @@ 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'")