mjalmoudy94
f1e5df29ce
- Backend: ConnectionManager, Redis-backed bus with in-process fallback, channel authorization, and typed emit helpers wired into workers (ai_runtime, sandbox_gateway), workforce/sandbox/billing/audit/error services. - Frontend: single shared WS client with backoff + heartbeat, RealtimeProvider, useLiveChannel/useLiveEvent hooks, live indicators on task detail, manager chat, dashboard, traces, sandbox terminal, admin errors, and billing. - Contracts: WsEvent/WsServerFrame/WsClientFrame types mirroring the port. All 255 backend tests pass; web typecheck and build pass.
64 lines
2.4 KiB
Python
64 lines
2.4 KiB
Python
"""Health and readiness endpoints."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from fastapi import APIRouter, Depends
|
|
from sqlalchemy import text
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.core.config import settings
|
|
from app.core.database import get_session
|
|
from app.infrastructure.adapters.registry import get_model_provider
|
|
|
|
router = APIRouter(tags=["health"])
|
|
|
|
|
|
@router.get("/health")
|
|
async def health() -> dict:
|
|
"""Liveness. Must stay dependency-free so it answers during a DB outage."""
|
|
return {"status": "ok", "app": settings.app_name, "env": settings.app_env}
|
|
|
|
|
|
@router.get("/health/ready")
|
|
async def readiness(session: AsyncSession = Depends(get_session)) -> dict:
|
|
"""Readiness: verifies the database and reports which adapters are active."""
|
|
checks: dict[str, object] = {}
|
|
try:
|
|
await session.execute(text("SELECT 1"))
|
|
checks["database"] = "ok"
|
|
except Exception as exc: # noqa: BLE001 - reported, not raised
|
|
checks["database"] = f"error: {exc.__class__.__name__}"
|
|
|
|
try:
|
|
model_health = await get_model_provider().health()
|
|
checks["model_provider"] = "ok" if model_health.ok else f"degraded: {model_health.detail}"
|
|
except Exception as exc: # noqa: BLE001
|
|
checks["model_provider"] = f"error: {exc.__class__.__name__}"
|
|
|
|
checks["adapters"] = {
|
|
"ai": settings.ai_default_provider,
|
|
"git": settings.git_provider,
|
|
"domain_router": settings.domain_router,
|
|
"sandbox": settings.sandbox_provider,
|
|
"payment": settings.payment_provider,
|
|
}
|
|
|
|
# Live-feed visibility: how many browser sockets this process is serving,
|
|
# and whether the cross-process relay (Redis) is connected. An operator
|
|
# wondering "is realtime working?" should not have to read the logs.
|
|
try:
|
|
from app.interfaces.realtime.bus import get_bus
|
|
from app.interfaces.realtime.router import realtime_manager
|
|
|
|
manager = realtime_manager()
|
|
checks["realtime"] = {
|
|
"connections": manager.connection_count,
|
|
"channels": manager.channel_count,
|
|
"redis_relay": "connected" if get_bus().redis_healthy else "in_process_only",
|
|
}
|
|
except Exception: # noqa: BLE001 - health must answer regardless
|
|
checks["realtime"] = "unavailable"
|
|
|
|
healthy = checks.get("database") == "ok"
|
|
return {"status": "ok" if healthy else "degraded", "checks": checks}
|