Spaces:
Configuration error
Configuration error
File size: 2,508 Bytes
bcce530 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 | import { NextRequest, NextResponse } from 'next/server'
import prisma from '@/lib/prisma'
import { getAuthUser } from '@/lib/auth'
// GET /api/notifications — get current user's notifications
export async function GET(request: NextRequest) {
try {
const authUser = await getAuthUser()
if (!authUser) {
return NextResponse.json({ error: 'Authentication required' }, { status: 401 })
}
const { searchParams } = new URL(request.url)
const unreadOnly = searchParams.get('unread') === 'true'
const limit = Math.min(parseInt(searchParams.get('limit') || '20'), 50)
const where: Record<string, unknown> = { userId: authUser.id }
if (unreadOnly) {
where.isRead = false
}
const [notifications, unreadCount] = await Promise.all([
prisma.notification.findMany({
where,
orderBy: { createdAt: 'desc' },
take: limit,
}),
prisma.notification.count({
where: { userId: authUser.id, isRead: false },
}),
])
return NextResponse.json({ notifications, unreadCount })
} catch (error) {
console.error('Error fetching notifications:', error)
return NextResponse.json({ error: 'Internal server error' }, { status: 500 })
}
}
// PATCH /api/notifications — mark notifications as read
export async function PATCH(request: NextRequest) {
try {
const authUser = await getAuthUser()
if (!authUser) {
return NextResponse.json({ error: 'Authentication required' }, { status: 401 })
}
const body = await request.json()
const { notificationIds, markAllRead } = body
if (markAllRead) {
await prisma.notification.updateMany({
where: { userId: authUser.id, isRead: false },
data: { isRead: true },
})
} else if (notificationIds && Array.isArray(notificationIds)) {
await prisma.notification.updateMany({
where: {
id: { in: notificationIds },
userId: authUser.id,
},
data: { isRead: true },
})
}
return NextResponse.json({ success: true })
} catch (error) {
console.error('Error updating notifications:', error)
return NextResponse.json({ error: 'Internal server error' }, { status: 500 })
}
}
|