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

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

@@ -7,11 +7,14 @@ import {
   activeTabIdAtom,
   archiveInitialViewAtom,
   currentWorkspaceIdAtom,
+  agentRuntimeEventsAtom,
   settingsInitialTabAtom,
   sidebarCollapsedAtom,
   tabsAtom,
   workspacePinnedIdsAtom,
 } from '@/atoms'
+import { removeRuntimeEvents } from '@/hooks/runtime-event-state'
+import { threadMessagesCache } from '@/components/agent/thread-messages-cache'
 import { CreateWorkspaceDialog } from '@/components/workspace/CreateWorkspaceDialog'
 import { ConfirmDialog } from '@/components/ui/confirm-dialog'
 import {
@@ -103,6 +106,7 @@ export function LeftSidebar({ forceCollapsed = false }: { forceCollapsed?: boole
   const [workspaces, setWorkspaces] = useAtom(agentWorkspacesAtom)
   const [pinnedIds, setPinnedIds] = useAtom(workspacePinnedIdsAtom)
   const setSettingsInitialTab = useSetAtom(settingsInitialTabAtom)
+  const setRuntimeEvents = useSetAtom(agentRuntimeEventsAtom)
   const setArchiveInitialView = useSetAtom(archiveInitialViewAtom)
   const [expandedWorkspaceIds, setExpandedWorkspaceIds] = useState<string[]>([])
   const [createWorkspaceOpen, setCreateWorkspaceOpen] = useState(false)
@@ -362,6 +366,8 @@ export function LeftSidebar({ forceCollapsed = false }: { forceCollapsed?: boole
         try {
           await sidecarCall(AGENT_IPC_CHANNELS.TRASH_THREAD, { threadId: thread.id })
           removeThreadFromNavigation(thread.id)
+          setRuntimeEvents((prev) => removeRuntimeEvents(prev, thread.id))
+          threadMessagesCache.invalidate(thread.id)
           toast.success('已移入回收站')
         } catch (error) {
           console.error('[LeftSidebar] 移入回收站失败:', error)

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

@@ -12,7 +12,9 @@ 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 { agentInputDraftAtom, agentInputHistoryAtom, agentRuntimeEventsAtom, agentWorkspacesAtom } from '@/atoms'
+import { removeRuntimeEvents } from '@/hooks/runtime-event-state'
+import { threadMessagesCache } from '@/components/agent/thread-messages-cache'
 import { sidecarCall } from '@/lib/desktop-api'
 import { removeDraft, removeHistory } from '@/lib/agent-input-draft-state'
 import { ConfirmDialog } from '@/components/ui/confirm-dialog'
@@ -36,12 +38,15 @@ export function ArchiveSettings({ initialView }: { initialView?: 'archive' | 'tr
   const workspaces = useAtomValue(agentWorkspacesAtom)
   const setDraftState = useSetAtom(agentInputDraftAtom)
   const setHistoryState = useSetAtom(agentInputHistoryAtom)
+  const setRuntimeEvents = useSetAtom(agentRuntimeEventsAtom)
   const removeThreadInputState = React.useCallback(
     (threadId: string) => {
       setDraftState((prev) => removeDraft(prev, threadId))
       setHistoryState((prev) => removeHistory(prev, threadId))
+      setRuntimeEvents((prev) => removeRuntimeEvents(prev, threadId))
+      threadMessagesCache.invalidate(threadId)
     },
-    [setDraftState, setHistoryState],
+    [setDraftState, setHistoryState, setRuntimeEvents],
   )
   const [view, setView] = React.useState<View>(initialView ?? 'archive')
   const [archivedThreads, setArchivedThreads] = React.useState<AgentThreadMeta[]>([])

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,46 @@ 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('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,9 @@ export function hydrateRuntimeEvents(
   if (result.events.length === 0) {
     return prev
   }
-  const events = mergeHydratedRuntimeEvents(result.events, current?.events ?? [])
+  // 与 append 路径同上限：sidecar 回放不封顶，hydrate 不 trim 会让重开的超长线程
+  // 全量驻留内存（且直到下一条 append 前都无界）。trim 规则同 append：先丢头部 delta。
+  const events = trimRuntimeEvents(mergeHydratedRuntimeEvents(result.events, current?.events ?? []))
   if (current && sameRuntimeEvents(current.events, events)) {
     return prev
   }
@@ -91,6 +93,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[],