Function open

frontend/dashboard/src/hooks/useEventStream.ts:44–72

()

    let cancelled = false;

    const open = () => {
      if (cancelled) return;
      source = new EventSource(url);

      source.onopen = () => {
        retryIndex = 0;
        setConnected(true);
      };

      source.onmessage = (msg) => {
        if (!msg.data) return;
        try {
          const parsed = JSON.parse(msg.data) as StreamEvent;
          handlerRef.current(parsed);
        } catch {
          // malformed payload — ignore
        }
      };

      source.onerror = () => {
        setConnected(false);
        source?.close();
        source = null;
        if (cancelled) return;
        const wait = BACKOFFS_MS[Math.min(retryIndex, BACKOFFS_MS.length - 1)];
        retryIndex += 1;
        reconnectTimer = window.setTimeout(open, wait);
      };
    };

    open();