Method connect

apps/kimi-web/src/api/daemon/ws.ts:94–138

Open the WebSocket connection. No-op while one is open or after close().

()

  /** Open the WebSocket connection. No-op while one is open or after close(). */
  connect(): void {
    if (this.ws !== null || this.closed) return;

    traceWsLifecycle('connect', { url: this.wsUrl, attempt: this.reconnectAttempts });
    const credential = getCredential();
    const protocols =
      credential !== undefined ? [`${WS_BEARER_PROTOCOL_PREFIX}${credential}`] : undefined;
    const ws = new WebSocket(this.wsUrl, protocols);
    this.ws = ws;

    ws.onopen = () => {
      // Don't mark as connected yet — wait for server_hello
      traceWsLifecycle('open');
    };

    ws.onmessage = (ev: MessageEvent) => {
      try {
        const frame = JSON.parse(String(ev.data)) as WireServerFrame;
        traceWsIn(frame);
        this.handleFrame(frame);
      } catch (error) {
        traceWsLifecycle('parse-error', { error: String(error) });
        this.handlers.onError(0, `Failed to parse WS frame: ${String(error)}`, false);
      }
    };

    ws.onerror = () => {
      // The error details are not exposed by the browser WS API; the close
      // event with a reason code follows immediately.
      traceWsLifecycle('error');
      this.handlers.onError(0, 'WebSocket error', false);
    };

    ws.onclose = (ev?: CloseEvent) => {
      traceWsLifecycle('close', ev ? { code: ev.code, reason: ev.reason, wasClean: ev.wasClean } : undefined);
      this.connected = false;
      this.ws = null;
      this.handlers.onConnectionState(false);
      // Unexpected drop (daemon restart, sleep, network blip) → reconnect.
      // onServerHello re-sends every kept subscription via client_hello, and
      // the server answers a too-large seq gap with resync_required, so live
      // updates resume without a page reload.
      this.scheduleReconnect();
    };
  }

  private scheduleReconnect(): void {
    if (this.closed || this.reconnectTimer !== null) return;