Method _handleMessage

apps/collab-server/src/sockets.ts:389–438

(messageBuffer: ArrayBuffer)

  }

  private async _handleMessage(messageBuffer: ArrayBuffer) {
    const [sessionInvalidated, userPlan, pageGroupId, pageIsFree] =
      await Promise.all([
        dataAbstraction().hget('session', this.sessionId!, 'invalidated'),
        dataAbstraction().hget('user', this.userId!, 'plan'),
        dataAbstraction().hget('page', this.room.pageId, 'group-id'),
        dataAbstraction().hget('page', this.room.pageId, 'free'),
      ]);

    // Check if session is invalidated

    if (sessionInvalidated) {
      this.destroySocket();

      return;
    }

    // Check if has permission to edit

    const role = await dataAbstraction().hget(
      'group-member',
      `${pageGroupId}:${this.userId}`,
      'role',
    );

    if (
      !rolesMap()[role]?.permissions.editGroupPages ||
      (userPlan !== 'pro' && !pageIsFree)
    ) {
      moduleLogger.info('Ignored message from unauthorized user');
      return;
    }

    const message = new Uint8Array(messageBuffer);

    const decoder = decoding.createDecoder(message);

    const messageType = decoding.readVarUint(decoder);

    switch (messageType) {
      case CollabMessageType.AWARENESS:
        await this._handleAwarenessMessage(decoder, message);
        break;
      case CollabMessageType.DOC:
        await this._handleDocMessage(decoder);
        break;
      default:
        throw new Error('Unknown message type');
    }
  }

  private async _handleAwarenessMessage(
    decoder: decoding.Decoder,