Method checkVersion

packages/core/src/sync/room.ts:351–387

(resourceRevisions: IResourceRevision[] | null)

  @errorCapture<RoomService>()
  async checkVersion(resourceRevisions: IResourceRevision[] | null) {
    const missVersionEngines: { collaEngine: Engine; revision: number }[] = [];

    if (!resourceRevisions || !resourceRevisions.length) {
      console.log('The current resource has not been operated for a long time, and the data is automatically updated');
      await this.collaEngineMap.get(this.roomId)?.event.reloadResourceData();
      return;
    }

    for (const { resourceId, revision } of resourceRevisions) {
      const collaEngine = this.collaEngineMap.get(resourceId);

      if (!collaEngine) {
        continue;
      }

      const baseRevision = collaEngine.getRevision();
      const versionDiffs = numbersBetween(baseRevision, revision + 1);
      if (!versionDiffs.length) {
        continue;
      }
      if (versionDiffs.length >= 100) {
        throw new EnhanceError({
          code: StatusCode.FRONT_VERSION_ERROR,
          message: t(Strings.changeset_diff_big_tip),
          modalType: ModalType.Info,
        });
      }
      missVersionEngines.push({ collaEngine, revision });
    }

    return await Promise.all(
      missVersionEngines.map<Promise<any>>(({ collaEngine, revision }) => {
        return collaEngine.prepare(revision + 1);
      })
    );
  }

  /**
   * @description unwatch no longer needs to pay attention to whether the coordinator queue is emptied,