Method handleRejectCommit

packages/core/src/sync/room.ts:586–618

(data: ISocketResponseData, clearAllStorage = true)

  @errorCapture<RoomService>()
  @socketGuard()
  async handleRejectCommit(data: ISocketResponseData, clearAllStorage = true) {
    // If the message is repeated, no need to refresh
    if (data.code === OtErrorCode.MSG_ID_DUPLICATE) {
      console.log(data.message);
      this.nextSend();
      return;
    }

    const bufferStorage = this.collaEngineMap.get(this.roomId)?.bufferStorage;

    Player.doTrigger(Events.app_error_logger, {
      error: new Error(`Incorrect op message: ${data.message}`),
      metaData: {
        roomId: this.roomId,
        connected: this.connected,
        socketConnected: this.io.socket.connected,
        opBuffer: JSON.stringify(bufferStorage?.opBuffer),
        localPendingChangeset: JSON.stringify(bufferStorage?.localPendingChangeset),
      },
    });

    if (clearAllStorage) {
      // Before clearing the data, make a local backup of the cleared data
      await this.backupDB.setItem(String(Date.now()), {
        opBufferMap: this.getBufferOperateMap(),
        changesetMap: keyBy(this.getLocalPendingChangesets(), 'resourceId'),
      });
      this.clearAllStorage();
    }

    console.trace('Wrong op information');
    throw new EnhanceError(data);
  }

  private getBufferOperateMap() {
    const bufferOperateMap: Record<string, IOperation[]> = {};