deploy first

app/api/channel/stats/route.ts

@@ -0,0 +1,43 @@
+import { NextResponse } from 'next/server'
+import { PrismaClient } from '@/app/generated/prisma'
+import { auth } from '@/auth'
+
+export async function GET(request: Request) {
+  const prisma = new PrismaClient()
+  try {
+    const session = await auth()
+    const { searchParams } = new URL(request.url)
+    const handleIdsParam = searchParams.get('handleIds')
+    let handleIds: string[] | null = null
+    if (handleIdsParam) {
+      handleIds = handleIdsParam.split(',').map(s => s.trim()).filter(Boolean)
+    }
+
+    if (!handleIds) {
+      if (!session?.user?.email) return NextResponse.json({ items: [] })
+      const myHandles = await prisma.handle.findMany({
+        where: { users: { some: { email: session.user.email } } },
+        select: { id: true },
+      })
+      handleIds = myHandles.map(h => h.id)
+    }
+
+    const items: Array<{ handleId: string, videoCount: number, views: number }> = []
+    for (const id of handleIds) {
+      const videoCount = await prisma.content.count({ where: { handleId: id } })
+      const agg = await prisma.contentDayView.aggregate({
+        _sum: { views: true },
+        where: { content: { handleId: id } },
+      })
+      items.push({ handleId: id, videoCount, views: Number(agg._sum.views ?? 0) })
+    }
+
+    return NextResponse.json({ items })
+  } catch (e) {
+    return NextResponse.json({ error: 'stats failed' }, { status: 500 })
+  } finally {
+    try { await prisma.$disconnect() } catch {}
+  }
+}
+
+