Method doTransform

packages/core/src/engine/engine.ts:438–491

(cs: IRemoteChangeset)

  }

  private doTransform(cs: IRemoteChangeset) {
    let remoteActions = cs.operations.reduce<IJOTAction[]>((pre, op) => {
      pre.push(...op.actions);
      return pre;
    }, []);

    this.event.getUndoManager().doTransform(remoteActions);

    // localChangeset needs to be transformed and updated to the latest version
    if (this.bufferStorage.localPendingChangeset) {
      console.log(
        'localPendingChangeset before transform:',
        { localChangeset: this.bufferStorage.localPendingChangeset, remoteActions },
      );
      const newOperations = this.bufferStorage.localPendingChangeset.operations.map(op => {
        const [leftOp, rightOp] = jot.transformX(op.actions, remoteActions);
        remoteActions = rightOp;
        return {
          cmd: op.cmd,
          actions: leftOp,
        };
      });
      this.bufferStorage.localPendingChangeset = {
        ...this.bufferStorage.localPendingChangeset,
        operations: newOperations,
        baseRevision: cs.revision,
      };
      console.log(
        'localChangeset after transformed: ',
        { localChangeset: this.bufferStorage.localPendingChangeset, remoteActions },
      );
    }

    if (this.bufferStorage.opBuffer.length) {
      console.log(
        'opBuffer before transform:',
        { localChangeset: this.bufferStorage.localPendingChangeset, remoteActions },
      );
      this.bufferStorage.opBuffer = this.bufferStorage.opBuffer.map(op => {
        const [leftOp, rightOp] = jot.transformX(op.actions, remoteActions);
        remoteActions = rightOp;
        return {
          cmd: op.cmd,
          actions: leftOp,
        };
      });
      console.log(
        'opBuffer after transformed: ',
        { localPendingChangeset: this.bufferStorage.localPendingChangeset, serverOperations: remoteActions },
      );
    }

    return remoteActions;
  }
}