Method sendLocalChangesetWithInit

packages/core/src/sync/room.ts:169–226

()

  // When initializing, you need to send the locally cached localPendingChangeset (if any) to the server
  @errorCapture<RoomService>()
  async sendLocalChangesetWithInit() {
    const localPendingChangesetStorage = this.lsStore.namespace(BufferStorage.pendingChangesetsNamespace);
    const opBufferStorage = this.lsStore.namespace(BufferStorage.bufferStorageNamespace);

    const changesetMap = localPendingChangesetStorage.getAll();
    const opBufferMap = opBufferStorage.getAll();

    if (!Object.keys(changesetMap).length && !Object.keys(opBufferMap).length) {
      return;
    }
    this.event.setRoomIOClear(false);
    opBufferStorage.clearAll();
    localPendingChangesetStorage.clearAll();

    this.clearAllStorage();
    try {
      await this.applyLocalData(changesetMap, opBufferMap);
    } catch (e) {
      try {
        await this.backupDB.setItem(String(Date.now()), {
          changesetMap,
          opBufferMap,
        });
      } catch (e) {
        if ((e as any).name === 'QuotaExceededError') {
          await this.backupDB.clear();
          await this.backupDB.setItem(String(Date.now()), { changesetMap, opBufferMap });
        }
      }

      const timestamps = await this.backupDB.keys();
      await Promise.all(
        timestamps.map(async (timestamp) => {
          // Clean up data whose backup time is greater than two weeks
          if (dayjs().diff(Date.now(), 'day') > 14) {
            await this.backupDB.removeItem(timestamp);
          }
        })
      );

      Player.doTrigger(Events.app_error_logger, {
        error: new Error(`Failed to initialize applyChangeset: ${(e as any).message}`),
        metaData: {
          roomId: this.roomId,
          changesetMap: JSON.stringify(changesetMap),
          opBufferMap: JSON.stringify(opBufferMap),
        },
      });

      throw new EnhanceError({
        code: ErrorCode.CollaModalError,
        message: t(Strings.initialization_failed_message),
        modalType: ModalType.Warning,
      });
    }

    this.event.setRoomIOClear(true);
  }