Function connect

frontend/src/hooks/useTerminalStream.ts:179–269

()

    let source: EventSource | null = null;

    const connect = async () => {
      try {
        console.debug('[useTerminalStream] connecting to SSE', {
          runId,
          nodeId,
          stream,
          cursor: cursorRef.current,
        });
        source = await api.executions.stream(runId, {
          terminalCursor: cursorRef.current ?? undefined,
        });
        if (!isMounted) {
          source.close();
          return;
        }
        eventSourceRef.current = source;
        setIsStreaming(true);
        setMode((prev) => (prev === 'idle' ? 'live' : prev));
        console.debug('[useTerminalStream] SSE connected successfully', { runId, nodeId, stream });

        const handleTerminal = (event: MessageEvent) => {
          try {
            const payload = JSON.parse(event.data) as Awaited<
              ReturnType<typeof api.executions.getTerminalChunks>
            >;
            console.debug('[useTerminalStream] terminal SSE event received', {
              totalChunks: payload.chunks?.length,
              nodeId,
              stream,
              cursor: payload.cursor,
            });
            if (!payload.chunks?.length) {
              console.debug('[useTerminalStream] no chunks in payload');
              return;
            }
            const relevant = payload.chunks.filter(
              (chunk) => chunk.nodeRef === nodeId && chunk.stream === stream,
            );
            console.debug('[useTerminalStream] filtered chunks', {
              relevantCount: relevant.length,
              totalCount: payload.chunks.length,
              nodeRefs: payload.chunks.map((c) => c.nodeRef),
              streams: payload.chunks.map((c) => c.stream),
            });
            if (relevant.length === 0) {
              console.debug('[useTerminalStream] no relevant chunks for nodeId/stream');
              return;
            }
            cursorRef.current = payload.cursor ?? cursorRef.current;
            setChunks((prev) => {
              const merged = mergeTerminalChunks(prev, relevant);
              console.debug('[useTerminalStream] updating chunks', {
                prevCount: prev.length,
                newCount: relevant.length,
                mergedCount: merged.length,
                lastChunkIndex: merged[merged.length - 1]?.chunkIndex,
              });
              return merged;