added backlinks

prisma/schema.prisma

@@ -34,6 +34,7 @@ model Workspace {
   receiverThreads        ExchangeThread[] @relation("ReceiverWorkspace")
   giverLinkPlacements    LinkPlacement[]  @relation("GiverLinkPlacements")
   receiverLinkPlacements LinkPlacement[]  @relation("ReceiverLinkPlacements")
+  notifications          Notification[]
 }
 
 model TeamMember {
@@ -100,6 +101,20 @@ model AdminNotification {
   createdAt   DateTime @default(now())
 }
 
+model Notification {
+  id          String   @id @default(uuid())
+  workspaceId String
+  type        String
+  title       String?
+  body        String?
+  link        String?
+  read        Boolean  @default(false)
+  createdAt   DateTime @default(now())
+  payload     String?  
+
+  workspace   Workspace @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
+}
+
 model SystemSettings {
   id              String   @id @default("singleton")
   cronExpression  String   @default("*/10 * * * *")

src/controllers/threads.js

@@ -208,13 +208,7 @@ const updateThreadStatus = async (req, res) => {
         receiverWorkspaceName: selfWorkspace.websiteName,
         receiverWorkspaceDomain: selfWorkspace.domain,
       });
-      // also notify self just in case
-      wsManager.sendNotification(member.workspaceId, {
-        type: 'connection_accepted',
-        threadId: updated.id,
-        receiverWorkspaceName: selfWorkspace.websiteName,
-        receiverWorkspaceDomain: selfWorkspace.domain,
-      });
+
     } else if (newStatus === 'REJECTED') {
       wsManager.sendNotification(otherId, {
         type: 'connection_rejected',

src/index.js

@@ -7,6 +7,7 @@ const workspaceRoutes = require('./routes/workspaces');
 const threadRoutes = require('./routes/threads');
 const messageRoutes = require('./routes/messages');
 const linkRoutes = require('./routes/links');
+const notificationRoutes = require('./routes/notifications');
 
 const app = express();
 
@@ -63,6 +64,7 @@ app.use('/api/workspaces', workspaceRoutes);
 app.use('/api/threads', threadRoutes);
 app.use('/api/messages', messageRoutes);
 app.use('/api/links', linkRoutes);
+app.use('/api/notifications', notificationRoutes);
 
 const adminRoutes = require('./routes/admin');
 app.use('/api/admin', adminRoutes);

src/lib/ws.js

@@ -1,4 +1,5 @@
 const { Server } = require('socket.io');
+const prisma = require('./prisma');
 
 class SocketManager {
   constructor() {
@@ -57,10 +58,21 @@ class SocketManager {
     }
   }
 
-  sendNotification(workspaceId, payload) {
+  async sendNotification(workspaceId, payload) {
     if (this.io) {
       this.io.to(`workspace:${workspaceId}`).emit('notification', payload);
     }
+    try {
+      await prisma.notification.create({
+        data: {
+          workspaceId,
+          type: payload.type,
+          payload: JSON.stringify(payload),
+        }
+      });
+    } catch (err) {
+      console.error('Failed to persist notification:', err);
+    }
   }
 
   broadcastGlobalNotification(payload) {

src/routes/notifications.js

@@ -0,0 +1,45 @@
+const express = require('express');
+const authMiddleware = require('../middleware/auth');
+const prisma = require('../lib/prisma');
+const router = express.Router();
+
+router.get('/', authMiddleware, async (req, res) => {
+  try {
+    const member = await prisma.teamMember.findFirst({
+      where: { userId: req.user.userId },
+    });
+    if (!member) return res.status(404).json({ error: 'No workspace found' });
+
+    const notifications = await prisma.notification.findMany({
+      where: { workspaceId: member.workspaceId },
+      orderBy: { createdAt: 'desc' },
+      take: 50
+    });
+
+    res.json({ notifications });
+  } catch (err) {
+    console.error(err);
+    res.status(500).json({ error: 'Server error' });
+  }
+});
+
+router.post('/mark-read', authMiddleware, async (req, res) => {
+  try {
+    const member = await prisma.teamMember.findFirst({
+      where: { userId: req.user.userId },
+    });
+    if (!member) return res.status(404).json({ error: 'No workspace found' });
+
+    await prisma.notification.updateMany({
+      where: { workspaceId: member.workspaceId, read: false },
+      data: { read: true }
+    });
+
+    res.json({ success: true });
+  } catch (err) {
+    console.error(err);
+    res.status(500).json({ error: 'Server error' });
+  }
+});
+
+module.exports = router;