import { useEffect, useRef, useState } from 'react'; import { Badge } from '@renderer/components/ui/badge'; import { Button } from '@renderer/components/ui/button'; import { cn } from '@renderer/lib/utils'; import { ChevronDown, ChevronRight, Loader2 } from 'lucide-react'; import { MarkdownViewer } from '../chat/viewers/MarkdownViewer'; import { CliLogsRichView } from './CliLogsRichView'; import { STEP_LABELS, STEP_ORDER } from './provisioningSteps'; import type { ProvisioningStep } from './provisioningSteps'; export interface ProvisioningProgressBlockProps { /** Title above the steps, e.g. "Launching team" */ title: string; /** Optional status message */ message?: string | null; /** Visual tone (e.g. highlight errors) */ tone?: 'default' | 'error'; /** Whether Live output is expanded by default */ defaultLiveOutputOpen?: boolean; /** Index of the current step in STEP_ORDER (0-based), or -1 if unknown */ currentStepIndex: number; /** Show spinner next to title */ loading?: boolean; /** Cancel button label and handler */ onCancel?: (() => void) | null; /** ISO timestamp when provisioning started */ startedAt?: string; /** PID of the CLI process */ pid?: number; /** Tail of CLI logs */ cliLogsTail?: string; /** Accumulated assistant text output for live preview */ assistantOutput?: string; className?: string; } function formatElapsed(seconds: number): string { const m = Math.floor(seconds / 60); const s = seconds % 60; return `${m}:${String(s).padStart(2, '0')}`; } function useElapsedTimer(startedAt?: string, isRunning = true): string | null { const [elapsedSeconds, setElapsedSeconds] = useState(null); useEffect(() => { if (!startedAt) { setElapsedSeconds(null); return; } const startMs = Date.parse(startedAt); if (isNaN(startMs)) { setElapsedSeconds(null); return; } const computeElapsedSeconds = (): number => Math.max(0, Math.floor((Date.now() - startMs) / 1000)); if (!isRunning) { // Freeze timer on terminal states (failed/ready/cancelled) instead of continuing to tick. setElapsedSeconds((prev) => (prev === null ? computeElapsedSeconds() : prev)); return; } const tick = (): void => { setElapsedSeconds(computeElapsedSeconds()); }; tick(); const id = window.setInterval(tick, 1000); return () => { window.clearInterval(id); }; }, [startedAt, isRunning]); if (!startedAt) return null; if (elapsedSeconds === null) return null; return formatElapsed(elapsedSeconds); } function sanitizeAssistantOutput(raw?: string, isError = false): string | null { if (!raw) return null; if (!isError) return raw; const looksLikeRawApiEnvelope = raw.includes('API Error: 400') && (raw.includes('"_requests"') || raw.includes('"session_id"') || raw.includes('"parent_tool_use_id"') || raw.includes('\\u000')); if (!looksLikeRawApiEnvelope) { return raw; } return ( 'API Error: 400\n\n' + 'Raw payload from CLI stream hidden because it contains encoded/binary-like content.\n\n' + 'Open **CLI logs** below for readable diagnostics.' ); } export const ProvisioningProgressBlock = ({ title, message, tone = 'default', defaultLiveOutputOpen = true, currentStepIndex, loading = false, onCancel, startedAt, pid, cliLogsTail, assistantOutput, className, }: ProvisioningProgressBlockProps): React.JSX.Element => { const elapsed = useElapsedTimer(startedAt, loading); const [logsOpen, setLogsOpen] = useState(() => tone === 'error' && Boolean(cliLogsTail)); const [liveOutputOpen, setLiveOutputOpen] = useState(defaultLiveOutputOpen); const outputScrollRef = useRef(null); const isError = tone === 'error'; const displayAssistantOutput = sanitizeAssistantOutput(assistantOutput, isError); // Auto-scroll assistant output useEffect(() => { if (liveOutputOpen && outputScrollRef.current) { outputScrollRef.current.scrollTop = outputScrollRef.current.scrollHeight; } }, [assistantOutput, liveOutputOpen]); // If parent changes the default (e.g. transitioning to "ready"), respect it. useEffect(() => { setLiveOutputOpen(defaultLiveOutputOpen); }, [defaultLiveOutputOpen]); // On error with logs available, prioritize logs view over noisy live stream payload. useEffect(() => { if (isError && cliLogsTail) { setLogsOpen(true); setLiveOutputOpen(false); } }, [isError, cliLogsTail]); return (
{loading ? ( ) : null}

{title}

{elapsed !== null ? ( {elapsed} ) : null} {pid !== undefined ? ( PID {pid} ) : null}
{onCancel ? ( ) : null}
{message ? (

{message}

) : null}
{STEP_ORDER.filter((s): s is ProvisioningStep => s !== 'ready').map((step, index) => { const isDone = currentStepIndex >= 0 && index < currentStepIndex; const isCurrent = currentStepIndex >= 0 && index === currentStepIndex; return (
{index + 1} {STEP_LABELS[step]} {index < STEP_ORDER.filter((s) => s !== 'ready').length - 1 ? ( ) : null}
); })}
{liveOutputOpen ? (
{displayAssistantOutput ? ( ) : (

No output captured yet.

)}
) : null}
{cliLogsTail ? (
{logsOpen ? : null}
) : null}
); };