Function useEventStream

studio/src/hooks/useEventStream.ts:31–205

(options: UseEventStreamOptions = {})

};

export function useEventStream(options: UseEventStreamOptions = {}): UseEventStreamResult {
  const opts = { ...DEFAULT_OPTIONS, ...options };

  const [events, setEvents] = useState<StreamEvent[]>([]);
  const [status, setStatus] = useState<ConnectionStatus>('disconnected');
  const [stats, setStats] = useState<EventStreamStats | null>(null);
  const [error, setError] = useState<string | null>(null);

  const wsRef = useRef<WebSocket | null>(null);
  const reconnectAttempts = useRef(0);
  const reconnectTimeout = useRef<ReturnType<typeof setTimeout> | null>(null);
  const filtersRef = useRef<StreamEventFilters>({});

  // Build WebSocket URL
  const getWsUrl = useCallback(() => {
    const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
    const host = window.location.host;
    return `${protocol}//${host}/v1/dashboard/events/stream`;
  }, []);

  // Connect to WebSocket
  const connect = useCallback(() => {
    if (wsRef.current?.readyState === WebSocket.OPEN) {
      return;
    }

    // Clean up existing connection
    if (wsRef.current) {
      wsRef.current.close();
      wsRef.current = null;
    }

    setStatus('connecting');
    setError(null);

    try {
      const ws = new WebSocket(getWsUrl());
      wsRef.current = ws;

      ws.onopen = () => {
        setStatus('connected');
        setError(null);
        reconnectAttempts.current = 0;

        // Always send subscription on connect (even with empty filters to subscribe to all)
        ws.send(JSON.stringify({
          action: 'subscribe',
          filters: filtersRef.current,
        }));
      };

      ws.onmessage = (event) => {
        try {
          const data = JSON.parse(event.data);

          switch (data.type) {
            case 'event':
              // Extract payload as the actual event data