Function handleTerminal

frontend/src/hooks/useTerminalStream.ts:199–242

(event: MessageEvent)

        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;
            });
            setMode('live');
          } catch (err) {
            console.error('[useTerminalStream] failed to parse terminal SSE', err);
          }
        };

        const handleComplete = () => {
          setIsStreaming(false);