Method constructor

apps/realtime-server/src/sockets.ts:57–79

(socket: WebSocket, req: IncomingMessage)

  ][] = [];

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

    this.sessionId = req.sessionId;

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

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

    socket.on('pong', () => {
      socket.aux.isAwaitingPong = false;
    });

    socket.on('close', () => {
      socket.aux?.destroySocket();
    });
  }

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