Method constructor

apps/collab-server/src/sockets.ts:48–80

(socket: WebSocket, req: IncomingMessage)

  readonly clientIds: Set<number> = new Set();

  constructor(socket: WebSocket, req: IncomingMessage) {
    this.socket = socket;

    this.sessionId = req.sessionId;

    // Listen to events

    this.socket.on('message', async (message: ArrayBuffer) => {
      try {
        await this._setupPromise;

        await this._handleMessage(message);
      } catch (error) {
        moduleLogger.error('Message handling error: %o', error);
      }
    });

    this.socket.on('pong', () => {
      moduleLogger.info(`[${this.room?.name}] Pong received`);

      this.isAwaitingPong = false;
    });

    this.socket.on('close', async () => {
      if (this.socket?.aux == null) {
        return;
      }

      moduleLogger.info(`[${this.room?.name}] Socket closed`);

      this.destroySocket();
    });
  }

  private async _checkSessionInvalidated() {
    if (this.sessionId != null) {