feat(desktop): add persistent memory recall and conversation search

apps/desktop/e2e-tests/test/helpers/openSettingsWindow.js

@@ -0,0 +1,49 @@
+export async function openSettingsWindow() {
+    const mainWindowHandle = await browser.getWindowHandle();
+    let settingsHandle = null;
+
+    await browser.waitUntil(async () => {
+        return browser.execute(() => Boolean(window.__TOUCHAI_E2E__));
+    });
+
+    await browser
+        .executeAsync((done) => {
+            window.__TOUCHAI_E2E__
+                .openSettingsWindow()
+                .then(() => done({ ok: true }))
+                .catch((error) => done({ ok: false, error: String(error) }));
+        })
+        .then((result) => {
+            if (!result?.ok) {
+                throw new Error(
+                    `Failed to open settings window: ${result?.error ?? 'unknown error'}`
+                );
+            }
+        });
+
+    await browser.waitUntil(async () => {
+        const handles = await browser.getWindowHandles();
+        for (const handle of handles) {
+            if (handle === mainWindowHandle) {
+                continue;
+            }
+
+            await browser.switchToWindow(handle);
+            const currentUrl = await browser.getUrl();
+            if (currentUrl.includes('/settings')) {
+                settingsHandle = handle;
+                return true;
+            }
+        }
+
+        await browser.switchToWindow(mainWindowHandle);
+        return false;
+    });
+
+    if (!settingsHandle) {
+        throw new Error('Unable to locate settings window handle.');
+    }
+
+    await browser.switchToWindow(settingsHandle);
+    return { mainWindowHandle, settingsHandle };
+}

apps/desktop/e2e-tests/test/specs/settings-memory.e2e.js

@@ -0,0 +1,68 @@
+import { openSettingsWindow } from '../helpers/openSettingsWindow.js';
+
+describe('TouchAI settings memory acceptance', () => {
+    it('persists a completed memory when the user switches sections immediately', async () => {
+        const { mainWindowHandle } = await openSettingsWindow();
+        const settingsView = await $("[data-testid='settings-view']");
+        const memoryNav = await $("[data-testid='settings-nav-memory']");
+        const generalNav = await $("[data-testid='settings-nav-general']");
+
+        await settingsView.waitForDisplayed();
+        await memoryNav.waitForDisplayed();
+        await memoryNav.click();
+
+        const addButton = await $("[data-testid='settings-memory-add-button']");
+        await addButton.waitForDisplayed();
+        await addButton.click();
+
+        const titleInput = await $("[data-testid='settings-memory-title-input']");
+        const applicabilityInput = await $("[data-testid='settings-memory-applicability-input']");
+        const contentInput = await $("[data-testid='settings-memory-content-input']");
+
+        await titleInput.waitForDisplayed();
+        await titleInput.setValue('Desktop workflow');
+        await applicabilityInput.setValue('When TouchAI settings or tray flows matter');
+        await contentInput.setValue(
+            'TouchAI is a desktop agent. Verify settings and tray behavior before answering.'
+        );
+
+        await generalNav.click();
+
+        const generalSection = await $("[data-testid='settings-general-section']");
+        await generalSection.waitForDisplayed();
+
+        await memoryNav.click();
+        const persistedTitleInput = await $("[data-testid='settings-memory-title-input']");
+        const persistedApplicabilityInput = await $(
+            "[data-testid='settings-memory-applicability-input']"
+        );
+        const persistedContentInput = await $("[data-testid='settings-memory-content-input']");
+        await persistedTitleInput.waitForDisplayed();
+
+        await browser.waitUntil(async () => {
+            return (await persistedTitleInput.getValue()) === 'Desktop workflow';
+        });
+        await browser.waitUntil(async () => {
+            return (
+                (await persistedApplicabilityInput.getValue()) ===
+                'When TouchAI settings or tray flows matter'
+            );
+        });
+        await browser.waitUntil(async () => {
+            return (
+                (await persistedContentInput.getValue()) ===
+                'TouchAI is a desktop agent. Verify settings and tray behavior before answering.'
+            );
+        });
+
+        const memoryItems = await $$("[data-testid^='settings-memory-item-']");
+        if (memoryItems.length !== 1) {
+            throw new Error(
+                `Expected exactly one persisted memory item, received ${memoryItems.length}.`
+            );
+        }
+
+        await browser.closeWindow();
+        await browser.switchToWindow(mainWindowHandle);
+    });
+});

apps/desktop/e2e-tests/test/specs/settings-smoke.e2e.js

@@ -1,51 +1,8 @@
+import { openSettingsWindow } from '../helpers/openSettingsWindow.js';
+
 describe('TouchAI settings smoke', () => {
     it('opens the settings window and persists the start-minimized toggle', async () => {
-        const mainWindowHandle = await browser.getWindowHandle();
-        let settingsHandle = null;
-
-        await browser.waitUntil(async () => {
-            return browser.execute(() => Boolean(window.__TOUCHAI_E2E__));
-        });
-
-        await browser
-            .executeAsync((done) => {
-                window.__TOUCHAI_E2E__
-                    .openSettingsWindow()
-                    .then(() => done({ ok: true }))
-                    .catch((error) => done({ ok: false, error: String(error) }));
-            })
-            .then((result) => {
-                if (!result?.ok) {
-                    throw new Error(
-                        `Failed to open settings window: ${result?.error ?? 'unknown error'}`
-                    );
-                }
-            });
-
-        await browser.waitUntil(async () => {
-            const handles = await browser.getWindowHandles();
-            for (const handle of handles) {
-                if (handle === mainWindowHandle) {
-                    continue;
-                }
-
-                await browser.switchToWindow(handle);
-                const currentUrl = await browser.getUrl();
-                if (currentUrl.includes('/settings')) {
-                    settingsHandle = handle;
-                    return true;
-                }
-            }
-
-            await browser.switchToWindow(mainWindowHandle);
-            return false;
-        });
-
-        if (!settingsHandle) {
-            throw new Error('Unable to locate settings window handle.');
-        }
-
-        await browser.switchToWindow(settingsHandle);
+        const { mainWindowHandle } = await openSettingsWindow();
 
         const settingsView = await $("[data-testid='settings-view']");
         const generalSection = await $("[data-testid='settings-general-section']");

apps/desktop/e2e-tests/wdio.conf.js

@@ -177,6 +177,7 @@ export const config = {
             path.join(__dirname, 'test/specs/search-smoke.e2e.js'),
             path.join(__dirname, 'test/specs/settings-smoke.e2e.js'),
         ],
+        path.join(__dirname, 'test/specs/settings-memory.e2e.js'),
     ],
     bail: 1,
     maxInstances: 1,

apps/desktop/src-tauri/src/core/database/runtime/import.rs

@@ -155,22 +155,72 @@ async fn ensure_import_required_tables(
     ];
 
     for &table in REQUIRED_TABLES {
-        let exists = sqlx::query_scalar::<_, i64>(
-            "SELECT COUNT(*) FROM imported.sqlite_master WHERE type = 'table' AND name = ?",
-        )
-        .bind(table)
-        .fetch_one(&mut **connection)
-        .await
-        .map_err(|error| format!("Failed to inspect import table '{table}': {error}"))?;
-
-        if exists == 0 {
+        if !imported_table_exists(connection, table).await? {
             return Err(format!("导入数据库缺少必需数据表: {table}"));
         }
     }
 
     Ok(())
 }
 
+async fn imported_table_exists(
+    connection: &mut sqlx::pool::PoolConnection<Sqlite>,
+    table: &str,
+) -> Result<bool, String> {
+    let exists = sqlx::query_scalar::<_, i64>(
+        "SELECT COUNT(*) FROM imported.sqlite_master WHERE type = 'table' AND name = ?",
+    )
+    .bind(table)
+    .fetch_one(&mut **connection)
+    .await
+    .map_err(|error| format!("Failed to inspect import table '{table}': {error}"))?;
+
+    Ok(exists > 0)
+}
+
+async fn prepare_full_import_memory_items(
+    connection: &mut sqlx::pool::PoolConnection<Sqlite>,
+) -> Result<(), String> {
+    sqlx::raw_sql(
+        "DROP TABLE IF EXISTS temp_imported_memory_items;
+         CREATE TEMP TABLE temp_imported_memory_items (
+             id INTEGER PRIMARY KEY,
+             title TEXT NOT NULL,
+             applicability TEXT NOT NULL,
+             content TEXT NOT NULL,
+             enabled INTEGER NOT NULL,
+             source_session_id INTEGER,
+             source_message_id INTEGER,
+             created_at TEXT NOT NULL,
+             updated_at TEXT NOT NULL,
+             last_used_at TEXT
+         );",
+    )
+    .execute(&mut **connection)
+    .await
+    .map_err(|error| format!("Failed to prepare imported memory staging table: {error}"))?;
+
+    if !imported_table_exists(connection, "memory_items").await? {
+        return Ok(());
+    }
+
+    sqlx::raw_sql(
+        "INSERT INTO temp_imported_memory_items (
+             id, title, applicability, content, enabled, source_session_id, source_message_id,
+             created_at, updated_at, last_used_at
+         )
+         SELECT
+             id, title, applicability, content, enabled, source_session_id, source_message_id,
+             created_at, updated_at, last_used_at
+         FROM imported.memory_items;",
+    )
+    .execute(&mut **connection)
+    .await
+    .map_err(|error| format!("Failed to stage imported memory items: {error}"))?;
+
+    Ok(())
+}
+
 async fn merge_chat_data(
     connection: &mut sqlx::pool::PoolConnection<Sqlite>,
     database_contract: &DatabaseContractSource,
@@ -194,6 +244,7 @@ async fn merge_full_data(
     )
     .await?;
     merge_chat_data(connection, database_contract).await?;
+    prepare_full_import_memory_items(connection).await?;
     execute_sql_artifact_on_connection(
         connection,
         database_contract,

apps/desktop/src/database/artifacts/import/full_postlude.sql

@@ -1,3 +1,26 @@
+DELETE FROM main.memory_items;
+
+INSERT INTO main.memory_items (
+    id, title, applicability, content, enabled, source_session_id, source_message_id,
+    created_at, updated_at, last_used_at
+)
+SELECT
+    source_memory.id,
+    source_memory.title,
+    source_memory.applicability,
+    source_memory.content,
+    source_memory.enabled,
+    source_session_map.target_session_id,
+    source_message_map.target_message_id,
+    source_memory.created_at,
+    source_memory.updated_at,
+    source_memory.last_used_at
+FROM temp_imported_memory_items AS source_memory
+LEFT JOIN temp_session_map AS source_session_map
+    ON source_session_map.source_session_id = source_memory.source_session_id
+LEFT JOIN temp_message_map AS source_message_map
+    ON source_message_map.source_message_id = source_memory.source_message_id;
+
 DELETE FROM main.sqlite_sequence
 WHERE name IN (
     'providers',
@@ -8,6 +31,7 @@ WHERE name IN (
     'message_attachments',
     'session_turns',
     'session_turn_attempts',
+    'memory_items',
     'settings',
     'statistics',
     'llm_metadata'
@@ -21,6 +45,7 @@ INSERT INTO main.sqlite_sequence (name, seq) SELECT 'attachments', COALESCE(MAX(
 INSERT INTO main.sqlite_sequence (name, seq) SELECT 'message_attachments', COALESCE(MAX(id), 0) FROM main.message_attachments;
 INSERT INTO main.sqlite_sequence (name, seq) SELECT 'session_turns', COALESCE(MAX(id), 0) FROM main.session_turns;
 INSERT INTO main.sqlite_sequence (name, seq) SELECT 'session_turn_attempts', COALESCE(MAX(id), 0) FROM main.session_turn_attempts;
+INSERT INTO main.sqlite_sequence (name, seq) SELECT 'memory_items', COALESCE(MAX(id), 0) FROM main.memory_items;
 INSERT INTO main.sqlite_sequence (name, seq) SELECT 'settings', COALESCE(MAX(id), 0) FROM main.settings;
 INSERT INTO main.sqlite_sequence (name, seq) SELECT 'statistics', COALESCE(MAX(id), 0) FROM main.statistics;
 INSERT INTO main.sqlite_sequence (name, seq) SELECT 'llm_metadata', COALESCE(MAX(id), 0) FROM main.llm_metadata;

apps/desktop/src/database/artifacts/runtime/seed.sql

@@ -117,12 +117,24 @@ INSERT INTO built_in_tools (
 SELECT 'file_search', 'FileSearch', '搜索本机文件', 1, 'low', NULL
 WHERE NOT EXISTS (SELECT 1 FROM built_in_tools WHERE tool_id = 'file_search');
 
+INSERT INTO built_in_tools (
+    tool_id, display_name, description, enabled, risk_level, config_json
+)
+SELECT 'memory', 'Memory', '读取和维护记忆', 1, 'medium', NULL
+WHERE NOT EXISTS (SELECT 1 FROM built_in_tools WHERE tool_id = 'memory');
+
 INSERT INTO built_in_tools (
     tool_id, display_name, description, enabled, risk_level, config_json
 )
 SELECT 'read', 'Read', '读取本地文件或目录，支持图片与 PDF', 1, 'medium', NULL
 WHERE NOT EXISTS (SELECT 1 FROM built_in_tools WHERE tool_id = 'read');
 
+INSERT INTO built_in_tools (
+    tool_id, display_name, description, enabled, risk_level, config_json
+)
+SELECT 'search_conversation', 'SearchConversation', '搜索历史对话', 1, 'low', NULL
+WHERE NOT EXISTS (SELECT 1 FROM built_in_tools WHERE tool_id = 'search_conversation');
+
 INSERT INTO built_in_tools (
     tool_id, display_name, description, enabled, risk_level, config_json
 )

apps/desktop/src/database/drizzle/0003_memory_items.sql

@@ -0,0 +1,17 @@
+CREATE TABLE `memory_items` (
+	`id` integer PRIMARY KEY AUTOINCREMENT NOT NULL,
+	`title` text NOT NULL,
+	`applicability` text NOT NULL,
+	`content` text NOT NULL,
+	`enabled` integer DEFAULT 1 NOT NULL,
+	`source_session_id` integer,
+	`source_message_id` integer,
+	`created_at` text DEFAULT (datetime('now')) NOT NULL,
+	`updated_at` text DEFAULT (datetime('now')) NOT NULL,
+	`last_used_at` text,
+	FOREIGN KEY (`source_session_id`) REFERENCES `sessions`(`id`) ON UPDATE no action ON DELETE set null,
+	FOREIGN KEY (`source_message_id`) REFERENCES `messages`(`id`) ON UPDATE no action ON DELETE set null
+);
+--> statement-breakpoint
+CREATE INDEX `memory_items_enabled_idx` ON `memory_items` (`enabled`);--> statement-breakpoint
+CREATE INDEX `memory_items_updated_at_idx` ON `memory_items` (`updated_at`);

apps/desktop/src/database/drizzle/meta/_journal.json

@@ -22,6 +22,13 @@
       "when": 1780185600000,
       "tag": "0002_quick_search_click_stats_unique",
       "breakpoints": true
+    },
+    {
+      "idx": 3,
+      "version": "7",
+      "when": 1780550400000,
+      "tag": "0003_memory_items",
+      "breakpoints": true
     }
   ]
 }

apps/desktop/src/database/queries/index.ts

@@ -8,10 +8,12 @@ export * from './llmMetadata';
 export * from './mcpServers';
 export * from './mcpToolLogs';
 export * from './mcpTools';
+export * from './memoryItems';
 export * from './messages';
 export * from './models';
 export * from './providers';
 export * from './quickSearchClicks';
+export * from './searchConversation';
 export * from './sessions';
 export * from './sessionTurnAttempts';
 export * from './sessionTurns';