Method createSocket

packages/widget-sdk/src/resource/service.ts:300–351

()

  }

  private createSocket() {
    const state = this.store.getState();
    const spaceId = state.space.activeId || state.share.spaceId;
    const version = window['__initialization_data__'].version;
    const socket = SocketIO(Url.WEBSOCKET_NAMESPACE, {
      path: Url.ROOM_PATH,
      transports: ['websocket'],
      secure: true,
      query: {
        version,
        spaceId,
      },
    });
    socket.on('disconnect', (reason: any) => {
      console.warn('! ' + 'socket disconnect from server');
      // Player.doTrigger(Events.app_error_logger, { error: new Error('socket disconnect reason: ' + reason) });

      this.store.dispatch(StoreActions.setReconnecting(true));
      this.roomService.setConnected(false);
      let count = 1;

      const interval = window.setInterval(async () => {
        if (socket.connected) {
          clearInterval(interval);
          await this.roomService.watch();
          this.roomService.setConnected(true);
          this.store.dispatch(StoreActions.setReconnecting(false));
          console.log('connected');
          return;
        }
        if (reason === 'io server disconnect') {
          // the disconnection was initiated by the server, you need to reconnect manually
          socket.connect();
          console.warn('! ' + `room attempt to reconnect ${count++} ...`);
        }
      }, RECONNECT_DELAY);
    });

    socket.on('connect', () => {
      this.reportSocketError = true;
      this.store.dispatch(StoreActions.setConnected(true));
    });

    socket.on('connect_error', () => {
      if (!this.reportSocketError) {
        return;
      }
      this.reportSocketError = false;
      // Player.doTrigger(Events.app_error_logger, { error: new Error('socket has happened some error: ' + JSON.stringify(error)) });
    });
    return socket;
  }

  getCollaEngine(resourceId: string) {
    return this.roomService.collaEngineMap.get(resourceId);