{pastChatTitle(session)}
{preview &&
{preview}
}
- {(turns || ts) && (
+ {(turnsKnown || turnsPending || ts) && (
- {turns && {t("composer.sessionTurns", { n: session.turns })}}
+ {turnsPending && {t("history.indexing")}}
+ {turnsKnown && {t("composer.sessionTurns", { n: session.turns })}}
{ts && · {fmtSessionTime(ts)}}
)}
@@ -4152,7 +4155,11 @@ export function Composer({
{pastChatTitle(session)}
- {turns ? ` (${t("composer.sessionTurns", { n: session.turns })})` : ""}
+ {turnsPending
+ ? ` (${t("history.indexing")})`
+ : turnsKnown
+ ? ` (${t("composer.sessionTurns", { n: session.turns })})`
+ : ""}
@@ -4317,7 +4324,11 @@ export function Composer({
{ref.title}
- {typeof ref.turns === "number" ? ` (${t("composer.sessionTurns", { n: ref.turns })})` : ""}
+ {ref.turnsState === "unknown"
+ ? ` (${t("history.indexing")})`
+ : typeof ref.turns === "number"
+ ? ` (${t("composer.sessionTurns", { n: ref.turns })})`
+ : ""}
diff --git a/desktop/frontend/src/components/HistoryPanel.tsx b/desktop/frontend/src/components/HistoryPanel.tsx
index f825a905f7..0cdfd499a3 100644
--- a/desktop/frontend/src/components/HistoryPanel.tsx
+++ b/desktop/frontend/src/components/HistoryPanel.tsx
@@ -542,7 +542,11 @@ export function HistoryPanel({
{s.recovered &&
{tr("recovery.badge")}}
{sessionLocation(s, tr) &&
{sessionLocation(s, tr)}}
-
{tr(s.turns === 1 ? "history.turnOne" : "history.turnOther", { n: s.turns })}
+
+ {s.turnsState === "unknown"
+ ? tr("history.indexing")
+ : tr(s.turns === 1 ? "history.turnOne" : "history.turnOther", { n: s.turns })}
+
·
{timeLabel(isTrash ? s.deletedAt || sessionActivityTime(s) : sessionActivityTime(s))}
{!isTrash && running && (
@@ -688,7 +692,10 @@ function sessionMetaLine(s: SessionMeta, tr: ReturnType
, isTrash =
const time = timeLabel(isTrash ? s.deletedAt || sessionActivityTime(s) : sessionActivityTime(s));
const suffix = isTrash && s.deletedAt ? ` · ${tr("history.deleted")}` : "";
const prefix = isChannelSession(s) ? `${tr("history.channelReadOnly")} · ` : "";
- return `${prefix}${tr(s.turns === 1 ? "history.turnOne" : "history.turnOther", { n: s.turns })} · ${time}${suffix}`;
+ const turns = s.turnsState === "unknown"
+ ? tr("history.indexing")
+ : tr(s.turns === 1 ? "history.turnOne" : "history.turnOther", { n: s.turns });
+ return `${prefix}${turns} · ${time}${suffix}`;
}
function previewMessagesToItems(messages: HistoryMessage[]): Item[] {
diff --git a/desktop/frontend/src/components/ProjectTree.tsx b/desktop/frontend/src/components/ProjectTree.tsx
index a466ddc1ab..9b82e2d219 100644
--- a/desktop/frontend/src/components/ProjectTree.tsx
+++ b/desktop/frontend/src/components/ProjectTree.tsx
@@ -8,8 +8,8 @@ import type { CSSProperties, DragEvent as ReactDragEvent, KeyboardEvent as React
import { Archive, ArrowDown, Pencil, Plus, Folder, FolderPlus, Search, BriefcaseBusiness, Copy, FolderOpen, XCircle, Check, ListCollapse, ListRestart, MessageSquare, Clock, Pin, MoreHorizontal, Minimize2, Maximize2, GitBranch } from "lucide-react";
import { asArray } from "../lib/array";
import { useToast } from "../lib/toast";
-import { app } from "../lib/bridge";
-import type { ProjectNode, ProjectTopicStatus } from "../lib/types";
+import { app, onProjectTreeChangedV2 } from "../lib/bridge";
+import type { ProjectNode, ProjectTopicStatus, SessionCatalogStatus } from "../lib/types";
import { topicActivityTime } from "../lib/session";
import { getLocale, useT, type DictKey, type Translator } from "../lib/i18n";
import { PROJECT_COLOR_OPTIONS, projectColorValue } from "../lib/projectColors";
@@ -64,6 +64,32 @@ function isTopicNode(node: ProjectNode): boolean {
return node.kind === "topic" || node.kind === "global_topic";
}
+export function projectTreeRevisionIsFresh(currentRevision: number, incomingRevision: number): boolean {
+ return incomingRevision >= currentRevision;
+}
+
+export function mergeProjectTopicPage(current: ProjectNode[], incoming: ProjectNode[], append: boolean): ProjectNode[] {
+ if (!append) return [...incoming];
+ const next = [...current];
+ const positions = new Map(next.map((node, index) => [node.key, index]));
+ for (const node of incoming) {
+ const index = positions.get(node.key);
+ if (index === undefined) {
+ positions.set(node.key, next.length);
+ next.push(node);
+ } else {
+ next[index] = node;
+ }
+ }
+ return next;
+}
+
+export function projectTreeEventAffectsFolder(project: ProjectNode, roots: string[]): boolean {
+ if (roots.length === 0) return true;
+ const root = project.kind === "global_folder" ? "" : project.root ?? "";
+ return roots.includes(root);
+}
+
export type ProjectTreeTopicOpenRequest = {
scope: "global" | "project";
workspaceRoot: string;
@@ -134,7 +160,8 @@ function topicIsActive(node: ProjectNode, activeScope?: string, activeWorkspaceR
export function projectTreeTopicMetaLine(node: ProjectNode, t: Translator, compact = false): string {
const parts: string[] = [];
const turns = node.turns ?? 0;
- if (turns > 0) parts.push(t(turns === 1 ? "history.turnOne" : "history.turnOther", { n: turns }));
+ if (node.turnsState === "unknown") parts.push(t("history.indexing"));
+ else if (turns > 0) parts.push(t(turns === 1 ? "history.turnOne" : "history.turnOther", { n: turns }));
const activityAt = node.lastActivityAt || node.createdAt || 0;
if (activityAt) parts.push(topicActivityLabel(activityAt, t, compact));
if (parts.length === 0) parts.push(t("projectTree.previously"));
@@ -617,6 +644,20 @@ export function ProjectTree({
const compactTopics = variant === "workbench";
const creationTopics = variant === "creation";
const [tree, setTree] = useState([]);
+ const treeRef = useRef([]);
+ const latestRevisionRef = useRef(0);
+ const [catalogStatus, setCatalogStatus] = useState({
+ state: "opening", revision: 0, indexed: 0, total: 0, repairPending: 0,
+ });
+ const [topicPageState, setTopicPageState] = useState>({});
+ const topicPageStateRef = useRef(topicPageState);
+ const updateTopicPageState = useCallback((key: string, next: { nextCursor?: string; loading: boolean }) => {
+ setTopicPageState((current) => {
+ const updated = { ...current, [key]: next };
+ topicPageStateRef.current = updated;
+ return updated;
+ });
+ }, []);
const [expanded, setExpanded] = useState>(new Set());
const [manuallyCollapsed, setManuallyCollapsed] = useState>(new Set());
const [creatingProject, setCreatingProject] = useState(null);
@@ -695,15 +736,61 @@ export function ProjectTree({
});
}, []);
- // Keyed by the data, not the selection: a switch cannot change the tree.
+ const loadProjectTopics = useCallback(async (project: ProjectNode, append = false) => {
+ if (project.kind !== "project" && project.kind !== "global_folder") return;
+ const key = project.key;
+ const pageState = topicPageStateRef.current[key];
+ if (pageState?.loading) return;
+ const cursor = append ? pageState?.nextCursor ?? "" : "";
+ if (append && !cursor) return;
+ updateTopicPageState(key, { ...pageState, loading: true });
+ try {
+ const page = await app.ListProjectTopics({
+ scope: project.kind === "global_folder" ? "global" : "project",
+ workspaceRoot: project.kind === "global_folder" ? "" : project.root ?? "",
+ cursor,
+ limit: timeFilter === "10" ? 10 : timeFilter === "20" ? 20 : 50,
+ query: query.trim(),
+ timeFilter: timeFilter === "10" || timeFilter === "20" || timeFilter === "all" ? "" : timeFilter,
+ });
+ if (!projectTreeRevisionIsFresh(latestRevisionRef.current, page.revision)) {
+ updateTopicPageState(key, { ...topicPageStateRef.current[key], loading: false });
+ return;
+ }
+ latestRevisionRef.current = Math.max(latestRevisionRef.current, page.revision);
+ const items = asArray(page.items);
+ setTree((current) => current.map((node) => {
+ if (node.key !== key) return node;
+ return { ...node, children: mergeProjectTopicPage(asArray(node.children), items, append) };
+ }));
+ updateTopicPageState(key, { nextCursor: page.nextCursor, loading: false });
+ } catch {
+ updateTopicPageState(key, { ...topicPageStateRef.current[key], loading: false });
+ }
+ }, [query, timeFilter, updateTopicPageState]);
+
+ // Snapshot is intentionally shells-only. Preserve already loaded pages by
+ // project key so a metadata refresh does not collapse or blank the sidebar.
const refresh = useCallback(async () => {
try {
- setTree(asArray(await app.ListProjectTree()));
+ const snapshot = await app.GetProjectTreeSnapshot();
+ if (!projectTreeRevisionIsFresh(latestRevisionRef.current, snapshot.revision ?? 0)) return;
+ const projects = asArray(snapshot.projects);
+ latestRevisionRef.current = Math.max(latestRevisionRef.current, snapshot.revision ?? 0);
+ setCatalogStatus(snapshot.catalog);
+ setTree((current) => projects.map((project) => {
+ const previous = current.find((node) => node.key === project.key);
+ return { ...project, children: asArray(previous?.children) };
+ }));
} catch {
/* bridge unavailable */
}
}, []);
+ useEffect(() => {
+ treeRef.current = tree;
+ }, [tree]);
+
useEffect(() => {
manuallyCollapsedRef.current = manuallyCollapsed;
}, [manuallyCollapsed]);
@@ -719,6 +806,26 @@ export function ProjectTree({
void refresh();
}, [refresh, refreshSignal]);
+ useEffect(() => onProjectTreeChangedV2((event) => {
+ if (event.revision <= latestRevisionRef.current) return;
+ latestRevisionRef.current = event.revision;
+ void app.GetSessionCatalogStatus().then(setCatalogStatus).catch(() => {});
+ const affected = asArray(event.roots);
+ for (const project of treeRef.current) {
+ const key = projectNodeKey(project, 0);
+ if (!expanded.has(key)) continue;
+ if (projectTreeEventAffectsFolder(project, affected)) void loadProjectTopics(project);
+ }
+ }), [expanded, loadProjectTopics]);
+
+ useEffect(() => {
+ const filtering = query.trim() !== "" || timeFilter !== "all";
+ for (const project of treeRef.current) {
+ const key = projectNodeKey(project, 0);
+ if (filtering || expanded.has(key)) void loadProjectTopics(project);
+ }
+ }, [expanded, loadProjectTopics, query, timeFilter]);
+
// Following the active topic is a view concern over the tree already held.
useEffect(() => {
const collapsed = manuallyCollapsedRef.current;
@@ -852,7 +959,7 @@ export function ProjectTree({
items[next]?.focus();
};
- const toggleExpand = (key: string) => {
+ const toggleExpand = (key: string, project?: ProjectNode) => {
const willCollapse = expanded.has(key);
setExpanded((prev) => {
const next = new Set(prev);
@@ -866,6 +973,7 @@ export function ProjectTree({
else next.delete(key);
return next;
});
+ if (!willCollapse && project) void loadProjectTopics(project);
};
const folderKeys = useMemo(() => collapsibleFolderKeys(tree), [tree]);
@@ -1291,7 +1399,9 @@ export function ProjectTree({
const children = asArray(node.children);
const isExpanded = query.trim() ? true : expanded.has(key);
const hasChildren = children.length > 0;
- const folderDisclosure = projectTreeFolderDisclosure(hasChildren, isExpanded, classicTopics);
+ // Snapshot rows are shells with no children until the first page is loaded,
+ // so every project folder must remain expandable while indexing.
+ const folderDisclosure = projectTreeFolderDisclosure(hasChildren, isExpanded, true);
if (isTopicNode(node) || isRuntimeSessionNode(node)) {
const isSessionNode = isRuntimeSessionNode(node);
@@ -1784,6 +1894,7 @@ export function ProjectTree({
? classicTopicWindow(children, folderShowAll)
: { visible: children, hiddenCount: 0 };
const windowToggleVisible = classicTruncationActive && (hiddenCount > 0 || (folderShowAll && children.length > CLASSIC_TOPIC_PREVIEW_LIMIT));
+ const backendPage = topicPageState[key];
const renderFolderChildren = () => {
if (!hasChildren) {
if (!classicTopics) return null;
@@ -1811,6 +1922,17 @@ export function ProjectTree({
{hiddenCount > 0 ? t("projectTree.showMoreTopics", { n: hiddenCount }) : t("projectTree.showFewerTopics")}
)}
+ {backendPage?.nextCursor && (
+
+ )}
);
@@ -1861,7 +1983,7 @@ export function ProjectTree({
className="project-tree__folder-main"
style={{ paddingLeft: 8 + depth * 16 }}
onClick={() => {
- if (folderDisclosure.canExpand) toggleExpand(key);
+ if (folderDisclosure.canExpand) toggleExpand(key, node);
}}
onKeyDown={(event) => {
if (event.key === "ContextMenu" || (event.shiftKey && event.key === "F10")) {
@@ -2317,6 +2439,11 @@ export function ProjectTree({
/>
)}
+ {(catalogStatus.state === "opening" || catalogStatus.state === "rebuilding" || catalogStatus.repairPending > 0) && (
+
+ {t("projectTree.indexingProgress", { done: catalogStatus.indexed, total: catalogStatus.total || "?" })}
+
+ )}
{compactTopics ? (
<>
{renderProjectHeader("workbench")}
diff --git a/desktop/frontend/src/lib/bridge.ts b/desktop/frontend/src/lib/bridge.ts
index 4a4cff51b6..dfd19059ce 100644
--- a/desktop/frontend/src/lib/bridge.ts
+++ b/desktop/frontend/src/lib/bridge.ts
@@ -9,6 +9,7 @@ import type * as GeneratedApp from "../../wailsjs/go/main/App";
import type { InvocationRequest } from "./invocationDisplay";
import { addBreadcrumb } from "./breadcrumbs";
+import { asArray } from "./array";
import { maybeShare } from "./queryCoalesce";
import { t } from "./i18n";
import { providerIsConfigured, providerRequiresKey, removeProviderAccessesForMock } from "./providerModels";
@@ -86,6 +87,12 @@ import type {
PluginInstallOptions,
PluginView,
ProjectNode,
+ ProjectTreeSnapshot,
+ ProjectTopicPageRequest,
+ ProjectTopicPage,
+ ProjectTopicKey,
+ SessionCatalogStatus,
+ ProjectTreeChangedV2,
PromptHistoryEntry,
PromptHistoryResult,
ProviderModelCatalogUpdate,
@@ -569,6 +576,11 @@ export interface AppBindings {
CloseTerminalForTab(tabID: string, sessionID: string): Promise