sync: 141 file da Baida98/AI@35be4001 (2026-08-07 14:06 UTC)

api/state.py

@@ -54,236 +54,6 @@ try:
                 _clients.append({"client": c, "id": cfg["id"], "status": "connected"})
                 _logger.info(f"BOOT: Supabase #{cfg['id']} connected OK")
             except Exception as e:
-                _logger.error(f"BOOT: Supabase #{cfg['id']} init failed: {e}")
-except ImportError:
-    _logger.error("BOOT: Supabase init module failed: create_client not found.")
-
-def _get_sb() -> Any:
-    """Ritorna il client Supabase corrente dal pool (round-robin)."""
-    global _current_client_idx
-    if not _clients: return None
-    # S-FIX: Salta i client marcati come "failed" (semplice circuit breaker)
-    for _ in range(len(_clients)):
-        entry = _clients[_current_client_idx]
-        _current_client_idx = (_current_client_idx + 1) % len(_clients)
-        if entry["status"] != "failed":
-            return entry["client"]
-    return _clients[0]["client"] if _clients else None
-
-_sb = _get_sb()
-
-# ── SENSITIVE keys set (Z-GAP-4) ──────────────────────────────────────────────
-SENSITIVE = {
-    'OPENROUTER_API_KEY', 'OPENAI_API_KEY', 'GEMINI_API_KEY', 'GROQ_API_KEY',
-    'HF_TOKEN', 'HUGGINGFACE_API_KEY', 'GH_TOKEN', 'GITHUB_TOKEN',
-    'QDRANT_API_KEY', 'DATABASE_URL', 'SESSION_SECRET', 'SECRET_KEY',
-    'RAILWAY_TOKEN', 'SUPABASE_KEY', 'SUPABASE_ANON_KEY',
-    'TELEGRAM_BOT_TOKEN', 'TELEGRAM_CHAT_ID',
-    'CF_API_TOKEN', 'CLOUDFLARE_API_TOKEN', 'CF_ACCOUNT_ID',
-    'CF_API_TOKEN_B', 'CF_ACCOUNT_ID_B',
-    'CEREBRAS_API_KEY', 'SAMBANOVA_API_KEY',
-    'VAULT_KEY', 'INTERNAL_TOKEN', 'DEPLOY_SECRET', 'WEBHOOK_TOKEN',
-    'TERMINAL_SECRET', 'EXEC_TOKEN', 'VITE_INTERNAL_TOKEN', 'VITE_TERMINAL_SECRET',
-    'VITE_OPENROUTER_API_KEY', 'VITE_HF_TOKEN', 'VITE_GROQ_API_KEY',
-    'GH_PAGES_TOKEN', 'VERCEL_TOKEN',
-}
-
-# ── In-memory stores ──────────────────────────────────────────────────────────
-_mem_fallback: dict[str, dict] = {}
-_agent_tasks: dict[str, dict] = {}
-_run_stream_tasks: dict[str, dict] = {}
-_loop_registry: dict[str, dict] = {}
-_LOOP_REGISTRY_TTL_S: float = 10 * 60
-_task_checkpoints: dict[str, dict] = {}
-_CHECKPOINT_TTL_MS = 2 * 60 * 60 * 1000
-_CHECKPOINT_MAX    = 100
-_AGENT_TASK_TTL_MS = 2 * 60 * 60 * 1000
-_AGENT_TASK_MAX    = 200
-
-# ── Telemetry & Health ────────────────────────────────────────────────────────
-_ai_health_cache: dict = {"data": None, "at": 0.0}
-_AI_HEALTH_TTL = 60.0
-_heartbeat_state: dict = {
-    "last_run_at":     None,
-    "next_run_at":     None,
-    "best_provider":   None,
-    "best_latency_ms": None,
-    "providers":       [],
-    "runs":            0,
-}
-
-# ── Singleton Getters ─────────────────────────────────────────────────────────
-def get_supabase() -> Optional[Any]:
-    """Ritorna il client Supabase primario."""
-    return _sb
-
-_mem_manager: Any = None
-_mem_manager_inited = False
-def _get_mem_manager() -> Any:
-    global _mem_manager, _mem_manager_inited
-    if _mem_manager_inited: return _mem_manager
-    try:
-        from memory.memory_manager import MemoryManager
-        try:
-            _mem_manager = MemoryManager()
-            _mem_manager_inited = True
-        except RuntimeError: pass
-    except Exception: _mem_manager = None
-    return _mem_manager
-
-_executor: Any = None
-def _get_executor() -> Any:
-    global _executor
-    if _executor is not None: return _executor
-    try:
-        from agents.executor import Executor
-        _executor = Executor(memory=_get_mem_manager())
-    except Exception: _executor = None
-    return _executor
-
-_ai_client: Any = None
-def _get_ai_client() -> Any:
-    global _ai_client
-    if _ai_client is not None: return _ai_client
-    try:
-        from models.ai_client import AIClient
-        _ai_client = AIClient()
-    except Exception: _ai_client = None
-    return _ai_client
-
-_planner: Any = None
-def _get_planner() -> Any:
-    global _planner
-    if _planner is not None: return _planner
-    try:
-        from agents.planner import Planner
-        _planner = Planner(llm_client=_get_ai_client())
-    except Exception: _planner = None
-    return _planner
-
-
-_memory_manager: Any = None
-_memory_manager_lock = _asyncio_mod.Lock()
-
-async def _get_mem_manager_async() -> Any:
-    """Return the shared initialized MemoryManager for agent runs."""
-    global _memory_manager
-    if _memory_manager is not None:
-        return _memory_manager
-    async with _memory_manager_lock:
-        if _memory_manager is not None:
-            return _memory_manager
-        from memory.manager import MemoryManager
-        manager = MemoryManager(sb_client=_get_sb())
-        await manager.init()
-        _memory_manager = manager
-        return _memory_manager
-
-# ── Prune helpers ─────────────────────────────────────────────────────────────
-def _prune_checkpoints() -> None:
-    now = int(time.time() * 1000)
-    expired = [k for k, v in list(_task_checkpoints.items()) if now - v.get('savedAt', 0) > _CHECKPOINT_TTL_MS]
-    for k in expired: _task_checkpoints.pop(k, None)
-    if len(_task_checkpoints) > _CHECKPOINT_MAX:
-        oldest = sorted(list(_task_checkpoints.items()), key=lambda x: x[1].get('savedAt', 0))
-        for k, _ in oldest[:len(_task_checkpoints) - _CHECKPOINT_MAX]: _task_checkpoints.pop(k, None)
-
-def _prune_agent_tasks() -> None:
-    now = int(time.time() * 1000)
-    expired = [k for k, v in list(_agent_tasks.items()) if v.get('status') in ('SUCCESS', 'ERROR', 'CANCELLED') and now - v.get('created_at', 0) > _AGENT_TASK_TTL_MS]
-    for k in expired: _agent_tasks.pop(k, None)
-    if len(_agent_tasks) > _AGENT_TASK_MAX:
-        oldest = sorted(list(_agent_tasks.items()), key=lambda x: x[1].get('created_at', 0))
-        for k, _ in oldest[:len(_agent_tasks) - _AGENT_TASK_MAX]: _agent_tasks.pop(k, None)
-
-def _prune_loop_registry() -> None:
-    now = time.time()
-    stale = [k for k, v in list(_loop_registry.items()) if v.get('done') and now - v.get('finished_at', 0.0) > _LOOP_REGISTRY_TTL_S]
-    for k in stale: _loop_registry.pop(k, None)
-
-# ── Shared Pydantic models ────────────────────────────────────────────────────
-class ReasonLoopIn(BaseModel):
-    goal: str
-    context: list[dict] = []
-    max_steps: int = 8
-    project_context: str = ""
-    learning_hints: list[str] = []
-    session_id: Optional[str] = None
-    negative_constraints: Optional[str] = ""
-
-    @field_validator('goal', mode='before')
-    @classmethod
-    def validate_goal(cls, v: object) -> str:
-        if not isinstance(v, str) or not v.strip(): raise ValueError('goal must be a non-empty string')
-        return v.strip()
-
-    @field_validator('context', 'learning_hints', mode='before')
-    @classmethod
-    def coerce_list(cls, v: object) -> list:
-        return v if isinstance(v, list) else []
-
-    @field_validator('project_context', mode='before')
-    @classmethod
-    def coerce_str(cls, v: object) -> str:
-        return str(v).strip()[:2000] if v else ""
-
-class AgentTaskIn(BaseModel):
-    goal: str
-    context: list[dict] = []
-    max_steps: int = 8
-    taskId: Optional[str] = None
-    project_context: str = ""
-    learning_hints: list[str] = []
-    session_id: Optional[str] = None
-    resume_from_step: Optional[int] = None
-    persona: Optional[str] = None
-    negative_constraints: Optional[str] = ""
-
-    @field_validator('goal', mode='before')
-    @classmethod
-    def validate_goal(cls, v: object) -> str:
-        if not isinstance(v, str) or not v.strip(): raise ValueError('goal must be a non-empty string')
-        return v.strip()
-
-    @field_validator('context', 'learning_hints', mode='before')
-    @classmethod
-    def coerce_list(cls, v: object) -> list:
-        return v if isinstance(v, list) else []
-
-@router.get("/health")
-async def health_check(request: Request):
-    """
-    Z-GAP-3: Healthcheck endpoint per monitoraggio deploy (TMA/HF).
-    Verifica lo stato del server e la connettività al database.
-    """
-    health = {
-        "status": "ok",
-        "timestamp": time.time(),
-        "version": "1.5.5",
-        "database": "unknown",
-        "pool_size": len(_clients)
-    }
-    try:
-        if _sb:
-            # S-FIX: Verifica reale con try-except per gestire errori PostgREST malformati
-            try:
-                # S-FIX: select('key') è più leggero di select('count') per health check
-                res = _sb.table("agent_memory").select("key").limit(1).execute()
-                health["database"] = "connected"
-            except Exception as inner_e:
-                # Se il client corrente fallisce, lo marchiamo per il pool
-                for entry in _clients:
-                    if entry["client"] == _sb:
-                        entry["status"] = "failed"
-                        break
-                raise inner_e
-        else:
-            health["database"] = "disconnected"
-    except Exception as e:
         health["status"] = "degraded"
-        # S-FIX: Estrae il messaggio di errore in modo più pulito
-        err_msg = str(e)
-        if "JSON could not be generated" in err_msg:
-            err_msg = "PostgREST JSON error (likely RLS or schema mismatch)"
-        health["database"] = f"error: {err_msg[:100]}"
+        health["database"] = f"RAW_ERROR: {str(e)}"
     return health