37 lines
843 B
JavaScript
37 lines
843 B
JavaScript
'use server';
|
|
import connectDB from '@/config/database';
|
|
import Message from '@/models/Message';
|
|
import { getSessionUser } from '@/utils/getSessionUser';
|
|
import { revalidatePath } from 'next/cache';
|
|
|
|
async function markMessageAsRead(messageId) {
|
|
await connectDB();
|
|
|
|
const sessionUser = await getSessionUser();
|
|
|
|
if (!sessionUser || !sessionUser.user) {
|
|
throw new Error('User ID is required');
|
|
}
|
|
|
|
const { userId } = sessionUser;
|
|
|
|
const message = await Message.findById(messageId);
|
|
|
|
if (!message) throw new Error('Message not found');
|
|
|
|
// Verify ownership
|
|
if (message.recipient.toString() !== userId) {
|
|
return new Response('Unauthorized', { status: 401 });
|
|
}
|
|
|
|
message.read = !message.read;
|
|
|
|
revalidatePath('/messages', 'page');
|
|
|
|
await message.save();
|
|
|
|
return message.read;
|
|
}
|
|
|
|
export default markMessageAsRead;
|