import type { FilePart, Project, UserMessage, VcsFileDiff } from "@opencode-ai/sdk/v2" import { getFilename } from "@opencode-ai/core/util/path" import { useDialog } from "@opencode-ai/ui/context/dialog" import { createQuery, skipToken, useMutation, useQueryClient } from "@tanstack/solid-query" import { batch, ErrorBoundary, onCleanup, Suspense, Show, Match, Switch, createMemo, createEffect, createComputed, createSignal, on, onMount, type ParentProps, untrack, } from "solid-js" import { makeEventListener } from "@solid-primitives/event-listener" import { createMediaQuery } from "@solid-primitives/media" import { createResizeObserver } from "@solid-primitives/resize-observer" import { debounce } from "@solid-primitives/scheduled" import { useLocal } from "@/context/local" import { FileProvider, selectionFromLines, useFile, type FileSelection, type SelectedLineRange } from "@/context/file" import { createStore } from "solid-js/store" import type { SessionReviewLineComment } from "@opencode-ai/session-ui/session-review" import { ResizeHandle } from "@opencode-ai/ui/resize-handle" import { Select } from "@opencode-ai/ui/select" import { SelectV2 } from "@opencode-ai/ui/v2/select-v2" import { isScrollKeyTarget, scrollKey, scrollKeyOwner } from "@opencode-ai/ui/scroll-view" import { Tabs } from "@opencode-ai/ui/tabs" import { ButtonV2 } from "@opencode-ai/ui/v2/button-v2" import { createAutoScroll } from "@opencode-ai/ui/hooks" import { previewSelectedLines } from "@opencode-ai/session-ui/pierre/selection-bridge" import { Button } from "@opencode-ai/ui/button" import { showToast } from "@/utils/toast" import { base64Encode, checksum } from "@opencode-ai/core/util/encode" import { useLocation, useNavigate, useParams, useSearchParams } from "@solidjs/router" import { NewSessionView, SessionHeader } from "@/components/session" import { ErrorPage } from "@/pages/error" import { CommentsProvider, useComments } from "@/context/comments" import { useCommand } from "@/context/command" import { DirectoryDataProvider } from "@/pages/directory-layout" import { useServerSync } from "@/context/server-sync" import { useLanguage } from "@/context/language" import { useLayout } from "@/context/layout" import { ModelsProvider } from "@/context/models" import { useNotification } from "@/context/notification" import { PromptProvider, usePrompt } from "@/context/prompt" import { usePlatform } from "@/context/platform" import { SDKProvider, useSDK } from "@/context/sdk" import { useServerSDK } from "@/context/server-sdk" import { ServerConnection, serverName, useServer } from "@/context/server" import { useSettings } from "@/context/settings" import { useSync } from "@/context/sync" import { useTabs } from "@/context/tabs" import { TerminalProvider, useTerminal } from "@/context/terminal" import { PromptInput } from "@/components/prompt-input" import { PromptInputV2Composer, usePromptInputV2Controller } from "@/components/prompt-input-v2" import { useSettingsCommand } from "@/components/settings-dialog" import { setCursorPosition } from "@/components/prompt-input/editor-dom" import { promptLength } from "@/components/prompt-input/history" import { type FollowupDraft, sendFollowupDraft } from "@/components/prompt-input/submit" import { createPromptInputController, createSessionComposerController, createSessionComposerRegionController, SessionComposerRegion, } from "@/pages/session/composer" import { createOpenReviewFile, createSessionTabs, createSizing, shouldShowFileTree } from "@/pages/session/helpers" import { MessageTimeline } from "@/pages/session/timeline/message-timeline" import { createTimelineModel } from "@/pages/session/timeline/model" import { type DiffStyle, SessionReviewTab, type SessionReviewTabProps } from "@/pages/session/review-tab" import { useSessionLayout } from "@/pages/session/session-layout" import { restorePromptModel, syncPromptModel, syncSessionModel } from "@/pages/session/session-model-helpers" import { clampSessionPanelWidth, SESSION_PANEL_WIDTH_MIN, sessionPanelWidthMax, } from "@/pages/session/session-panel-width" import { SessionSidePanel } from "@/pages/session/session-side-panel" import { sessionPanelLayout } from "@/pages/session/session-panel-layout" import { SessionReviewEmptyChangesV2 } from "@opencode-ai/session-ui/v2/session-review-empty-changes-v2" import { SessionReviewEmptyNoGitV2 } from "@opencode-ai/session-ui/v2/session-review-empty-no-git-v2" import { SessionReviewV2SidebarToggle } from "@opencode-ai/session-ui/v2/session-review-v2" import { ReviewPanelV2 } from "@/pages/session/v2/review-panel-v2" import { createReviewPanelV2State } from "@/pages/session/v2/review-panel-v2-state" import { reviewDiffDirectory, reviewDiffNeedsLoad, reviewRootDirectory } from "@/pages/session/v2/review-diff-kinds" import { TerminalPanel } from "@/pages/session/terminal-panel" import { TerminalPanelV2 } from "@/pages/session/terminal-panel-v2" import { useComposerCommands } from "@/pages/session/use-composer-commands" import { useSessionCommands } from "@/pages/session/use-session-commands" import { useSessionHashScroll } from "@/pages/session/use-session-hash-scroll" import { Identifier } from "@/utils/id" import { diffs as list } from "@/utils/diffs" import { Persist, persisted } from "@/utils/persist" import { extractPromptFromParts } from "@/utils/prompt" import { formatServerError, isLocalSessionNotFoundError, isSessionNotFoundError } from "@/utils/server-errors" import { legacySessionHref, requireServerKey, sessionHref } from "@/utils/session-route" import { useUsageExceededDialogs } from "./session/usage-exceeded-dialogs" import { createSessionOwnership } from "./session/session-ownership" import { createSessionLineage } from "./session/session-lineage" type FollowupItem = FollowupDraft & { id: string } type FollowupEdit = Pick const emptyFollowups: FollowupItem[] = [] type ChangeMode = "git" | "branch" | "turn" type VcsMode = "git" | "branch" const sessionViewState = () => ({ messageId: undefined as string | undefined, mobileTab: "session" as "session" | "changes", }) function isCurrentSessionNotFoundError(error: unknown, sessionID: string | undefined) { if (!sessionID) return false return isSessionNotFoundError(error, sessionID) || isLocalSessionNotFoundError(error, sessionID) } async function runPromptRollbackMutation(input: { capturePrompt: () => { current: () => T[]; set: (value: T[]) => void; reset: () => void } optimistic: (prompt: { set: (value: T[]) => void; reset: () => void }) => void request: () => Promise complete: (result: R) => void rollback: () => void fail: (error: unknown) => void }) { const prompt = input.capturePrompt() const previous = prompt.current().slice() batch(() => input.optimistic(prompt)) await input .request() .then(input.complete) .catch((error) => { batch(() => { input.rollback() prompt.set(previous) }) input.fail(error) }) } export function SessionPage() { return ( ) } // Rendered under app.tsx's TargetSessionRoute, which owns the per-server keyed // remount around the server-scoped providers. Nothing here may key on the // session ID: session tabs on the same server share this route instance, and // workspace-scoped state (terminal, directory providers) lives below. export function TargetSessionRouteContent() { const params = useParams<{ serverKey: string; id: string }>() const serverSync = useServerSync() const directory = createMemo(() => serverSync().session.lineage.peek(params.id)?.session.directory) return ( // Settings must keep the target-server SDK, sync, and models context and remain registered // when session content falls back to the route error boundary. params.id}> ) } function TargetSessionSettingsCommand() { useSettingsCommand() return null } export function SessionRouteErrorBoundary( props: ParentProps<{ sessionID?: string; serverKey?: ServerConnection.Key; padded?: boolean }>, ) { const settings = useSettings() return ( settings.general.newLayoutDesigns() ? ( ) : ( ) } > {props.children} ) } function SessionErrorFallback(props: { error: unknown; sessionID?: string; serverKey?: ServerConnection.Key }) { const language = useLanguage() const server = useServer() const tabs = useTabs() const displayServer = createMemo(() => { const key = props.serverKey ?? server.key const conn = server.list.find((item) => ServerConnection.key(item) === key) return conn ? serverName(conn) : key }) const closeTab = () => { if (!props.sessionID) return tabs.removeSessionTab({ server: props.serverKey ?? server.key, sessionId: props.sessionID }) } if (isCurrentSessionNotFoundError(props.error, props.sessionID)) { return (
{language.t("session.error.notFound")}
{language.t("session.error.notFound.description")}
{(sessionID) => (
{displayServer()}
{sessionID()}
)}
{language.t("session.error.notFound.closeTab")}
) } return } function ResolvedTargetSessionRoute() { const params = useParams<{ serverKey: string; id: string }>() const tabs = useTabs() const sync = useServerSync() const serverKey = createMemo(() => requireServerKey(params.serverKey)) const current = createSessionLineage( () => params.id, () => sync().session.lineage, ) const directory = createMemo(() => current()?.session.directory) const targetDirectory = () => directory()! createEffect(() => { const session = current() if (!session) return tabs.addSessionTab({ server: serverKey(), sessionId: session.root.id, }) }) return ( // Non-keyed: closes only while the target's directory is unknown (uncached // lineage mid-resolution), which tears down the workspace subtree including // the terminal. Same-workspace tab switches keep it open because warm // targets resolve synchronously from the sync cache. ) } // Owns the workspace-identity remount. Must not include the session ID in the // key: SessionPage handles session changes reactively, and remounting here // destroys workspace-scoped state (terminal PTYs, file/prompt providers). function TargetSessionPage() { const sdk = useSDK() const serverSDK = useServerSDK() return ( ) } function TargetServerScopedProviders( props: ParentProps<{ directory?: () => string | undefined; sessionID?: () => string | undefined }>, ) { return ( <> {props.children} ) } function MarkSessionNotificationsViewed(props: { sessionID?: () => string | undefined }) { const notification = useNotification() createEffect(() => { const sessionID = props.sessionID?.() if (!notification.ready() || !sessionID) return if (notification.session.unseenCount(sessionID) === 0) return notification.session.markViewed(sessionID) }) return null } function SessionProviders(props: ParentProps) { return ( {props.children} ) } function SessionRouteFrame(props: ParentProps<{ padded?: boolean }>) { return (
{props.children}
) } function SessionPanelFrame(props: ParentProps<{ newLayout: boolean; raised?: boolean }>) { return (
{props.children}
) } export default function Page() { const serverSync = useServerSync() const layout = useLayout() const local = useLocal() const file = useFile() const sync = useSync() const queryClient = useQueryClient() const dialog = useDialog() const language = useLanguage() const sdk = useSDK() const serverSDK = useServerSDK() const settings = useSettings() const platform = usePlatform() const prompt = usePrompt() const comments = useComments() const command = useCommand() const terminal = useTerminal() const [searchParams, setSearchParams] = useSearchParams<{ prompt?: string }>() const location = useLocation() const navigate = useNavigate() const { params, sessionKey, workspaceKey, tabs, view } = useSessionLayout() const reviewMode = () => view().review.mode() ?? "git" const reviewFile = () => view().review.file() const sessionOwnership = createSessionOwnership(sessionKey) const newSessionDesign = createMemo(() => settings.general.newLayoutDesigns()) createEffect(() => { if (!prompt.ready()) return untrack(() => { if (params.id) return const text = searchParams.prompt if (!text) return prompt.set([{ type: "text", content: text, start: 0, end: text.length }], text.length) setSearchParams({ ...searchParams, prompt: undefined }) }) }) const [ui, setUi] = createStore({ pendingMessage: undefined as string | undefined, reviewSnap: false, scrollGesture: 0, scroll: { overflow: false, bottom: true, jump: false, }, }) const composer = createSessionComposerController() const inputController = createPromptInputController({ sessionKey, sessionID: () => params.id, queryOptions: serverSync().queryOptions, }) const workspaceTabs = createMemo(() => layout.tabs(workspaceKey)) const sessionPanelKey = createMemo(() => (params.id ? `${serverSDK().scope}\0${params.id}` : undefined)) createEffect( on( () => params.id, (id, prev) => { if (!id) return if (prev) return const pending = layout.handoff.tabs() if (!pending) return if (Date.now() - pending.at > 60_000) { layout.handoff.clearTabs() return } if (pending.scope !== serverSDK().scope) return if (pending.id !== id) return layout.handoff.clearTabs() if (pending.dir !== base64Encode(sdk().directory)) return const from = workspaceTabs().tabs() if (from.all.length === 0 && !from.active) return const current = tabs().tabs() if (current.all.length > 0 || current.active) return const all = normalizeTabs(from.all) const active = from.active ? normalizeTab(from.active) : undefined tabs().setAll(all) tabs().setActive(active && all.includes(active) ? active : all[0]) workspaceTabs().setAll([]) workspaceTabs().setActive(undefined) }, { defer: true }, ), ) const isDesktop = createMediaQuery("(min-width: 768px)") const size = createSizing() const desktopReviewOpen = createMemo(() => isDesktop() && view().reviewPanel.opened()) const desktopV2ReviewOpen = createMemo(() => newSessionDesign() && desktopReviewOpen() && !!params.id) const terminalOpen = createMemo(() => view().terminal.opened()) const desktopTerminalOpen = createMemo(() => isDesktop() && terminalOpen()) const desktopInlineTerminalOnlyOpen = createMemo( () => newSessionDesign() && desktopTerminalOpen() && !desktopV2ReviewOpen(), ) const desktopFileTreeOpen = createMemo( () => isDesktop() && shouldShowFileTree({ visible: settings.visibility.fileTree(), opened: layout.fileTree.opened(), }), ) const desktopSessionResizeOpen = createMemo(() => newSessionDesign() ? desktopV2ReviewOpen() || desktopTerminalOpen() : desktopReviewOpen(), ) const desktopSidePanelOpen = createMemo(() => desktopSessionResizeOpen() || desktopFileTreeOpen()) let panelRow: HTMLDivElement | undefined const [panelRowWidth, setPanelRowWidth] = createSignal() createResizeObserver( () => panelRow, ({ width }) => setPanelRowWidth(width), ) const splitReview = createMemo( () => (newSessionDesign() ? desktopV2ReviewOpen() : desktopReviewOpen()) && layout.review.diffStyle() === "split", ) // The observer reports the content-box width, which already excludes the row // padding; only the flex gap between the panels remains to subtract. const sessionPanelAvailable = createMemo(() => { const width = panelRowWidth() if (width === undefined) return undefined return width - (settings.general.newLayoutDesigns() ? 8 : 0) }) const sessionPanelMax = createMemo(() => { const available = sessionPanelAvailable() if (available === undefined) return 1000 return sessionPanelWidthMax({ available, split: splitReview() }) }) // Clamp at render time so window or sidebar resizes squeeze the chat panel // instead of the review pane, without overwriting the persisted width. const sessionPanelResizedWidth = createMemo(() => clampSessionPanelWidth({ width: layout.session.width(), available: sessionPanelAvailable(), split: splitReview(), }), ) const sessionPanelWidth = createMemo(() => { if (!desktopSidePanelOpen()) return "100%" if (desktopSessionResizeOpen()) return `${sessionPanelResizedWidth()}px` return `calc(100% - ${layout.fileTree.width()}px)` }) const centered = createMemo(() => isDesktop() && (newSessionDesign() || !desktopReviewOpen())) const desktopV2PanelLayout = createMemo(() => sessionPanelLayout({ review: desktopV2ReviewOpen(), terminal: desktopTerminalOpen(), files: desktopFileTreeOpen(), }), ) function normalizeTab(tab: string) { if (!tab.startsWith("file://")) return tab return file.tab(tab) } function normalizeTabs(list: string[]) { const seen = new Set() const next: string[] = [] for (const item of list) { const value = normalizeTab(item) if (seen.has(value)) continue seen.add(value) next.push(value) } return next } const openReviewPanel = () => { if (!view().reviewPanel.opened()) view().reviewPanel.open() } const info = createMemo(() => (params.id ? sync().session.get(params.id) : undefined)) const isChildSession = createMemo(() => !!info()?.parentID) const canReview = createMemo(() => !!sync().project) const reviewTab = createMemo(() => isDesktop()) const tabState = createSessionTabs({ tabs, pathFromTab: file.pathFromTab, normalizeTab, review: reviewTab, hasReview: canReview, }) const activeTab = tabState.activeTab const activeFileTab = tabState.activeFileTab const revertMessageID = createMemo(() => info()?.revert?.messageID) const timeline = createTimelineModel({ sessionID: () => params.id, revertMessageID }) const historyLoading = timeline.history.loading const historyMore = timeline.history.more const lastUserMessage = timeline.lastUserMessage const messages = timeline.messages const messagesReady = timeline.ready const sessionSync = timeline.resource const userMessages = timeline.userMessages const visibleUserMessages = timeline.visibleUserMessages createEffect(() => { const tab = activeFileTab() if (!tab) return const path = file.pathFromTab(tab) if (path) void file.load(path) }) createEffect( on( () => lastUserMessage()?.id, () => { const msg = lastUserMessage() if (!msg) return syncSessionModel(local, msg) }, ), ) let restoredModelSession: string | undefined createEffect(() => { const id = params.id if (!id || !prompt.ready() || !local.session.ready()) return if (restoredModelSession !== id) { restoredModelSession = id if (restorePromptModel(local, prompt)) return } syncPromptModel(local, prompt) }) createEffect( on( () => ({ dir: sdk().directory, id: params.id }), (next, prev) => { if (!prev) return if (next.dir === prev.dir && next.id === prev.id) return if (prev.id && !next.id) local.session.reset() }, { defer: true }, ), ) const [store, setStore] = createStore({ ...sessionViewState(), newSessionWorktree: "main", deferRender: false, }) const [followup, setFollowup] = persisted( Persist.serverWorkspace(serverSDK().scope, sdk().directory, "followup", ["followup.v1"]), createStore<{ items: Record failed: Record paused: Record edit: Record }>({ items: {}, failed: {}, paused: {}, edit: {}, }), ) createComputed((prev) => { const key = sessionKey() if (key !== prev) { setStore("deferRender", true) const owner = sessionOwnership.capture() requestAnimationFrame(() => { setTimeout(() => owner.run(() => setStore("deferRender", false)), 0) }) } return key }) let reviewFrame: number | undefined let todoFrame: number | undefined let todoTimer: number | undefined let diffFrame: number | undefined let diffTimer: number | undefined createComputed((prev) => { const open = desktopReviewOpen() if (prev === undefined || prev === open) return open if (reviewFrame !== undefined) cancelAnimationFrame(reviewFrame) setUi("reviewSnap", true) reviewFrame = requestAnimationFrame(() => { reviewFrame = undefined setUi("reviewSnap", false) }) return open }, desktopReviewOpen()) const turnDiffs = createMemo(() => list(lastUserMessage()?.summary?.diffs)) const nogit = createMemo(() => { const project = sync().project return !!project && project.vcs !== "git" }) const changesOptions = createMemo(() => { const list: ChangeMode[] = [] const project = sync().project const vcs = sync().data.vcs if (project?.vcs === "git") list.push("git") if (project?.vcs === "git" && vcs?.branch && vcs?.default_branch && vcs.branch !== vcs.default_branch) { list.push("branch") } list.push("turn") return list }) const mobileChanges = createMemo(() => !isDesktop() && store.mobileTab === "changes") const wantsReview = createMemo(() => isDesktop() ? desktopFileTreeOpen() || (desktopReviewOpen() && (activeTab() === "review" || (newSessionDesign() && !!activeFileTab()))) : store.mobileTab === "changes", ) const vcsMode = createMemo(() => { const mode = reviewMode() if (mode === "git" || mode === "branch") return mode }) const vcsKey = createMemo( () => ["session-vcs", sdk().directory, sync().data.vcs?.branch ?? "", sync().data.vcs?.default_branch ?? ""] as const, ) const vcsQuery = createQuery(() => { const mode = vcsMode() const enabled = wantsReview() && sync().project?.vcs === "git" return { queryKey: [...vcsKey(), mode] as const, enabled, queryFn: mode ? () => sdk() .api.vcs.diff({ location: { directory: sdk().directory }, mode: mode === "git" ? "working" : mode }) .then((result) => result.data) .catch((error) => { console.debug("[session-review] failed to load vcs diff", { mode, error }) return [] }) : skipToken, } }) const refreshVcs = debounce(() => void queryClient.invalidateQueries({ queryKey: vcsKey() }), 100) const reviewDiffs = () => { if (reviewMode() === "git" || reviewMode() === "branch") // avoids suspense return vcsQuery.isFetched ? (vcsQuery.data ?? []) : [] return turnDiffs() } const activeReviewFile = () => { const diffs = reviewDiffs() const selected = reviewFile() if (selected && diffs.some((diff) => diff.file === selected)) return selected return diffs[0]?.file } const reviewCount = () => reviewDiffs().length const hasReview = () => reviewCount() > 0 const reviewReady = () => { if (reviewMode() === "git" || reviewMode() === "branch") return !vcsQuery.isPending return true } const loadReviewDiff = async (file: string, version?: number): Promise => { const mode = vcsMode() if (!mode) return const root = reviewRootDirectory(sync().project?.worktree ?? sdk().directory) const directory = reviewDiffDirectory(root, file) const source = reviewDiffs().find((diff) => diff.file === file) const valid = (diff: VcsFileDiff | undefined) => { if (!diff || !source) return if (diff.additions !== source.additions || diff.deletions !== source.deletions) return if (reviewDiffNeedsLoad(diff)) return return diff } const request = (scope: string, context?: number) => queryClient .fetchQuery({ queryKey: [serverSDK().scope, ...vcsKey(), mode, "directory", scope, context, version] as const, staleTime: Number.POSITIVE_INFINITY, retry: 2, queryFn: () => sdk() .api.vcs.diff({ location: { directory: scope }, mode: mode === "git" ? "working" : mode, context, }) .then((result) => result.data), }) .then((diffs) => diffs.find((diff) => diff.file === file)) if (directory !== root) { try { const scoped = valid(await request(directory)) if (scoped) return scoped } catch (error) { console.debug("[session-review] failed to load scoped vcs diff", { mode, file, directory, error }) } } try { const bounded = valid(await request(root, 3)) if (bounded) return bounded } catch (error) { console.debug("[session-review] failed to load bounded vcs diff", { mode, file, root, error }) } } const newSessionWorktree = createMemo(() => { if (store.newSessionWorktree === "create") return "create" const project = sync().project if (project && sdk().directory !== project.worktree) return sdk().directory return "main" }) const setActiveMessage = (message: UserMessage | undefined) => { messageMark = scrollMark setStore("messageId", message?.id) } const anchor = (id: string) => `message-${id}` const cursor = () => { const root = scroller if (!root) return store.messageId const box = root.getBoundingClientRect() const line = box.top + 100 const list = [...root.querySelectorAll("[data-message-id]")] .map((el) => { const id = el.dataset.messageId if (!id) return const rect = el.getBoundingClientRect() return { id, top: rect.top, bottom: rect.bottom } }) .filter((item): item is { id: string; top: number; bottom: number } => !!item) const shown = list.filter((item) => item.bottom > box.top && item.top < box.bottom) const hit = shown.find((item) => item.top <= line && item.bottom >= line) if (hit) return hit.id const near = [...shown].sort((a, b) => { const da = Math.abs(a.top - line) const db = Math.abs(b.top - line) if (da !== db) return da - db return a.top - b.top })[0] if (near) return near.id return list.filter((item) => item.top <= line).at(-1)?.id ?? list[0]?.id ?? store.messageId } function navigateMessageByOffset(offset: number) { const msgs = visibleUserMessages() if (msgs.length === 0) return const current = store.messageId && messageMark === scrollMark ? store.messageId : cursor() const base = current ? msgs.findIndex((m) => m.id === current) : msgs.length const currentIndex = base === -1 ? msgs.length : base const targetIndex = currentIndex + offset if (targetIndex < 0 || targetIndex > msgs.length) return if (targetIndex === msgs.length) { resumeScroll() return } autoScroll.pause() scrollToMessage(msgs[targetIndex], "auto") } function upsert(next: Project) { const list = serverSync().data.project sync().set("project", next.id) const idx = list.findIndex((item) => item.id === next.id) if (idx >= 0) { serverSync().set( "project", list.map((item, i) => (i === idx ? { ...item, ...next } : item)), ) return } const at = list.findIndex((item) => item.id > next.id) if (at >= 0) { serverSync().set("project", [...list.slice(0, at), next, ...list.slice(at)]) return } serverSync().set("project", [...list, next]) } const gitMutation = useMutation(() => ({ mutationFn: () => sdk().client.project.initGit(), onSuccess: (x) => { if (!x.data) return upsert(x.data) }, onError: (err) => { showToast({ variant: "error", title: language.t("common.requestFailed"), description: formatServerError(err, language.t), }) }, })) function initGit() { if (gitMutation.isPending) return gitMutation.mutate() } let inputRef!: HTMLDivElement let promptDock: HTMLDivElement | undefined let dockHeight = 0 let scroller: HTMLDivElement | undefined let content: HTMLDivElement | undefined let revealMessage = (_id: string) => {} let scrollToEnd = () => {} let scrollMark = 0 let messageMark = 0 const scrollGestureWindowMs = 250 const markScrollGesture = (target?: EventTarget | null) => { const root = scroller if (!root) return const el = target instanceof Element ? target : undefined const nested = el?.closest("[data-scrollable]") if (nested && nested !== root) return setUi("scrollGesture", Date.now()) } const hasScrollGesture = () => Date.now() - ui.scrollGesture < scrollGestureWindowMs createEffect( on( () => { const id = params.id return [ sdk().directory, id, id ? (sync().data.session_status[id]?.type ?? "idle") : "idle", id ? composer.blocked() : false, ] as const }, ([dir, id, status, blocked]) => { if (todoFrame !== undefined) cancelAnimationFrame(todoFrame) if (todoTimer !== undefined) window.clearTimeout(todoTimer) todoFrame = undefined todoTimer = undefined if (!id) return if (status === "idle" && !blocked) return const cached = untrack(() => sync().data.todo[id] !== undefined) todoFrame = requestAnimationFrame(() => { todoFrame = undefined todoTimer = window.setTimeout(() => { todoTimer = undefined if (sdk().directory !== dir || params.id !== id) return untrack(() => { void sync().session.todo(id, cached ? { force: true } : undefined) }) }, 0) }) }, { defer: true }, ), ) createEffect( on( () => visibleUserMessages().at(-1)?.id, (lastId, prevLastId) => { if (lastId && prevLastId && lastId > prevLastId) { setStore("messageId", undefined) } }, { defer: true }, ), ) createEffect( on( sessionKey, () => { setStore(sessionViewState()) setUi("pendingMessage", undefined) }, { defer: true }, ), ) const stopVcs = sdk().event.listen((evt) => { const details = evt.details as { type: string; properties?: unknown } if (details.type !== "file.watcher.updated" && details.type !== "filesystem.changed") return const props = typeof details.properties === "object" && details.properties ? (details.properties as Record) : undefined const file = typeof props?.file === "string" ? props.file : undefined if (!file || file.startsWith(".git/")) return refreshVcs() }) onCleanup(stopVcs) createEffect( on( () => sdk().directory, (dir) => { if (!dir) return setStore("newSessionWorktree", "main") }, { defer: true }, ), ) const selectionPreview = (path: string, selection: FileSelection) => { const content = file.get(path)?.content?.content if (!content) return undefined return previewSelectedLines(content, { start: selection.startLine, end: selection.endLine }) } const addCommentToContext = (input: { file: string selection: SelectedLineRange comment: string preview?: string origin?: "review" | "file" }) => { const selection = selectionFromLines(input.selection) const preview = input.preview ?? selectionPreview(input.file, selection) const saved = comments.add({ file: input.file, selection: input.selection, comment: input.comment, }) prompt.context.add({ type: "file", path: input.file, selection, comment: input.comment, commentID: saved.id, commentOrigin: input.origin, preview, }) } const updateCommentInContext = (input: { id: string file: string selection: SelectedLineRange comment: string preview?: string }) => { comments.update(input.file, input.id, input.comment) prompt.context.updateComment(input.file, input.id, { comment: input.comment, ...(input.preview ? { preview: input.preview } : {}), }) } const removeCommentFromContext = (input: { id: string; file: string }) => { comments.remove(input.file, input.id) prompt.context.removeComment(input.file, input.id) } const reviewCommentActions = createMemo(() => ({ moreLabel: language.t("common.moreOptions"), editLabel: language.t("common.edit"), deleteLabel: language.t("common.delete"), saveLabel: language.t("common.save"), })) const isEditableTarget = (target: EventTarget | null | undefined) => { if (!(target instanceof HTMLElement)) return false return /^(INPUT|TEXTAREA|SELECT|BUTTON)$/.test(target.tagName) || target.isContentEditable } const deepActiveElement = () => { let current: Element | null = document.activeElement while (current instanceof HTMLElement && current.shadowRoot?.activeElement) { current = current.shadowRoot.activeElement } return current instanceof HTMLElement ? current : undefined } const handleKeyDown = (event: KeyboardEvent) => { const path = event.composedPath() const target = path.find((item): item is HTMLElement => item instanceof HTMLElement) const activeElement = deepActiveElement() const protectedTarget = path.some( (item) => item instanceof HTMLElement && item.closest("[data-prevent-autofocus]") !== null, ) if (protectedTarget || isEditableTarget(target)) return if (activeElement) { const isProtected = activeElement.closest("[data-prevent-autofocus]") const isInput = isEditableTarget(activeElement) if (isProtected || isInput) return } if (dialog.active) return if (activeElement === inputRef) { if (event.key === "Escape") inputRef?.blur() return } const key = scrollKey(event) if (key) { if (!scroller || !isScrollKeyTarget(target ?? null, key)) return if (scrollKeyOwner(scroller, target ?? null, key) !== scroller) return markScrollGesture(scroller) return } if (event.key.length === 1 && event.key !== "Unidentified" && !(event.ctrlKey || event.metaKey)) { if (composer.blocked() || isChildSession()) return const input = inputRef if (!input) return input.focus() setCursorPosition(input, prompt.cursor() ?? promptLength(prompt.current())) } } createEffect(() => { if (!layout.ready()) return if (sync().status !== "complete") return if (!sync().project) return const list = changesOptions() const mode = reviewMode() if (list.includes(mode)) return const next = list[0] if (!next) return view().review.setMode(next) }) createEffect( on( () => sync().data.session_status[params.id ?? ""]?.type, (next, prev) => { if (next !== "idle" || prev === undefined || prev === "idle") return refreshVcs() }, { defer: true }, ), ) const fileTreeTab = () => layout.fileTree.tab() const setFileTreeTab = (value: "changes" | "all") => layout.fileTree.setTab(value) const [tree, setTree] = createStore({ reviewScroll: undefined as HTMLDivElement | undefined, pendingDiff: undefined as string | undefined, }) createEffect( on( sessionKey, () => { setTree({ reviewScroll: undefined, pendingDiff: undefined, }) }, { defer: true }, ), ) const showAllFiles = () => { if (fileTreeTab() !== "changes") return setFileTreeTab("all") } const focusInput = () => { if (isChildSession()) return inputRef?.focus() } useComposerCommands() useSessionCommands({ navigateMessageByOffset, setActiveMessage, focusInput, review: reviewTab, fileBrowser: () => newSessionDesign() && isDesktop() && !!params.id, }) command.register("session-palette", () => [ { id: "command.palette", title: language.t("command.palette"), hidden: true, onSelect: () => command.trigger("file.open", "palette"), }, ]) const openReviewFile = createOpenReviewFile({ showAllFiles, tabForPath: file.tab, openTab: tabs().open, setActive: tabs().setActive, loadFile: file.load, }) const changesLabel = (option: ChangeMode) => { if (option === "git") return language.t("ui.sessionReview.title.git") if (option === "branch") return language.t("ui.sessionReview.title.branch") return language.t("ui.sessionReview.title.lastTurn") } const changesTitle = () => { if (!canReview()) { return null } return (