Update index.js

index.js

@@ -8,39 +8,37 @@ const io = new Server(server);
 
 app.use(express.static("public"));
 
-let rooms = {};
-
 io.on("connection", (socket) => {
   console.log("User connected:", socket.id);
 
   socket.on("join-room", ({ roomId, name }) => {
     socket.join(roomId);
+    socket.name = name;
+    socket.roomId = roomId;
 
-    if (!rooms[roomId]) rooms[roomId] = {};
-    rooms[roomId][socket.id] = name;
-
-    socket.to(roomId).emit("user-joined", { id: socket.id, name });
-
-    socket.emit("all-users", rooms[roomId]);
+    socket.to(roomId).emit("message", {
+      name: "System",
+      text: `${name} joined the room`
+    });
   });
 
-  socket.on("signal", ({ to, data }) => {
-    io.to(to).emit("signal", {
-      from: socket.id,
-      data,
+  socket.on("send-message", (msg) => {
+    io.to(socket.roomId).emit("message", {
+      name: socket.name,
+      text: msg
     });
   });
 
   socket.on("disconnect", () => {
-    for (const roomId in rooms) {
-      if (rooms[roomId][socket.id]) {
-        socket.to(roomId).emit("user-left", socket.id);
-        delete rooms[roomId][socket.id];
-      }
+    if (socket.roomId) {
+      socket.to(socket.roomId).emit("message", {
+        name: "System",
+        text: `${socket.name} left the room`
+      });
     }
   });
 });
 
 server.listen(7860, () => {
-  console.log("Server running on http://localhost:3000");
+  console.log("Server running at http://localhost:3000");
 });