Method setup

apps/collab-server/src/sockets.ts:99–165

(req: IncomingMessage)

  }

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

    this._setupPromise = (async () => {
      // Check user permissions

      const roomName = (req.url ?? '').slice(1);
      const pageId = splitStr(roomName, ':', 2)[1];

      const groupId = await dataAbstraction().hget('page', pageId, 'group-id');

      const groupIsPublic = await dataAbstraction().hget(
        'group',
        groupId!,
        'is-public',
      );

      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.');
        }

        if (!groupIsPublic) {
          const groupMemberRole = await dataAbstraction().hget(
            'group-member',
            `${groupId}:${this.userId}`,
            'role',
          );

          if (groupMemberRole == null) {
            throw new Error('User is not a member of the group.');
          }
        }
      } else {
        if (!groupIsPublic) {
          this.destroySocket();

          throw new Error(
            'Unauthenticated users can only access public groups.',
          );
        }
      }

      // Setup room

      this.room = getRoom(roomName);
      this.room.addSocket(this.socket);