Method applyLocalData

packages/core/src/sync/room.ts:228–278

(changesetMap: Record<string, ILocalChangeset>, opBufferMap: Record<string, IOperation[]>)

  }

  async applyLocalData(changesetMap: Record<string, ILocalChangeset>, opBufferMap: Record<string, IOperation[]>) {
    if (Object.keys(changesetMap).length) {
      const res = await Api.applyResourceChangesets(Object.values(changesetMap), this.roomId);
      const { success, message, code } = res.data;
      if (!success && code !== 4001) {
        throw new Error(`changesetMap: ${message}`);
      }
    }

    if (Object.keys(opBufferMap).length) {
      const changesets: ILocalChangeset[] = [];
      for (const resourceId in opBufferMap) {
        if (changesetMap[resourceId]) {
          const changeset = BufferStorage.ops2Changeset(
            opBufferMap[resourceId]!,
            changesetMap[resourceId]!.baseRevision + 1,
            resourceId,
            changesetMap[resourceId]!.resourceType
          );
          changesets.push(changeset);
          continue;
        }
        const opBuffer = opBufferMap[resourceId]!;
        const revision = opBuffer[0]!.revision;
        const resourceType = opBuffer[0]!.resourceType;
        const changeset = BufferStorage.ops2Changeset(opBuffer, revision as number, resourceId, resourceType as ResourceType);

        if (opBuffer.every((operation) => !operation.mainLinkDstId)) {
          const res = await Api.applyResourceChangesets([changeset], this.roomId);
          const { success, message } = res.data;
          if (!success) {
            throw new Error(`single changesets: ${message}`);
          }
          delete opBufferMap[resourceId];
          continue;
        }

        changesets.push(changeset);
      }

      if (!changesets.length) {
        return;
      }

      const res = await Api.applyResourceChangesets(Object.values(changesets), this.roomId);
      const { success, message } = res.data;
      if (!success) {
        throw new Error(`opBufferMap: ${message}`);
      }
    }
  }

  /**
   * The backend server actively pushes changesets submitted by others