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
This commit is contained in:
@@ -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>,
|
||||
),
|
||||
};
|
||||
},
|
||||
);
|
||||
@@ -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"
|
||||
|
||||
Reference in New Issue
Block a user