Method setup

apps/realtime-server/src/sockets.ts:99–126

()

  }

  async setup() {
    if (this._setupPromise != null) {
      return await this._setupPromise;
    }

    this._setupPromise = new Resolvable();

    if (this.sessionId != null) {
      let sessionInvalidated;

      [this.userId, sessionInvalidated] = await Promise.all([
        dataAbstraction().hget('session', this.sessionId, 'user-id'),

        this._checkSessionInvalidated(),
      ]);

      if (this.userId == null || sessionInvalidated) {
        this.destroySocket();
        throw new Error('Invalid session.');
      }

      getSub().on('messageBuffer', this._handleUserNotification);

      await getSub().subscribe(`user-notification:${this.userId}`);
    }

    this._setupPromise.resolve();
  }

  private _handleUserNotification = async (
    channelBuffer: Buffer,