From b853293f184c1fe0deab5ff8aa50eee7cbced431 Mon Sep 17 00:00:00 2001
From: huangruiteng <huangrt01@163.com>
Date: Thu, 1 Oct 2026 16:30:37 +0800
Subject: [PATCH] fix(chat): retain inline steering drafts and retry identity

Signed-off-by: huangruiteng <huangrt01@163.com>
---
 .../composer-steering-recovery.ts             | 36 -----------
 .../personal-workspace/message-activity.tsx   | 52 +++++++++++++---
 .../personal-workspace-page.tsx               | 17 +-----
 .../personal-workspace/steering-recovery.ts   | 59 +++++++++++++++++++
 .../capable-manager-semantic-handoff-v0.md    | 12 ++++
 .../rfcs/loopx-overall-roadmap-v0.md          |  7 +++
 .../conversation-activity.mjs                 | 45 +++++++++++++-
 7 files changed, 166 insertions(+), 62 deletions(-)
 delete mode 100644 apps/presentation/dashboard/src/features/personal-workspace/composer-steering-recovery.ts
 create mode 100644 apps/presentation/dashboard/src/features/personal-workspace/steering-recovery.ts

diff --git a/apps/presentation/dashboard/src/features/personal-workspace/composer-steering-recovery.ts b/apps/presentation/dashboard/src/features/personal-workspace/composer-steering-recovery.ts
deleted file mode 100644
index bfd75598da..0000000000
--- a/apps/presentation/dashboard/src/features/personal-workspace/composer-steering-recovery.ts
+++ /dev/null
@@ -1,36 +0,0 @@
-/** Client retry identity only; the Chat ingress/store still owns delivery. */
-export type ComposerSteeringRequest = {
-  sessionId: string;
-  turnId: string;
-  text: string;
-  id: string;
-};
-
-const storageKey = "loopx-pw-composer-steering";
-
-export function readComposerSteeringRequests(): Map<string, ComposerSteeringRequest> {
-  try {
-    const raw = window.sessionStorage.getItem(storageKey);
-    const entries: unknown = raw ? JSON.parse(raw) : [];
-    if (!Array.isArray(entries)) return new Map();
-    return new Map(entries.flatMap((entry): [string, ComposerSteeringRequest][] => {
-      if (!Array.isArray(entry) || entry.length !== 2 || typeof entry[0] !== "string") return [];
-      const request = entry[1];
-      if (!request || typeof request !== "object" || Array.isArray(request)
-        || ![request.sessionId, request.turnId, request.text, request.id]
-          .every(value => typeof value === "string" && value.length > 0)) return [];
-      return [[entry[0], { sessionId: request.sessionId, turnId: request.turnId, text: request.text, id: request.id }]];
-    }));
-  } catch {
-    return new Map();
-  }
-}
-
-export function persistComposerSteeringRequests(requests: ReadonlyMap<string, ComposerSteeringRequest>) {
-  try {
-    window.sessionStorage.setItem(storageKey, JSON.stringify([...requests]));
-  } catch {
-    // As with composer drafts, unavailable browser storage retains only memory.
-    // No provider action or delivery conclusion follows from this cache.
-  }
-}
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx b/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx
index cf10c8b4de..5f6d35757b 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx
+++ b/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx
@@ -1,6 +1,7 @@
 import { useEffect, useRef, useState } from "react";
 import { Square } from "lucide-react";
 import { ChatApiError } from "../../data/chat.js";
+import { readSteeringRequest, retainSteeringRequest, retireSteeringRequest, type SteeringRequest } from "./steering-recovery";
 import { useWorkspaceI18n } from "./i18n";
 import type { WorkspaceMessage } from "./personal-workspace-model";
 
@@ -15,12 +16,23 @@ export function MessageActivity({ message, onInterruptTurn, onSteerTurn, onCance
   const zh = locale === "zh-CN";
   const [stopping, setStopping] = useState(false);
   const [error, setError] = useState<string | null>(null);
-  const [editing, setEditing] = useState(false);
-  const [draft, setDraft] = useState("");
+  const cacheKey = message.sourceSessionId && message.sourceTurnId
+    ? JSON.stringify(["inline", message.sourceSessionId, message.sourceTurnId]) : null;
+  const [restoredRequest] = useState(() => cacheKey ? readSteeringRequest(cacheKey) : undefined);
+  const [editing, setEditing] = useState(Boolean(restoredRequest));
+  const [draft, setDraft] = useState(restoredRequest?.text ?? "");
   const [steering, setSteering] = useState(false);
   const [steerError, setSteerError] = useState<string | null>(null);
   const [steerReceipt, setSteerReceipt] = useState(false);
-  const request = useRef<{ text: string; id: string } | null>(null);
+  const request = useRef<SteeringRequest | null>(restoredRequest ?? null);
+  useEffect(() => {
+    const restored = cacheKey ? readSteeringRequest(cacheKey) : undefined;
+    request.current = restored ?? null;
+    setDraft(restored?.text ?? "");
+    setEditing(Boolean(restored));
+    setSteerError(null);
+    setSteerReceipt(false);
+  }, [cacheKey]);
   const activity = message.activity ?? [];
   const [now, setNow] = useState(() => Date.now());
   useEffect(() => {
@@ -35,19 +47,43 @@ export function MessageActivity({ message, onInterruptTurn, onSteerTurn, onCance
     : `${Math.floor(elapsed / 60)}${zh ? "分" : "m "}${elapsed % 60}${zh ? "秒" : "s"}`;
   const quiet = message.updatedAt !== undefined && now - message.updatedAt >= 20000;
 
+  function updateDraft(text: string) {
+    setDraft(text);
+    const previous = request.current;
+    if (!text) {
+      if (cacheKey && previous) retireSteeringRequest(cacheKey, previous.id);
+      request.current = null;
+      return;
+    }
+    const next = { sessionId: message.sourceSessionId ?? "", turnId: message.sourceTurnId ?? "", text,
+      id: previous?.text.trim() === text.trim() ? previous.id : crypto.randomUUID() };
+    request.current = next;
+    if (cacheKey) retainSteeringRequest(cacheKey, next);
+  }
+
   async function steer() {
     const text = draft.trim();
     if (!text || !message.pending || !message.sourceTurnId || !onSteerTurn || steering) return;
     // Retain the operation identity after a lost response; retry cannot deliver twice.
-    if (request.current?.text !== text) request.current = { text, id: crypto.randomUUID() };
+    if (request.current?.text.trim() !== text) updateDraft(draft);
+    const sent = request.current!;
+    if (cacheKey) retainSteeringRequest(cacheKey, sent);
     setSteering(true);
     setSteerError(null);
     try {
-      await onSteerTurn(message.sourceTurnId, text, request.current.id);
-      setDraft(""); setEditing(false); setSteerReceipt(true); request.current = null;
+      await onSteerTurn(message.sourceTurnId, text, sent.id);
+      if (cacheKey) retireSteeringRequest(cacheKey, sent.id);
+      if (request.current?.id === sent.id) {
+        setDraft(""); setEditing(false); setSteerReceipt(true); request.current = null;
+      }
     } catch (cause) {
       const definitelyNotDelivered = cause instanceof ChatApiError && cause.payload.delivery_state === "not_delivered";
-      if (definitelyNotDelivered) request.current = null;
+      if (definitelyNotDelivered && request.current?.id === sent.id) {
+        // Preserve the draft; only confirmed non-delivery can renew retry identity.
+        const next = { ...sent, id: crypto.randomUUID() };
+        request.current = next;
+        if (cacheKey && readSteeringRequest(cacheKey)?.id === sent.id) retainSteeringRequest(cacheKey, next);
+      }
       const message = cause instanceof Error ? cause.message : (zh ? "未确认接收，草稿已保留。" : "Delivery unconfirmed. Draft retained.");
       setSteerError(definitelyNotDelivered
         ? (zh ? "本次未送达；请检查当前回合与执行器，条件恢复后可重试原文。" : "Not delivered; check the current turn and executor, then retry the unchanged draft.")
@@ -85,7 +121,7 @@ export function MessageActivity({ message, onInterruptTurn, onSteerTurn, onCance
       : "No new activity yet. Waiting for the executor to update."}</p> : null}
     {editing ? <form className="personal-message-steer" onSubmit={event => { event.preventDefault(); void steer(); }}>
       <label>{zh ? "追加给本轮的指令" : "Instructions for this turn"}<textarea value={draft} maxLength={12000} disabled={steering}
-        onChange={event => setDraft(event.target.value)} rows={3}/></label>
+        onChange={event => updateDraft(event.target.value)} rows={3}/></label>
       <span>{message.pending
         ? (zh ? "调整当前工作，保持原有任务与会话。" : "Adjust the current work in this conversation.")
         : (zh ? "本轮已结束，草稿已保留；可复制到输入框作为新消息发送。" : "This turn ended. Copy the retained draft to the composer to send a new message.")}</span>
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx
index a9daf7b81c..dcb17b274a 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx
+++ b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx
@@ -1,5 +1,5 @@
 import { goalCreateRequest } from "./goal-create-request";
-import { persistComposerSteeringRequests, readComposerSteeringRequests, type ComposerSteeringRequest } from "./composer-steering-recovery";
+import { readSteeringRequest, retainSteeringRequest, retireSteeringRequest } from "./steering-recovery";
 import type { ConversationHistoryStatus } from "../../data/use-conversation-history";
 import { GoalDraftCard } from "./goal-draft-card";
 import type { GoalDraft } from "../../../../../../loopx/control_plane/collaboration/goal_draft.js";
@@ -838,8 +838,6 @@ export function PersonalWorkspacePage({
   });
   const [sending, setSending] = useState(false);
   const [steering, setSteering] = useState(false);
-  const [restoredSteeringRequests] = useState(readComposerSteeringRequests);
-  const steeringRequests = useRef(restoredSteeringRequests);
   const [actionDraft, setActionDraft] = useState<WorkspaceActionDraft | null>(null);
   const [loopxMode, setLoopxMode] = useState<LoopXModeSnapshot | null>(null);
   const [loopxDelivery, setLoopxDelivery] = useState<"queue" | "inbox" | "steer">("queue");
@@ -904,17 +902,6 @@ export function PersonalWorkspacePage({
   function setComposer(value: string) {
     setComposerDraft(composerDraftKey, value);
   }
-  function retainSteeringRequest(key: string, request: ComposerSteeringRequest) {
-    steeringRequests.current.set(key, request);
-    // Persist before sending: reload after provider acceptance must replay the
-    // original ingress, never silently submit another Turn.
-    persistComposerSteeringRequests(steeringRequests.current);
-  }
-  function retireSteeringRequest(key: string, id: string) {
-    if (steeringRequests.current.get(key)?.id !== id) return;
-    steeringRequests.current.delete(key);
-    persistComposerSteeringRequests(steeringRequests.current);
-  }
   async function reviewGoalDraft(draft: GoalDraft, edit = false, draftId = "") {
     // Source message + reviewed contents survive retry without merging distinct requests.
     if (!edit && !draft.question && draft.completion_criteria.trim()) {
@@ -1681,7 +1668,7 @@ export function PersonalWorkspacePage({
     const pendingImages = messageOverride ? [] : imageAttachments;
     const message = (messageOverride ?? composer).trim() || (pendingImages.length ? t("composer.imageAnalysisPrompt") : "");
     if (!message || composerBlocked || conversationHistoryState?.sendBlocked) return;
-    const previousSteering = steeringRequests.current.get(composerDraftKey);
+    const previousSteering = readSteeringRequest(composerDraftKey);
     const retry = previousSteering && previousSteering.sessionId === conversationSessionId && previousSteering.text === message
       ? previousSteering : undefined;
     if ((retry || steeringTurnId) && conversationSessionId && callbacks.onSteerConversationTurn) {
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/steering-recovery.ts b/apps/presentation/dashboard/src/features/personal-workspace/steering-recovery.ts
new file mode 100644
index 0000000000..646006c265
--- /dev/null
+++ b/apps/presentation/dashboard/src/features/personal-workspace/steering-recovery.ts
@@ -0,0 +1,59 @@
+/** Local drafts/retry identity only; Chat ingress/store still owns delivery. */
+export type SteeringRequest = {
+  sessionId: string;
+  turnId: string;
+  text: string;
+  id: string;
+};
+
+const storageKey = "loopx-pw-composer-steering";
+
+let requests: Map<string, SteeringRequest> | undefined;
+
+function restoreRequests(): Map<string, SteeringRequest> {
+  try {
+    const raw = window.sessionStorage.getItem(storageKey);
+    const entries: unknown = raw ? JSON.parse(raw) : [];
+    if (!Array.isArray(entries)) return new Map();
+    return new Map(entries.flatMap((entry): [string, SteeringRequest][] => {
+      if (!Array.isArray(entry) || entry.length !== 2 || typeof entry[0] !== "string") return [];
+      const request = entry[1];
+      if (!request || typeof request !== "object" || Array.isArray(request)
+        || ![request.sessionId, request.turnId, request.text, request.id]
+          .every(value => typeof value === "string" && value.length > 0)) return [];
+      return [[entry[0], { sessionId: request.sessionId, turnId: request.turnId, text: request.text, id: request.id }]];
+    }));
+  } catch {
+    return new Map();
+  }
+}
+
+function persistRequests() {
+  try {
+    window.sessionStorage.setItem(storageKey, JSON.stringify([...requestCache()]));
+  } catch {
+    // Unavailable browser storage retains drafts/retries in this shared page cache.
+    // No provider action or delivery conclusion follows from this cache.
+  }
+}
+
+// One cache prevents composer and inline controls from overwriting each other's
+// entries. Lazy restoration also supports environments without browser storage.
+function requestCache() {
+  return requests ??= restoreRequests();
+}
+
+export function readSteeringRequest(key: string) {
+  return requestCache().get(key);
+}
+
+export function retainSteeringRequest(key: string, request: SteeringRequest) {
+  requestCache().set(key, request);
+  persistRequests();
+}
+
+export function retireSteeringRequest(key: string, id: string) {
+  if (requestCache().get(key)?.id !== id) return;
+  requestCache().delete(key);
+  persistRequests();
+}
diff --git a/docs/architecture/rfcs/capable-manager-semantic-handoff-v0.md b/docs/architecture/rfcs/capable-manager-semantic-handoff-v0.md
index 9dd2a7da61..11f6c5a5bb 100644
--- a/docs/architecture/rfcs/capable-manager-semantic-handoff-v0.md
+++ b/docs/architecture/rfcs/capable-manager-semantic-handoff-v0.md
@@ -490,6 +490,18 @@ Artifact continuity is part of semantic continuity. Reuse the artifact owner to
 Long-running work must remain legible in the existing conversation: what is being attempted, who owns the next step, what is actually blocking, and what conclusion is owed. Provide expandable tool/artifact activity and current semantic context in the frontend; Lark gets a concise equivalent and actionable results. Distinguish a queued worker, unavailable host, permission refusal, website login and undelivered answer. Do not expose raw protocol envelopes or claim fine-grained tool activity on adapters that cannot supply it.
 
 The App must also preserve the user's chosen work view across reload and browser history. Manager conversation and Goal overview/tasks/conversation/artifacts use the existing typed workspace route; source loading must not insert duplicate history entries. Preserve the source and Goal identity, retain an unsent draft under its existing owner, and never start or replay a Turn merely to restore navigation. Fresh-entry defaults remain distinct from restoring an explicit view. Packaged navigation recovery qualifies this presentation boundary only; actual receiver adoption, steering and owed-result return retain their independent acceptance requirements.
+The shared App activity control preserves an unsent or unconfirmed adjustment
+across view changes and reload. Composer and inline controls use one TS client
+cache; each inline draft is bound to its original session and Turn. Restoring a
+draft dispatches nothing. Retries of unchanged text retain the same ingress
+identity after unknown delivery or mismatched receipts; confirmed non-delivery
+allows a fresh identity. Editing the instruction starts a distinct request.
+Accepted delivery retires that exact entry without erasing another draft. An
+ended Turn keeps its unsent draft readable and cannot redirect it to newer work.
+Unavailable browser storage preserves page-memory recovery only, not reload
+recovery. Packaged browser transport and the real Chat steering/store tests
+qualify this bounded recovery behavior; live executor adoption, installed App
+readback and Lark steering remain separate acceptance.
 
 Reuse existing capability instructions, context hooks, memory and scheduling owners. Reusable methods may inform planning and handoff, with their source/version visible; remembered lessons do not replace accepted task state or current verification. Stable recurring work may use the existing schedule/event path after its task and replay behavior are understood. This RFC does not add a routine engine, compulsory method learning, a new hook family or business-specific automation.
 
diff --git a/docs/architecture/rfcs/loopx-overall-roadmap-v0.md b/docs/architecture/rfcs/loopx-overall-roadmap-v0.md
index cbe7e01824..5f02410626 100644
--- a/docs/architecture/rfcs/loopx-overall-roadmap-v0.md
+++ b/docs/architecture/rfcs/loopx-overall-roadmap-v0.md
@@ -625,6 +625,13 @@ Current status is design proposal; no G1 or default-screen promotion.
 - **Exit:** actual manager→worker and worker→worker callers; follow-up messages, lost source session, oversized answer, duplicate callback, successful send with lost ACK and transport restart. CLI, packaged frontend and Lark read back the same result with audience isolation. Ordinary already-authorized work gains no second confirmation.
 - **Migration/rollback:** characterize first, record old writer/reader mappings and deletion payoff; disabling new production must leave old requests drainable. Do not retain two writable lifecycles.
 
+The GQ08 App correction path now retains inline adjustments and ingress identity
+across view changes/reload through the same TS client cache as the composer.
+Restoration never dispatches work, and a terminal Turn cannot inherit a new
+Turn's target. Packaged recovery, blocked storage, coexisting drafts and real
+Chat ingress/store regression are bounded evidence; live recipient adoption,
+installed readback and Lark correction still belong to R3 qualification.
+
 R3 also qualifies the handoff RFC's hierarchical A6/A8/A13 extension: a managed
 worker requests, validates and integrates another peer's artifact before returning
 to the lead. Reuse the same request and work owners at each level. The ingress
diff --git a/examples/personal-workspace-browser/conversation-activity.mjs b/examples/personal-workspace-browser/conversation-activity.mjs
index 954ffae369..e62428f9c1 100644
--- a/examples/personal-workspace-browser/conversation-activity.mjs
+++ b/examples/personal-workspace-browser/conversation-activity.mjs
@@ -24,7 +24,14 @@ export const conversationActivityScenario = {
     const context = await openWorkspacePage(browser, url, { collectCoverage });
     const { page, api } = context;
     try {
-      await page.route("**/events/**", route => route.continue({ url: `http://127.0.0.1:${server.address().port}${new URL(route.request().url()).pathname}` }));
+      for (const pattern of ["**/events/**", "**/api/chat/sessions/*/turns/*/events"]) {
+        await page.route(pattern, route => {
+          const path = new URL(route.request().url()).pathname;
+          const restored = path.match(/^\/api\/chat\/sessions\/([^/]+)\/turns\/([^/]+)\/events$/);
+          const streamPath = restored ? `/events/${restored[1]}/${restored[2]}` : path;
+          return route.continue({ url: `http://127.0.0.1:${server.address().port}${streamPath}` });
+        });
+      }
       await page.getByRole("navigation", { name: "管家视图" }).getByRole("button", { name: /^(Chat|对话)$/ }).click();
       const send = async message => {
         await page.getByLabel("向 LoopX 发送消息").fill(message);
@@ -48,10 +55,16 @@ export const conversationActivityScenario = {
       assert.equal(await pending.locator(".personal-message-elapsed").textContent(), elapsedBefore);
       await page.clock.resume();
       const adjustments = [];
+      const composerAdjustments = [];
       await page.route("**/steer", async route => {
         const body = route.request().postDataJSON();
-        adjustments.push(body);
         const [sessionId, turnId] = new URL(route.request().url()).pathname.match(/sessions\/([^/]+)\/turns\/([^/]+)\/steer/).slice(1);
+        if (body.message === "保留完整结论。") {
+          composerAdjustments.push(body);
+          if (composerAdjustments.length === 1) return route.fulfill({ status: 409, json: { ok: false, error: "主输入框指令未确认" } });
+          return route.fulfill({ json: { ok: true, session_id: sessionId, turn_id: turnId, client_ingress_id: body.client_ingress_id, status: "delivered", created: true } });
+        }
+        adjustments.push(body);
         if (adjustments.length === 1) return route.fulfill({ status: 409, json: { ok: false, error: "执行器暂时未确认接收，草稿已保留。" } });
         if (adjustments.length === 3) return route.fulfill({ status: 409, json: { ok: false, error: "执行器暂时不可用。", error_code: "live_steering_session_not_attached", delivery_state: "not_delivered" } });
         return route.fulfill({ json: { ok: true, session_id: sessionId, turn_id: adjustments.length === 2 ? "wrong-turn" : turnId, client_ingress_id: body.client_ingress_id, status: "delivered", created: true } });
@@ -61,8 +74,25 @@ export const conversationActivityScenario = {
       await pending.getByRole("button", { name: "发送调整", exact: true }).click();
       await pending.getByRole("alert").filter({ hasText: "暂时未确认" }).waitFor();
       assert.equal(await pending.getByLabel("追加给本轮的指令").inputValue(), "先核对依赖，再继续当前任务。");
+      await page.getByLabel("向 LoopX 发送消息").fill("保留完整结论。");
+      await page.getByRole("button", { name: "发送", exact: true }).click();
+      await page.getByRole("status").filter({ hasText: "主输入框指令未确认" }).waitFor();
+      await page.getByRole("navigation", { name: "管家视图" }).getByRole("button", { name: "总览", exact: true }).click();
+      await tray.getByLabel("追加给本轮的指令").waitFor({ timeout: 5000 });
+      assert.equal(await tray.getByLabel("追加给本轮的指令").inputValue(), "先核对依赖，再继续当前任务。", "uncertain adjustment survives a view switch");
+      await tray.getByRole("button", { name: "查看完整对话", exact: true }).click();
       await pending.getByRole("button", { name: "发送调整", exact: true }).click();
       await pending.getByRole("alert").filter({ hasText: "回执不匹配" }).waitFor();
+      await page.reload({ waitUntil: "domcontentloaded" });
+      await page.getByRole("navigation", { name: "管家视图" }).getByRole("button", { name: /^(Chat|对话)$/ }).click();
+      await pending.getByLabel("追加给本轮的指令").waitFor();
+      assert.equal(await pending.getByLabel("追加给本轮的指令").inputValue(), "先核对依赖，再继续当前任务。", "reload retains the uncertain adjustment");
+      assert.equal(adjustments.length, 2, "restoration never resends an adjustment");
+      assert.equal(api.turnRequests.length, 1, "restoration never starts work");
+      assert.equal(await page.getByLabel("向 LoopX 发送消息").inputValue(), "保留完整结论。", "composer and inline drafts coexist");
+      await page.getByRole("button", { name: "发送", exact: true }).click();
+      await page.getByRole("status").filter({ hasText: "执行器已接收本轮追加指令" }).waitFor();
+      assert.equal(composerAdjustments[1].client_ingress_id, composerAdjustments[0].client_ingress_id, "inline writes preserve the composer's retry identity");
       await page.screenshot({ path: resolve(outputDir, "conversation-steering-draft.png"), animations: "disabled" });
       await page.setViewportSize({ width: 390, height: 844 });
       await pending.getByLabel("追加给本轮的指令").scrollIntoViewIfNeeded();
@@ -145,6 +175,10 @@ export const conversationActivityScenario = {
       assert.equal(await page.getByRole("button", { name: "中断本轮", exact: true }).count(), 0);
       assert.equal(await page.getByLabel("追加给本轮的指令").inputValue(), "保留我的未发送草稿。");
       assert.equal(await page.getByRole("button", { name: "发送调整", exact: true }).isDisabled(), true);
+      await page.getByRole("navigation", { name: "管家视图" }).getByRole("button", { name: "总览", exact: true }).click();
+      await page.getByRole("navigation", { name: "管家视图" }).getByRole("button", { name: /^(Chat|对话)$/ }).click();
+      assert.equal(await page.getByLabel("追加给本轮的指令").inputValue(), "保留我的未发送草稿。", "finished turn retains the unsent draft across unmount");
+      assert.equal(await page.getByRole("button", { name: "发送调整", exact: true }).isDisabled(), true, "finished draft cannot steer another turn");
       await page.unroute("**/interrupt");
 
       // The same interaction is present in Goal Chat, through the same timeline.
@@ -152,13 +186,18 @@ export const conversationActivityScenario = {
       await page.getByRole("navigation", { name: "Goal 视图" }).getByRole("button", { name: /^(Chat|对话)$/ }).click();
       const goalTurn = await send("请检查这个 Goal 的当前状态。");
       await page.getByRole("button", { name: "调整本轮", exact: true }).click();
+      assert.equal(await page.getByLabel("追加给本轮的指令").inputValue(), "", "another conversation never inherits the old draft");
+      await page.evaluate(() => { window.sessionStorage.setItem = () => { throw new Error("storage unavailable"); }; });
       await page.getByLabel("追加给本轮的指令").fill("先检查最新证据。");
+      await page.getByRole("navigation", { name: "Goal 视图" }).getByRole("button", { name: "任务", exact: true }).click();
+      await page.getByRole("navigation", { name: "Goal 视图" }).getByRole("button", { name: /^(Chat|对话)$/ }).click();
+      assert.equal(await page.getByLabel("追加给本轮的指令").inputValue(), "先检查最新证据。", "blocked storage preserves drafts within this page");
       await page.getByRole("button", { name: "发送调整", exact: true }).click();
       await page.getByText("执行器已接收本轮追加指令。", { exact: true }).waitFor();
       await page.getByRole("button", { name: "中断本轮", exact: true }).click();
       await page.getByText("已中断。你可以在当前会话继续发送消息。", { exact: true }).waitFor();
       assert.deepEqual(api.interrupts.at(-1), { sessionId: goalTurn.sessionId, turnId: goalTurn.turnId });
-      return { coverageEntries: context.coverageEntries, note: "Shared steward/Goal activity, exact-turn steering and interruption, receipt mismatch, idempotent retry, preserved drafts/partial output and completion races." };
+      return { coverageEntries: context.coverageEntries, note: "Shared steward/Goal activity and steering: view/reload recovery without automatic dispatch, coexisting composer identity, blocked storage, terminal draft isolation, interruption and completion races." };
     } finally {
       for (const response of streams.values()) response.destroy();
       server.closeAllConnections();