Message count

app/actions/getUnreadMessageCount.js

@@ -0,0 +1,26 @@
+'use server';
+
+import connectDB from '@/config/database';
+import Message from '@/models/Message';
+import { getSessionUser } from '@/utils/getSessionUser';
+
+async function getUnreadMessageCount() {
+  await connectDB();
+
+  const sessionUser = await getSessionUser();
+
+  if (!sessionUser || !sessionUser.user) {
+    return { error: 'User ID is required' };
+  }
+
+  const { userId } = sessionUser;
+
+  const count = await Message.countDocuments({
+    recipient: userId,
+    read: false,
+  });
+
+  return { count };
+}
+
+export default getUnreadMessageCount;