@@ -12,7 +12,7 @@ import {launchBrowser, loadPlaywright, waitForHttp} from "../dashboard-browser-s
 import {openWorkspacePage} from "./scenario-context.mjs";
 import {outputDir, packaged, port, repoRoot, startServer} from "./fixture.mjs";
 
-async function startAuthority() {
+async function startAuthority({unsettled = true} = {}) {
   const root = await mkdtemp(resolve(tmpdir(), "loopx-old-storage-browser-"));
   const source = "---\ngoal_id: multi-agent-projection\nhandoff_mode: soft_claim\n---\n" +
     "## Agent Todo\n- [ ] Private current requirement\n" +
@@ -26,7 +26,7 @@ async function startAuthority() {
   }));
   const leases = resolve(root, "runtime/goals/multi-agent-projection/task-leases");
   await mkdir(leases, {recursive: true});
-  await writeFile(resolve(leases, "removed.json"), JSON.stringify({schema_version: "task_lease_v0",
+  if (unsettled) await writeFile(resolve(leases, "removed.json"), JSON.stringify({schema_version: "task_lease_v0",
     goal_id: "multi-agent-projection", todo_id: "removed", owner: "agent-a", status: "active",
     idempotency_key: "original-private-key", version: 4, lease_epoch: 2,
     expires_at: "2000-01-01T00:00:00Z", write_scopes: []}));
@@ -66,6 +66,69 @@ server.serve_forever()
   }
 }
 
+async function importSettled(browser, url, provider) {
+  const authority = await startAuthority({unsettled: false});
+  let context;
+  let applyCount = 0;
+  try {
+    context = await openWorkspacePage(browser, url, {beforeGoto: async (_api, page) => {
+      await page.route(/\/api\/chat\/goal-(storage|ownership)(?:[/?]|$)/, async route => {
+        const parsed = new URL(route.request().url());
+        const response = await route.fetch({url: authority.url + parsed.pathname + parsed.search});
+        if (parsed.pathname.endsWith("/import/apply") && ++applyCount === 1) {
+          assert.equal(response.status(), 200); // Commit succeeded; only its response is lost.
+          await route.abort("failed");
+        } else await route.fulfill({response});
+      });
+    }});
+    const {page} = context;
+    async function open() {
+      const navigation = page.getByRole("button", {name: "打开 Goal 导航", exact: true});
+      if (await navigation.isVisible()) await navigation.click();
+      await page.locator(".personal-goal-link", {hasText: "Multi Agent Projection"}).click();
+      await page.getByRole("button", {name: "Goal 设置", exact: true}).click();
+      await page.getByRole("button", {name: "任务所有权", exact: true}).click();
+      return page.getByRole("region", {name: "Goal 数据存储"});
+    }
+    let panel = await open();
+    await panel.getByText("1 项当前任务 · 1 项归档任务 · 0 项未结算 lease", {exact: true}).waitFor();
+    await panel.getByRole("combobox", {name: "目标存储", exact: true}).selectOption(provider);
+    await panel.getByRole("combobox", {name: "新策略", exact: true}).selectOption("hard_lease");
+    await panel.getByRole("button", {name: "备份并预览导入", exact: true}).click();
+    const apply = panel.getByRole("button", {name: "导入已审核的 Markdown 来源", exact: true});
+    try { await panel.getByRole("checkbox").waitFor(); }
+    catch (error) { throw new Error(`${error.message}; panel=${await panel.innerText()}`); }
+    assert.ok(await apply.isDisabled());
+    const saved = await page.evaluate(() => localStorage.getItem("loopx-storage-preview:multi-agent-projection"));
+    assert.ok(saved && !saved.includes(authority.root) && !saved.includes("Private"));
+    await page.reload({waitUntil: "networkidle"});
+    panel = await open();
+    await panel.getByRole("checkbox").waitFor();
+    await panel.getByRole("status").filter({hasText: "已准备"}).waitFor();
+    assert.ok(await panel.getByRole("button", {name: "导入已审核的 Markdown 来源", exact: true}).isDisabled());
+    assert.equal(applyCount, 0, "reload observes the original prepared operation without applying");
+    await page.setViewportSize({width: 390, height: 844});
+    assert.equal(await page.evaluate(() => document.documentElement.scrollWidth > innerWidth + 1), false);
+    await panel.getByRole("checkbox").focus();
+    await page.keyboard.press("Space");
+    assert.equal(await panel.getByRole("checkbox").isChecked(), true);
+    await panel.getByRole("button", {name: "导入已审核的 Markdown 来源", exact: true}).click();
+    await panel.getByRole("alert").waitFor();
+    assert.equal(applyCount, 1);
+    assert.equal(await page.evaluate(() => localStorage.getItem("loopx-storage-preview:multi-agent-projection")), saved);
+    await page.reload({waitUntil: "networkidle"});
+    panel = await open();
+    await panel.getByRole("status").filter({hasText: "原导入回执已核验"}).waitFor();
+    assert.equal(applyCount, 1, "completed readback does not apply again");
+    await panel.getByText(provider, {exact: true}).waitFor();
+    assert.equal(await panel.getByRole("checkbox").count(), 0);
+    assert.equal(await readFile(resolve(authority.root, "state.md"), "utf8"), authority.source);
+    await panel.getByRole("status").filter({hasText: "原导入回执已核验"}).scrollIntoViewIfNeeded();
+    await page.screenshot({path: resolve(outputDir, `goal-storage-import-${provider}-mobile.png`), animations: "disabled"});
+    assert.equal(context.errors.filter(e => !e.includes("ERR_FAILED")).length, 0, context.errors.join("; "));
+  } finally { await context?.close(); await authority.close(); }
+}
+
 const goalStorageScenario = {
   id: "goal-storage",
   async run({browser, url}) {
@@ -90,8 +153,12 @@ const goalStorageScenario = {
       let panel = await open();
       await panel.getByText("1 项当前任务 · 1 项归档任务 · 1 项未结算 lease", {exact: true}).waitFor();
       assert.equal(await panel.getByRole("checkbox").count(), 0);
-      assert.equal(await panel.getByRole("combobox").count(), 0);
-      assert.ok((await panel.innerText()).includes("尚不能导入"));
+      assert.equal(await panel.getByRole("combobox").count(), 2);
+      assert.ok((await panel.innerText()).includes("此操作不会替你停止 Host"));
+      await panel.getByRole("combobox", {name: "新策略", exact: true}).selectOption("soft_claim");
+      await panel.getByRole("button", {name: "备份并预览导入", exact: true}).click();
+      await panel.getByText("cold_import_lease_requires_settlement", {exact: true}).waitFor();
+      assert.equal(await panel.getByRole("checkbox").count(), 0);
       assert.ok(!(await panel.innerText()).includes("Private"));
       await page.screenshot({path: resolve(outputDir, "goal-storage-cold-desktop.png"), animations: "disabled"});
       const outbox = resolve(authority.root, "runtime/authority-shadow/outbox/multi-agent-projection/todos");
@@ -116,13 +183,14 @@ const goalStorageScenario = {
       await page.reload({waitUntil: "networkidle"});
       panel = await open("en");
       await panel.getByText("1 active tasks · 1 archived tasks · 1 unsettled leases", {exact: true}).waitFor();
-      assert.ok((await panel.innerText()).includes("Import is not available here yet"));
-      assert.equal(writes, 0);
+      assert.ok((await panel.innerText()).includes("This does not stop Hosts"));
+      assert.equal(writes, 1, "only the explicit refused preview posts");
       assert.equal(await readFile(resolve(authority.root, "state.md"), "utf8"), authority.source);
       assert.equal(await readFile(residue, "utf8"), "{unrecognized original bytes");
       // Deliberately induced HTTP failures may be logged by the browser.
-      assert.equal(context.errors.filter(e => !e.includes("503")).length, 0, context.errors.join("; "));
-      return {note: "Cold/archived tasks, expired orphan lease, original outbox, unavailable source and fresh recovery; no import or write; packaged Chinese/English desktop/mobile."};
+      assert.equal(context.errors.filter(e => !e.includes("503") && !e.includes("409")).length, 0, context.errors.join("; "));
+      for (const provider of ["file", "sqlite"]) await importSettled(browser, url, provider);
+      return {note: "Cold/archived tasks, expired orphan lease, original outbox, unavailable source and fresh recovery; refused expired lease; confirmed File/SQLite import, readonly reload and lost-response original receipt recovery; packaged Chinese/English desktop/mobile."};
     } finally { await context?.close(); await authority.close(); }
   },
 };