🐛 fix(web): 修复 runtime events 内存无界增长

apps/web/src/components/app-shell/LeftSidebar.tsx

@@ -12,6 +12,7 @@ import {
   tabsAtom,
   workspacePinnedIdsAtom,
 } from '@/atoms'
+import { useReleaseThreadState } from '@/hooks/use-release-thread-state'
 import { CreateWorkspaceDialog } from '@/components/workspace/CreateWorkspaceDialog'
 import { ConfirmDialog } from '@/components/ui/confirm-dialog'
 import {
@@ -103,6 +104,7 @@ export function LeftSidebar({ forceCollapsed = false }: { forceCollapsed?: boole
   const [workspaces, setWorkspaces] = useAtom(agentWorkspacesAtom)
   const [pinnedIds, setPinnedIds] = useAtom(workspacePinnedIdsAtom)
   const setSettingsInitialTab = useSetAtom(settingsInitialTabAtom)
+  const releaseThreadState = useReleaseThreadState()
   const setArchiveInitialView = useSetAtom(archiveInitialViewAtom)
   const [expandedWorkspaceIds, setExpandedWorkspaceIds] = useState<string[]>([])
   const [createWorkspaceOpen, setCreateWorkspaceOpen] = useState(false)
@@ -339,6 +341,8 @@ export function LeftSidebar({ forceCollapsed = false }: { forceCollapsed?: boole
         try {
           await sidecarCall(AGENT_IPC_CHANNELS.ARCHIVE_THREAD, { threadId: thread.id })
           removeThreadFromNavigation(thread.id)
+          // 归档后线程只能恢复后再打开，重开时 hydrate 重建，清掉无副作用
+          releaseThreadState(thread.id)
           toast.success('已归档')
         } catch (error) {
           console.error('[LeftSidebar] 归档失败:', error)
@@ -362,6 +366,7 @@ export function LeftSidebar({ forceCollapsed = false }: { forceCollapsed?: boole
         try {
           await sidecarCall(AGENT_IPC_CHANNELS.TRASH_THREAD, { threadId: thread.id })
           removeThreadFromNavigation(thread.id)
+          releaseThreadState(thread.id)
           toast.success('已移入回收站')
         } catch (error) {
           console.error('[LeftSidebar] 移入回收站失败:', error)
@@ -426,6 +431,13 @@ export function LeftSidebar({ forceCollapsed = false }: { forceCollapsed?: boole
         await sidecarCall(AGENT_IPC_CHANNELS.DELETE_WORKSPACE, { id: workspaceId, mode })
         setWorkspaces((previous) => previous.filter((w) => w.id !== workspaceId))
         setCurrentWorkspaceId((current) => current === workspaceId ? null : current)
+        if (mode === 'deleteLumeData') {
+          // 会话随项目数据进回收站：与单线程删除路径一致，统一释放渲染端状态
+          // （keepHistory 会话转为普通会话仍在用，不能清）
+          for (const thread of threads.filter((item) => item.workspaceId === workspaceId)) {
+            releaseThreadState(thread.id)
+          }
+        }
         const nextThreads = await sidecarCall<AgentThreadMeta[]>(AGENT_IPC_CHANNELS.LIST_THREADS, {})
         setThreads(Array.isArray(nextThreads) ? nextThreads : [])
         toast.success(mode === 'keepHistory' ? '已移除项目，会话已转为普通会话' : '已移除项目并将 Lume 用户数据移入回收站')

apps/web/src/components/settings/ArchiveSettings.tsx

@@ -7,14 +7,14 @@ import {
   Trash,
   Trash2,
 } from 'lucide-react'
-import { useAtomValue, useSetAtom } from 'jotai'
+import { useAtomValue } from 'jotai'
 import { toast } from 'sonner'
 import type { AgentThreadMeta } from '@lume/shared'
 import { AGENT_IPC_CHANNELS } from '@lume/shared'
 import { cn } from '@/lib/utils'
-import { agentInputDraftAtom, agentInputHistoryAtom, agentWorkspacesAtom } from '@/atoms'
+import { agentWorkspacesAtom } from '@/atoms'
+import { useReleaseThreadState } from '@/hooks/use-release-thread-state'
 import { sidecarCall } from '@/lib/desktop-api'
-import { removeDraft, removeHistory } from '@/lib/agent-input-draft-state'
 import { ConfirmDialog } from '@/components/ui/confirm-dialog'
 
 import { Button } from '@/components/ui/button'
@@ -34,15 +34,7 @@ function formatDate(timestamp: number): string {
 
 export function ArchiveSettings({ initialView }: { initialView?: 'archive' | 'trash' }) {
   const workspaces = useAtomValue(agentWorkspacesAtom)
-  const setDraftState = useSetAtom(agentInputDraftAtom)
-  const setHistoryState = useSetAtom(agentInputHistoryAtom)
-  const removeThreadInputState = React.useCallback(
-    (threadId: string) => {
-      setDraftState((prev) => removeDraft(prev, threadId))
-      setHistoryState((prev) => removeHistory(prev, threadId))
-    },
-    [setDraftState, setHistoryState],
-  )
+  const removeThreadInputState = useReleaseThreadState()
   const [view, setView] = React.useState<View>(initialView ?? 'archive')
   const [archivedThreads, setArchivedThreads] = React.useState<AgentThreadMeta[]>([])
   const [trashedThreads, setTrashedThreads] = React.useState<AgentThreadMeta[]>([])

apps/web/src/components/settings/DataManagementSettings.tsx

@@ -11,8 +11,10 @@ import {
 import { toast } from 'sonner'
 import { listen } from '@/lib/desktop-runtime/event'
 import { relaunch } from '@/lib/desktop-runtime/process'
-import { DATA_CATEGORY_META } from '@lume/shared'
-import type { StorageStats } from '@lume/shared'
+import { AGENT_IPC_CHANNELS, DATA_CATEGORY_META } from '@lume/shared'
+import type { AgentThreadMeta, StorageStats } from '@lume/shared'
+import { useReleaseThreadState } from '@/hooks/use-release-thread-state'
+import { sidecarCall } from '@/lib/desktop-api'
 import { Button } from '@/components/ui/button'
 import { Checkbox } from '@/components/ui/checkbox'
 import {
@@ -44,6 +46,7 @@ import {
 import { useModelMetaReload } from '@/lib/model-meta-context'
 
 export function DataManagementSettings() {
+  const releaseThreadState = useReleaseThreadState()
   const [stats, setStats] = React.useState<StorageStats | null>(null)
   const [loadingStats, setLoadingStats] = React.useState(true)
   const [selection, setSelection] = React.useState<CleanupSelection>(createDefaultCleanupSelection())
@@ -111,7 +114,10 @@ export function DataManagementSettings() {
   const handleEmptyTrash = async () => {
     setEmptying(true)
     try {
+      // 与 ArchiveSettings 清空回收站同语义：回收站里的线程一并释放渲染端状态
+      const trashedThreads = await sidecarCall<AgentThreadMeta[]>(AGENT_IPC_CHANNELS.LIST_TRASHED_THREADS, {})
       const { cleanedCount } = await emptyTrash()
+      for (const thread of trashedThreads ?? []) releaseThreadState(thread.id)
       toast.success(`已清空回收站 ${cleanedCount} 项`)
       await refreshStats()
     } catch (error) {

apps/web/src/hooks/runtime-event-state.test.ts

@@ -1,5 +1,5 @@
 import { describe, expect, test } from 'bun:test'
-import { appendRuntimeEvent, appendRuntimeEvents, hydrateRuntimeEvents } from './runtime-event-state'
+import { appendRuntimeEvent, appendRuntimeEvents, hydrateRuntimeEvents, removeRuntimeEvents } from './runtime-event-state'
 import type { AgentThreadRuntimeEventsResult, LumeRuntimeEvent } from '@lume/shared'
 
 function runtimeEvent(event: Partial<LumeRuntimeEvent> & Pick<LumeRuntimeEvent, 'type'>): LumeRuntimeEvent {
@@ -290,6 +290,83 @@ describe('runtime-event-state', () => {
     expect(hydrated['thread-1']?.terminalStatus).toBe('completed')
   })
 
+  test('hydrate 同样受 MAX_EVENTS_PER_THREAD 上限约束', () => {
+    // 重开超长线程：sidecar 返回全量持久化事件，hydrate 后也必须 ≤ MAX，
+    // 与 append 路径上限一致（否则内存驻留无界，直到下一条 append 才触发 trim）。
+    const events: LumeRuntimeEvent[] = [
+      {
+        id: 'u0',
+        type: 'message.user.submitted',
+        threadId: 'thread-1',
+        runId: 'run-1',
+        createdAt: '2026-06-21T00:00:00.000Z',
+        text: 'hi',
+      } as LumeRuntimeEvent,
+    ]
+    for (let i = 1; i <= 2500; i++) {
+      events.push({
+        id: `d${i}`,
+        type: 'assistant.delta',
+        threadId: 'thread-1',
+        runId: 'run-1',
+        messageId: `msg-${i}`,
+        sequence: i,
+        createdAt: '2026-06-21T00:00:00.000Z',
+        delta: `c${i}`,
+      } as LumeRuntimeEvent)
+    }
+    const hydrated = hydrateRuntimeEvents({}, { threadId: 'thread-1', events })
+
+    expect(hydrated['thread-1']?.events.length).toBeLessThanOrEqual(2000)
+    expect(hydrated['thread-1']?.events[0]?.type).toBe('message.user.submitted')
+  })
+
+  test('hydrate 先合并相邻同流 delta 再 trim：同一条消息的分片回放不触发上限、正文完整', () => {
+    // 回放路径没有 assistant.final，正文完全靠 delta 累积；若不先按 live 规则合并，
+    // 逐 chunk 的回放计数会膨胀到上限，trim 丢头部 delta = 该 turn 渲染为空泡。
+    const events: LumeRuntimeEvent[] = [
+      {
+        id: 'u0',
+        type: 'message.user.submitted',
+        threadId: 'thread-1',
+        runId: 'run-1',
+        createdAt: '2026-06-21T00:00:00.000Z',
+        text: 'hi',
+      } as LumeRuntimeEvent,
+    ]
+    let full = ''
+    for (let i = 1; i <= 2500; i++) {
+      events.push({
+        id: `d${i}`,
+        type: 'assistant.delta',
+        threadId: 'thread-1',
+        runId: 'run-1',
+        messageId: 'msg-1',
+        sequence: i,
+        createdAt: '2026-06-21T00:00:00.000Z',
+        delta: `c${i};`,
+      } as LumeRuntimeEvent)
+      full += `c${i};`
+    }
+    const hydrated = hydrateRuntimeEvents({}, { threadId: 'thread-1', events })
+
+    const hydratedEvents = hydrated['thread-1']?.events ?? []
+    expect(hydratedEvents.length).toBe(2)
+    expect(hydratedEvents[1]?.type).toBe('assistant.delta')
+    expect(hydratedEvents[1]?.delta).toBe(full)
+    // 重开幂等：同样的回放再次 hydrate 不改变结果
+    expect(hydrateRuntimeEvents(hydrated, { threadId: 'thread-1', events })).toBe(hydrated)
+  })
+
+  test('removeRuntimeEvents 删除线程条目；条目不存在时返回原引用', () => {
+    const prev = appendRuntimeEvent({}, runtimeEvent({ type: 'run.completed' }))
+    const next = removeRuntimeEvents(prev, 'thread-1')
+
+    expect(next['thread-1']).toBeUndefined()
+    expect(removeRuntimeEvents(next, 'thread-1')).toBe(next)
+    expect(removeRuntimeEvents(next, 'other-thread')).toBe(next)
+  })
+
   test('超过 MAX_EVENTS_PER_THREAD 时优先丢头部 delta，保留结构事件与 user 提交', () => {
     let state: Record<string, { events: LumeRuntimeEvent[] }> = {}
     const u0 = {

apps/web/src/hooks/runtime-event-state.ts

@@ -74,7 +74,10 @@ export function hydrateRuntimeEvents(
   if (result.events.length === 0) {
     return prev
   }
-  const events = mergeHydratedRuntimeEvents(result.events, current?.events ?? [])
+  // 与 append 路径同上限：sidecar 回放不封顶，hydrate 不 trim 会让重开的超长线程
+  // 全量驻留内存（且直到下一条 append 前都无界）。merge 阶段已按 live 规则合并相邻
+  // 同流 delta（回放无 assistant.final，正文全靠 delta，先合并再 trim 才不会误伤）。
+  const events = trimRuntimeEvents(mergeHydratedRuntimeEvents(result.events, current?.events ?? []))
   if (current && sameRuntimeEvents(current.events, events)) {
     return prev
   }
@@ -91,6 +94,17 @@ export function hydrateRuntimeEvents(
   }
 }
 
+/** 删除线程的 runtime events 条目（回收站/永久删除时调用，防止 Record 只增不减）。 */
+export function removeRuntimeEvents(
+  prev: RuntimeEventState,
+  threadId: string,
+): RuntimeEventState {
+  if (!(threadId in prev)) return prev
+  const next = { ...prev }
+  delete next[threadId]
+  return next
+}
+
 function mergeHydratedRuntimeEvents(
   persistedEvents: LumeRuntimeEvent[],
   liveEvents: LumeRuntimeEvent[],
@@ -103,7 +117,30 @@ function mergeHydratedRuntimeEvents(
     seenIds.add(event.id)
     merged.push(event)
   }
-  return sortRuntimeEvents(merged)
+  // 回放按内容块/流事件逐条产出 delta，不像 live 路径边流边合并，计数远更膨胀——
+  // 直接 trim 会把头部 turn 的正文 delta 丢掉（回放没有 assistant.final 兜底重建，
+  // 投影 text 完全靠 delta 累积，丢了就是空泡）。先按 live 同规则合并相邻同流 delta，
+  // 让上限语义两条路径一致。
+  return mergeAdjacentStreamDeltas(sortRuntimeEvents(merged))
+}
+
+function mergeAdjacentStreamDeltas(events: LumeRuntimeEvent[]): LumeRuntimeEvent[] {
+  const merged: LumeRuntimeEvent[] = []
+  for (const event of events) {
+    const last = merged[merged.length - 1]
+    if (
+      last !== undefined
+      && (last.type === 'assistant.delta' || last.type === 'assistant.thinking_delta')
+      && (event.type === 'assistant.delta' || event.type === 'assistant.thinking_delta')
+      && last.type === event.type
+      && hasSameAssistantStreamOwner(last, event)
+    ) {
+      merged[merged.length - 1] = { ...last, delta: last.delta + event.delta }
+      continue
+    }
+    merged.push(event)
+  }
+  return merged
 }
 
 function compareRuntimeEvents(a: LumeRuntimeEvent, b: LumeRuntimeEvent): number {

apps/web/src/hooks/use-release-thread-state.ts

@@ -0,0 +1,28 @@
+import * as React from 'react'
+import { useSetAtom } from 'jotai'
+import { agentInputDraftAtom, agentInputHistoryAtom, agentRuntimeEventsAtom } from '@/atoms'
+import { removeRuntimeEvents } from '@/hooks/runtime-event-state'
+import { threadMessagesCache } from '@/components/agent/thread-messages-cache'
+import { removeDraft, removeHistory } from '@/lib/agent-input-draft-state'
+
+/**
+ * 线程移入回收站/永久删除/随项目数据删除时的渲染端状态统一释放。
+ *
+ * 所有移除路径必须走这里而不是手拼子集：draft/history 是 atomWithStorage
+ * （localStorage，跨重启残留），runtimeEvents/messagesCache 是会话期内存驻留，
+ * 漏清任何一项都会孤儿化。恢复路径无需对称操作——重开线程时 hydrate 会重建。
+ */
+export function useReleaseThreadState() {
+  const setDraftState = useSetAtom(agentInputDraftAtom)
+  const setHistoryState = useSetAtom(agentInputHistoryAtom)
+  const setRuntimeEvents = useSetAtom(agentRuntimeEventsAtom)
+  return React.useCallback(
+    (threadId: string) => {
+      setDraftState((prev) => removeDraft(prev, threadId))
+      setHistoryState((prev) => removeHistory(prev, threadId))
+      setRuntimeEvents((prev) => removeRuntimeEvents(prev, threadId))
+      threadMessagesCache.invalidate(threadId)
+    },
+    [setDraftState, setHistoryState, setRuntimeEvents],
+  )
+}