From 7ae134dc4ec46db83d5022d3c172e4306803a860 Mon Sep 17 00:00:00 2001
From: Rohit <rohit.rajan031101@gmail.com>
Date: Thu, 14 Aug 2025 15:57:01 +0530
Subject: [PATCH] feat: add queued run namespace

---
 server/src/server.ts | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/server/src/server.ts b/server/src/server.ts
index 7f2d04d3..11b25a37 100644
--- a/server/src/server.ts
+++ b/server/src/server.ts
@@ -162,6 +162,22 @@ app.use((req, res, next) => {
   next();
 });
 
+io.of('/queued-run').on('connection', (socket) => {
+  const userId = socket.handshake.query.userId as string;
+  
+  if (userId) {
+    socket.join(`user-${userId}`);
+    logger.log('info', `Client joined queued-run namespace for user: ${userId}, socket: ${socket.id}`);
+    
+    socket.on('disconnect', () => {
+      logger.log('info', `Client disconnected from queued-run namespace: ${socket.id}`);
+    });
+  } else {
+    logger.log('warn', `Client connected to queued-run namespace without userId: ${socket.id}`);
+    socket.disconnect();
+  }
+});
+
 server.listen(SERVER_PORT, '0.0.0.0', async () => {
   try {
     await connectDB();