# Files changed · PR \#23063 · pingdotgg/t3code [View on GitCafe](https://git.cafe/pingdotgg/t3code/pull/23063/diffs) Repository: [pingdotgg/t3code](https://git.cafe/pingdotgg/t3code) Visibility: public [refactor\(web\): ChatView's terminal actions live in useChatTerminalActions](https://git.cafe/pingdotgg/t3code/pull/23063.md) Version: 6 Head commit: 089570e0a46fc41404d2402da2d54826d55380d9 Base commit: d17ebeae9f3fcceaefe276bbfda6ac610dd7b312 Comparison base: d17ebeae9f3fcceaefe276bbfda6ac610dd7b312 Showing up to 20 entries from this revision. If the pull request changes, reopen the first page before continuing. ## apps/web/src/components/ChatView.tsx Status: modified; +40; −320 ```diff @@ -1,3 +1,4 @@ +import { type TerminalLaunchContext, useChatTerminalActions } from "./chat/useChatTerminalActions"; import { useComposerSend } from "./chat/useComposerSend"; import { formatFilePathForClipboard } from "@t3tools/client-runtime/media-actions"; import { resolvePathLinkTarget } from "@t3tools/shared/fileLinks"; @@ -21,7 +22,6 @@ import { useStableCallback } from "../hooks/useStableCallback"; import { useProjectScriptEditing } from "./chat/useProjectScriptEditing"; import { RightPanelSurfaceContent } from "./chat/RightPanelSurfaceContent"; -import { useThreadTerminalActions } from "./terminal/useThreadTerminalActions"; import { usePendingThreadRequests } from "./chat/usePendingThreadRequests"; import { isScratchProject } from "@t3tools/client-runtime/state/projects"; import { visibleThreadPullRequests } from "@t3tools/shared/threadPullRequests"; @@ -38,7 +38,6 @@ pasteTextToFocusComposer, shouldRedirectInputToComposer, } from "./chat/composerFocusRedirect"; -import { getTerminalLabel } from "@t3tools/shared/terminalLabels"; import * as Schema from "effect/Schema"; import { AuthOrchestrationOperateScope, @@ -53,7 +52,6 @@ type MessageId, type ModelSelection, type OrchestrationV2ProviderTurn, - type ProjectScript, type PreviewAnnotationPayload, ProviderInstanceId, type ServerProvider, @@ -99,11 +97,7 @@ scopeThreadRef, } from "@t3tools/client-runtime/environment"; import { formatModelSlugName, resolveSelectableModel } from "@t3tools/shared/model"; -import { - projectScriptCwd, - projectScriptTerminalInput, - resolveProjectScripts, -} from "@t3tools/shared/projectScripts"; +import { projectScriptCwd, resolveProjectScripts } from "@t3tools/shared/projectScripts"; import { derivePendingBackgroundWork } from "@t3tools/shared/orchestrationV2PendingBackgroundWork"; import { latestUnheldRun, @@ -147,7 +141,7 @@ import { type LegendListRef } from "@legendapp/list/react"; import { useUiStateStore } from "../uiStateStore"; import { useWorkspaceMutationRefresh } from "../hooks/useWorkspaceMutationRefresh"; +import { DEFAULT_INTERACTION_MODE, type ChatMessage } from "../types"; -import { DEFAULT_INTERACTION_MODE, MAX_TERMINALS_PER_GROUP, type ChatMessage } from "../types"; import { useTheme } from "../hooks/useTheme"; import { writeTextToClipboard } from "../hooks/useCopyToClipboard"; import { isCommandPaletteOpen } from "../commandPaletteBus"; @@ -173,8 +167,7 @@ setActivePreviewTab, useThreadPreviewState, } from "../previewStateStore"; -import { BrowserSettingsReadError, openUrlInPreview } from "../browser/openFileInPreview"; +import { BrowserSettingsReadError } from "../browser/openFileInPreview"; -import { resolveDiscoveredServerUrl } from "../browser/browserTargetResolver"; import { previewRuntimeTabId } from "../browser/previewRuntimeTabId"; import { addBrowserSurface } from "./preview/addBrowserSurface"; import { ThreadPreviewMiniPlayer } from "./preview/ThreadPreviewMiniPlayer"; @@ -227,10 +220,8 @@ import { useRemoveClonedProject } from "../hooks/useRemoveClonedProject"; import { useOpenPanelPullRequestUrl } from "../hooks/useOpenPanelPullRequestUrl"; import { resolveAppModelSelectionForInstance } from "../modelSelection"; -import { confirmTerminalClose } from "../lib/terminalCloseConfirm"; import { isPreviewFocused } from "../lib/previewFocus"; import { getTerminalFocusOwner } from "../lib/terminalFocus"; -import { findReusableProjectScriptTerminal } from "../lib/projectScriptTerminal"; import { resolveNewDraftStartFromOrigin } from "../lib/chatThreadActions"; import { deriveLogicalProjectKeyFromSettings, @@ -249,7 +240,7 @@ useComposerDraftStore, DraftId, } from "../composerDraftStore"; +import { type TerminalContextDraft } from "../lib/terminalContext"; -import { type TerminalContextDraft, type TerminalContextSelection } from "../lib/terminalContext"; import { collectInlineContextIds } from "../lib/composerContextReferences"; import { selectThreadTerminalUiState, useTerminalUiStateStore } from "../terminalUiStateStore"; import { useKnownTerminalSessions, useThreadRunningTerminalIds } from "../state/terminalSessions"; @@ -375,8 +366,6 @@ shouldShowPlanFollowUpPrompt, shouldRenderPreviewMiniPlayer, getStartedThreadModelChangeBlockReason, - LAST_INVOKED_SCRIPT_BY_PROJECT_KEY, - LastInvokedScriptByProjectSchema, deriveLockedProvider, resolveFileAttachmentUrl, resolveComposerInteractionMode, @@ -440,9 +429,6 @@ const EMPTY_PENDING_FILE_SURFACE_IDS: ReadonlySet = new Set(); -const SCRIPT_TERMINAL_COLS = 120; -const SCRIPT_TERMINAL_ROWS = 30; - type ChatViewProps = | { environmentId: EnvironmentId; @@ -463,12 +449,6 @@ draftId: DraftId; }; -interface TerminalLaunchContext { - threadId: ThreadId; - cwd: string; - worktreePath: string | null; -} - const EMPTY_HELD_TURN_DIFF_SUMMARIES: readonly never[] = []; const noopHeldTurnDiff = (_turnId: RunId, _filePath?: string) => {}; const noopHeldRevert = (_targetTurnCount: number) => {}; @@ -485,8 +465,6 @@ } = props; const canOperateThread = useEnvironmentScope(environmentId, AuthOrchestrationOperateScope); const canOperateTerminal = useEnvironmentScope(environmentId, AuthTerminalOperateScope); - const hasTerminalWriteAccess = () => - readEnvironmentScope(environmentId, AuthTerminalOperateScope); const canReadTerminal = useEnvironmentScope(environmentId, AuthTerminalReadScope); const draftId = routeKind === "draft" ? props.draftId : null; const handleNewThread = useNewThreadHandler(); @@ -816,11 +794,6 @@ pendingServerThreadStartFromOriginByThreadId, setPendingServerThreadStartFromOriginByThreadId, ] = useState>({}); - const [lastInvokedScriptByProjectId, setLastInvokedScriptByProjectId] = useLocalStorage( - LAST_INVOKED_SCRIPT_BY_PROJECT_KEY, - {}, - LastInvokedScriptByProjectSchema, - ); const legendListRef = useRef(null); const getTimelineScrollableNode = () => legendListRef.current?.getScrollableNode() ?? null; const getTimelineScrollableNodeStable = useStableCallback(getTimelineScrollableNode); @@ -853,12 +826,6 @@ const terminalUiState = useTerminalUiStateStore((state) => selectThreadTerminalUiState(state.terminalUiStateByThreadKey, routeThreadRef), ); - const storeSetTerminalOpen = useTerminalUiStateStore((s) => s.setTerminalOpen); - const storeEnsureTerminal = useTerminalUiStateStore((state) => state.ensureTerminal); - const storeSplitTerminal = useTerminalUiStateStore((s) => s.splitTerminal); - const storeSplitTerminalVertical = useTerminalUiStateStore((s) => s.splitTerminalVertical); - const storeNewTerminal = useTerminalUiStateStore((s) => s.newTerminal); - const storeCloseTerminal = useTerminalUiStateStore((s) => s.closeTerminal); const fallbackDraftProjectRef = draftThread ? scopeProjectRef(draftThread.environmentId, draftThread.projectId) @@ -1026,7 +993,6 @@ return labels; })(); const activeThreadRef = useActiveThreadRef(activeThread); - const terminalActions = useThreadTerminalActions(activeThreadRef); const activeThreadKey = activeThreadRef ? scopedThreadKey(activeThreadRef) : null; const activeEnvironmentServerBrowser = useEnvironmentSupportsServerBrowser( activeThreadRef?.environmentId ?? null, @@ -2379,17 +2345,6 @@ sendInFlightRef, }); - const activeTerminalGroup = - terminalUiState.terminalGroups.find( - (group) => group.id === terminalUiState.activeTerminalGroupId, - ) ?? - terminalUiState.terminalGroups.find((group) => - group.terminalIds.includes(terminalUiState.activeTerminalId), - ) ?? - null; - const hasReachedSplitLimit = - (activeTerminalGroup?.terminalIds.length ?? 0) >= MAX_TERMINALS_PER_GROUP; - const focusComposer = () => { composerRef.current?.focusAtEnd(); }; @@ -2460,200 +2415,43 @@ }; const sendAppMessageStable = useStableCallback(sendAppMessage); const queuedRunsControlRef = useRef(null); - const addTerminalContextToDraft = (selection: TerminalContextSelection) => { - composerRef.current?.addTerminalContext(selection); - }; - const addTerminalContextToDraftStable = useStableCallback(addTerminalContextToDraft); - const setTerminalOpen = (open: boolean) => { - if (!activeThreadRef) return; - storeSetTerminalOpen(activeThreadRef, open); - }; - const setTerminalOpenStable = useStableCallback(setTerminalOpen); - const toggleTerminalVisibility = () => { - if (!activeThreadRef) return; - const nextOpen = !terminalUiState.terminalOpen; - if ( - nextOpen && - !readEnvironmentScope(environmentId, AuthTerminalReadScope) && - !hasTerminalWriteAccess() - ) - return; - if (nextOpen && hasTerminalWriteAccess() && terminalUiState.terminalIds.length === 0) { - // Server-created setup terminals exist before this client's drawer mounts. - // Reuse them before allocating a shell from the still-empty UI state. - const existingTerminalId = - runningTerminalIds.find((id) => !panelTerminalIds.has(id)) ?? - activeServerOrderedTerminalIds.find((id) => !panelTerminalIds.has(id)); - if (existingTerminalId !== undefined) { - storeEnsureTerminal(activeThreadRef, existingTerminalId, { open: true, active: true }); - return; - } - void terminalActions.launchTerminal({ - place: (terminalId) => storeEnsureTerminal(activeThreadRef, terminalId, { open: true }), - })?.result; - return; - } - setTerminalOpen(nextOpen); - }; - const toggleTerminalVisibilityStable = useStableCallback(toggleTerminalVisibility); - const splitTerminal = (direction: "horizontal" | "vertical" = "horizontal") => { - if (!activeThreadRef || hasReachedSplitLimit) return; - const launched = terminalActions.launchTerminal({ - place: (terminalId) => - direction === "vertical" - ? storeSplitTerminalVertical(activeThreadRef, terminalId) - : storeSplitTerminal(activeThreadRef, terminalId), - }); - if (!launched) return; - setTerminalFocusRequestId((value) => value + 1); - void launched.result; - }; - const splitTerminalStable = useStableCallback(splitTerminal); - const createNewTerminal = () => { - if (!activeThreadRef) return; - const launched = terminalActions.launchTerminal({ - place: (terminalId) => storeNewTerminal(activeThreadRef, terminalId), - }); - if (!launched) return; - setTerminalFocusRequestId((value) => value + 1); - void launched.result; - }; - const createNewTerminalStable = useStableCallback(createNewTerminal); - const closeTerminal = (terminalId: string) => { - if (!hasTerminalWriteAccess() || !activeThreadRef) return; - terminalActions.closeTerminalSession(terminalId); - storeCloseTerminal(activeThreadRef, terminalId); - setTerminalFocusRequestId((value) => value + 1); - }; - const runProjectScript = async ( - script: ProjectScript, - options?: { - cwd?: string; - env?: Record; - worktreePath?: string | null; - preferNewTerminal?: boolean; - rememberAsLastInvoked?: boolean; - shellHistory?: "preserve" | "suppress"; - }, - ) => { - if (!hasTerminalWriteAccess() || !activeThreadId || !activeProject || !activeThread) return; - if (options?.rememberAsLastInvoked !== false) { - setLastInvokedScriptByProjectId((current) => { - if (current[activeProject.id] === script.id) return current; - return { ...current, [activeProject.id]: script.id }; - }); - } - const targetCwd = options?.cwd ?? gitCwd ?? activeProject.workspaceRoot; - const reusableTerminalId = - options?.preferNewTerminal || - !canReuseTerminal || - !readEnvironmentScope(environmentId, AuthTerminalReadScope) - ? null - : findReusableProjectScriptTerminal({ - // Server sessions cover drawer terminals this client has not opened yet, such as a - // worktree setup shell; the helper drops the panel-owned ones. - drawerTerminalIds: [ - ...new Set([...terminalUiState.terminalIds, ...activeServerOrderedTerminalIds]), - ], - activeTerminalId: terminalUiState.activeTerminalId, - panelTerminalIds, - runningTerminalIds, - }); - const targetWorktreePath = options?.worktreePath ?? activeThread.worktreePath ?? null; - setTerminalUiLaunchContext({ - threadId: activeThreadId, - cwd: targetCwd, - worktreePath: targetWorktreePath, - }); - if (!activeThreadRef) { - return; - } - setTerminalFocusRequestId((value) => value + 1); - - const launched = terminalActions.launchTerminal({ - // The drawer opens with the target already placed: opening it empty would claim - // DEFAULT_THREAD_TERMINAL_ID, which a right-panel terminal may already own. - place: (terminalId) => - reusableTerminalId === null - ? storeNewTerminal(activeThreadRef, terminalId) - : storeEnsureTerminal(activeThreadRef, terminalId, { open: true }), - ...(reusableTerminalId === null - ? { size: { cols: SCRIPT_TERMINAL_COLS, rows: SCRIPT_TERMINAL_ROWS } } - : { terminalId: reusableTerminalId }), - location: { cwd: targetCwd, worktreePath: targetWorktreePath }, - ...(options?.env ? { extraEnv: options.env } : {}), - }); - if (!launched) return; - const targetTerminalId = launched.terminalId; - const openResult = await launched.result; - if (openResult._tag === "Failure") { - if (!isAtomCommandInterrupted(openResult)) { - const error = squashAtomCommandFailure(openResult); - setThreadError( - activeThreadId, - error instanceof Error ? error.message : `Failed to run script "${script.name}".`, - ); - } - return; - } - - const writeResult = await terminalActions.writeToTerminal( - targetTerminalId, - options?.shellHistory === "preserve" - ? `${script.command}\r` - : projectScriptTerminalInput(script.command), - ); - if (!writeResult) return; - if (writeResult._tag === "Failure") { - if (!isAtomCommandInterrupted(writeResult)) { - const error = squashAtomCommandFailure(writeResult); - setThreadError( - activeThreadId, - error instanceof Error ? error.message : `Failed to run script "${script.name}".`, - ); - } - return; - } - if (script.autoOpenPreview && script.previewUrl && isPreviewSupportedInRuntime()) { - const previewResult = await openUrlInPreview({ - threadRef: activeThreadRef, - url: resolveDiscoveredServerUrl(activeThreadRef.environmentId, script.previewUrl), - openPreview, - }); - if (previewResult._tag === "Failure" && !isAtomCommandInterrupted(previewResult)) { - const error = squashAtomCommandFailure(previewResult); - toastManager.add( - stackedThreadToast({ - type: "error", - title: "Could not open preview", - description: error instanceof Error ? error.message : "An unexpected error occurred.", - }), - ); - } - } - }; - const runProjectScriptStable = useStableCallback(runProjectScript); - - const runProjectScriptRef = useRef(runProjectScriptStable); - useLayoutEffect(() => { - runProjectScriptRef.current = runProjectScriptStable; - }, [runProjectScriptStable]); - const runShellCommand = (command: string) => { - void runProjectScriptRef.current( - { - id: "chat-code-block", - name: "Chat code block", - command, - icon: "play", - runOnWorktreeCreate: false, - }, - { rememberAsLastInvoked: false, shellHistory: "preserve" }, - ); - }; - const runShellCommandStable = useStableCallback(runShellCommand); - const { + activatePanelTerminalStable, + addTerminalContextToDraftStable, + addTerminalSurfaceStable, + closePanelTerminalStable, + createNewTerminalStable, + lastInvokedScriptByProjectId, + requestClosePanelTerminalStable, + requestCloseTerminalStable, + runProjectScriptStable, + runShellCommandStable, + setTerminalOpenStable, + splitPanelTerminalStable, + splitPanelTerminalVerticalStable, + splitTerminalStable, + toggleTerminalVisibilityStable, + } = useChatTerminalActions({ + environmentId, + composerRef, + terminalUiState, + activeThread, + activeThreadId, + activeThreadRef, + activeProject, + activeRightPanelSurface, + runningTerminalIds, + activeServerOrderedTerminalIds, + activeTerminalLabelsById, + panelTerminalIds, + canReuseTerminal, + gitCwd, + setTerminalFocusRequestId, + setTerminalUiLaunchContext, + setThreadError, + }); + const { saveProjectScript: saveProjectScriptStable, updateProjectScript: updateProjectScriptStable, deleteProjectScript: deleteProjectScriptStable, @@ -2853,84 +2651,6 @@ } }; const togglePreviewPanelStable = useStableCallback(togglePreviewPanel); - const addTerminalSurface = () => { - if (!activeThreadRef) return; - const launched = terminalActions.launchTerminal({ - place: (terminalId) => - useRightPanelStore.getState().openTerminal(activeThreadRef, terminalId), - }); - if (!launched) return; - setTerminalFocusRequestId((value) => value + 1); - void launched.result; - }; - const addTerminalSurfaceStable = useStableCallback(addTerminalSurface); - const splitPanelTerminal = (direction: "horizontal" | "vertical" = "horizontal") => { - if ( - !activeThreadRef || - activeRightPanelSurface?.kind !== "terminal" || - activeRightPanelSurface.terminalIds.length >= MAX_TERMINALS_PER_GROUP - ) { - return; - } - const surfaceId = activeRightPanelSurface.id; - const launched = terminalActions.launchTerminal({ - place: (terminalId) => - useRightPanelStore - .getState() - .splitTerminal(activeThreadRef, surfaceId, terminalId, direction), - }); - if (!launched) return; - setTerminalFocusRequestId((value) => value + 1); - void launched.result; - }; - const splitPanelTerminalStable = useStableCallback(splitPanelTerminal); - const splitPanelTerminalVertical = () => { - splitPanelTerminal("vertical"); - }; - const splitPanelTerminalVerticalStable = useStableCallback(splitPanelTerminalVertical); - const activatePanelTerminal = (terminalId: string) => { - if (!activeThreadRef || activeRightPanelSurface?.kind !== "terminal") return; - useRightPanelStore - .getState() - .activateTerminal(activeThreadRef, activeRightPanelSurface.id, terminalId); - setTerminalFocusRequestId((value) => value + 1); - }; - const activatePanelTerminalStable = useStableCallback(activatePanelTerminal); - const closePanelTerminal = (terminalId: string) => { - if ( - !hasTerminalWriteAccess() || - !activeThreadRef || - activeRightPanelSurface?.kind !== "terminal" - ) - return; - terminalActions.closeTerminalSession(terminalId); - storeCloseTerminal(activeThreadRef, terminalId); - useRightPanelStore - .getState() - .closeTerminal(activeThreadRef, activeRightPanelSurface.id, terminalId); - setTerminalFocusRequestId((value) => value + 1); - }; - const closePanelTerminalStable = useStableCallback(closePanelTerminal); - const requestCloseTerminal = (terminalId: string) => { - if (!hasTerminalWriteAccess()) return; - const label = activeTerminalLabelsById.get(terminalId) ?? getTerminalLabel(terminalId); - void confirmTerminalClose([label]).then((confirmed) => { - if (confirmed && readEnvironmentScope(environmentId, AuthTerminalOperateScope)) { - closeTerminal(terminalId); - } - }); - }; - const requestCloseTerminalStable = useStableCallback(requestCloseTerminal); - const requestClosePanelTerminal = (terminalId: string) => { - if (!hasTerminalWriteAccess()) return; - const label = activeTerminalLabelsById.get(terminalId) ?? getTerminalLabel(terminalId); - void confirmTerminalClose([label]).then((confirmed) => { - if (confirmed && readEnvironmentScope(environmentId, AuthTerminalOperateScope)) { - closePanelTerminal(terminalId); - } - }); - }; - const requestClosePanelTerminalStable = useStableCallback(requestClosePanelTerminal); const activateRightPanelSurface = (surface: RightPanelSurface) => { if (!activeThreadRef) return; explicitDiffOpenRef.current = resolveExplicitDiffOpenOnActivate({ ``` ## apps/web/src/components/chat/useChatTerminalActions.ts Status: added; +408; −0 ```diff @@ -1,0 +1,408 @@ +import type { + EnvironmentProject, + EnvironmentThreadShell, +} from "@t3tools/client-runtime/state/shell"; +import type { Dispatch } from "react"; +import type { ComposerHandleRef } from "../../composerHandleContext"; +import type { selectThreadTerminalUiState } from "../../terminalUiStateStore"; +import { useStableCallback } from "../../hooks/useStableCallback"; +import { useThreadTerminalActions } from "../terminal/useThreadTerminalActions"; +import { getTerminalLabel } from "@t3tools/shared/terminalLabels"; +import { + AuthTerminalReadScope, + AuthTerminalOperateScope, + type EnvironmentId, + type ProjectScript, + type ScopedThreadRef, + type ThreadId, +} from "@t3tools/contracts"; +import { projectScriptTerminalInput } from "@t3tools/shared/projectScripts"; +import { type SetStateAction } from "react"; +import { + isAtomCommandInterrupted, + squashAtomCommandFailure, +} from "@t3tools/client-runtime/state/runtime"; +import { MAX_TERMINALS_PER_GROUP } from "../../types"; +import { type RightPanelSurface, useRightPanelStore } from "../../rightPanelStore"; +import { isPreviewSupportedInRuntime } from "../../previewStateStore"; +import { openUrlInPreview } from "../../browser/openFileInPreview"; +import { resolveDiscoveredServerUrl } from "../../browser/browserTargetResolver"; +import { stackedThreadToast, toastManager } from "../ui/toast"; +import { confirmTerminalClose } from "../../lib/terminalCloseConfirm"; +import { findReusableProjectScriptTerminal } from "../../lib/projectScriptTerminal"; +import { type TerminalContextSelection } from "../../lib/terminalContext"; +import { useTerminalUiStateStore } from "../../terminalUiStateStore"; +import { + LAST_INVOKED_SCRIPT_BY_PROJECT_KEY, + LastInvokedScriptByProjectSchema, + makeThreadErrorSetter, +} from "../ChatView.logic"; +import { useLocalStorage } from "~/hooks/useLocalStorage"; +import { previewEnvironment } from "../../state/preview"; +import { readEnvironmentScope } from "../../state/session"; +import { useAtomCommand } from "../../state/use-atom-command"; +const SCRIPT_TERMINAL_COLS = 120; +const SCRIPT_TERMINAL_ROWS = 30; + +export interface TerminalLaunchContext { + threadId: ThreadId; + cwd: string; + worktreePath: string | null; +} + +interface ChatTerminalActionsInput { + readonly environmentId: EnvironmentId; + readonly composerRef: ComposerHandleRef; + readonly terminalUiState: ReturnType; + readonly activeThread: EnvironmentThreadShell | undefined; + readonly activeThreadId: ThreadId | null; + readonly activeThreadRef: ScopedThreadRef | null; + readonly activeProject: EnvironmentProject | null; + readonly activeRightPanelSurface: RightPanelSurface | null; + readonly runningTerminalIds: ReadonlyArray; + readonly activeServerOrderedTerminalIds: ReadonlyArray; + readonly activeTerminalLabelsById: ReadonlyMap; + readonly panelTerminalIds: ReadonlySet; + readonly canReuseTerminal: boolean; + readonly gitCwd: string | null; + readonly setTerminalFocusRequestId: Dispatch>; + readonly setTerminalUiLaunchContext: Dispatch>; + readonly setThreadError: ReturnType; +} + +/** + * The thread's terminals: the drawer's and the right panel's, and project scripts and chat + * code blocks, which run in a reused or new drawer terminal. + */ +export function useChatTerminalActions(input: ChatTerminalActionsInput) { + const { + environmentId, + composerRef, + terminalUiState, + activeThread, + activeThreadId, + activeThreadRef, + activeProject, + activeRightPanelSurface, + runningTerminalIds, + activeServerOrderedTerminalIds, + activeTerminalLabelsById, + panelTerminalIds, + canReuseTerminal, + gitCwd, + setTerminalFocusRequestId, + setTerminalUiLaunchContext, + setThreadError, + } = input; + const openPreview = useAtomCommand(previewEnvironment.open, { reportFailure: false }); + + const hasTerminalWriteAccess = () => + readEnvironmentScope(environmentId, AuthTerminalOperateScope); + const [lastInvokedScriptByProjectId, setLastInvokedScriptByProjectId] = useLocalStorage( + LAST_INVOKED_SCRIPT_BY_PROJECT_KEY, + {}, + LastInvokedScriptByProjectSchema, + ); + const storeSetTerminalOpen = useTerminalUiStateStore((s) => s.setTerminalOpen); + const storeEnsureTerminal = useTerminalUiStateStore((state) => state.ensureTerminal); + const storeSplitTerminal = useTerminalUiStateStore((s) => s.splitTerminal); + const storeSplitTerminalVertical = useTerminalUiStateStore((s) => s.splitTerminalVertical); + const storeNewTerminal = useTerminalUiStateStore((s) => s.newTerminal); + const storeCloseTerminal = useTerminalUiStateStore((s) => s.closeTerminal); + const terminalActions = useThreadTerminalActions(activeThreadRef); + + const activeTerminalGroup = + terminalUiState.terminalGroups.find( + (group) => group.id === terminalUiState.activeTerminalGroupId, + ) ?? + terminalUiState.terminalGroups.find((group) => + group.terminalIds.includes(terminalUiState.activeTerminalId), + ) ?? + null; + const hasReachedSplitLimit = + (activeTerminalGroup?.terminalIds.length ?? 0) >= MAX_TERMINALS_PER_GROUP; + /*__HOOK__*/ + const addTerminalContextToDraft = (selection: TerminalContextSelection) => { + composerRef.current?.addTerminalContext(selection); + }; + const addTerminalContextToDraftStable = useStableCallback(addTerminalContextToDraft); + const setTerminalOpen = (open: boolean) => { + if (!activeThreadRef) return; + storeSetTerminalOpen(activeThreadRef, open); + }; + const setTerminalOpenStable = useStableCallback(setTerminalOpen); + const toggleTerminalVisibility = () => { + if (!activeThreadRef) return; + const nextOpen = !terminalUiState.terminalOpen; + if ( + nextOpen && + !readEnvironmentScope(environmentId, AuthTerminalReadScope) && + !hasTerminalWriteAccess() + ) + return; + if (nextOpen && hasTerminalWriteAccess() && terminalUiState.terminalIds.length === 0) { + // Server-created setup terminals exist before this client's drawer mounts. + // Reuse them before allocating a shell from the still-empty UI state. + const existingTerminalId = + runningTerminalIds.find((id) => !panelTerminalIds.has(id)) ?? + activeServerOrderedTerminalIds.find((id) => !panelTerminalIds.has(id)); + if (existingTerminalId !== undefined) { + storeEnsureTerminal(activeThreadRef, existingTerminalId, { open: true, active: true }); + return; + } + void terminalActions.launchTerminal({ + place: (terminalId) => storeEnsureTerminal(activeThreadRef, terminalId, { open: true }), + })?.result; + return; + } + setTerminalOpen(nextOpen); + }; + const toggleTerminalVisibilityStable = useStableCallback(toggleTerminalVisibility); + const splitTerminal = (direction: "horizontal" | "vertical" = "horizontal") => { + if (!activeThreadRef || hasReachedSplitLimit) return; + const launched = terminalActions.launchTerminal({ + place: (terminalId) => + direction === "vertical" + ? storeSplitTerminalVertical(activeThreadRef, terminalId) + : storeSplitTerminal(activeThreadRef, terminalId), + }); + if (!launched) return; + setTerminalFocusRequestId((value) => value + 1); + void launched.result; + }; + const splitTerminalStable = useStableCallback(splitTerminal); + const createNewTerminal = () => { + if (!activeThreadRef) return; + const launched = terminalActions.launchTerminal({ + place: (terminalId) => storeNewTerminal(activeThreadRef, terminalId), + }); + if (!launched) return; + setTerminalFocusRequestId((value) => value + 1); + void launched.result; + }; + const createNewTerminalStable = useStableCallback(createNewTerminal); + const closeTerminal = (terminalId: string) => { + if (!hasTerminalWriteAccess() || !activeThreadRef) return; + terminalActions.closeTerminalSession(terminalId); + storeCloseTerminal(activeThreadRef, terminalId); + setTerminalFocusRequestId((value) => value + 1); + }; + const runProjectScript = async ( + script: ProjectScript, + options?: { + cwd?: string; + env?: Record; + worktreePath?: string | null; + preferNewTerminal?: boolean; + rememberAsLastInvoked?: boolean; + shellHistory?: "preserve" | "suppress"; + }, + ) => { + if (!hasTerminalWriteAccess() || !activeThreadId || !activeProject || !activeThread) return; + if (options?.rememberAsLastInvoked !== false) { + setLastInvokedScriptByProjectId((current) => { + if (current[activeProject.id] === script.id) return current; + return { ...current, [activeProject.id]: script.id }; + }); + } + const targetCwd = options?.cwd ?? gitCwd ?? activeProject.workspaceRoot; + const reusableTerminalId = + options?.preferNewTerminal || + !canReuseTerminal || + !readEnvironmentScope(environmentId, AuthTerminalReadScope) + ? null + : findReusableProjectScriptTerminal({ + // Server sessions cover drawer terminals this client has not opened yet, such as a + // worktree setup shell; the helper drops the panel-owned ones. + drawerTerminalIds: [ + ...new Set([...terminalUiState.terminalIds, ...activeServerOrderedTerminalIds]), + ], + activeTerminalId: terminalUiState.activeTerminalId, + panelTerminalIds, + runningTerminalIds, + }); + const targetWorktreePath = options?.worktreePath ?? activeThread.worktreePath ?? null; + + setTerminalUiLaunchContext({ + threadId: activeThreadId, + cwd: targetCwd, + worktreePath: targetWorktreePath, + }); + if (!activeThreadRef) { + return; + } + setTerminalFocusRequestId((value) => value + 1); + + const launched = terminalActions.launchTerminal({ + // The drawer opens with the target already placed: opening it empty would claim + // DEFAULT_THREAD_TERMINAL_ID, which a right-panel terminal may already own. + place: (terminalId) => + reusableTerminalId === null + ? storeNewTerminal(activeThreadRef, terminalId) + : storeEnsureTerminal(activeThreadRef, terminalId, { open: true }), + ...(reusableTerminalId === null + ? { size: { cols: SCRIPT_TERMINAL_COLS, rows: SCRIPT_TERMINAL_ROWS } } + : { terminalId: reusableTerminalId }), + location: { cwd: targetCwd, worktreePath: targetWorktreePath }, + ...(options?.env ? { extraEnv: options.env } : {}), + }); + if (!launched) return; + const targetTerminalId = launched.terminalId; + const openResult = await launched.result; + if (openResult._tag === "Failure") { + if (!isAtomCommandInterrupted(openResult)) { + const error = squashAtomCommandFailure(openResult); + setThreadError( + activeThreadId, + error instanceof Error ? error.message : `Failed to run script "${script.name}".`, + ); + } + return; + } + + const writeResult = await terminalActions.writeToTerminal( + targetTerminalId, + options?.shellHistory === "preserve" + ? `${script.command}\r` + : projectScriptTerminalInput(script.command), + ); + if (!writeResult) return; + if (writeResult._tag === "Failure") { + if (!isAtomCommandInterrupted(writeResult)) { + const error = squashAtomCommandFailure(writeResult); + setThreadError( + activeThreadId, + error instanceof Error ? error.message : `Failed to run script "${script.name}".`, + ); + } + return; + } + if (script.autoOpenPreview && script.previewUrl && isPreviewSupportedInRuntime()) { + const previewResult = await openUrlInPreview({ + threadRef: activeThreadRef, + url: resolveDiscoveredServerUrl(activeThreadRef.environmentId, script.previewUrl), + openPreview, + }); + if (previewResult._tag === "Failure" && !isAtomCommandInterrupted(previewResult)) { + const error = squashAtomCommandFailure(previewResult); + toastManager.add( + stackedThreadToast({ + type: "error", + title: "Could not open preview", + description: error instanceof Error ? error.message : "An unexpected error occurred.", + }), + ); + } + } + }; + const runProjectScriptStable = useStableCallback(runProjectScript); + + const runShellCommand = (command: string) => { + void runProjectScript( + { + id: "chat-code-block", + name: "Chat code block", + command, + icon: "play", + runOnWorktreeCreate: false, + }, + { rememberAsLastInvoked: false, shellHistory: "preserve" }, + ); + }; + const runShellCommandStable = useStableCallback(runShellCommand); + const addTerminalSurface = () => { + if (!activeThreadRef) return; + const launched = terminalActions.launchTerminal({ + place: (terminalId) => + useRightPanelStore.getState().openTerminal(activeThreadRef, terminalId), + }); + if (!launched) return; + setTerminalFocusRequestId((value) => value + 1); + void launched.result; + }; + const addTerminalSurfaceStable = useStableCallback(addTerminalSurface); + const splitPanelTerminal = (direction: "horizontal" | "vertical" = "horizontal") => { + if ( + !activeThreadRef || + activeRightPanelSurface?.kind !== "terminal" || + activeRightPanelSurface.terminalIds.length >= MAX_TERMINALS_PER_GROUP + ) { + return; + } + const surfaceId = activeRightPanelSurface.id; + const launched = terminalActions.launchTerminal({ + place: (terminalId) => + useRightPanelStore + .getState() + .splitTerminal(activeThreadRef, surfaceId, terminalId, direction), + }); + if (!launched) return; + setTerminalFocusRequestId((value) => value + 1); + void launched.result; + }; + const splitPanelTerminalStable = useStableCallback(splitPanelTerminal); + const splitPanelTerminalVertical = () => { + splitPanelTerminal("vertical"); + }; + const splitPanelTerminalVerticalStable = useStableCallback(splitPanelTerminalVertical); + const activatePanelTerminal = (terminalId: string) => { + if (!activeThreadRef || activeRightPanelSurface?.kind !== "terminal") return; + useRightPanelStore + .getState() + .activateTerminal(activeThreadRef, activeRightPanelSurface.id, terminalId); + setTerminalFocusRequestId((value) => value + 1); + }; + const activatePanelTerminalStable = useStableCallback(activatePanelTerminal); + const closePanelTerminal = (terminalId: string) => { + if ( + !hasTerminalWriteAccess() || + !activeThreadRef || + activeRightPanelSurface?.kind !== "terminal" + ) + return; + terminalActions.closeTerminalSession(terminalId); + storeCloseTerminal(activeThreadRef, terminalId); + useRightPanelStore + .getState() + .closeTerminal(activeThreadRef, activeRightPanelSurface.id, terminalId); + setTerminalFocusRequestId((value) => value + 1); + }; + const closePanelTerminalStable = useStableCallback(closePanelTerminal); + const requestCloseTerminal = (terminalId: string) => { + if (!hasTerminalWriteAccess()) return; + const label = activeTerminalLabelsById.get(terminalId) ?? getTerminalLabel(terminalId); + void confirmTerminalClose([label]).then((confirmed) => { + if (confirmed && readEnvironmentScope(environmentId, AuthTerminalOperateScope)) { + closeTerminal(terminalId); + } + }); + }; + const requestCloseTerminalStable = useStableCallback(requestCloseTerminal); + const requestClosePanelTerminal = (terminalId: string) => { + if (!hasTerminalWriteAccess()) return; + const label = activeTerminalLabelsById.get(terminalId) ?? getTerminalLabel(terminalId); + void confirmTerminalClose([label]).then((confirmed) => { + if (confirmed && readEnvironmentScope(environmentId, AuthTerminalOperateScope)) { + closePanelTerminal(terminalId); + } + }); + }; + const requestClosePanelTerminalStable = useStableCallback(requestClosePanelTerminal); + return { + activatePanelTerminalStable, + addTerminalContextToDraftStable, + addTerminalSurfaceStable, + closePanelTerminalStable, + createNewTerminalStable, + lastInvokedScriptByProjectId, + requestClosePanelTerminalStable, + requestCloseTerminalStable, + runProjectScriptStable, + runShellCommandStable, + setTerminalOpenStable, + splitPanelTerminalStable, + splitPanelTerminalVerticalStable, + splitTerminalStable, + toggleTerminalVisibilityStable, + }; +} ```