Method handleSubscriptions

packages/core/src/engine/engine.ts:219–249

* Member remote changeset update record subscriptions * @param remoteChangeset

(remoteChangeset: IRemoteChangeset)

   * @param remoteChangeset
   */
  handleSubscriptions(remoteChangeset: IRemoteChangeset) {
    let hasCreatedFieldWithSubscription = false;
    let otherCmdTriggerSubscription = false;

    const fieldMap = getFieldMap(this.getState(), this.resourceId);
    remoteChangeset.operations.forEach(op => {
      // AddRecords
      if (op.cmd === CollaCommandName.AddRecords) {
        if (fieldMap && Object.values(fieldMap).some(field => field.type === FieldType.CreatedBy && field.property.subscription)) {
          hasCreatedFieldWithSubscription = true;
          return;
        }
      } else {
        // other command
        op.actions.map(action => {
          const path = testPath(action.p, ['recordMap', ':recordId', 'data', ':fieldId']);
          if (path.pass) {
            const field = fieldMap?.[path.fieldId];
            if (field?.type === FieldType.Member && Boolean(field.property.subscription)) {
              otherCmdTriggerSubscription = true;
              return;
            }
          }
        });
      }
    });

    if (hasCreatedFieldWithSubscription || otherCmdTriggerSubscription) {
      this.dispatch(getSubscriptionsAction(this.resourceId));
    }
  }

  /**
    * The submitted changeset is accepted by the service