Class ResourceService

packages/widget-sdk/src/resource/service.ts:66–506

};

export class ResourceService implements IResourceService {
  socket!: SocketIOClient.Socket;
  roomService!: RoomService;
  initialized?: boolean;
  undoManager!: UndoManager;
  resourceStashManager!: ResourceStashManager;
  opEventManager: OPEventManager;
  computeRefManager: ComputeRefManager;
  reportSocketError = true;
  roomIOClear = true;
  roomLastSendTime?: number;
  firstRoomInit = true;
  private database!: databus.Database;
  private databus: databus.DataBus;
  currentResource: databus.Datasheet | undefined;

  /**
   * @deprecated This is a temporary member. All dependencies of CommandManager in the front-end will be removed in the future.
   */
  readonly commandManager: CollaCommandManager;

  constructor(
    public store: Store<IReduxState>,
    public onError: IServiceError
  ) {
    this.opEventManager = new OPEventManager({
      options: {
        enableVirtualEvent: true,
        // enableCombEvent: true, // The client does not need to enable aggregated events.
      },
      // eslint-disable-next-line require-await
      getState: () => {
        return store.getState();
      },
      op2Event: new OP2Event(clientWatchedEvents),
    });
    this.computeRefManager = new ComputeRefManager();
    this.databus = this.createDataBus();
    this.commandManager = this.createCommandManager();
  }

  init() {
    if (this.initialized) {
      console.error('Do not repeat the initialization of the datasheet store.');
      return;
    }
    this.initialized = true;

    this.bindBeforeUnload();
    this.socket = this.createSocket();
    this.database = this.createDatabase();
    this.resourceStashManager = new ResourceStashManager(this.store, () => {
      return this.roomService;
    });
  }

  destroy() {
    if (!this.initialized) {