Function useTerminalStream

frontend/src/hooks/useTerminalStream.ts:51–300

(options: UseTerminalStreamOptions)

}

export function useTerminalStream(options: UseTerminalStreamOptions): UseTerminalStreamResult {
  const { runId, nodeId, stream = 'pty', autoConnect = true } = options;
  const [chunks, setChunks] = useState<TerminalChunk[]>([]);
  const [isHydrating, setIsHydrating] = useState(false);
  const [isStreaming, setIsStreaming] = useState(false);
  const [error, setError] = useState<string | null>(null);
  const [mode, setMode] = useState<TerminalStreamMode>('idle');
  const cursorRef = useRef<string | null>(null);
  const eventSourceRef = useRef<EventSource | null>(null);
  const pendingRunKey = `${runId ?? 'none'}:${nodeId}:${stream}`;

  const closeStream = useCallback(() => {
    eventSourceRef.current?.close();
    eventSourceRef.current = null;
    setIsStreaming(false);
  }, []);

  const hydrate = useCallback(
    async (cursorOverride?: string | null) => {
      if (!runId) {
        return;
      }
      setIsHydrating(true);
      setError(null);
      try {
        const result = await api.executions.getTerminalChunks(runId, {
          nodeRef: nodeId,
          stream,
          cursor: cursorOverride ?? undefined,
        });
        cursorRef.current = result.cursor ?? null;
        setChunks((prev) =>
          cursorOverride ? mergeTerminalChunks(prev, result.chunks) : result.chunks,
        );
        if (result.chunks.length > 0) {
          setMode(autoConnect ? 'live' : 'replay');
        }
      } catch (err) {
        console.error('[useTerminalStream] hydrate failed', err);
        setError(err instanceof Error ? err.message : 'Failed to load terminal output');
      } finally {
        setIsHydrating(false);
      }
    },
    [runId, nodeId, stream, autoConnect],
  );

  const fetchMore = useCallback(async () => {
    if (!runId || !cursorRef.current) {
      return;
    }
    try {
      const result = await api.executions.getTerminalChunks(runId, {
        nodeRef: nodeId,
        stream,
        cursor: cursorRef.current,
      });
      if (result.chunks.length === 0) {