import { EDITORS, type EditorId, ModelSlug, type NativeApi, PROVIDER_SEND_TURN_MAX_INPUT_CHARS, PROVIDER_SEND_TURN_MAX_ATTACHMENTS, PROVIDER_SEND_TURN_MAX_IMAGE_BYTES, type ResolvedKeybindingsConfig, type ProviderApprovalDecision, type ProviderSendTurnAttachmentInput, } from "@t3tools/contracts"; import { type ClipboardEvent, type DragEvent, type FormEvent, type KeyboardEvent, memo, type RefObject, useCallback, useEffect, useLayoutEffect, useMemo, useRef, useState, } from "react"; import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query"; import { type VirtualItem, useVirtualizer } from "@tanstack/react-virtual"; import { gitBranchesQueryOptions, gitCreateWorktreeMutationOptions } from "~/lib/gitReactQuery"; import { serverConfigQueryOptions } from "~/lib/serverReactQuery"; import { isElectron } from "../env"; import { buildBootstrapInput } from "../historyBootstrap"; import { DEFAULT_MODEL, DEFAULT_REASONING, MODEL_OPTIONS, REASONING_OPTIONS, ReasoningEffort, resolveModelSlug, } from "../model-logic"; import { derivePendingApprovals, derivePhase, deriveTimelineEntries, type PendingApproval, deriveWorkLogEntries, formatDuration, formatElapsed, formatTimestamp, } from "../session-logic"; import { isScrollContainerNearBottom } from "../chat-scroll"; import { useStore } from "../store"; import type { ChatImageAttachment } from "../types"; import BranchToolbar from "./BranchToolbar"; import GitActionsControl from "./GitActionsControl"; import { isOpenFavoriteEditorShortcut, isTerminalCloseShortcut, isTerminalNewShortcut, isTerminalSplitShortcut, isTerminalToggleShortcut, shortcutLabelForCommand, } from "../keybindings"; import ChatMarkdown from "./ChatMarkdown"; import ThreadTerminalDrawer from "./ThreadTerminalDrawer"; import { useNativeApi } from "../hooks/useNativeApi"; import { Alert, AlertAction, AlertDescription, AlertTitle } from "./ui/alert"; import { ChevronDownIcon, CircleAlertIcon, FolderClosedIcon, InfoIcon, LockIcon, LockOpenIcon, XIcon, } from "lucide-react"; import { Button } from "./ui/button"; import { Select, SelectItem, SelectPopup, SelectTrigger, SelectValue } from "./ui/select"; import { Separator } from "./ui/separator"; import { Group, GroupSeparator } from "./ui/group"; import { Menu, MenuItem, MenuPopup, MenuShortcut, MenuTrigger } from "./ui/menu"; import { CursorIcon, Icon } from "./Icons"; import { cn, isMacPlatform, isWindowsPlatform } from "~/lib/utils"; import { Badge } from "./ui/badge"; function formatMessageMeta(createdAt: string, duration: string | null): string { if (!duration) return formatTimestamp(createdAt); return `${formatTimestamp(createdAt)} • ${duration}`; } const LAST_EDITOR_KEY = "t3code:last-editor"; const MAX_VISIBLE_WORK_LOG_ENTRIES = 6; const IMAGE_SIZE_LIMIT_LABEL = `${Math.round(PROVIDER_SEND_TURN_MAX_IMAGE_BYTES / (1024 * 1024))}MB`; const IMAGE_ONLY_BOOTSTRAP_PROMPT = "[User attached one or more images without additional text. Respond using the conversation context and the attached image(s).]"; const EMPTY_KEYBINDINGS: ResolvedKeybindingsConfig = []; function workToneClass(tone: "thinking" | "tool" | "info" | "error"): string { if (tone === "error") return "text-rose-300/50 dark:text-rose-300/50"; if (tone === "tool") return "text-muted-foreground/70"; if (tone === "thinking") return "text-muted-foreground/50"; return "text-muted-foreground/40"; } type SessionContinuityState = "resumed" | "new" | "fallback_new"; interface EnsuredSessionInfo { sessionId: string; resolvedThreadId: string | null; continuityState: SessionContinuityState; } interface ComposerImageAttachment extends Omit { previewUrl: string; file: File; } interface ExpandedImagePreview { src: string; name: string; } function readFileAsDataUrl(file: File): Promise { return new Promise((resolve, reject) => { const reader = new FileReader(); reader.addEventListener("load", () => { if (typeof reader.result === "string") { resolve(reader.result); return; } reject(new Error("Could not read image data.")); }); reader.addEventListener("error", () => { reject(reader.error ?? new Error("Failed to read image.")); }); reader.readAsDataURL(file); }); } export default function ChatView() { const { state, dispatch } = useStore(); const api = useNativeApi(); const queryClient = useQueryClient(); const createWorktreeMutation = useMutation( gitCreateWorktreeMutationOptions({ api, queryClient }), ); const [prompt, setPrompt] = useState(""); const [composerImages, setComposerImages] = useState([]); const [isDragOverComposer, setIsDragOverComposer] = useState(false); const [expandedImage, setExpandedImage] = useState(null); const [isSending, setIsSending] = useState(false); const [isConnecting, setIsConnecting] = useState(false); const [selectedEffort, setSelectedEffort] = useState(DEFAULT_REASONING); const [envMode, setEnvMode] = useState<"local" | "worktree">("local"); const [isSwitchingRuntimeMode, setIsSwitchingRuntimeMode] = useState(false); const [respondingRequestIds, setRespondingRequestIds] = useState([]); const [expandedWorkGroups, setExpandedWorkGroups] = useState>({}); const [nowTick, setNowTick] = useState(() => Date.now()); const [terminalFocusRequestId, setTerminalFocusRequestId] = useState(0); const messagesScrollRef = useRef(null); const shouldAutoScrollRef = useRef(true); const textareaRef = useRef(null); const composerImagesRef = useRef([]); const dragDepthRef = useRef(0); const terminalOpenByThreadRef = useRef>({}); const activeThread = state.threads.find((t) => t.id === state.activeThreadId); const activeThreadId = activeThread?.id ?? null; const activeSessionId = activeThread?.session?.sessionId; const activeProject = state.projects.find((p) => p.id === activeThread?.projectId); const selectedModel = resolveModelSlug( activeThread?.model ?? activeProject?.model ?? DEFAULT_MODEL, ); const phase = derivePhase(activeThread?.session ?? null); const isWorking = phase === "running" || isSending || isConnecting; const nowIso = new Date(nowTick).toISOString(); const workLogEntries = useMemo( () => deriveWorkLogEntries(activeThread?.events ?? [], undefined), [activeThread?.events], ); const latestTurnWorkEntries = useMemo( () => deriveWorkLogEntries(activeThread?.events ?? [], activeThread?.latestTurnId), [activeThread?.events, activeThread?.latestTurnId], ); const pendingApprovals = useMemo( () => derivePendingApprovals(activeThread?.events ?? []), [activeThread?.events], ); const assistantCompletionByItemId = useMemo(() => { const map = new Map(); const ordered = [...(activeThread?.events ?? [])].toReversed(); for (const event of ordered) { if (event.method !== "item/completed") continue; if (!event.itemId) continue; map.set(event.itemId, event.createdAt); } return map; }, [activeThread?.events]); const timelineEntries = useMemo( () => deriveTimelineEntries(activeThread?.messages ?? [], workLogEntries), [activeThread?.messages, workLogEntries], ); const completionSummary = useMemo(() => { if (!activeThread?.latestTurnStartedAt) return null; if (!activeThread.latestTurnCompletedAt) return null; if (!latestTurnWorkEntries.some((entry) => entry.tone === "tool")) { return null; } if ( typeof activeThread.latestTurnDurationMs === "number" && Number.isFinite(activeThread.latestTurnDurationMs) && activeThread.latestTurnDurationMs >= 0 ) { return `Worked for ${formatDuration(activeThread.latestTurnDurationMs)}`; } const elapsed = formatElapsed( activeThread.latestTurnStartedAt, activeThread.latestTurnCompletedAt, ); return elapsed ? `Worked for ${elapsed}` : null; }, [ activeThread?.latestTurnStartedAt, activeThread?.latestTurnCompletedAt, activeThread?.latestTurnDurationMs, latestTurnWorkEntries, ]); const completionDividerBeforeEntryId = useMemo(() => { if (!activeThread?.latestTurnStartedAt) return null; if (!activeThread.latestTurnCompletedAt) return null; if (!completionSummary) return null; const turnStartedAt = Date.parse(activeThread.latestTurnStartedAt); const turnCompletedAt = Date.parse(activeThread.latestTurnCompletedAt); if (Number.isNaN(turnStartedAt)) return null; if (Number.isNaN(turnCompletedAt)) return null; let inRangeMatch: string | null = null; let fallbackMatch: string | null = null; for (const timelineEntry of timelineEntries) { if (timelineEntry.kind !== "message") continue; if (timelineEntry.message.role !== "assistant") continue; const messageAt = Date.parse(timelineEntry.message.createdAt); if (Number.isNaN(messageAt) || messageAt < turnStartedAt) continue; fallbackMatch = timelineEntry.id; if (messageAt <= turnCompletedAt) { inRangeMatch = timelineEntry.id; } } return inRangeMatch ?? fallbackMatch; }, [ activeThread?.latestTurnCompletedAt, activeThread?.latestTurnStartedAt, completionSummary, timelineEntries, ]); const runtimeSessionConfig = state.runtimeMode === "full-access" ? ({ approvalPolicy: "never", sandboxMode: "danger-full-access", } as const) : ({ approvalPolicy: "on-request", sandboxMode: "workspace-write", } as const); const gitCwd = activeThread?.worktreePath ?? activeProject?.cwd ?? null; const branchesQuery = useQuery(gitBranchesQueryOptions(api, gitCwd)); const keybindingsQuery = useQuery({ ...serverConfigQueryOptions(api), select: (config) => config.keybindings, }); const keybindings = keybindingsQuery.data ?? EMPTY_KEYBINDINGS; // Default true while loading to avoid toolbar flicker. const isGitRepo = branchesQuery.data?.isRepo ?? true; const splitTerminalShortcutLabel = useMemo( () => shortcutLabelForCommand(keybindings, "terminal.split"), [keybindings], ); const newTerminalShortcutLabel = useMemo( () => shortcutLabelForCommand(keybindings, "terminal.new"), [keybindings], ); const closeTerminalShortcutLabel = useMemo( () => shortcutLabelForCommand(keybindings, "terminal.close"), [keybindings], ); const envLocked = Boolean( activeThread && (activeThread.messages.length > 0 || (activeThread.session !== null && activeThread.session.status !== "closed")), ); const revokePreviewUrls = useCallback((images: Array<{ previewUrl?: string }>) => { for (const image of images) { if (!image.previewUrl) continue; URL.revokeObjectURL(image.previewUrl); } }, []); const focusComposer = useCallback(() => { const textarea = textareaRef.current; if (!textarea) return; textarea.focus(); const cursor = textarea.value.length; textarea.setSelectionRange(cursor, cursor); }, []); const scheduleComposerFocus = useCallback(() => { window.requestAnimationFrame(() => { focusComposer(); }); }, [focusComposer]); const toggleTerminalVisibility = useCallback(() => { if (!activeThreadId) return; dispatch({ type: "SET_THREAD_TERMINAL_OPEN", threadId: activeThreadId, open: !activeThread?.terminalOpen, }); }, [activeThread?.terminalOpen, activeThreadId, dispatch]); const splitTerminal = useCallback(() => { if (!activeThreadId) return; dispatch({ type: "SPLIT_THREAD_TERMINAL", threadId: activeThreadId, terminalId: `terminal-${crypto.randomUUID()}`, }); setTerminalFocusRequestId((value) => value + 1); }, [activeThreadId, dispatch]); const createNewTerminal = useCallback(() => { if (!activeThreadId) return; dispatch({ type: "NEW_THREAD_TERMINAL", threadId: activeThreadId, terminalId: `terminal-${crypto.randomUUID()}`, }); setTerminalFocusRequestId((value) => value + 1); }, [activeThreadId, dispatch]); const activateTerminal = useCallback( (terminalId: string) => { if (!activeThreadId) return; dispatch({ type: "SET_THREAD_ACTIVE_TERMINAL", threadId: activeThreadId, terminalId, }); setTerminalFocusRequestId((value) => value + 1); }, [activeThreadId, dispatch], ); const closeTerminal = useCallback( (terminalId: string) => { if (!activeThreadId || !api) return; const isFinalTerminal = (activeThread?.terminalIds.length ?? 0) <= 1; const fallbackExitWrite = () => api.terminal .write({ threadId: activeThreadId, terminalId, data: "exit\n" }) .catch(() => undefined); if ("close" in api.terminal && typeof api.terminal.close === "function") { void (async () => { if (isFinalTerminal) { await api.terminal .clear({ threadId: activeThreadId, terminalId }) .catch(() => undefined); } await api.terminal.close({ threadId: activeThreadId, terminalId, deleteHistory: true }); })().catch(() => fallbackExitWrite()); } else { void fallbackExitWrite(); } dispatch({ type: "CLOSE_THREAD_TERMINAL", threadId: activeThreadId, terminalId, }); setTerminalFocusRequestId((value) => value + 1); }, [activeThread?.terminalIds.length, activeThreadId, api, dispatch], ); const handleRuntimeModeChange = async (mode: "approval-required" | "full-access") => { if (mode === state.runtimeMode) return; dispatch({ type: "SET_RUNTIME_MODE", mode }); scheduleComposerFocus(); if (!api) return; const sessionIds = state.threads .map((t) => t.session) .filter((s): s is NonNullable => s !== null && s.status !== "closed") .map((s) => s.sessionId); if (sessionIds.length === 0) return; setIsSwitchingRuntimeMode(true); try { await Promise.all( sessionIds.map((id) => api.providers.stopSession({ sessionId: id }).catch(() => undefined)), ); } finally { setIsSwitchingRuntimeMode(false); } }; // Auto-scroll on new messages const messageCount = activeThread?.messages.length ?? 0; const workLogCount = workLogEntries.length; const scrollMessagesToBottom = useCallback((behavior: ScrollBehavior = "auto") => { const scrollContainer = messagesScrollRef.current; if (!scrollContainer) return; scrollContainer.scrollTo({ top: scrollContainer.scrollHeight, behavior }); shouldAutoScrollRef.current = true; }, []); const onMessagesScroll = useCallback(() => { const scrollContainer = messagesScrollRef.current; if (!scrollContainer) return; shouldAutoScrollRef.current = isScrollContainerNearBottom(scrollContainer); }, []); useLayoutEffect(() => { if (!activeThread?.id) return; scrollMessagesToBottom(); }, [activeThread?.id, scrollMessagesToBottom]); useEffect(() => { if (!shouldAutoScrollRef.current) return; scrollMessagesToBottom("smooth"); }, [messageCount, scrollMessagesToBottom]); useEffect(() => { if (phase !== "running") return; if (!shouldAutoScrollRef.current) return; scrollMessagesToBottom("smooth"); }, [phase, workLogCount, scrollMessagesToBottom]); useEffect(() => { setExpandedWorkGroups({}); }, [activeThread?.id]); useEffect(() => { if (!activeThread?.id || activeThread.terminalOpen) return; const frame = window.requestAnimationFrame(() => { focusComposer(); }); return () => { window.cancelAnimationFrame(frame); }; }, [activeThread?.id, activeThread?.terminalOpen, focusComposer]); useEffect(() => { composerImagesRef.current = composerImages; }, [composerImages]); useEffect(() => { setComposerImages((existing) => { revokePreviewUrls(existing); return []; }); dragDepthRef.current = 0; setIsDragOverComposer(false); setExpandedImage(null); }, [activeThread?.id, revokePreviewUrls]); useEffect(() => { return () => { revokePreviewUrls(composerImagesRef.current); }; }, [revokePreviewUrls]); /** * Close expanded image on Escape key */ useEffect(() => { if (!expandedImage) { return; } const onKeyDown = (event: globalThis.KeyboardEvent) => { if (event.key !== "Escape") return; setExpandedImage(null); }; window.addEventListener("keydown", onKeyDown); return () => window.removeEventListener("keydown", onKeyDown); }, [expandedImage]); const activeWorktreePath = activeThread?.worktreePath; useEffect(() => { if (!activeThread?.id) return; setEnvMode(activeWorktreePath ? "worktree" : "local"); }, [activeThread?.id, activeWorktreePath]); // Auto-resize textarea useEffect(() => { const ta = textareaRef.current; if (!ta) return; ta.style.height = "auto"; ta.style.height = `${Math.min(ta.scrollHeight, 200)}px`; }, [prompt]); useEffect(() => { if (phase !== "running") return; const timer = window.setInterval(() => { setNowTick(Date.now()); }, 1000); return () => { window.clearInterval(timer); }; }, [phase]); useEffect(() => { if (!activeThreadId) return; const previous = terminalOpenByThreadRef.current[activeThreadId] ?? false; const current = Boolean(activeThread?.terminalOpen); if (!previous && current) { setTerminalFocusRequestId((value) => value + 1); } else if (previous && !current) { terminalOpenByThreadRef.current[activeThreadId] = current; const frame = window.requestAnimationFrame(() => { focusComposer(); }); return () => { window.cancelAnimationFrame(frame); }; } terminalOpenByThreadRef.current[activeThreadId] = current; }, [activeThread?.terminalOpen, activeThreadId, focusComposer]); useEffect(() => { const isTerminalFocused = (): boolean => { const activeElement = document.activeElement; if (!(activeElement instanceof HTMLElement)) return false; if (activeElement.classList.contains("xterm-helper-textarea")) return true; return activeElement.closest(".thread-terminal-drawer .xterm") !== null; }; const handler = (event: globalThis.KeyboardEvent) => { if (!activeThreadId || event.defaultPrevented) return; const shortcutContext = { terminalFocus: isTerminalFocused(), terminalOpen: Boolean(activeThread?.terminalOpen), }; if (isTerminalToggleShortcut(event, keybindings, { context: shortcutContext })) { event.preventDefault(); event.stopPropagation(); toggleTerminalVisibility(); return; } if (isTerminalSplitShortcut(event, keybindings, { context: shortcutContext })) { event.preventDefault(); event.stopPropagation(); if (!activeThread?.terminalOpen) { dispatch({ type: "SET_THREAD_TERMINAL_OPEN", threadId: activeThreadId, open: true, }); } splitTerminal(); return; } if (isTerminalCloseShortcut(event, keybindings, { context: shortcutContext })) { event.preventDefault(); event.stopPropagation(); if (!activeThread?.terminalOpen) return; closeTerminal(activeThread.activeTerminalId); return; } if (!isTerminalNewShortcut(event, keybindings, { context: shortcutContext })) return; event.preventDefault(); event.stopPropagation(); if (!activeThread?.terminalOpen) { dispatch({ type: "SET_THREAD_TERMINAL_OPEN", threadId: activeThreadId, open: true, }); } createNewTerminal(); }; window.addEventListener("keydown", handler); return () => window.removeEventListener("keydown", handler); }, [ activeThread?.terminalOpen, activeThread?.activeTerminalId, activeThreadId, closeTerminal, createNewTerminal, dispatch, splitTerminal, keybindings, toggleTerminalVisibility, ]); const setThreadError = (threadId: string | null, error: string | null) => { if (!threadId) return; dispatch({ type: "SET_ERROR", threadId, error, }); }; const addComposerImages = (files: File[]) => { if (!activeThreadId || files.length === 0) return; const nextImages = [...composerImagesRef.current]; let error: string | null = null; for (const file of files) { if (!file.type.startsWith("image/")) { error = `Unsupported file type for '${file.name}'. Please attach image files only.`; continue; } if (file.size > PROVIDER_SEND_TURN_MAX_IMAGE_BYTES) { error = `'${file.name}' exceeds the ${IMAGE_SIZE_LIMIT_LABEL} attachment limit.`; continue; } if (nextImages.length >= PROVIDER_SEND_TURN_MAX_ATTACHMENTS) { error = `You can attach up to ${PROVIDER_SEND_TURN_MAX_ATTACHMENTS} images per message.`; break; } const previewUrl = URL.createObjectURL(file); nextImages.push({ type: "image", id: crypto.randomUUID(), name: file.name || "image", mimeType: file.type, sizeBytes: file.size, previewUrl, file, }); } setComposerImages(nextImages); setThreadError(activeThreadId, error); }; const removeComposerImage = (imageId: string) => { setComposerImages((existing) => { const match = existing.find((image) => image.id === imageId); if (match?.previewUrl) { URL.revokeObjectURL(match.previewUrl); } return existing.filter((image) => image.id !== imageId); }); }; const onComposerPaste = (event: ClipboardEvent) => { const files = Array.from(event.clipboardData.files); if (files.length === 0) { return; } const imageFiles = files.filter((file) => file.type.startsWith("image/")); if (imageFiles.length === 0) { return; } event.preventDefault(); addComposerImages(imageFiles); }; const onComposerDragEnter = (event: DragEvent) => { if (!event.dataTransfer.types.includes("Files")) { return; } event.preventDefault(); dragDepthRef.current += 1; setIsDragOverComposer(true); }; const onComposerDragOver = (event: DragEvent) => { if (!event.dataTransfer.types.includes("Files")) { return; } event.preventDefault(); event.dataTransfer.dropEffect = "copy"; setIsDragOverComposer(true); }; const onComposerDragLeave = (event: DragEvent) => { if (!event.dataTransfer.types.includes("Files")) { return; } event.preventDefault(); const nextTarget = event.relatedTarget; if (nextTarget instanceof Node && event.currentTarget.contains(nextTarget)) { return; } dragDepthRef.current = Math.max(0, dragDepthRef.current - 1); if (dragDepthRef.current === 0) { setIsDragOverComposer(false); } }; const onComposerDrop = (event: DragEvent) => { if (!event.dataTransfer.types.includes("Files")) { return; } event.preventDefault(); dragDepthRef.current = 0; setIsDragOverComposer(false); const files = Array.from(event.dataTransfer.files); addComposerImages(files); focusComposer(); }; const ensureSession = async (cwdOverride?: string): Promise => { if (!api || !activeThread || !activeProject) return null; if (activeThread.session && activeThread.session.status !== "closed") { const sessionThreadId = activeThread.session.threadId ?? null; const continuityState: SessionContinuityState = activeThread.codexThreadId === null ? "new" : sessionThreadId === activeThread.codexThreadId ? "resumed" : "fallback_new"; return { sessionId: activeThread.session.sessionId, resolvedThreadId: sessionThreadId, continuityState, } satisfies EnsuredSessionInfo; } const priorCodexThreadId = activeThread.codexThreadId; setIsConnecting(true); try { const session = await api.providers.startSession({ provider: "codex", cwd: cwdOverride ?? activeThread.worktreePath ?? activeProject.cwd, model: selectedModel || undefined, resumeThreadId: priorCodexThreadId ?? undefined, approvalPolicy: runtimeSessionConfig.approvalPolicy, sandboxMode: runtimeSessionConfig.sandboxMode, }); dispatch({ type: "UPDATE_SESSION", threadId: activeThread.id, session, }); const resolvedThreadId = session.threadId ?? null; const continuityState: SessionContinuityState = priorCodexThreadId === null ? "new" : resolvedThreadId === priorCodexThreadId ? "resumed" : "fallback_new"; return { sessionId: session.sessionId, resolvedThreadId, continuityState, }; } catch (err) { dispatch({ type: "SET_ERROR", threadId: activeThread.id, error: err instanceof Error ? err.message : "Failed to connect.", }); return null; } finally { setIsConnecting(false); } }; const onSend = async (e: FormEvent) => { e.preventDefault(); if (!api || !activeThread || isSending || isConnecting) return; const trimmed = prompt.trim(); if (!trimmed && composerImages.length === 0) return; if (!activeProject) return; const composerImagesSnapshot = [...composerImages]; // On first message: lock in branch + create worktree if needed. let sessionCwd: string | undefined; if ( activeThread.messages.length === 0 && activeThread.branch && envMode === "worktree" && !activeThread.worktreePath ) { try { const newBranch = `codething/${crypto.randomUUID().slice(0, 8)}`; const result = await createWorktreeMutation.mutateAsync({ cwd: activeProject.cwd, branch: activeThread.branch, newBranch, }); sessionCwd = result.worktree.path; dispatch({ type: "SET_THREAD_BRANCH", threadId: activeThread.id, branch: result.worktree.branch, worktreePath: result.worktree.path, }); } catch (err) { dispatch({ type: "SET_ERROR", threadId: activeThread.id, error: err instanceof Error ? err.message : "Failed to create worktree", }); return; } } // Auto-title from first message if (activeThread.messages.length === 0) { const titleSeed = trimmed || (composerImagesSnapshot.length > 0 ? `Image: ${composerImagesSnapshot[0]?.name ?? "attachment"}` : "New thread"); const title = titleSeed.length > 50 ? `${titleSeed.slice(0, 50)}...` : titleSeed; dispatch({ type: "SET_THREAD_TITLE", threadId: activeThread.id, title, }); } setThreadError(activeThread.id, null); const messageAttachments: ChatImageAttachment[] = composerImagesSnapshot.map((image) => ({ type: "image", id: image.id, name: image.name, mimeType: image.mimeType, sizeBytes: image.sizeBytes, previewUrl: image.previewUrl, })); dispatch({ type: "PUSH_USER_MESSAGE", threadId: activeThread.id, id: crypto.randomUUID(), text: trimmed, ...(messageAttachments.length > 0 ? { attachments: messageAttachments } : {}), }); const previousMessages = activeThread.messages; setPrompt(""); setComposerImages([]); const sessionInfo = await ensureSession(sessionCwd); if (!sessionInfo) return; setIsSending(true); try { const turnAttachments = await Promise.all( composerImagesSnapshot.map( async (image): Promise => ({ type: "image", name: image.name, mimeType: image.mimeType, sizeBytes: image.sizeBytes, dataUrl: await readFileAsDataUrl(image.file), }), ), ); const shouldBootstrap = previousMessages.length > 0 && (sessionInfo.continuityState === "new" || sessionInfo.continuityState === "fallback_new"); const latestPromptForBootstrap = trimmed || IMAGE_ONLY_BOOTSTRAP_PROMPT; const input = shouldBootstrap ? buildBootstrapInput( previousMessages, latestPromptForBootstrap, PROVIDER_SEND_TURN_MAX_INPUT_CHARS, ).text : trimmed || undefined; await api.providers.sendTurn({ sessionId: sessionInfo.sessionId, ...(input ? { input } : {}), ...(turnAttachments.length > 0 ? { attachments: turnAttachments } : {}), model: selectedModel || undefined, effort: selectedEffort || undefined, }); } catch (err) { setThreadError( activeThread.id, err instanceof Error ? err.message : "Failed to send message.", ); } finally { setIsSending(false); } }; const onInterrupt = async () => { if (!api || !activeThread?.session) return; await api.providers.interruptTurn({ sessionId: activeThread.session.sessionId, turnId: activeThread.session.activeTurnId, }); }; const onRespondToApproval = useCallback( async (requestId: string, decision: ProviderApprovalDecision) => { if (!api || !activeSessionId || !activeThreadId) return; setRespondingRequestIds((existing) => existing.includes(requestId) ? existing : [...existing, requestId], ); try { await api.providers.respondToRequest({ sessionId: activeSessionId, requestId, decision, }); } catch (err) { dispatch({ type: "SET_ERROR", threadId: activeThreadId, error: err instanceof Error ? err.message : "Failed to submit approval decision.", }); } finally { setRespondingRequestIds((existing) => existing.filter((id) => id !== requestId)); } }, [activeSessionId, activeThreadId, api, dispatch], ); const onModelSelect = useCallback( (model: ModelSlug) => { if (!activeThread) return; dispatch({ type: "SET_THREAD_MODEL", threadId: activeThread.id, model: resolveModelSlug(model), }); scheduleComposerFocus(); }, [activeThread, dispatch, scheduleComposerFocus], ); const onEffortSelect = useCallback( (effort: ReasoningEffort) => { setSelectedEffort(effort); scheduleComposerFocus(); }, [scheduleComposerFocus], ); const onEnvModeChange = useCallback( (mode: "local" | "worktree") => { setEnvMode(mode); scheduleComposerFocus(); }, [scheduleComposerFocus], ); const onKeyDown = (e: KeyboardEvent) => { if (e.key === "Enter" && !e.shiftKey) { e.preventDefault(); void onSend(e as unknown as FormEvent); } }; const onToggleWorkGroup = useCallback((groupId: string) => { setExpandedWorkGroups((existing) => ({ ...existing, [groupId]: !existing[groupId], })); }, []); const onExpandTimelineImage = useCallback((image: ExpandedImagePreview) => { setExpandedImage(image); }, []); const onToggleDiff = useCallback(() => { dispatch({ type: "TOGGLE_DIFF" }); }, [dispatch]); // Empty state: no active thread if (!activeThread) { return (
{isElectron && (
No active thread
)}

Select a thread or create a new one to get started.

); } return (
{/* Top bar */}
{/* Error banner */} {/* Messages */}
0} isWorking={isWorking} scrollContainerRef={messagesScrollRef} timelineEntries={timelineEntries} completionDividerBeforeEntryId={completionDividerBeforeEntryId} completionSummary={completionSummary} assistantCompletionByItemId={assistantCompletionByItemId} nowIso={nowIso} expandedWorkGroups={expandedWorkGroups} onToggleWorkGroup={onToggleWorkGroup} onImageExpand={onExpandTimelineImage} />
{/* Input bar */}
{/* Textarea area */}
{composerImages.length > 0 && (
{composerImages.map((image) => (
{image.previewUrl ? ( {image.name} setExpandedImage({ src: image.previewUrl, name: image.name }) } /> ) : (
{image.name}
)}
))}
)}