added rejection limit

prisma/schema.prisma

@@ -57,6 +57,7 @@ model ExchangeThread {
   status              String    @default("PENDING") // PENDING | ACCEPTED | REJECTED
   giverAccepted       Boolean   @default(false)
   receiverAccepted    Boolean   @default(false)
+  rejectedByWorkspaceId String?
   createdAt           DateTime  @default(now())
   updatedAt           DateTime  @updatedAt
 
@@ -119,5 +120,6 @@ model SystemSettings {
   id              String   @id @default("singleton")
   cronExpression  String   @default("*/10 * * * *")
   matchAmount     Int      @default(2)
+  rejectLimit     Int      @default(5)
   updatedAt       DateTime @updatedAt
 }

src/controllers/admin.js

@@ -73,7 +73,30 @@ const getUsers = async (req, res) => {
         }
       }
     });
-    res.json({ users });
+
+    const usersWithCounts = await Promise.all(users.map(async (u) => {
+      let rejectedIn = 0;
+      let rejectedOut = 0;
+
+      if (u.teamMemberships && u.teamMemberships.length > 0) {
+        const wsId = u.teamMemberships[0].workspaceId;
+        const rejectedThreads = await prisma.exchangeThread.findMany({
+          where: { rejectedByWorkspaceId: wsId, status: 'REJECTED' }
+        });
+        for (const t of rejectedThreads) {
+          if (t.receiverWorkspaceId === wsId) rejectedIn++;
+          if (t.giverWorkspaceId === wsId) rejectedOut++;
+        }
+      }
+
+      return {
+        ...u,
+        rejectedIn,
+        rejectedOut
+      };
+    }));
+
+    res.json({ users: usersWithCounts });
   } catch (err) {
     console.error(err);
     res.status(500).json({ error: 'Server error' });
@@ -212,12 +235,12 @@ const getSettings = async (req, res) => {
 };
 
 const updateSettings = async (req, res) => {
-  const { cronExpression, matchAmount } = req.body;
+  const { cronExpression, matchAmount, rejectLimit } = req.body;
   try {
     const settings = await prisma.systemSettings.upsert({
       where: { id: 'singleton' },
-      update: { cronExpression, matchAmount },
-      create: { id: 'singleton', cronExpression, matchAmount },
+      update: { cronExpression, matchAmount, rejectLimit },
+      create: { id: 'singleton', cronExpression, matchAmount, rejectLimit },
     });
     
     // Also re-initialize the cron job with the new expression

src/controllers/threads.js

@@ -83,6 +83,9 @@ const getThreads = async (req, res) => {
     else if (filter === 'out') {
       where = { giverWorkspaceId: wsId, status: { not: 'REJECTED' } };
     }
+    else if (filter === 'rejected') {
+      where = { rejectedByWorkspaceId: wsId, status: 'REJECTED' };
+    }
 
     const threads = await prisma.exchangeThread.findMany({
       where,
@@ -105,7 +108,10 @@ const getThreads = async (req, res) => {
       orderBy: { updatedAt: 'desc' },
     });
 
-    res.json({ threads, workspaceId: wsId });
+    let settings = await prisma.systemSettings.findUnique({ where: { id: 'singleton' } });
+    const rejectLimit = settings ? settings.rejectLimit : 5;
+
+    res.json({ threads, workspaceId: wsId, rejectLimit });
   } catch (err) {
     console.error(err);
     res.status(500).json({ error: 'Server error' });
@@ -176,9 +182,19 @@ const updateThreadStatus = async (req, res) => {
     let receiverAccepted = thread.receiverAccepted;
 
     if (status === 'REJECTED') {
+      let settings = await prisma.systemSettings.findUnique({ where: { id: 'singleton' } });
+      const rejectLimit = settings ? settings.rejectLimit : 5;
+
+      const rejectedCount = await prisma.exchangeThread.count({
+        where: { rejectedByWorkspaceId: member.workspaceId, status: 'REJECTED' }
+      });
+      if (rejectedCount >= rejectLimit) {
+        return res.status(403).json({ error: `Cannot reject more than ${rejectLimit} requests` });
+      }
+
       newStatus = 'REJECTED';
       newStage = 'NEW';
-      updateData = { status: newStatus, stage: newStage };
+      updateData = { status: newStatus, stage: newStage, rejectedByWorkspaceId: member.workspaceId };
     } else if (status === 'ACCEPTED') {
       if (isGiver) giverAccepted = true;
       if (isReceiver) receiverAccepted = true;