fix(buddy): stabilize desktop notification navigation

.playwright/scripts/__tests__/extensionContributions.e2e.mjs

@@ -5,7 +5,16 @@
 test('plugin-owned preferences activate contributions, yield native content and restore across restart', async ({ buddy }) => {
   const instance = await buddy.createInstance('plugin-contributions')
   let { app, page, diagnostics } = await instance.launch()
-  const navigate = async name => page.locator('.desktop-app-sidebar').getByRole('button', { name, exact: true }).click()
+  const backToTasks = async () => {
+    const back = page.locator('.desktop-back-to-tasks')
+    if (await back.count())
+      await back.click()
+  }
+  const openModule = async name => {
+    await backToTasks()
+    await page.locator('.desktop-sidebar-footer').getByRole('button', { name, exact: true }).click()
+  }
+  const openPluginPage = async id => page.locator(`[data-extension-id="${id}"]`).getByRole('button', { name: '打开', exact: true }).click()
   const nativeFooter = () => page.locator('.desktop-chat-composer__disclaimer')
   const pluginFrame = async (name, file) => {
     let result
@@ -24,7 +33,7 @@
   async function install(name) {
     const directory = path.join(instance.home, 'fixtures', name)
     const id = await writeContributionPlugin(directory, name)
-    await navigate('插件')
+    await openModule('插件')
     await app.evaluate(({ dialog }, directory) => {
       dialog.showOpenDialog = async () => ({ canceled: false, filePaths: [directory] })
     }, directory)
@@ -35,14 +44,15 @@
     await expect(page.getByText('界面呈现', { exact: true })).toHaveCount(0)
   }
   async function preference(name, enabled) {
-    await navigate(`Settings ${name}`)
+    await openModule('插件')
+    await openPluginPage(`tests.${name}`)
     const settings = await pluginFrame(name, 'settings')
     await settings.getByRole('checkbox', { name: 'Enable footer' }).setChecked(enabled)
     await expect(settings.getByRole('status')).toHaveText(enabled ? 'Enabled' : 'Disabled')
-    await navigate('任务')
+    await backToTasks()
   }
   await install('alpha')
-  await navigate('任务')
+  await backToTasks()
   await expect(nativeFooter()).toBeVisible()
   await preference('alpha', true)
   const alpha = await pluginFrame('alpha', 'footer')
@@ -72,7 +82,7 @@
 
   await instance.stop()
   ;({ app, page, diagnostics } = await instance.launch())
-  await navigate('任务')
+  await backToTasks()
   const restoredAlpha = await pluginFrame('alpha', 'footer')
   await expect.poll(() => restoredAlpha.evaluate(() => window.fixture.visible)).toBe(true)
   await page.evaluate(() => window.lexoraDesktop.extensions.enable('tests.alpha', false))

README.md

@@ -73,7 +73,7 @@ Vue + Electron 承载桌面体验，独立的 TypeScript Runtime 承载本地 Ag
 
 ## 本地开发
 
-需要 Node.js 26+、pnpm 11.5+ 与 Rust 工具链；平台依赖见[构建说明](packaging/buddy/README.md)。在仓库根目录运行：
+需要 Node.js 26+、pnpm 12.5.1+ 与 Rust 工具链；平台依赖见[构建说明](packaging/buddy/README.md)。在仓库根目录运行：
 
 ```bash
 pnpm --filter @uselexora/lexora --filter '@uselexora/lexora-buddy...' --filter @uselexora/lexora-website install --frozen-lockfile
@@ -83,6 +83,17 @@ pnpm dev
 pnpm dev:website
 ```
 
+### 使用真实数据预览 Buddy UI
+
+Buddy 未打包开发模式默认使用独立的数据目录 `~/.lexora-dev`。如果需要让最新代码继承已安装 Lexora 的真实配置、会话和授权，可在启动前使用 `stable` profile：
+
+```powershell
+$env:LEXORA_BUDDY_PROFILE = "stable"
+pnpm dev:buddy
+```
+
+开发预览地址为 <http://localhost:1420/>。`stable` profile 会直接使用正式数据目录 `~/.lexora`；Windows 下通常对应 `C:\Users\<用户名>\.lexora`。它不会复制或迁移数据，因此开发版产生的配置、会话或授权写入也可能影响正式版。该方式适合 UI 预览，执行会修改数据的功能测试前应先备份真实数据，或改用默认的开发目录。
+
 ## 参与贡献
 
 发现问题，欢迎[提个 Issue](https://github.com/useLexora/Lexora/issues)。若你已经动手实现了自己的想法，欢迎按[贡献说明](CONTRIBUTING.md)提交 PR，和大家分享你的方案。

apps/buddy/electron/main/DesktopNotificationService.ts

@@ -11,7 +11,10 @@ export interface DesktopNotificationInput {
 }
 
 export interface DesktopSystemNotification {
+  close: () => void
   onClick: (listener: () => void) => void
+  onClose: (listener: (reason?: 'userCanceled' | 'applicationHidden' | 'timedOut') => void) => void
+  onFailed: (listener: () => void) => void
   show: () => void
 }
 
@@ -28,6 +31,7 @@ export interface DesktopNotificationServiceOptions {
     'notificationsEnabled' | 'notifyWhenFocused'
   >
   isWindowFocused: () => boolean
+  onError: (error: unknown) => void
   openTarget: (target: DesktopNotificationTarget) => Promise<void> | void
   request: DesktopRuntimeGateway['request']
 }
@@ -50,19 +54,23 @@ const BODY_LABELS = {
 export class DesktopNotificationService {
   readonly #options: DesktopNotificationServiceOptions
   readonly #shownEvents = new Set<string>()
+  readonly #pendingEvents = new Set<string>()
+  // Keep native click handlers alive independently of the selected conversation.
+  readonly #notifications = new Map<string, DesktopSystemNotification>()
+  #disposed = false
 
   constructor(options: DesktopNotificationServiceOptions) {
     this.#options = options
   }
 
   async handle(notification: { method: string, params: unknown }): Promise<void> {
-    if (notification.method !== 'run.event')
+    if (this.#disposed || notification.method !== 'run.event')
       return
     const event = runsRequestSchemas.runStateEvent.safeParse(notification.params)
     if (!event.success)
       return
     const eventKey = `${event.data.runId}:${event.data.sequence}:${event.data.type}`
-    if (this.#shownEvents.has(eventKey))
+    if (this.#shownEvents.has(eventKey) || this.#pendingEvents.has(eventKey))
       return
     if (!shouldShowDesktopNotification({
       eventType: event.data.type,
@@ -72,24 +80,79 @@ export class DesktopNotificationService {
       return
     }
 
-    const run = runsResponseSchemas.run.parse(
-      await this.#options.request('runs.get', { runId: event.data.runId }),
-    )
-    const conversation = conversationResponseSchemas.conversation.parse(
-      await this.#options.request('conversations.get', { conversationId: run.conversationId }),
-    )
-    const labels = BODY_LABELS[this.#options.getLanguage()]
-    const systemNotification = this.#options.createNotification({
-      body: labels[event.data.type as keyof Omit<typeof labels, 'untitled'>],
-      title: conversation.title?.trim() || labels.untitled,
-    })
-    systemNotification.onClick(() => {
-      void this.#options.openTarget({
-        conversationId: run.conversationId,
-        runId: run.id,
+    this.#pendingEvents.add(eventKey)
+    try {
+      const run = runsResponseSchemas.run.parse(
+        await this.#options.request('runs.get', { runId: event.data.runId }),
+      )
+      if (this.#disposed)
+        return
+      const conversation = conversationResponseSchemas.conversation.parse(
+        await this.#options.request('conversations.get', { conversationId: run.conversationId }),
+      )
+      if (this.#disposed)
+        return
+      const labels = BODY_LABELS[this.#options.getLanguage()]
+      const systemNotification = this.#options.createNotification({
+        body: labels[event.data.type as keyof Omit<typeof labels, 'untitled'>],
+        title: conversation.title?.trim() || labels.untitled,
       })
-    })
-    systemNotification.show()
-    this.#shownEvents.add(eventKey)
+      this.#notifications.set(eventKey, systemNotification)
+      const release = () => {
+        if (this.#notifications.get(eventKey) !== systemNotification)
+          return false
+        this.#notifications.delete(eventKey)
+        return true
+      }
+      systemNotification.onClick(() => {
+        if (!release())
+          return
+        void Promise.resolve().then(() => {
+          if (!this.#disposed) {
+            return this.#options.openTarget({
+              conversationId: run.conversationId,
+              runId: run.id,
+            })
+          }
+        }).catch(error => this.#options.onError(error))
+      })
+      systemNotification.onClose((reason) => {
+        // A timed-out/hidden Windows banner can still be clicked in Action Center.
+        if (reason === 'userCanceled')
+          release()
+      })
+      systemNotification.onFailed(() => {
+        if (release())
+          this.#shownEvents.delete(eventKey)
+      })
+      this.#shownEvents.add(eventKey)
+      try {
+        systemNotification.show()
+      }
+      catch (error) {
+        release()
+        this.#shownEvents.delete(eventKey)
+        throw error
+      }
+    }
+    finally {
+      this.#pendingEvents.delete(eventKey)
+    }
+  }
+
+  dispose(): void {
+    this.#disposed = true
+    const notifications = [...this.#notifications.values()]
+    this.#notifications.clear()
+    this.#shownEvents.clear()
+    this.#pendingEvents.clear()
+    for (const notification of notifications) {
+      try {
+        notification.close()
+      }
+      catch (error) {
+        this.#options.onError(error)
+      }
+    }
   }
 }