Mark message as read

app/actions/markMessageAsRead.js

@@ -0,0 +1,36 @@
+'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;