Method initializeSocket

webui/js/websocket.js:618–692

()

  }

  initializeSocket() {
    this.socket = io(this.namespace, {
      autoConnect: false,
      reconnection: true,
      transports: ["websocket", "polling"],
      withCredentials: true,
      auth: (cb) => {
        const handlers = [...this._handlers];
        getCsrfToken()
          .then((token) => cb({ csrf_token: token, handlers }))
          .catch((error) => {
            console.error("[websocket] failed to fetch CSRF token for connect", error);
            cb({ handlers });
          });
      },
    });

    this.socket.on("connect", () => {
      this.connected = true;
      this._csrfInvalidatedForConnectError = false;
      this._connectErrorRetryAttempt = 0;
      this._clearConnectErrorRetryTimer();

      const runtimeId = getRuntimeId();
      const runtimeChanged = Boolean(
        this._lastRuntimeId &&
          runtimeId &&
          this._lastRuntimeId !== runtimeId
      );
      const firstConnect = !this._hasConnectedOnce;
      this._hasConnectedOnce = true;
      this._lastRuntimeId = runtimeId;

      this.debugLog("socket connected", {
        sid: this.socket.id,
        runtimeId,
        runtimeChanged,
        firstConnect,
      });
      this.connectCallbacks.forEach((cb) => {
        try {
          cb({ runtimeId, runtimeChanged, firstConnect });
        } catch (error) {
          console.error("WebSocket onConnect callback error:", error);
        }
      });
    });

    this.socket.on("disconnect", (reason) => {
      this.connected = false;
      this.debugLog("socket disconnected", { reason });
      this.disconnectCallbacks.forEach((cb) => {
        try {
          cb(reason);
        } catch (error) {
          console.error("WebSocket onDisconnect callback error:", error);
        }
      });