Feat/sse tickets

app.js

@@ -28,6 +28,7 @@ import mumukshuRoutes from './routes/client/mumukshuBooking.routes.js';
 import paymentRoutes from './routes/client/payment.routes.js';
 import supportRoutes from './routes/client/support.routes.js';
 import updateRoutes from './routes/client/updates.routes.js';
+import ticketRoutes from './routes/client/ticket.routes.js';
 
 // Admin Route Imports
 import authRoutes from './routes/admin/auth.routes.js';
@@ -48,6 +49,7 @@ import {
 } from './routes/admin/utsavManagement.routes.js';
 import avtManagementRoutes from './routes/admin/avtManagement.routes.js';
 import wifiManagementRoutes from './routes/admin/wifiManagement.routes.js';
+import ticketManagementRoutes from './routes/admin/ticketManagement.routes.js';
 
 // Unified Route Imports
 import unifiedBookingRoutes from './routes/client/unifiedBooking.routes.js';
@@ -170,6 +172,7 @@ app.use('/api/v1/profile', profileRoutes);
 app.use('/api/v1/location', locationRoutes);
 app.use('/api/v1/razorpay', paymentRoutes);
 app.use('/api/v1/support', supportRoutes);
+app.use('/api/v1/tickets', ticketRoutes);
 
 // Admin Routes
 app.use('/api/v1/admin/sudo', adminControlRoutes);
@@ -188,6 +191,7 @@ app.use('/api/v1/admin/utsav', utsavPublicRouter); // No auth
 app.use('/api/v1/admin/utsav', utsavAdminRouter); // With auth
 app.use('/api/v1/admin/avt', avtManagementRoutes);
 app.use('/api/v1/admin/wifi', wifiManagementRoutes);
+app.use('/api/v1/admin/tickets', ticketManagementRoutes);
 
 // Unified Routes
 app.use('/api/v1/unified', unifiedBookingRoutes);

config/socket.js

@@ -0,0 +1,33 @@
+import { Server } from 'socket.io';
+
+let io;
+
+export const initSocket = (httpServer) => {
+  io = new Server(httpServer, {
+    cors: {
+      origin: '*', // restrict later if needed
+      methods: ['GET', 'POST']
+    }
+  });
+
+  io.on('connection', socket => {
+    console.log('Admin connected:', socket.id);
+
+    socket.on('join_admin', () => {
+      socket.join('admins');
+    });
+
+    socket.on('disconnect', () => {
+      console.log('Disconnected:', socket.id);
+    });
+  });
+
+  return io;
+};
+
+export const getIO = () => {
+  if (!io) {
+    throw new Error('Socket.io not initialized');
+  }
+  return io;
+};

controllers/admin/auth.controller.js

@@ -10,13 +10,14 @@ export const login = async (req, res) => {
   const admin = await AdminUsers.findOne({
     where: { username: username }
   });
-  if (admin.dataValues.status === STATUS_INACTIVE)
-    throw new ApiError(401, 'Account Deactivated');
 
   if (!admin) {
     throw new ApiError(404, 'Invalid Username');
   }
-
+
+  if (admin.dataValues.status === STATUS_INACTIVE)
+    throw new ApiError(401, 'Account Deactivated');
+
   const roles = await AdminRoles.findAll({
     attributes: ['role_name'],
     where: { user_id: admin.dataValues.id, status: STATUS_ACTIVE }
@@ -80,21 +81,23 @@ export const createAdmin = async (req, res) => {
   return res.status(201).send({ message: 'successfully created admin' });
 };
 
-
-
 export const resetPassword = async (req, res) => {
   const { username, newPassword } = req.body;
 
-    if (!username || !newPassword) {
-    return res.status(400).json({ message: 'Username and new password are required' });
+  if (!username || !newPassword) {
+    return res
+      .status(400)
+      .json({ message: 'Username and new password are required' });
   }
 
   if (newPassword.length < 8) {
-    return res.status(400).json({ message: 'Password must be at least 8 characters long' });
+    return res
+      .status(400)
+      .json({ message: 'Password must be at least 8 characters long' });
   }
 
   try {
-        const user = await AdminUsers.findOne({ where: { username } });
+    const user = await AdminUsers.findOne({ where: { username } });
     if (!user) {
       return res.status(404).json({ message: 'User not found' });
     }

controllers/admin/ticketManagement.controller.js

@@ -0,0 +1,163 @@
+import { Ticket, TicketMessage } from '../../models/associations.js';
+import { Sequelize } from 'sequelize';
+import {
+  MSG_FETCH_SUCCESSFUL,
+  MSG_UPDATE_SUCCESSFUL,
+  STATUS_INPROGRESS,
+  STATUS_OPEN
+} from '../../config/constants.js';
+import ticketStreamManager from '../../utils/ticketStreamManager.js';
+import ApiError from '../../utils/ApiError.js';
+
+// export const getAllTickets = async (req, res) => {
+//   const { status, service } = req.query;
+//   const where = {};
+
+//   if (status) where.status = status;
+//   if (service) where.service = service;
+
+//   const tickets = await Ticket.findAll({
+//     where,
+//     order: [['createdAt', 'DESC']]
+//   });
+
+//   res.status(200).json({
+//     status: 'success',
+//     message: MSG_FETCH_SUCCESSFUL,
+//     data: tickets
+//   });
+// };
+
+export const getAllTickets = async (req, res) => {
+  const { status, service } = req.query;
+  const where = {};
+  if (status) where.status = status;
+  if (service) where.service = service;
+
+  const tickets = await Ticket.findAll({
+    where,
+    attributes: {
+      include: [
+        [
+          Sequelize.literal(`(
+            SELECT MAX(createdAt)
+            FROM ticket_messages
+            WHERE ticket_messages.ticket_id = Ticket.id
+          )`),
+          'last_message_at'
+        ]
+      ]
+    },
+    order: [['createdAt', 'DESC']]
+  });
+
+  res.status(200).json({
+    status: 'success',
+    data: tickets
+  });
+};
+
+export const getTicketDetails = async (req, res) => {
+  const { id } = req.params;
+
+  const ticket = await Ticket.findByPk(id);
+  if (!ticket) {
+    throw new ApiError(404, 'Ticket not found');
+  }
+
+  const messages = await TicketMessage.findAll({
+    where: { ticket_id: id },
+    order: [['createdAt', 'ASC']]
+  });
+
+  res.status(200).json({
+    status: 'success',
+    message: MSG_FETCH_SUCCESSFUL,
+    data: { ...ticket.toJSON(), messages }
+  });
+};
+
+export const streamTicketMessages = async (req, res) => {
+  const { id } = req.params;
+
+  const ticket = await Ticket.findByPk(id);
+  if (!ticket) {
+    throw new ApiError(404, 'Ticket not found');
+  }
+
+  // Set SSE headers
+  res.setHeader('Content-Type', 'text/event-stream');
+  res.setHeader('Cache-Control', 'no-cache');
+  res.setHeader('Connection', 'keep-alive');
+  res.flushHeaders();
+
+  // Add admin to manager
+  ticketStreamManager.addClient(id, res, 'admin');
+
+  // Initial connection message
+  res.write(
+    `data: ${JSON.stringify({
+      type: 'connected',
+      user: req.user.username
+    })}\n\n`
+  );
+};
+
+export const adminAddMessage = async (req, res) => {
+  const { id } = req.params;
+  const { message } = req.body;
+
+  if (!message) {
+    throw new ApiError(400, 'Message is required');
+  }
+
+  const ticket = await Ticket.findByPk(id);
+  if (!ticket) {
+    throw new ApiError(404, 'Ticket not found');
+  }
+
+  if (ticket.status === 'closed') {
+    throw new ApiError(400, 'ticket is closed');
+  }
+
+  const newMessage = await TicketMessage.create({
+    ticket_id: id,
+    sender_id: req.user.username,
+    sender_type: 'admin',
+    message
+  });
+
+  ticketStreamManager.broadcastMessage(id, newMessage);
+
+  // Update ticket updatedBy and status if needed
+  const updates = { updatedBy: req.user.username };
+  if (ticket.status === STATUS_OPEN) {
+    updates.status = STATUS_INPROGRESS;
+  }
+
+  await ticket.update(updates);
+
+  res.status(201).json({
+    status: 'success',
+    message: MSG_UPDATE_SUCCESSFUL,
+    data: newMessage
+  });
+};
+
+export const updateTicketStatus = async (req, res) => {
+  const { id } = req.params;
+  const { status } = req.body;
+
+  const ticket = await Ticket.findByPk(id);
+  if (!ticket) {
+    throw new ApiError(404, 'Ticket not found');
+  }
+
+  await ticket.update({ status, updatedBy: req.user.username });
+
+  res.status(200).json({
+    status: 'success',
+    message: MSG_UPDATE_SUCCESSFUL,
+    data: ticket
+  });
+};