socket.js

function SocketConnection(io) {
  // io.use((socket, next) => {
  //   const token = socket.handshake.query.token;
  //   if (!token) {
  //     return next(new Error('Authentication token missing'));
  //   }
  //   jwt.verify(token, SECRET_KEY, (err, decoded) => {
  //     if (err) {
  //       return next(new Error('Authentication error'));
  //     }
  //     const user = users.find(u => u.id === decoded.userId);
  //     if (!user) {
  //       return next(new Error('User not found'));
  //     }
  //     socket.user = user;
  //     next();
  //   });
  // });

  io.on("connection", (socket) => {
    console.log(`Connected to ${socket.id}`);

    // joined chat
    socket.on("join-chat", (data) => {
      socket.join(data.roomId);
      console.log(`Connected to ${socket.id}`);
    });

    // sent & receive  message
    socket.on("send-chat-message", (data) => {
      socket.to(data.roomId).emit("received-chat-message", data);
    });

    // typing indicator
    socket.on("typing", (data) => {
      socket.to(data.roomId).emit("userTyping", data);
    });

    // stop-typing indicator
    socket.on("stop typing", (data) => {
      socket.to(data.roomId).emit("userStoppedTyping", data);
    });

    socket.on("disconnect", () => {
      console.log("Disconnected to" + socket.id);
    });
    // end
  });
}

module.exports = { SocketConnection };