Function renderLiveChunk

src/cli/sessionDisplay.ts:183–212

(chunk: string)

  let lastLength = 0;
  const renderLiveChunk = (chunk: string): void => {
    if (!liveRenderState || chunk.length === 0) {
      process.stdout.write(chunk);
      return;
    }
    if (liveRenderState.fallback) {
      process.stdout.write(chunk);
      return;
    }

    liveRenderState.pending += chunk;
    const { chunks, remainder } = extractRenderableChunks(liveRenderState.pending, liveRenderState);
    liveRenderState.pending = remainder;

    for (const candidate of chunks) {
      const projected = liveRenderState.renderedBytes + Buffer.byteLength(candidate, 'utf8');
      if (projected > MAX_RENDER_BYTES) {
        if (!liveRenderState.noticedFallback) {
          console.log(dim(`Render skipped (log too large: > ${MAX_RENDER_BYTES} bytes). Showing raw text.`));
          liveRenderState.noticedFallback = true;
        }
        liveRenderState.fallback = true;
        process.stdout.write(candidate + liveRenderState.pending);
        liveRenderState.pending = '';
        return;
      }
      process.stdout.write(renderMarkdownAnsi(candidate));
      liveRenderState.renderedBytes += Buffer.byteLength(candidate, 'utf8');
    }
  };

  const flushRemainder = (): void => {
    if (!liveRenderState || liveRenderState.fallback) {