cc-haha/desktop/src/components/chat/StreamingIndicator.tsx
程序员阿江(Relakkes) e437199b81 fix: Surface API retry progress in desktop chat
CLI retry events already include retry attempts, delay, and upstream status, but
the desktop WebSocket translation dropped api_retry system messages. The desktop
chat now keeps the current retry state in session state and renders a compact
active-turn indicator with attempt count, HTTP status, and countdown.

Constraint: Desktop users need visible feedback during provider retry waits after auth or network failures.
Rejected: Add retry rows to the transcript | retry heartbeats would clutter chat history instead of describing the active turn.
Confidence: high
Scope-risk: moderate
Directive: Keep api_retry as active-turn state; do not persist retry heartbeats into transcript history without a product decision.
Tested: bun test src/server/__tests__/ws-memory-events.test.ts
Tested: cd desktop && bun run test src/stores/chatStore.test.ts src/components/chat/MessageList.test.tsx
Tested: cd desktop && bun run lint
Tested: bun run check:server
Tested: Browser smoke with temp CLAUDE_CONFIG_DIR and mock OpenAI-compatible 503 endpoint, screenshot /tmp/cc-haha-retry-ui.png
Not-tested: Live ChatGPT logout retry path against OpenAI production auth.
2026-05-20 18:48:36 +08:00

117 lines
4.6 KiB
TypeScript

import { useEffect, useState } from 'react'
import { RefreshCw } from 'lucide-react'
import { useChatStore } from '../../stores/chatStore'
import { useTabStore } from '../../stores/tabStore'
import { useTranslation, type TranslationKey } from '../../i18n'
function formatElapsed(seconds: number): string {
if (seconds < 60) return `${seconds}s`
const m = Math.floor(seconds / 60)
const s = seconds % 60
return `${m}m ${s}s`
}
function translateServerVerb(
t: (key: TranslationKey) => string,
verb: string,
): string {
const key = `serverVerb.${verb}` as TranslationKey
const translated = t(key)
return translated === key ? verb : translated
}
function formatRetrySeconds(ms: number): number {
return Math.max(0, Math.ceil(ms / 1000))
}
function formatErrorType(errorType: string | undefined): string | null {
if (!errorType) return null
return errorType
.replace(/[_-]+/g, ' ')
.replace(/\s+/g, ' ')
.trim()
}
export function StreamingIndicator() {
const t = useTranslation()
const [now, setNow] = useState(() => Date.now())
const activeTabId = useTabStore((s) => s.activeTabId)
const sessionState = useChatStore((s) => activeTabId ? s.sessions[activeTabId] : undefined)
const chatState = sessionState?.chatState ?? 'idle'
const statusVerb = sessionState?.statusVerb ?? ''
const apiRetry = sessionState?.apiRetry ?? null
const elapsedSeconds = sessionState?.elapsedSeconds ?? 0
const tokenUsage = sessionState?.tokenUsage ?? { input_tokens: 0, output_tokens: 0 }
useEffect(() => {
if (!apiRetry) return undefined
setNow(Date.now())
const timer = window.setInterval(() => setNow(Date.now()), 1000)
return () => window.clearInterval(timer)
}, [apiRetry?.receivedAt, apiRetry?.retryDelayMs])
if (apiRetry) {
const remainingMs = Math.max(0, apiRetry.retryDelayMs - (now - apiRetry.receivedAt))
const statusText = apiRetry.errorStatus !== null
? t('chat.retry.httpStatus', { status: apiRetry.errorStatus })
: formatErrorType(apiRetry.errorType) ?? t('chat.retry.networkError')
const detailText = apiRetry.errorMessage?.trim()
return (
<div
data-testid="api-retry-indicator"
role="status"
aria-live="polite"
className="mb-2 flex w-full max-w-[min(720px,100%)] flex-wrap items-center gap-2 rounded-md border border-amber-500/35 bg-amber-50/80 px-3 py-2 text-xs text-amber-950 shadow-sm dark:border-amber-400/25 dark:bg-amber-950/30 dark:text-amber-100"
>
<RefreshCw size={14} strokeWidth={2.2} className="shrink-0 animate-spin text-amber-700 dark:text-amber-300" aria-hidden="true" />
<span className="font-medium">{t('chat.retry.title')}</span>
<span className="rounded-[4px] border border-amber-700/20 bg-white/70 px-1.5 py-0.5 font-mono text-[11px] leading-none text-amber-900 dark:border-amber-300/20 dark:bg-black/15 dark:text-amber-100">
{t('chat.retry.attempt', { attempt: apiRetry.attempt, max: apiRetry.maxRetries })}
</span>
<span className="rounded-[4px] border border-amber-700/20 bg-white/70 px-1.5 py-0.5 font-mono text-[11px] leading-none text-amber-900 dark:border-amber-300/20 dark:bg-black/15 dark:text-amber-100">
{statusText}
</span>
<span className="text-amber-800 dark:text-amber-200">
{t('chat.retry.waiting', { seconds: formatRetrySeconds(remainingMs) })}
</span>
{detailText && (
<span className="min-w-0 max-w-full truncate text-amber-700 dark:text-amber-200" title={detailText}>
{detailText}
</span>
)}
</div>
)
}
let verb: string
if (statusVerb) {
verb = translateServerVerb(t, statusVerb)
} else {
verb = chatState === 'thinking'
? t('serverVerb.Thinking')
: chatState === 'compacting'
? t('serverVerb.Compacting conversation')
: chatState === 'tool_executing'
? t('serverVerb.Running')
: t('serverVerb.Working')
}
return (
<div className="mb-2 flex w-fit items-center gap-2 rounded-full border border-[var(--color-border)]/40 bg-[var(--color-surface-container-low)] px-3 py-1">
<span className="text-[var(--color-brand)] animate-shimmer text-xs"></span>
<span className="text-xs font-medium text-[var(--color-text-secondary)]">{verb}...</span>
{elapsedSeconds > 0 && (
<span className="text-[10px] text-[var(--color-text-tertiary)]">
{formatElapsed(elapsedSeconds)}
</span>
)}
{tokenUsage.output_tokens > 0 && (
<span className="text-[10px] text-[var(--color-text-tertiary)]">
· {tokenUsage.output_tokens}
</span>
)}
</div>
)
}