Function v2_get_session_stats

app/api/agentops/api/routes/v2.py:746–794

(session_id: str, request: Request, supabase: AsyncSupabaseClient)

@router.get("/sessions/{session_id}/stats")
async def v2_get_session_stats(session_id: str, request: Request, supabase: AsyncSupabaseClient):
    try:
        api_key = request.headers.get("X-Agentops-Api-Key")
        if api_key is None:
            raise RuntimeError("API Key is Missing")

        validate_uuid(api_key)

        # Get project ID from API key
        project_response = await supabase.table("projects").select("id").eq("api_key", api_key).execute()
        project = project_response.data[0] if project_response.data else None

        if not project:
            raise RuntimeError("Invalid API Key")

        # Check if session belongs to this project
        session_response = (
            await supabase.table("sessions")
            .select("id")
            .eq("id", session_id)
            .eq("project_id", project["id"])
            .execute()
        )
        if not session_response.data:
            raise RuntimeError("Session does not belong to this project")

        stats_response = await supabase.table("stats").select("*").eq("session_id", session_id).execute()
        stats = (
            stats_response.data[0]
            if stats_response.data
            else {
                "events": 0,
                "cost": "0.00",
                "prompt_tokens": 0,
                "completion_tokens": 0,
                "errors": 0,
            }
        )

        return JSONResponse(stats)

    except InvalidAPIKeyError as e:
        # This is a user error (invalid API key format), not a system error
        # Log as warning to avoid Sentry alerts
        logger.warning(f"{request.url.path}: Invalid API key format for session {session_id}")
        return JSONResponse({"path": request.url.path, "message": "Invalid API key format"}, status_code=400)
    except RuntimeError as e:
        logger.error(f"Error getting session stats: {e}")
        return JSONResponse({"path": request.url.path, "message": str(e)}, status_code=400)


@router.get("/sessions/{session_id}/export")