Method setupConnectionHandling

server/modules/socketManager.js:181–266

()

  }

  setupConnectionHandling() {
    this.io.on("connection", (socket) => {
      // Authentication middleware
      socket.on("authenticate", async (data) => {
        const { token, teamId } = data;
        let user;

        try {
          user = await this.authenticateToken(token);
        } catch (error) {
          socket.emit("authenticated", { success: false, error: error.message || "Unauthorized access" });
          return;
        }

        // Remove old connection for this user if exists
        const existingSocket = this.activeConnections.get(user.id);
        if (existingSocket && existingSocket.id !== socket.id) {
          existingSocket.disconnect(true);
        }

        this.activeConnections.set(user.id, socket);
        // oxlint-disable-next-line no-param-reassign
        socket.userId = user.id;
        // oxlint-disable-next-line no-param-reassign
        socket.teamId = teamId;

        // Join team room for team-wide broadcasts
        if (teamId) {
          socket.join(`team:${teamId}`);
          this.addToRoom(`team:${teamId}`, socket.id);
        }

        // Join user room for private messages
        socket.join(`user:${user.id}`);
        this.addToRoom(`user:${user.id}`, socket.id);

        socket.emit("authenticated", { success: true });
      });

      // Handle conversation room joining
      socket.on("join-conversation", async (data) => {
        const { conversationId } = data;
        if (!conversationId) {
          return;
        }

        if (!socket.userId) {
          // Not authenticated yet, queue this for after authentication
          return;
        }

        const canJoin = await this.canJoinConversation(socket.userId, conversationId, socket.teamId);
        if (!canJoin) {
          socket.emit("conversation-join-denied", { conversationId });
          return;
        }

        socket.join(`conversation:${conversationId}`);