Method register

packages/server/src/socket/socket-gateway.ts:40–98

(socket: AuthenticatedSocket)

      cleanup();
    }
    this.cleanups = [];
  }

  register(socket: AuthenticatedSocket): void {
    // --- Subscribe / Unsubscribe ---
    socket.on(ClientEvents.SUBSCRIBE, (payload: SubscribePayload, ack?: (res: AckResponse) => void) => {
      if (!this.ensureSocketAuthIsCurrent(socket, ack)) return;
      this.handleSubscribe(socket, payload, ack);
    });

    socket.on(ClientEvents.UNSUBSCRIBE, (payload: UnsubscribePayload, ack?: (res: AckResponse) => void) => {
      if (!this.ensureSocketAuthIsCurrent(socket, ack)) return;
      this.handleUnsubscribe(socket, payload, ack);
    });

    // --- Agent session I/O ---
    socket.on(ClientEvents.INPUT, (payload: SessionInputPayload) => {
      if (!this.ensureSocketAuthIsCurrent(socket)) return;
      if (!payload?.sessionId || typeof payload.data !== 'string') return;
      try {
        this.sessionManager.writeInput(payload.sessionId, payload.data);
      } catch (err) {
        console.error(`[SocketGateway] INPUT error for session ${payload.sessionId}:`, err);
      }
    });

    socket.on(ClientEvents.RESIZE, (payload: SessionResizePayload) => {
      if (!this.ensureSocketAuthIsCurrent(socket)) return;
      if (!payload?.sessionId || typeof payload.cols !== 'number' || typeof payload.rows !== 'number') return;
      try {
        this.sessionManager.resize(payload.sessionId, payload.cols, payload.rows);
      } catch (err) {
        console.error(`[SocketGateway] RESIZE error for session ${payload.sessionId}:`, err);
      }
    });

    // --- Standalone terminal I/O ---
    socket.on(ClientEvents.TERMINAL_INPUT, (payload: TerminalInputPayload) => {
      if (!this.ensureSocketAuthIsCurrent(socket)) return;
      if (!payload?.terminalId || typeof payload.data !== 'string') return;
      try {
        this.terminalManager.write(payload.terminalId, payload.data);
      } catch (err) {
        console.error(`[SocketGateway] TERMINAL_INPUT error for terminal ${payload.terminalId}:`, err);
      }
    });

    socket.on(ClientEvents.TERMINAL_RESIZE, (payload: TerminalResizePayload) => {
      if (!this.ensureSocketAuthIsCurrent(socket)) return;
      if (!payload?.terminalId || typeof payload.cols !== 'number' || typeof payload.rows !== 'number') return;
      try {
        this.terminalManager.resize(payload.terminalId, payload.cols, payload.rows);
      } catch (err) {
        console.error(`[SocketGateway] TERMINAL_RESIZE error for terminal ${payload.terminalId}:`, err);
      }
    });

    // --- Socket disconnect: clean up owned terminals ---