sync: 194 file da Baida98/AI@d7f0f6a2 (2026-08-30 07:28 UTC) (#150)

- sync: 194 file da Baida98/AI@d7f0f6a2 (2026-08-30 07:28 UTC) (8dde3786510cacdc19504dcffb07c60ac7c8fe75)

api/public_snapshot.py

@@ -8,9 +8,49 @@ from __future__ import annotations
 
 import asyncio
 import logging
+import os
 from typing import Any
 
-from .state import _agent_tasks, _loop_registry, sb
+from .state import _agent_tasks, _loop_registry
+
+try:
+    from supabase import create_client
+except ImportError:  # pragma: no cover - deployment dependency guard
+    create_client = None
+
+_snapshot_client: Any | None = None
+_snapshot_client_initialized = False
+
+
+def get_snapshot_client() -> Any | None:
+    """Return one stable Supabase client for the canonical snapshot project.
+
+    Unlike the general round-robin pool, this client never changes project
+    between a write and a read. Dedicated variables can be used when the
+    snapshot lives in a separate project; otherwise project A is canonical.
+    """
+    global _snapshot_client, _snapshot_client_initialized
+    if _snapshot_client_initialized:
+        return _snapshot_client
+    _snapshot_client_initialized = True
+    if create_client is None:
+        _logger.warning("BOOT: public snapshot skipped — supabase package unavailable")
+        return None
+    url = os.getenv("PUBLIC_SNAPSHOT_SUPABASE_URL") or os.getenv("SUPABASE_URL")
+    key = (
+        os.getenv("PUBLIC_SNAPSHOT_SUPABASE_SERVICE_ROLE_KEY")
+        or os.getenv("SUPABASE_SERVICE_ROLE_KEY")
+        or os.getenv("SUPABASE_KEY")
+    )
+    if not url or not key:
+        _logger.warning("BOOT: public snapshot skipped — canonical Supabase URL/key unavailable")
+        return None
+    try:
+        _snapshot_client = create_client(url, key)
+        _logger.info("BOOT: canonical Supabase snapshot client initialized")
+    except Exception as exc:
+        _logger.warning("BOOT: canonical Supabase snapshot client init failed type=%s", type(exc).__name__)
+    return _snapshot_client
 from .version import RUNTIME_VERSION
 
 _logger = logging.getLogger("agente_ai.public_snapshot")
@@ -37,7 +77,7 @@ async def write_public_dashboard_snapshot() -> bool:
     public status route remains available with its degraded response while the
     service continues booting; the exact exception is kept in backend logs.
     """
-    client = sb()
+    client = get_snapshot_client()
     if client is None:
         _logger.warning("BOOT: public snapshot skipped — Supabase client unavailable")
         return False

api/public_snapshot_diagnostics.py

@@ -12,7 +12,7 @@ from typing import Any, Optional
 from fastapi import APIRouter, Depends
 
 from .auth_guard import AuthRole, require_role
-from .state import sb
+from .public_snapshot import get_snapshot_client
 
 router = APIRouter(
     prefix="/api/diagnostics/public-snapshot",
@@ -40,7 +40,7 @@ def _safe_error(exc: Exception) -> dict[str, Optional[str]]:
 @router.get("")
 async def public_snapshot_diagnostics() -> dict[str, Any]:
     """Return snapshot presence and a sanitized exact Supabase error, if any."""
-    client = sb()
+    client = get_snapshot_client()
     if client is None:
         return {
             "ok": False,