44 lines
1.4 KiB
TypeScript
44 lines
1.4 KiB
TypeScript
|
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 {}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|