sync: 193 file da Baida98/AI@bfa5fae8 (2026-08-28 07:20 UTC) [deploy-all] (#90)

- sync: 193 file da Baida98/AI@bfa5fae8 (2026-08-28 07:20 UTC) [deploy-all] (b1a3f45b3f9b0e05c6a5884aca3471562eb6abc5)

api/performance_rum.py

@@ -18,6 +18,7 @@ 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
@@ -123,6 +124,29 @@ 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
     import psycopg2.extras
@@ -200,6 +224,7 @@ async def debug_db_check(role: AuthRole = Depends(require_role(AuthRole.MACHINE)
         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,
@@ -221,10 +246,16 @@ async def debug_db_check(role: AuthRole = Depends(require_role(AuthRole.MACHINE)
             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,