import { type ScopedThreadRef } from "@t3tools/contracts"; import type { GitActionProgressEvent, GitRunStackedActionResult, GitStackedAction, SourceControlCloneProtocol, SourceControlProviderDiscoveryItem, SourceControlProviderKind, SourceControlPublishRepositoryResult, SourceControlRepositoryVisibility, VcsStatusResult, } from "@t3tools/contracts"; import { useIsMutating, useMutation, useQueryClient } from "@tanstack/react-query"; import { useNavigate } from "@tanstack/react-router"; import * as Option from "effect/Option"; import { useCallback, useEffect, useEffectEvent, useMemo, useRef, useState } from "react"; import { flushSync } from "react-dom"; import { CheckIcon, ChevronDownIcon, CloudUploadIcon, ExternalLinkIcon, GitCommitIcon, InfoIcon, LockIcon, GlobeIcon, } from "lucide-react"; import { Radio as RadioPrimitive } from "@base-ui/react/radio"; import { AzureDevOpsIcon, BitbucketIcon, GitHubIcon, GitLabIcon } from "~/components/Icons"; import { RadioGroup } from "~/components/ui/radio-group"; import { Spinner } from "~/components/ui/spinner"; import { cn } from "~/lib/utils"; import { buildGitActionProgressStages, buildMenuItems, type GitActionIconName, type GitActionMenuItem, type GitQuickAction, type DefaultBranchConfirmableAction, requiresDefaultBranchConfirmation, resolveDefaultBranchActionDialogCopy, resolveLiveThreadBranchUpdate, resolveQuickAction, resolveThreadBranchUpdate, } from "./GitActionsControl.logic"; import { AnimatedHeight } from "./AnimatedHeight"; import { Button } from "~/components/ui/button"; import { Checkbox } from "~/components/ui/checkbox"; import { Dialog, DialogDescription, DialogFooter, DialogHeader, DialogPanel, DialogPopup, DialogTitle, } from "~/components/ui/dialog"; import { Group, GroupSeparator } from "~/components/ui/group"; import { Input } from "~/components/ui/input"; import { Menu, MenuItem, MenuPopup, MenuTrigger } from "~/components/ui/menu"; import { Popover, PopoverPopup, PopoverTrigger } from "~/components/ui/popover"; import { ScrollArea } from "~/components/ui/scroll-area"; import { Textarea } from "~/components/ui/textarea"; import { stackedThreadToast, toastManager, type ThreadToastData } from "~/components/ui/toast"; import { Tooltip, TooltipPopup, TooltipTrigger } from "~/components/ui/tooltip"; import { openInPreferredEditor } from "~/editorPreferences"; import { gitInitMutationOptions, gitMutationKeys, gitPullMutationOptions, gitRunStackedActionMutationOptions, sourceControlPublishRepositoryMutationOptions, } from "~/lib/gitReactQuery"; import { refreshGitStatus, useGitStatus } from "~/lib/gitStatusState"; import { useSourceControlDiscovery } from "~/lib/sourceControlDiscoveryState"; import { newCommandId, randomUUID } from "~/lib/utils"; import { resolvePathLinkTarget } from "~/terminal-links"; import { type DraftId, useComposerDraftStore } from "~/composerDraftStore"; import { readEnvironmentApi } from "~/environmentApi"; import { readLocalApi } from "~/localApi"; import { getSourceControlPresentation } from "~/sourceControlPresentation"; import { useStore } from "~/store"; import { createThreadSelectorByRef } from "~/storeSelectors"; interface GitActionsControlProps { gitCwd: string | null; activeThreadRef: ScopedThreadRef | null; draftId?: DraftId; } interface PendingDefaultBranchAction { action: DefaultBranchConfirmableAction; branchName: string; includesCommit: boolean; commitMessage?: string; onConfirmed?: () => void; filePaths?: string[]; } type PublishProviderKind = Extract< SourceControlProviderKind, "github" | "gitlab" | "bitbucket" | "azure-devops" >; type GitActionToastId = ReturnType; interface ActiveGitActionProgress { toastId: GitActionToastId; toastData: ThreadToastData | undefined; actionId: string; title: string; phaseStartedAtMs: number | null; hookStartedAtMs: number | null; hookName: string | null; lastOutputLine: string | null; currentPhaseLabel: string | null; } interface RunGitActionWithToastInput { action: GitStackedAction; commitMessage?: string; onConfirmed?: () => void; skipDefaultBranchPrompt?: boolean; statusOverride?: VcsStatusResult | null; featureBranch?: boolean; progressToastId?: GitActionToastId; filePaths?: string[]; } const GIT_STATUS_WINDOW_REFRESH_DEBOUNCE_MS = 250; const PUBLISH_PROVIDER_OPTIONS = [ { value: "github", label: "GitHub", description: "github.com", host: "github.com", pathPlaceholder: "owner/repo", Icon: GitHubIcon, }, { value: "gitlab", label: "GitLab", description: "gitlab.com", host: "gitlab.com", pathPlaceholder: "group/project", Icon: GitLabIcon, }, { value: "bitbucket", label: "Bitbucket", description: "bitbucket.org", host: "bitbucket.org", pathPlaceholder: "workspace/repository", Icon: BitbucketIcon, }, { value: "azure-devops", label: "Azure DevOps", description: "dev.azure.com", host: "dev.azure.com", pathPlaceholder: "project/repository", Icon: AzureDevOpsIcon, }, ] as const satisfies ReadonlyArray<{ readonly value: PublishProviderKind; readonly label: string; readonly description: string; readonly host: string; readonly pathPlaceholder: string; readonly Icon: typeof GitHubIcon; }>; function publishProviderOption(provider: PublishProviderKind) { return ( PUBLISH_PROVIDER_OPTIONS.find((option) => option.value === provider) ?? PUBLISH_PROVIDER_OPTIONS[0] ); } function isPublishProviderKind( provider: SourceControlProviderKind, ): provider is PublishProviderKind { return PUBLISH_PROVIDER_OPTIONS.some((option) => option.value === provider); } function getPublishProviderReadiness(input: { provider: PublishProviderKind; sourceControlProviders: ReadonlyArray; }): { readonly ready: boolean; readonly hint: string | null } { const discovered = input.sourceControlProviders.find( (provider) => provider.kind === input.provider, ); if (!discovered) { return { ready: false, hint: "Provider status unavailable. Open Settings -> Source Control and rescan.", }; } if (discovered.status !== "available") { return { ready: false, hint: discovered.installHint }; } if (discovered.auth.status === "unauthenticated") { return { ready: false, hint: Option.getOrNull(discovered.auth.detail) ?? `${discovered.label} is not authenticated. Open Settings -> Source Control for setup guidance.`, }; } return { ready: true, hint: null }; } function formatElapsedDescription(startedAtMs: number | null): string | undefined { if (startedAtMs === null) { return undefined; } const elapsedSeconds = Math.max(0, Math.floor((Date.now() - startedAtMs) / 1000)); if (elapsedSeconds < 60) { return `Running for ${elapsedSeconds}s`; } const minutes = Math.floor(elapsedSeconds / 60); const seconds = elapsedSeconds % 60; return `Running for ${minutes}m ${seconds}s`; } function resolveProgressDescription(progress: ActiveGitActionProgress): string | undefined { if (progress.lastOutputLine) { return progress.lastOutputLine; } return formatElapsedDescription(progress.hookStartedAtMs ?? progress.phaseStartedAtMs); } function getMenuActionDisabledReason({ item, gitStatus, isBusy, hasPrimaryRemote, }: { item: GitActionMenuItem; gitStatus: VcsStatusResult | null; isBusy: boolean; hasPrimaryRemote: boolean; }): string | null { if (!item.disabled) return null; if (isBusy) return "Git action in progress."; if (!gitStatus) return "Git status is unavailable."; const hasBranch = gitStatus.refName !== null; const hasChanges = gitStatus.hasWorkingTreeChanges; const hasOpenPr = gitStatus.pr?.state === "open"; const isAhead = gitStatus.aheadCount > 0; const isBehind = gitStatus.behindCount > 0; const terminology = getSourceControlPresentation(gitStatus.sourceControlProvider).terminology; if (item.id === "commit") { if (!hasChanges) { return "Worktree is clean. Make changes before committing."; } return "Commit is currently unavailable."; } if (item.id === "push") { if (!hasBranch) { return "Detached HEAD: checkout a refName before pushing."; } if (hasChanges) { return "Commit or stash local changes before pushing."; } if (isBehind) { return "Branch is behind upstream. Pull/rebase before pushing."; } if (!gitStatus.hasUpstream && !hasPrimaryRemote) { return 'Add an "origin" remote before pushing.'; } if (!isAhead) { return "No local commits to push."; } return "Push is currently unavailable."; } if (hasOpenPr) { return `View ${terminology.singular} is currently unavailable.`; } if (!hasBranch) { return `Detached HEAD: checkout a refName before creating a ${terminology.singular}.`; } if (hasChanges) { return `Commit local changes before creating a ${terminology.singular}.`; } if (!gitStatus.hasUpstream && !hasPrimaryRemote) { return `Add an "origin" remote before creating a ${terminology.singular}.`; } if (!isAhead) { return `No local commits to include in a ${terminology.singular}.`; } if (isBehind) { return `Branch is behind upstream. Pull/rebase before creating a ${terminology.singular}.`; } return `Create ${terminology.singular} is currently unavailable.`; } const COMMIT_DIALOG_TITLE = "Commit changes"; const COMMIT_DIALOG_DESCRIPTION = "Review and confirm your commit. Leave the message blank to auto-generate one."; function GitActionItemIcon({ icon, SourceControlIcon, }: { icon: GitActionIconName; SourceControlIcon: ReturnType["Icon"]; }) { if (icon === "commit") return ; if (icon === "push") return ; return ; } function GitQuickActionIcon({ quickAction, SourceControlIcon, }: { quickAction: GitQuickAction; SourceControlIcon: ReturnType["Icon"]; }) { const iconClassName = "size-3.5"; if (quickAction.kind === "open_pr") return ; if (quickAction.kind === "open_publish") return ; if (quickAction.kind === "run_pull") return ; if (quickAction.kind === "run_action") { if (quickAction.action === "commit") return ; if (quickAction.action === "push" || quickAction.action === "commit_push") { return ; } return ; } if (quickAction.label === "Commit") return ; return ; } interface PublishRepositoryDialogProps { readonly open: boolean; readonly onOpenChange: (open: boolean) => void; readonly environmentId: ScopedThreadRef["environmentId"] | null; readonly gitCwd: string; } function PublishRepositoryDialog(props: PublishRepositoryDialogProps) { const queryClient = useQueryClient(); const navigate = useNavigate(); const sourceControlDiscovery = useSourceControlDiscovery(); const [publishProvider, setPublishProvider] = useState("github"); const [publishRepository, setPublishRepository] = useState(""); const [publishVisibility, setPublishVisibility] = useState("private"); const [publishRemoteName, setPublishRemoteName] = useState("origin"); const [publishProtocol, setPublishProtocol] = useState("ssh"); const [publishWizardStep, setPublishWizardStep] = useState(0); const [publishAdvancedOpen, setPublishAdvancedOpen] = useState(false); const [publishError, setPublishError] = useState(null); const [publishResult, setPublishResult] = useState( null, ); const [hasUserEditedPublishRepository, setHasUserEditedPublishRepository] = useState(false); const publishRepositoryMutation = useMutation( sourceControlPublishRepositoryMutationOptions({ environmentId: props.environmentId, cwd: props.gitCwd, queryClient, }), ); const publishAccountByProvider = useMemo(() => { const accounts: Record = { github: null, gitlab: null, bitbucket: null, "azure-devops": null, }; for (const provider of sourceControlDiscovery.data?.sourceControlProviders ?? []) { if (isPublishProviderKind(provider.kind)) { accounts[provider.kind] = Option.getOrNull(provider.auth.account); } } return accounts; }, [sourceControlDiscovery.data]); const publishProviderReadiness = useMemo(() => { const sourceControlProviders = sourceControlDiscovery.data?.sourceControlProviders ?? []; return Object.fromEntries( PUBLISH_PROVIDER_OPTIONS.map((option) => [ option.value, getPublishProviderReadiness({ provider: option.value, sourceControlProviders, }), ]), ) as Record; }, [sourceControlDiscovery.data]); const hasReadyPublishProvider = useMemo( () => PUBLISH_PROVIDER_OPTIONS.some((option) => publishProviderReadiness[option.value].ready), [publishProviderReadiness], ); const sortedPublishProviderOptions = useMemo( () => PUBLISH_PROVIDER_OPTIONS.toSorted((left, right) => { const leftReady = publishProviderReadiness[left.value].ready; const rightReady = publishProviderReadiness[right.value].ready; if (leftReady !== rightReady) { return leftReady ? -1 : 1; } return left.label.localeCompare(right.label); }), [publishProviderReadiness], ); const selectedPublishProviderReadiness = publishProviderReadiness[publishProvider]; const publishRepositoryPrefill = publishAccountByProvider[publishProvider] ? `${publishAccountByProvider[publishProvider]}/` : ""; const currentPublishProvider = publishProviderOption(publishProvider); const publishHost = currentPublishProvider.host; const publishPathPlaceholder = currentPublishProvider.pathPlaceholder; const publishProviderLabel = currentPublishProvider.label; const publishWizardSteps = ["Provider", "Repository", "Summary"] as const; const publishWizardStepSummaries = [ publishProviderLabel, publishResult?.repository.nameWithOwner ?? null, null, ] as const; useEffect(() => { if (!props.open || hasUserEditedPublishRepository) { return; } setPublishRepository(publishRepositoryPrefill); }, [hasUserEditedPublishRepository, props.open, publishRepositoryPrefill]); const canSubmitPublishRepository = useMemo(() => { if (!selectedPublishProviderReadiness.ready) return false; if (publishRepositoryMutation.isPending) return false; const repositoryParts = publishRepository.trim().split("/"); const owner = repositoryParts[0]?.trim() ?? ""; const rest = repositoryParts.slice(1); const name = rest.join("/").trim(); return owner.length > 0 && name.length > 0; }, [publishRepository, publishRepositoryMutation.isPending, selectedPublishProviderReadiness]); useEffect(() => { if (!props.open) { return; } if (publishProviderReadiness[publishProvider].ready) { return; } const firstReadyProvider = PUBLISH_PROVIDER_OPTIONS.find( (option) => publishProviderReadiness[option.value].ready, ); if (firstReadyProvider) { setPublishProvider(firstReadyProvider.value); } }, [props.open, publishProvider, publishProviderReadiness]); const submitPublishRepository = useCallback(() => { if (!canSubmitPublishRepository) { return; } setPublishError(null); void publishRepositoryMutation .mutateAsync({ provider: publishProvider, repository: publishRepository.trim(), visibility: publishVisibility, remoteName: publishRemoteName.trim() || "origin", protocol: publishProtocol, }) .then((result) => { flushSync(() => { setPublishResult(result); setPublishWizardStep(2); }); void refreshGitStatus({ environmentId: props.environmentId, cwd: props.gitCwd }).catch( () => undefined, ); }) .catch((err: unknown) => { setPublishError(err instanceof Error ? err.message : "An error occurred."); }); }, [ canSubmitPublishRepository, props.environmentId, props.gitCwd, publishProtocol, publishProvider, publishRemoteName, publishRepository, publishRepositoryMutation, publishVisibility, ]); const resetState = useCallback(() => { setPublishRemoteName("origin"); setPublishRepository(""); setHasUserEditedPublishRepository(false); setPublishWizardStep(0); setPublishAdvancedOpen(false); setPublishError(null); setPublishResult(null); }, []); const handleOpenChange = useCallback( (open: boolean) => { props.onOpenChange(open); if (!open) { resetState(); } }, [props, resetState], ); const openSourceControlSettings = useCallback(() => { handleOpenChange(false); void navigate({ to: "/settings/source-control" }); }, [handleOpenChange, navigate]); return (
Publish repository Pick where to host it, then point us at a repo to push to.
{publishWizardSteps.map((label, index) => { const isComplete = index < publishWizardStep; const isClickable = publishWizardStep !== 2 && index < publishWizardSteps.length - 1 && index <= publishWizardStep; return ( ); })}
Provider setPublishProvider(value as PublishProviderKind)} aria-labelledby="publish-provider-cards-label" className="grid grid-cols-2 gap-2.5" > {sortedPublishProviderOptions.map((option) => { const readiness = publishProviderReadiness[option.value]; const isSelected = publishProvider === option.value && readiness.ready; if (!readiness.ready) { return (
{option.label} { event.preventDefault(); event.stopPropagation(); openSourceControlSettings(); }} > Setup Required } /> {readiness.hint ?? "Open Settings -> Source Control to configure this provider."}
); } return ( {option.label} ); })}
{publishHost}/ { setPublishRepository(event.target.value); setHasUserEditedPublishRepository(true); }} onKeyDown={(event) => { if (event.key === "Enter") { event.preventDefault(); submitPublishRepository(); } }} placeholder={publishPathPlaceholder} disabled={publishRepositoryMutation.isPending} className="w-full bg-transparent px-3 py-2 font-mono text-sm placeholder:text-muted-foreground/60 focus:outline-none" />
Visibility setPublishVisibility(value as SourceControlRepositoryVisibility) } aria-labelledby="publish-visibility-cards-label" disabled={publishRepositoryMutation.isPending} className="grid grid-cols-2 gap-2.5" > {[ { value: "private" as const, label: "Private", description: "Only invited people", Icon: LockIcon, }, { value: "public" as const, label: "Public", description: "Anyone on the web", Icon: GlobeIcon, }, ].map((option) => { const isSelected = publishVisibility === option.value; return ( {option.label} {option.description} ); })}
{publishAdvancedOpen ? (
Protocol setPublishProtocol(value as SourceControlCloneProtocol) } aria-labelledby="publish-protocol-label" disabled={publishRepositoryMutation.isPending} className="grid grid-cols-2 gap-2" > {(["ssh", "https"] as const).map((value) => { const isSelected = publishProtocol === value; return ( {value === "ssh" ? "SSH" : "HTTPS"} ); })}
) : null}
{publishRepositoryMutation.isPending ? (
Publishing repository to {publishProviderLabel}...
) : null} {publishError && !publishRepositoryMutation.isPending ? (

Publish failed

{publishError}

) : null}
{publishResult ? ( <>

{publishResult.status === "pushed" ? "Repository published" : "Repository created"}

{publishResult.status === "pushed" ? `${publishResult.branch} is now live on ${publishProviderLabel}.` : `Remote "${publishResult.remoteName}" is set up. Make a commit and push it to share your code.`}

{publishResult.repository.nameWithOwner}
) : (
Publish result unavailable.
)}
{publishWizardStep === 2 ? ( ) : ( <> {publishWizardStep < 1 ? ( ) : ( )} )}
); } export default function GitActionsControl({ gitCwd, activeThreadRef, draftId, }: GitActionsControlProps) { const activeEnvironmentId = activeThreadRef?.environmentId ?? null; const threadToastData = useMemo( () => (activeThreadRef ? { threadRef: activeThreadRef } : undefined), [activeThreadRef], ); const activeServerThreadSelector = useMemo( () => createThreadSelectorByRef(activeThreadRef), [activeThreadRef], ); const activeServerThread = useStore(activeServerThreadSelector); const activeDraftThread = useComposerDraftStore((store) => draftId ? store.getDraftSession(draftId) : activeThreadRef ? store.getDraftThreadByRef(activeThreadRef) : null, ); const setDraftThreadContext = useComposerDraftStore((store) => store.setDraftThreadContext); const setThreadBranch = useStore((store) => store.setThreadBranch); const queryClient = useQueryClient(); const [isCommitDialogOpen, setIsCommitDialogOpen] = useState(false); const [dialogCommitMessage, setDialogCommitMessage] = useState(""); const [excludedFiles, setExcludedFiles] = useState>(new Set()); const [isEditingFiles, setIsEditingFiles] = useState(false); const [isPublishDialogOpen, setIsPublishDialogOpen] = useState(false); const [pendingDefaultBranchAction, setPendingDefaultBranchAction] = useState(null); const activeGitActionProgressRef = useRef(null); let runGitActionWithToast: (input: RunGitActionWithToastInput) => Promise; const updateActiveProgressToast = useCallback(() => { const progress = activeGitActionProgressRef.current; if (!progress) { return; } toastManager.update(progress.toastId, { type: "loading", title: progress.title, description: resolveProgressDescription(progress), timeout: 0, data: progress.toastData, }); }, []); const persistThreadBranchSync = useCallback( (branch: string | null) => { if (!activeThreadRef) { return; } if (activeServerThread) { if (activeServerThread.branch === branch) { return; } const worktreePath = activeServerThread.worktreePath; const api = readEnvironmentApi(activeThreadRef.environmentId); if (api) { void api.orchestration .dispatchCommand({ type: "thread.meta.update", commandId: newCommandId(), threadId: activeThreadRef.threadId, branch, worktreePath, }) .catch(() => undefined); } setThreadBranch(activeThreadRef, branch, worktreePath); return; } if (!activeDraftThread || activeDraftThread.branch === branch) { return; } setDraftThreadContext(draftId ?? activeThreadRef, { branch, worktreePath: activeDraftThread.worktreePath, }); }, [ activeDraftThread, activeServerThread, activeThreadRef, draftId, setDraftThreadContext, setThreadBranch, ], ); const syncThreadBranchAfterGitAction = useCallback( (result: GitRunStackedActionResult) => { const branchUpdate = resolveThreadBranchUpdate(result); if (!branchUpdate) { return; } persistThreadBranchSync(branchUpdate.branch); }, [persistThreadBranchSync], ); const { data: gitStatus = null, error: gitStatusError } = useGitStatus({ environmentId: activeEnvironmentId, cwd: gitCwd, }); const sourceControlPresentation = useMemo( () => getSourceControlPresentation(gitStatus?.sourceControlProvider), [gitStatus?.sourceControlProvider], ); const changeRequestTerminology = sourceControlPresentation.terminology; const SourceControlIcon = sourceControlPresentation.Icon; // Default to true while loading so we don't flash init controls. const isRepo = gitStatus?.isRepo ?? true; const hasPrimaryRemote = gitStatus?.hasPrimaryRemote ?? false; const gitStatusForActions = gitStatus; const allFiles = gitStatusForActions?.workingTree.files ?? []; const selectedFiles = allFiles.filter((f) => !excludedFiles.has(f.path)); const allSelected = excludedFiles.size === 0; const noneSelected = selectedFiles.length === 0; const initMutation = useMutation( gitInitMutationOptions({ environmentId: activeEnvironmentId, cwd: gitCwd, queryClient }), ); const runImmediateGitActionMutation = useMutation( gitRunStackedActionMutationOptions({ environmentId: activeEnvironmentId, cwd: gitCwd, queryClient, }), ); const pullMutation = useMutation( gitPullMutationOptions({ environmentId: activeEnvironmentId, cwd: gitCwd, queryClient }), ); const isRunStackedActionRunning = useIsMutating({ mutationKey: gitMutationKeys.runStackedAction(activeEnvironmentId, gitCwd), }) > 0; const isPullRunning = useIsMutating({ mutationKey: gitMutationKeys.pull(activeEnvironmentId, gitCwd) }) > 0; const isPublishRunning = useIsMutating({ mutationKey: gitMutationKeys.publishRepository(activeEnvironmentId, gitCwd), }) > 0; const isGitActionRunning = isRunStackedActionRunning || isPullRunning || isPublishRunning; const isSelectingWorktreeBase = !activeServerThread && activeDraftThread?.envMode === "worktree" && activeDraftThread.worktreePath === null; useEffect(() => { if (isGitActionRunning || isSelectingWorktreeBase) { return; } const branchUpdate = resolveLiveThreadBranchUpdate({ threadBranch: activeServerThread?.branch ?? activeDraftThread?.branch ?? null, gitStatus: gitStatusForActions, }); if (!branchUpdate) { return; } persistThreadBranchSync(branchUpdate.branch); }, [ activeServerThread?.branch, activeDraftThread?.branch, gitStatusForActions, isGitActionRunning, isSelectingWorktreeBase, persistThreadBranchSync, ]); const isDefaultRef = useMemo(() => { return gitStatusForActions?.isDefaultRef ?? false; }, [gitStatusForActions?.isDefaultRef]); const gitActionMenuItems = useMemo( () => buildMenuItems(gitStatusForActions, isGitActionRunning, hasPrimaryRemote), [gitStatusForActions, hasPrimaryRemote, isGitActionRunning], ); const quickAction = useMemo( () => resolveQuickAction(gitStatusForActions, isGitActionRunning, isDefaultRef, hasPrimaryRemote), [gitStatusForActions, hasPrimaryRemote, isDefaultRef, isGitActionRunning], ); const quickActionDisabledReason = quickAction.disabled ? (quickAction.hint ?? "This action is currently unavailable.") : null; const pendingDefaultBranchActionCopy = pendingDefaultBranchAction ? resolveDefaultBranchActionDialogCopy({ action: pendingDefaultBranchAction.action, branchName: pendingDefaultBranchAction.branchName, includesCommit: pendingDefaultBranchAction.includesCommit, terminology: changeRequestTerminology, }) : null; useEffect(() => { const interval = window.setInterval(() => { if (!activeGitActionProgressRef.current) { return; } updateActiveProgressToast(); }, 1000); return () => { window.clearInterval(interval); }; }, [updateActiveProgressToast]); useEffect(() => { if (gitCwd === null) { return; } let refreshTimeout: number | null = null; const scheduleRefreshCurrentGitStatus = () => { if (refreshTimeout !== null) { window.clearTimeout(refreshTimeout); } refreshTimeout = window.setTimeout(() => { refreshTimeout = null; void refreshGitStatus({ environmentId: activeEnvironmentId, cwd: gitCwd }).catch( () => undefined, ); }, GIT_STATUS_WINDOW_REFRESH_DEBOUNCE_MS); }; const handleVisibilityChange = () => { if (document.visibilityState === "visible") { scheduleRefreshCurrentGitStatus(); } }; window.addEventListener("focus", scheduleRefreshCurrentGitStatus); document.addEventListener("visibilitychange", handleVisibilityChange); return () => { if (refreshTimeout !== null) { window.clearTimeout(refreshTimeout); } window.removeEventListener("focus", scheduleRefreshCurrentGitStatus); document.removeEventListener("visibilitychange", handleVisibilityChange); }; }, [activeEnvironmentId, gitCwd]); const openExistingPr = useCallback(async () => { const api = readLocalApi(); if (!api) { toastManager.add({ type: "error", title: "Link opening is unavailable.", data: threadToastData, }); return; } const prUrl = gitStatusForActions?.pr?.state === "open" ? gitStatusForActions.pr.url : null; if (!prUrl) { toastManager.add({ type: "error", title: "No open pull request found.", data: threadToastData, }); return; } void api.shell.openExternal(prUrl).catch((err: unknown) => { toastManager.add( stackedThreadToast({ type: "error", title: "Unable to open pull request link", description: err instanceof Error ? err.message : "An error occurred.", ...(threadToastData !== undefined ? { data: threadToastData } : {}), }), ); }); }, [gitStatusForActions, threadToastData]); runGitActionWithToast = useEffectEvent( async ({ action, commitMessage, onConfirmed, skipDefaultBranchPrompt = false, statusOverride, featureBranch = false, progressToastId, filePaths, }: RunGitActionWithToastInput) => { const actionStatus = statusOverride ?? gitStatusForActions; const actionBranch = actionStatus?.refName ?? null; const actionIsDefaultBranch = featureBranch ? false : isDefaultRef; const actionCanCommit = action === "commit" || action === "commit_push" || action === "commit_push_pr"; const includesCommit = actionCanCommit && (action === "commit" || !!actionStatus?.hasWorkingTreeChanges || featureBranch); if ( !skipDefaultBranchPrompt && requiresDefaultBranchConfirmation(action, actionIsDefaultBranch) && actionBranch ) { if ( action !== "push" && action !== "create_pr" && action !== "commit_push" && action !== "commit_push_pr" ) { return; } setPendingDefaultBranchAction({ action, branchName: actionBranch, includesCommit, ...(commitMessage ? { commitMessage } : {}), ...(onConfirmed ? { onConfirmed } : {}), ...(filePaths ? { filePaths } : {}), }); return; } onConfirmed?.(); const progressStages = buildGitActionProgressStages({ action, hasCustomCommitMessage: !!commitMessage?.trim(), hasWorkingTreeChanges: !!actionStatus?.hasWorkingTreeChanges, featureBranch, terminology: changeRequestTerminology, shouldPushBeforePr: action === "create_pr" && (!actionStatus?.hasUpstream || (actionStatus?.aheadCount ?? 0) > 0), }); const scopedToastData = threadToastData ? { ...threadToastData } : undefined; const actionId = randomUUID(); const resolvedProgressToastId = progressToastId ?? toastManager.add({ type: "loading", title: progressStages[0] ?? "Running git action...", description: "Waiting for Git...", timeout: 0, data: scopedToastData, }); activeGitActionProgressRef.current = { toastId: resolvedProgressToastId, toastData: scopedToastData, actionId, title: progressStages[0] ?? "Running git action...", phaseStartedAtMs: null, hookStartedAtMs: null, hookName: null, lastOutputLine: null, currentPhaseLabel: progressStages[0] ?? "Running git action...", }; if (progressToastId) { toastManager.update(progressToastId, { type: "loading", title: progressStages[0] ?? "Running git action...", description: "Waiting for Git...", timeout: 0, data: scopedToastData, }); } const applyProgressEvent = (event: GitActionProgressEvent) => { const progress = activeGitActionProgressRef.current; if (!progress) { return; } if (gitCwd && event.cwd !== gitCwd) { return; } if (progress.actionId !== event.actionId) { return; } const now = Date.now(); switch (event.kind) { case "action_started": progress.phaseStartedAtMs = now; progress.hookStartedAtMs = null; progress.hookName = null; progress.lastOutputLine = null; break; case "phase_started": progress.title = event.label; progress.currentPhaseLabel = event.label; progress.phaseStartedAtMs = now; progress.hookStartedAtMs = null; progress.hookName = null; progress.lastOutputLine = null; break; case "hook_started": progress.title = `Running ${event.hookName}...`; progress.hookName = event.hookName; progress.hookStartedAtMs = now; progress.lastOutputLine = null; break; case "hook_output": progress.lastOutputLine = event.text; break; case "hook_finished": progress.title = progress.currentPhaseLabel ?? "Committing..."; progress.hookName = null; progress.hookStartedAtMs = null; progress.lastOutputLine = null; break; case "action_finished": // Let the resolved mutation update the toast so we keep the // elapsed description visible until the final success state renders. return; case "action_failed": // Let the rejected mutation publish the error toast to avoid a // transient intermediate state before the final failure message. return; } updateActiveProgressToast(); }; const promise = runImmediateGitActionMutation.mutateAsync({ actionId, action, ...(commitMessage ? { commitMessage } : {}), ...(featureBranch ? { featureBranch } : {}), ...(filePaths ? { filePaths } : {}), onProgress: applyProgressEvent, }); try { const result = await promise; activeGitActionProgressRef.current = null; syncThreadBranchAfterGitAction(result); const closeResultToast = () => { toastManager.close(resolvedProgressToastId); }; const toastCta = result.toast.cta; let toastActionProps: { children: string; onClick: () => void; } | null = null; if (toastCta.kind === "run_action") { toastActionProps = { children: toastCta.label, onClick: () => { closeResultToast(); void runGitActionWithToast({ action: toastCta.action.kind, }); }, }; } else if (toastCta.kind === "open_pr") { toastActionProps = { children: toastCta.label, onClick: () => { const api = readLocalApi(); if (!api) return; closeResultToast(); void api.shell.openExternal(toastCta.url); }, }; } const successToastData = { ...scopedToastData, dismissAfterVisibleMs: 10_000, }; if (toastActionProps) { toastManager.update( resolvedProgressToastId, stackedThreadToast({ type: "success", title: result.toast.title, description: result.toast.description, timeout: 0, actionProps: toastActionProps, data: successToastData, }), ); } else { toastManager.update(resolvedProgressToastId, { type: "success", title: result.toast.title, description: result.toast.description, timeout: 0, data: successToastData, }); } } catch (err) { activeGitActionProgressRef.current = null; toastManager.update( resolvedProgressToastId, stackedThreadToast({ type: "error", title: "Action failed", description: err instanceof Error ? err.message : "An error occurred.", ...(scopedToastData !== undefined ? { data: scopedToastData } : {}), }), ); } }, ); const continuePendingDefaultBranchAction = () => { if (!pendingDefaultBranchAction) return; const { action, commitMessage, onConfirmed, filePaths } = pendingDefaultBranchAction; setPendingDefaultBranchAction(null); void runGitActionWithToast({ action, ...(commitMessage ? { commitMessage } : {}), ...(onConfirmed ? { onConfirmed } : {}), ...(filePaths ? { filePaths } : {}), skipDefaultBranchPrompt: true, }); }; const checkoutFeatureBranchAndContinuePendingAction = () => { if (!pendingDefaultBranchAction) return; const { action, commitMessage, onConfirmed, filePaths } = pendingDefaultBranchAction; setPendingDefaultBranchAction(null); void runGitActionWithToast({ action, ...(commitMessage ? { commitMessage } : {}), ...(onConfirmed ? { onConfirmed } : {}), ...(filePaths ? { filePaths } : {}), featureBranch: true, skipDefaultBranchPrompt: true, }); }; const runDialogActionOnNewBranch = () => { if (!isCommitDialogOpen) return; const commitMessage = dialogCommitMessage.trim(); setIsCommitDialogOpen(false); setDialogCommitMessage(""); setExcludedFiles(new Set()); setIsEditingFiles(false); void runGitActionWithToast({ action: "commit", ...(commitMessage ? { commitMessage } : {}), ...(!allSelected ? { filePaths: selectedFiles.map((f) => f.path) } : {}), featureBranch: true, skipDefaultBranchPrompt: true, }); }; const runQuickAction = () => { if (quickAction.kind === "open_pr") { void openExistingPr(); return; } if (quickAction.kind === "open_publish") { setIsPublishDialogOpen(true); return; } if (quickAction.kind === "run_pull") { const promise = pullMutation.mutateAsync(); void toastManager.promise< Awaited>, ThreadToastData >(promise, { loading: { title: "Pulling...", data: threadToastData }, success: (result) => ({ title: result.status === "pulled" ? "Pulled" : "Already up to date", description: result.status === "pulled" ? `Updated ${result.refName} from ${result.upstreamRef ?? "upstream"}` : `${result.refName} is already synchronized.`, data: threadToastData, }), error: (err) => ({ title: "Pull failed", description: err instanceof Error ? err.message : "An error occurred.", data: threadToastData, }), }); void promise.catch(() => undefined); return; } if (quickAction.kind === "show_hint") { toastManager.add({ type: "info", title: quickAction.label, description: quickAction.hint, data: threadToastData, }); return; } if (quickAction.action) { void runGitActionWithToast({ action: quickAction.action }); } }; const openDialogForMenuItem = (item: GitActionMenuItem) => { if (item.disabled) return; if (item.kind === "open_pr") { void openExistingPr(); return; } if (item.dialogAction === "push") { void runGitActionWithToast({ action: "push" }); return; } if (item.dialogAction === "create_pr") { void runGitActionWithToast({ action: "create_pr" }); return; } setExcludedFiles(new Set()); setIsEditingFiles(false); setIsCommitDialogOpen(true); }; const runDialogAction = () => { if (!isCommitDialogOpen) return; const commitMessage = dialogCommitMessage.trim(); setIsCommitDialogOpen(false); setDialogCommitMessage(""); setExcludedFiles(new Set()); setIsEditingFiles(false); void runGitActionWithToast({ action: "commit", ...(commitMessage ? { commitMessage } : {}), ...(!allSelected ? { filePaths: selectedFiles.map((f) => f.path) } : {}), }); }; const openChangedFileInEditor = useCallback( (filePath: string) => { const api = readLocalApi(); if (!api || !gitCwd) { toastManager.add({ type: "error", title: "Editor opening is unavailable.", data: threadToastData, }); return; } const target = resolvePathLinkTarget(filePath, gitCwd); void openInPreferredEditor(api, target).catch((error) => { toastManager.add( stackedThreadToast({ type: "error", title: "Unable to open file", description: error instanceof Error ? error.message : "An error occurred.", ...(threadToastData !== undefined ? { data: threadToastData } : {}), }), ); }); }, [gitCwd, threadToastData], ); const canPublishRepository = isRepo && gitStatusForActions !== null && !hasPrimaryRemote; if (!gitCwd) return null; return ( <> {!isRepo ? ( ) : ( {quickActionDisabledReason ? ( } > {quickAction.label} {quickActionDisabledReason} ) : ( )} { if (open) { void refreshGitStatus({ environmentId: activeEnvironmentId, cwd: gitCwd, }).catch(() => undefined); } }} > } disabled={isGitActionRunning} > {gitActionMenuItems.map((item) => { const disabledReason = getMenuActionDisabledReason({ item, gitStatus: gitStatusForActions, isBusy: isGitActionRunning, hasPrimaryRemote, }); if (item.disabled && disabledReason) { return ( } > {item.label} {disabledReason} ); } return ( { openDialogForMenuItem(item); }} > {item.label} ); })} {canPublishRepository ? ( { setIsPublishDialogOpen(true); }} > Publish repository... ) : null} {gitStatusForActions?.refName === null && (

Detached HEAD: create and checkout a refName to enable push and pull request actions.

)} {gitStatusForActions && gitStatusForActions.refName !== null && !gitStatusForActions.hasWorkingTreeChanges && gitStatusForActions.behindCount > 0 && gitStatusForActions.aheadCount === 0 && (

Behind upstream. Pull/rebase first.

)} {gitStatusError && (

{gitStatusError.message}

)}
)} { if (!open) { setIsCommitDialogOpen(false); setDialogCommitMessage(""); setExcludedFiles(new Set()); setIsEditingFiles(false); } }} > {COMMIT_DIALOG_TITLE} {COMMIT_DIALOG_DESCRIPTION}
Branch {gitStatusForActions?.refName ?? "(detached HEAD)"} {isDefaultRef && ( Warning: default refName )}
{isEditingFiles && allFiles.length > 0 && ( { setExcludedFiles( allSelected ? new Set(allFiles.map((f) => f.path)) : new Set(), ); }} /> )} Files {!allSelected && !isEditingFiles && ( ({selectedFiles.length} of {allFiles.length}) )}
{allFiles.length > 0 && ( )}
{!gitStatusForActions || allFiles.length === 0 ? (

none

) : (
{allFiles.map((file) => { const isExcluded = excludedFiles.has(file.path); return (
{isEditingFiles && ( { setExcludedFiles((prev) => { const next = new Set(prev); if (next.has(file.path)) { next.delete(file.path); } else { next.add(file.path); } return next; }); }} /> )}
); })}
+{selectedFiles.reduce((sum, f) => sum + f.insertions, 0)} / -{selectedFiles.reduce((sum, f) => sum + f.deletions, 0)}
)}

Commit message (optional)