Blame for src/controllers/admin.js

const prisma = require('../lib/prisma');

const getStats = async (req, res) => {
  try {
    const usersCount = await prisma.user.count({ where: { role: { not: 'ADMIN' } } });
    const sitesCount = await prisma.workspace.count();
    const linksCount = await prisma.linkPlacement.count();

    res.json({
      users: usersCount,
      sites: sitesCount,
      links: linksCount,
    });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const sendNotification = async (req, res) => {
  const { title, description } = req.body;
  if (!title || !description) {
    return res.status(400).json({ error: 'Title and description are required' });
  }

  try {
    const notification = await prisma.adminNotification.create({
      data: { title, description },
    });

    const wsManager = require('../lib/ws');
    await wsManager.broadcastGlobalNotification({
      type: 'admin_broadcast',
      id: notification.id,
      title,
      body: description,
      messageText: description, // for compatibility
      senderWorkspaceDomain: 'System Admin',
    });

    res.json({ success: true, message: 'Notification broadcasted successfully', notification });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const getNotifications = async (req, res) => {
  try {
    const notifications = await prisma.adminNotification.findMany({
      orderBy: { createdAt: 'desc' },
    });
    res.json({ notifications });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const getUsers = async (req, res) => {
  try {
    const users = await prisma.user.findMany({
      where: { role: { not: 'ADMIN' } },
      orderBy: { createdAt: 'desc' },
      select: {
        id: true,
        name: true,
        email: true,
        role: true,
        createdAt: true,
        teamMemberships: {
          include: { workspace: true }
        }
      }
    });

    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' });
  }
};

const getBacklinks = async (req, res) => {
  try {
    const backlinks = await prisma.linkPlacement.findMany({
      orderBy: { datePlaced: 'desc' },
      include: {
        giverWorkspace: true,
        receiverWorkspace: true,
      }
    });
    res.json({ backlinks });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const updateUser = async (req, res) => {
  const { name, email, role } = req.body;
  try {
    const updated = await prisma.user.update({
      where: { id: req.params.id },
      data: { name, email, role },
    });
    res.json({ user: updated });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const deleteUser = async (req, res) => {
  try {
    const userId = req.params.id;
    // Find the user's workspaces
    const teamMemberships = await prisma.teamMember.findMany({
      where: { userId },
      select: { workspaceId: true }
    });
    
    const workspaceIds = teamMemberships.map(tm => tm.workspaceId);
    
    // 1. Delete all messages sent by this user
    await prisma.chatMessage.deleteMany({
      where: { senderUserId: userId }
    });

    if (workspaceIds.length > 0) {
      // 2. Delete all link placements associated with these workspaces
      await prisma.linkPlacement.deleteMany({
        where: {
          OR: [
            { giverWorkspaceId: { in: workspaceIds } },
            { receiverWorkspaceId: { in: workspaceIds } }
          ]
        }
      });

      // 3. Delete all exchange threads associated with these workspaces
      await prisma.exchangeThread.deleteMany({
        where: {
          OR: [
            { giverWorkspaceId: { in: workspaceIds } },
            { receiverWorkspaceId: { in: workspaceIds } }
          ]
        }
      });

      // 4. Finally delete the workspaces themselves
      await prisma.workspace.deleteMany({
        where: { id: { in: workspaceIds } }
      });
    }

    // 5. Delete the user
    await prisma.user.delete({ where: { id: userId } });
    
    res.json({ success: true });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const updateBacklink = async (req, res) => {
  const { sourceUrl, targetUrl, anchorText, linkType, status } = req.body;
  try {
    const updated = await prisma.linkPlacement.update({
      where: { id: req.params.id },
      data: { sourceUrl, targetUrl, anchorText, linkType, status },
    });
    res.json({ backlink: updated });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const deleteBacklink = async (req, res) => {
  try {
    await prisma.linkPlacement.delete({ where: { id: req.params.id } });
    res.json({ success: true });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const triggerMatching = async (req, res) => {
  try {
    const { runWeeklyMatching } = require('../jobs/matcher');
    const result = await runWeeklyMatching();
    res.json(result);
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const getSettings = async (req, res) => {
  try {
    let settings = await prisma.systemSettings.findUnique({ where: { id: 'singleton' } });
    if (!settings) {
      settings = await prisma.systemSettings.create({ data: { id: 'singleton' } });
    }
    res.json({ settings });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

const updateSettings = async (req, res) => {
  const { cronExpression, matchAmount, rejectLimit } = req.body;
  try {
    const settings = await prisma.systemSettings.upsert({
      where: { id: 'singleton' },
      update: { cronExpression, matchAmount, rejectLimit },
      create: { id: 'singleton', cronExpression, matchAmount, rejectLimit },
    });
    
    // Also re-initialize the cron job with the new expression
    const { initCron } = require('../jobs/matcher');
    initCron();
    
    res.json({ success: true, settings });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Server error' });
  }
};

module.exports = {
  getStats,
  sendNotification,
  getNotifications,
  getUsers,
  getBacklinks,
  updateUser,
  deleteUser,
  updateBacklink,
  deleteBacklink,
  triggerMatching,
  getSettings,
  updateSettings,
};