Method watch

packages/core/src/sync/room.ts:309–334

()

   */
  @errorCapture<RoomService>()
  async watch() {
    const state = this.store.getState();
    const shareId = state.pageParams.shareId;
    const embedId = state.pageParams.embedId;
    const watchResponse = await this.io.watch<IWatchResponse, any>(this.roomId, shareId, embedId).catch((e) => {
      throw new EnhanceError(e);
    });

    this.setConnected(true);
    if (!watchResponse) {
      return;
    }
    const { resourceRevisions, collaborators } = watchResponse.data!;
    // console.log('resourceRevisions:', resourceRevisions);
    const collaEngine = this.collaEngineMap.get(this.roomId);
    if (!collaEngine) {
      return;
    }
    await this.checkVersion(resourceRevisions);
    const resourceType = collaEngine.resourceType;
    this.store.dispatch(roomInfoSync(this.roomId, resourceType, collaborators || []));
    this.store.dispatch(setResourceConnect(this.roomId, resourceType));
    this.loadFieldPermissionMap();
    this.bindSocketMessage();
    this.setSendingWatcher();
  }

  /**
   * Switching resources or reconnecting after disconnection requires the column permissions of all data tables in the room