From 244a29bd1bb88dac974cd67c30910857aecc2495 Mon Sep 17 00:00:00 2001
From: Adrian Bonpin <adrianbonpin@gmail.com>
Date: Thu, 30 Apr 2026 20:44:27 +0800
Subject: [PATCH] feat: create dashboard overview API endpoint

Add /api/dashboard/stats route that provides admin dashboard statistics:
- Total counts (games, benchmarks, users)
- Pending moderation items (reports, suggestions)
- 30-day activity metrics (recent benchmarks, recent games)
- Top 10 contributors by entry count
- Sync health breakdown by status
- Games by source distribution
- Playability distribution

Auth: requireContributorOrAdmin guard
Route registered in lib/api/index.ts
---
 lib/api/dashboard.ts | 163 +++++++++++++++++++++++++++++++++++++++++++
 lib/api/index.ts     |   1 +
 2 files changed, 164 insertions(+)
 create mode 100644 lib/api/dashboard.ts

diff --git a/lib/api/dashboard.ts b/lib/api/dashboard.ts
new file mode 100644
index 0000000..274b86c
--- /dev/null
+++ b/lib/api/dashboard.ts
@@ -0,0 +1,163 @@
+import { Elysia } from "elysia";
+import { db } from "@/lib/db/index";
+import {
+  games,
+  performanceEntries,
+  reports,
+  communitySuggestions,
+  user,
+} from "@/lib/db/schema";
+import { eq, count, sql, gte, and, desc } from "drizzle-orm";
+import { requireContributorOrAdmin } from "@/lib/auth/guard";
+
+export const dashboardRoutes = new Elysia({ prefix: "/api/dashboard" }).get(
+  "/stats",
+  async ({ request, set }) => {
+    const guard = await requireContributorOrAdmin(request.headers);
+    if (!guard.ok) {
+      set.status = guard.status;
+      return { error: guard.error };
+    }
+
+    const thirtyDaysAgo = new Date();
+    thirtyDaysAgo.setDate(thirtyDaysAgo.getDate() - 30);
+
+    const [
+      totalGames,
+      totalBenchmarks,
+      totalUsers,
+      pendingReports,
+      pendingSuggestions,
+      recentBenchmarks,
+      recentGames,
+      topContributors,
+      syncHealth,
+      gamesBySource,
+      playabilityDistribution,
+    ] = await Promise.all([
+      // Total games
+      db.select({ count: count() }).from(games),
+
+      // Total benchmarks
+      db
+        .select({ count: count() })
+        .from(performanceEntries)
+        .where(eq(performanceEntries.isRemoved, false)),
+
+      // Total users
+      db.select({ count: count() }).from(user),
+
+      // Pending reports
+      db
+        .select({ count: count() })
+        .from(reports)
+        .where(eq(reports.status, "open")),
+
+      // Pending suggestions
+      db
+        .select({ count: count() })
+        .from(communitySuggestions)
+        .where(eq(communitySuggestions.status, "pending")),
+
+      // Benchmarks in last 30 days
+      db
+        .select({ count: count() })
+        .from(performanceEntries)
+        .where(
+          and(
+            eq(performanceEntries.isRemoved, false),
+            gte(performanceEntries.createdAt, thirtyDaysAgo),
+          ),
+        ),
+
+      // Games added in last 30 days
+      db
+        .select({ count: count() })
+        .from(games)
+        .where(gte(games.createdAt, thirtyDaysAgo)),
+
+      // Top contributors
+      db
+        .select({
+          userId: performanceEntries.userId,
+          userName: user.name,
+          entryCount: count(),
+        })
+        .from(performanceEntries)
+        .leftJoin(user, eq(performanceEntries.userId, user.id))
+        .where(eq(performanceEntries.isRemoved, false))
+        .groupBy(performanceEntries.userId, user.name)
+        .orderBy(desc(count()))
+        .limit(10),
+
+      // Sync health
+      db
+        .select({
+          status: games.syncStatus,
+          count: count(),
+        })
+        .from(games)
+        .where(sql`${games.steamAppId} IS NOT NULL`)
+        .groupBy(games.syncStatus),
+
+      // Games by source
+      db
+        .select({
+          source: games.source,
+          count: count(),
+        })
+        .from(games)
+        .groupBy(games.source),
+
+      // Playability distribution
+      db
+        .select({
+          status: games.playabilityStatus,
+          count: count(),
+        })
+        .from(games)
+        .where(sql`${games.playabilityStatus} IS NOT NULL`)
+        .groupBy(games.playabilityStatus),
+    ]);
+
+    return {
+      overview: {
+        totalGames: totalGames[0]?.count ?? 0,
+        totalBenchmarks: totalBenchmarks[0]?.count ?? 0,
+        totalUsers: totalUsers[0]?.count ?? 0,
+        pendingReports: pendingReports[0]?.count ?? 0,
+        pendingSuggestions: pendingSuggestions[0]?.count ?? 0,
+      },
+      recent: {
+        benchmarksLast30Days: recentBenchmarks[0]?.count ?? 0,
+        gamesLast30Days: recentGames[0]?.count ?? 0,
+      },
+      topContributors: topContributors.map((c) => ({
+        userId: c.userId,
+        name: c.userName ?? "Anonymous",
+        count: c.entryCount,
+      })),
+      syncHealth: syncHealth.reduce(
+        (acc, s) => {
+          acc[s.status ?? "unknown"] = s.count;
+          return acc;
+        },
+        {} as Record<string, number>,
+      ),
+      gamesBySource: gamesBySource.reduce(
+        (acc, s) => {
+          acc[s.source ?? "unknown"] = s.count;
+          return acc;
+        },
+        {} as Record<string, number>,
+      ),
+      playabilityDistribution: playabilityDistribution.reduce(
+        (acc, p) => {
+          acc[p.status ?? "unknown"] = p.count;
+          return acc;
+        },
+        {} as Record<string, number>,
+      ),
+    };
+  },
+);
\ No newline at end of file
diff --git a/lib/api/index.ts b/lib/api/index.ts
index 95e74cc..516d557 100644
--- a/lib/api/index.ts
+++ b/lib/api/index.ts
@@ -21,3 +21,4 @@ export { playabilityRoutes } from "./playability"
 export { steamReviewRoutes } from "./steam-reviews"
 export { communitySuggestionRoutes } from "./community-suggestions"
 export { savedFilterRoutes } from "./saved-filters"
+export { dashboardRoutes } from "./dashboard"