From 92b76c96051228de93c8e7830db3dcba3b17e9c0 Mon Sep 17 00:00:00 2001
From: Nathan Shan <nathanielcrush51@gmail.com>
Date: Fri, 23 Oct 2026 15:46:56 +0800
Subject: [PATCH 1/6] =?UTF-8?q?fix(web):=20=E4=BF=9D=E7=95=99=E6=9C=AA?=
 =?UTF-8?q?=E4=BF=9D=E5=AD=98=E7=9A=84=E6=8E=92=E9=98=9F=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E7=BC=96=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

将编辑原文和附件移除记录随草稿持久化，返回线程时恢复已有编辑，避免原文覆盖草稿。

保存、取消及队列退出时清理编辑状态，保留线程独立草稿；通过 76 个相关测试、范围检查及隔离客户端前后验证。
---
 .../src/components/chat/queuedMessageEdit.ts  |   1 +
 .../chat/useQueuedRunEdit.browser.test.tsx    | 124 ++++++++++++++++++
 .../src/components/chat/useQueuedRunEdit.ts   |  27 +++-
 apps/web/src/composerDraftStore.ts            |  49 +++++++
 4 files changed, 196 insertions(+), 5 deletions(-)
 create mode 100644 apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx

diff --git a/apps/web/src/components/chat/queuedMessageEdit.ts b/apps/web/src/components/chat/queuedMessageEdit.ts
index 238534d91de47..193643cb1a58b 100644
--- a/apps/web/src/components/chat/queuedMessageEdit.ts
+++ b/apps/web/src/components/chat/queuedMessageEdit.ts
@@ -19,6 +19,7 @@ export function recoverQueuedMessageEdit(input: {
     (draft.prompt !== input.originalText || draft.images.length > 0 || draft.files.length > 0);
   if (dirty && !composerDraftHasUserContent(store.getComposerDraft(input.threadTarget))) {
     store.moveComposerPromptAndImages(input.editTarget, input.threadTarget);
+    store.setQueuedMessageEdit(input.editTarget, undefined);
     return "kept";
   }
   store.clearComposerContent(input.editTarget);
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
new file mode 100644
index 0000000000000..1adfddd23d348
--- /dev/null
+++ b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
@@ -0,0 +1,124 @@
+import { EnvironmentId, MessageId, RunId, ThreadId } from "@t3tools/contracts";
+import { scopeThreadRef } from "@t3tools/client-runtime/environment";
+import { useRef } from "react";
+import { expect, it, vi } from "vite-plus/test";
+import { render } from "../../../test/render";
+import {
+  partializeComposerDraftStoreState,
+  useComposerDraftStore,
+  useComposerThreadDraft,
+} from "../../composerDraftStore";
+import { useQueuedRunEdit } from "./useQueuedRunEdit";
+
+const commands = vi.hoisted(() => ({
+  save: vi.fn(async (_input: unknown) => ({ _tag: "Success" })),
+}));
+vi.mock(import("../../state/use-atom-command"), () => ({
+  useAtomCommand: (() => commands.save) as never,
+}));
+vi.mock(import("../../assets/assetUrls"), () => ({ useAssetUrls: () => [] }));
+
+function Editor() {
+  const environmentId = EnvironmentId.make("environment:queue-edit");
+  const threadId = ThreadId.make("thread:queue-edit");
+  const threadRef = scopeThreadRef(environmentId, threadId);
+  const promptRef = useRef("");
+  const edit = useQueuedRunEdit({
+    environmentId,
+    routeThreadRef: threadRef,
+    threadDraftTarget: threadRef,
+    activeThreadId: threadId,
+    serverProjection: null,
+    promptRef,
+    composerRef: { current: null },
+  });
+  const draft = useComposerThreadDraft(edit.draftTarget);
+  return (
+    <>
+      <button
+        onClick={() =>
+          edit.beginEdit({
+            runId: RunId.make("run:queued"),
+            messageId: MessageId.make("message:queued"),
+            text: "Original message",
+            attachments: [
+              {
+                type: "file",
+                id: "file:report",
+                name: "report.pdf",
+                mimeType: "application/pdf",
+                sizeBytes: 6,
+              },
+            ],
+          })
+        }
+      >
+        Edit queued message
+      </button>
+      <textarea
+        aria-label="Message"
+        value={draft.prompt}
+        onChange={(event) =>
+          useComposerDraftStore.getState().setPrompt(edit.draftTarget, event.target.value)
+        }
+      />
+      {edit.editingAttachments?.map(({ attachment }) => (
+        <button key={attachment.id} onClick={() => edit.removeEditingAttachment(attachment.id)}>
+          Remove {attachment.name}
+        </button>
+      ))}
+      <button onClick={edit.cancelEdit}>Cancel edit</button>
+      <button onClick={() => edit.saveEdit(draft, () => undefined)}>Save edit</button>
+    </>
+  );
+}
+
+it.each(["Updated message", ""])(
+  "restores the unsaved edit %j and attachment removals after leaving the thread",
+  async (text) => {
+    commands.save.mockClear();
+    useComposerDraftStore.setState({ draftsByThreadKey: {}, draftThreadsByThreadKey: {} });
+    await using screen = await render(<Editor />, { router: false });
+    await screen.getByRole("textbox", { name: "Message" }).fill("Separate draft");
+    await screen.getByRole("button", { name: "Edit queued message" }).click();
+    await screen.getByRole("textbox", { name: "Message" }).fill(text);
+    await screen.getByRole("button", { name: "Remove report.pdf" }).click();
+    await screen.rerender(<div>Another thread</div>);
+    const persisted = JSON.parse(
+      JSON.stringify(partializeComposerDraftStoreState(useComposerDraftStore.getState())),
+    );
+    useComposerDraftStore.setState(
+      useComposerDraftStore.persist.getOptions().merge!(
+        persisted,
+        useComposerDraftStore.getInitialState(),
+      ),
+    );
+    await screen.rerender(<Editor />);
+    await screen.getByRole("button", { name: "Edit queued message" }).click();
+    await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue(text);
+    await expect
+      .element(screen.getByRole("button", { name: "Remove report.pdf" }))
+      .not.toBeInTheDocument();
+    if (text) {
+      await screen.getByRole("button", { name: "Save edit" }).click();
+      expect(commands.save).toHaveBeenCalledWith(
+        expect.objectContaining({
+          input: expect.objectContaining({
+            text,
+            edit: expect.objectContaining({ attachments: [] }),
+          }),
+        }),
+      );
+    } else {
+      await screen.getByRole("button", { name: "Cancel edit" }).click();
+    }
+    await expect
+      .element(screen.getByRole("textbox", { name: "Message" }))
+      .toHaveValue("Separate draft");
+    await screen.getByRole("button", { name: "Edit queued message" }).click();
+    await expect
+      .element(screen.getByRole("textbox", { name: "Message" }))
+      .toHaveValue("Original message");
+    await expect.element(screen.getByRole("button", { name: "Remove report.pdf" })).toBeVisible();
+  },
+);
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.ts b/apps/web/src/components/chat/useQueuedRunEdit.ts
index 4ac1af47bf3c6..373c883f79f7d 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.ts
+++ b/apps/web/src/components/chat/useQueuedRunEdit.ts
@@ -219,17 +219,26 @@ export function useQueuedRunEdit(input: {
 
   const beginEdit = useStableCallback((request: EditQueuedRunRequest) => {
     if (activeThreadId === null) return;
-    if (editing !== null && editing.runId !== request.runId) clearEditDraft(editing.runId);
     const target = queuedEditDraftTarget(routeThreadRef, request.runId);
     const store = useComposerDraftStore.getState();
-    store.clearComposerContent(target);
-    store.setPrompt(target, request.text);
+    const savedEdit = store.getComposerDraft(target)?.queuedMessageEdit;
+    const edit =
+      savedEdit?.messageId === request.messageId
+        ? savedEdit
+        : { messageId: request.messageId, originalText: request.text, removedAttachmentIds: [] };
+    if (edit !== savedEdit) {
+      store.clearComposerContent(target);
+      store.setQueuedMessageEdit(target, edit);
+      store.setPrompt(target, request.text);
+    }
     setEditing({
       threadId: activeThreadId,
       runId: request.runId,
       messageId: request.messageId,
-      originalText: request.text,
-      existingAttachments: request.attachments,
+      originalText: edit.originalText,
+      existingAttachments: request.attachments.filter(
+        (attachment) => !edit.removedAttachmentIds.includes(attachment.id),
+      ),
       context: serverProjection?.messages.find((message) => message.id === request.messageId)
         ?.context,
     });
@@ -242,6 +251,14 @@ export function useQueuedRunEdit(input: {
     focusComposerSoon();
   });
   const removeEditingAttachment = useStableCallback((attachmentId: string) => {
+    if (editing === null) return;
+    const store = useComposerDraftStore.getState();
+    const draft = store.getComposerDraft(draftTarget)?.queuedMessageEdit;
+    if (draft)
+      store.setQueuedMessageEdit(draftTarget, {
+        ...draft,
+        removedAttachmentIds: [...draft.removedAttachmentIds, attachmentId],
+      });
     setEditing((current) =>
       current === null
         ? current
diff --git a/apps/web/src/composerDraftStore.ts b/apps/web/src/composerDraftStore.ts
index 57ffde65949ff..aa1da0c85c0f3 100644
--- a/apps/web/src/composerDraftStore.ts
+++ b/apps/web/src/composerDraftStore.ts
@@ -6,6 +6,7 @@ import {
   DEFAULT_MODEL_BY_PROVIDER,
   defaultInstanceIdForDriver,
   EnvironmentId,
+  MessageId,
   ModelSelection,
   ProjectId,
   ProviderInstanceId,
@@ -233,8 +234,17 @@ const PersistedTerminalContextDraft = Schema.Struct({
 });
 type PersistedTerminalContextDraft = typeof PersistedTerminalContextDraft.Type;
 
+const QueuedMessageEditDraft = Schema.Struct({
+  messageId: MessageId,
+  originalText: Schema.String,
+  removedAttachmentIds: Schema.Array(Schema.String),
+});
+type QueuedMessageEditDraft = typeof QueuedMessageEditDraft.Type;
+const isQueuedMessageEditDraft = Schema.is(QueuedMessageEditDraft);
+
 const PersistedComposerThreadDraftState = Schema.Struct({
   prompt: Schema.String,
+  queuedMessageEdit: Schema.optionalKey(QueuedMessageEditDraft),
   attachments: Schema.Array(PersistedComposerImageAttachment),
   files: Schema.optionalKey(Schema.Array(PersistedComposerDraftFileAttachment)),
   terminalContexts: Schema.optionalKey(Schema.Array(PersistedTerminalContextDraft)),
@@ -360,6 +370,7 @@ const contextInsertionHandlers = new Map<string, ComposerContextInsertionHandler
 
 export interface ComposerThreadDraftState {
   prompt: string;
+  queuedMessageEdit?: QueuedMessageEditDraft | undefined;
   images: ComposerImageAttachment[];
   files: ComposerFileAttachment[];
   nonPersistedImageIds: string[];
@@ -499,6 +510,10 @@ interface ComposerDraftStoreState {
   clearDraftThread: (threadRef: ComposerThreadTarget) => void;
   setStickyModelSelection: (modelSelection: ModelSelection | null | undefined) => void;
   setPrompt: (threadRef: ComposerThreadTarget, prompt: string) => void;
+  setQueuedMessageEdit: (
+    threadRef: ComposerThreadTarget,
+    edit: QueuedMessageEditDraft | undefined,
+  ) => void;
   setTerminalContexts: (threadRef: ComposerThreadTarget, contexts: TerminalContextDraft[]) => void;
   setModelSelection: (
     threadRef: ComposerThreadTarget,
@@ -866,6 +881,7 @@ function normalizeTerminalContextsForThread(
 
 function shouldRemoveDraft(draft: ComposerThreadDraftState): boolean {
   return (
+    draft.queuedMessageEdit === undefined &&
     draft.prompt.length === 0 &&
     draft.images.length === 0 &&
     draft.files.length === 0 &&
@@ -1761,6 +1777,12 @@ function normalizePersistedDraftsByThreadId(
       continue;
     }
     const draftCandidate = draftValue as PersistedComposerThreadDraftState;
+    const queuedMessageEdit = isQueuedMessageEditDraft(draftCandidate.queuedMessageEdit)
+      ? {
+          ...draftCandidate.queuedMessageEdit,
+          removedAttachmentIds: [...draftCandidate.queuedMessageEdit.removedAttachmentIds],
+        }
+      : undefined;
     const promptCandidate = typeof draftCandidate.prompt === "string" ? draftCandidate.prompt : "";
     const attachments = Array.isArray(draftCandidate.attachments)
       ? draftCandidate.attachments.flatMap((entry) => {
@@ -1893,6 +1915,7 @@ function normalizePersistedDraftsByThreadId(
       Object.keys(modelSelectionByProvider).length > 0 || activeProvider !== null;
     if (
       promptCandidate.length === 0 &&
+      queuedMessageEdit === undefined &&
       attachments.length === 0 &&
       files.length === 0 &&
       terminalContexts.length === 0 &&
@@ -1919,6 +1942,7 @@ function normalizePersistedDraftsByThreadId(
             })();
     nextDraftsByThreadKey[normalizedThreadKey] = {
       prompt,
+      ...(queuedMessageEdit ? { queuedMessageEdit } : {}),
       attachments,
       ...(files.length > 0 ? { files } : {}),
       ...(terminalContexts.length > 0 ? { terminalContexts } : {}),
@@ -2021,6 +2045,7 @@ export function partializeComposerDraftStoreState(
       Object.keys(draft.modelSelectionByProvider).length > 0 || draft.activeProvider !== null;
     if (
       draft.prompt.length === 0 &&
+      draft.queuedMessageEdit === undefined &&
       draft.persistedAttachments.length === 0 &&
       draft.files.length === 0 &&
       draft.terminalContexts.length === 0 &&
@@ -2035,6 +2060,14 @@ export function partializeComposerDraftStoreState(
     }
     const persistedDraft: DeepMutable<PersistedComposerThreadDraftState> = {
       prompt: draft.prompt,
+      ...(draft.queuedMessageEdit
+        ? {
+            queuedMessageEdit: {
+              ...draft.queuedMessageEdit,
+              removedAttachmentIds: [...draft.queuedMessageEdit.removedAttachmentIds],
+            },
+          }
+        : {}),
       attachments: draft.persistedAttachments,
       ...(draft.files.length > 0
         ? {
@@ -2344,6 +2377,9 @@ function toHydratedThreadDraft(
       ...files.map(fileContextReference),
     ]),
     images: hydrateImagesFromPersisted(persistedDraft.attachments),
+    ...(persistedDraft.queuedMessageEdit
+      ? { queuedMessageEdit: persistedDraft.queuedMessageEdit }
+      : {}),
     files,
     nonPersistedImageIds: [],
     persistedAttachments: [...persistedDraft.attachments],
@@ -2867,6 +2903,18 @@ const composerDraftStore = create<ComposerDraftStoreState>()(
             return { draftsByThreadKey: nextDraftsByThreadKey };
           });
         },
+        setQueuedMessageEdit: (threadRef, queuedMessageEdit) => {
+          const threadKey = resolveComposerDraftKey(get(), threadRef);
+          if (!threadKey) return;
+          set((state) => {
+            const existing = state.draftsByThreadKey[threadKey] ?? createEmptyThreadDraft();
+            const nextDraft = { ...existing, queuedMessageEdit };
+            const draftsByThreadKey = { ...state.draftsByThreadKey };
+            if (shouldRemoveDraft(nextDraft)) delete draftsByThreadKey[threadKey];
+            else draftsByThreadKey[threadKey] = nextDraft;
+            return { draftsByThreadKey };
+          });
+        },
         setPrompt: (threadRef, prompt) => {
           const threadKey = resolveComposerDraftKey(get(), threadRef) ?? "";
           if (threadKey.length === 0) {
@@ -3950,6 +3998,7 @@ const composerDraftStore = create<ComposerDraftStoreState>()(
             }
             const nextDraft: ComposerThreadDraftState = {
               ...current,
+              queuedMessageEdit: undefined,
               prompt: "",
               images: [],
               files: [],

From afd5be78acd04c14cc9b349a5b72290bb38078d9 Mon Sep 17 00:00:00 2001
From: Nathan Shan <nathanielcrush51@gmail.com>
Date: Fri, 23 Oct 2026 16:17:12 +0800
Subject: [PATCH 2/6] =?UTF-8?q?test(web):=20=E7=AD=89=E5=BE=85=E6=8E=92?=
 =?UTF-8?q?=E9=98=9F=E6=B6=88=E6=81=AF=E7=BC=96=E8=BE=91=E7=9A=84=E5=BC=82?=
 =?UTF-8?q?=E6=AD=A5=E4=BF=9D=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

保存断言等待异步命令到达，避免浏览器点击先返回造成偶发失败。

保留原有参数断言，相关浏览器测试及变更范围检查通过。
---
 .../chat/useQueuedRunEdit.browser.test.tsx         | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
index 1adfddd23d348..ad6f55d84f51d 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
+++ b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
@@ -101,13 +101,15 @@ it.each(["Updated message", ""])(
       .not.toBeInTheDocument();
     if (text) {
       await screen.getByRole("button", { name: "Save edit" }).click();
-      expect(commands.save).toHaveBeenCalledWith(
-        expect.objectContaining({
-          input: expect.objectContaining({
-            text,
-            edit: expect.objectContaining({ attachments: [] }),
+      await vi.waitFor(() =>
+        expect(commands.save).toHaveBeenCalledWith(
+          expect.objectContaining({
+            input: expect.objectContaining({
+              text,
+              edit: expect.objectContaining({ attachments: [] }),
+            }),
           }),
-        }),
+        ),
       );
     } else {
       await screen.getByRole("button", { name: "Cancel edit" }).click();

From ac8c246ad6f861d6e7397b2d2260368dcccded3b Mon Sep 17 00:00:00 2001
From: Julius Marminge <julius0216@outlook.com>
Date: Sat, 24 Oct 2026 10:45:38 +0000
Subject: [PATCH 3/6] fix(web): untouched queued edits reseed from the current
 message

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
---
 .../chat/useQueuedRunEdit.browser.test.tsx       | 16 ++++++++++++++--
 apps/web/src/components/chat/useQueuedRunEdit.ts | 13 +++++++++++--
 2 files changed, 25 insertions(+), 4 deletions(-)

diff --git a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
index ad6f55d84f51d..9041127470fea 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
+++ b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
@@ -18,7 +18,7 @@ vi.mock(import("../../state/use-atom-command"), () => ({
 }));
 vi.mock(import("../../assets/assetUrls"), () => ({ useAssetUrls: () => [] }));
 
-function Editor() {
+function Editor({ text = "Original message" }: { readonly text?: string }) {
   const environmentId = EnvironmentId.make("environment:queue-edit");
   const threadId = ThreadId.make("thread:queue-edit");
   const threadRef = scopeThreadRef(environmentId, threadId);
@@ -40,7 +40,7 @@ function Editor() {
           edit.beginEdit({
             runId: RunId.make("run:queued"),
             messageId: MessageId.make("message:queued"),
-            text: "Original message",
+            text,
             attachments: [
               {
                 type: "file",
@@ -124,3 +124,15 @@ it.each(["Updated message", ""])(
     await expect.element(screen.getByRole("button", { name: "Remove report.pdf" })).toBeVisible();
   },
 );
+
+it("reopens an untouched edit with the queued message saved by another client", async () => {
+  useComposerDraftStore.setState({ draftsByThreadKey: {}, draftThreadsByThreadKey: {} });
+  await using screen = await render(<Editor />, { router: false });
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await screen.rerender(<div>Another thread</div>);
+  await screen.rerender(<Editor text="Updated message" />);
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await expect
+    .element(screen.getByRole("textbox", { name: "Message" }))
+    .toHaveValue("Updated message");
+});
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.ts b/apps/web/src/components/chat/useQueuedRunEdit.ts
index 373c883f79f7d..b98297df94a38 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.ts
+++ b/apps/web/src/components/chat/useQueuedRunEdit.ts
@@ -16,6 +16,7 @@ import { ATTACHMENT_ONLY_BOOTSTRAP_PROMPT } from "@t3tools/shared/composerContex
 import { useEffect, useRef, useState, type RefObject } from "react";
 import { useAssetUrls } from "../../assets/assetUrls";
 import {
+  composerDraftHasUserContent,
   DraftId,
   useComposerDraftStore,
   type ComposerFileAttachment,
@@ -221,9 +222,17 @@ export function useQueuedRunEdit(input: {
     if (activeThreadId === null) return;
     const target = queuedEditDraftTarget(routeThreadRef, request.runId);
     const store = useComposerDraftStore.getState();
-    const savedEdit = store.getComposerDraft(target)?.queuedMessageEdit;
+    const savedDraft = store.getComposerDraft(target);
+    const savedEdit = savedDraft?.queuedMessageEdit;
+    // An untouched draft reseeds, so it never restores text another client replaced.
+    const savedEditIsDirty =
+      savedDraft !== null &&
+      savedEdit !== undefined &&
+      (savedDraft.prompt !== savedEdit.originalText ||
+        savedEdit.removedAttachmentIds.length > 0 ||
+        composerDraftHasUserContent({ ...savedDraft, prompt: "" }));
     const edit =
-      savedEdit?.messageId === request.messageId
+      savedEdit?.messageId === request.messageId && savedEditIsDirty
         ? savedEdit
         : { messageId: request.messageId, originalText: request.text, removedAttachmentIds: [] };
     if (edit !== savedEdit) {

From cc93ef18cff881d40cd499d214e66e9f165b75bb Mon Sep 17 00:00:00 2001
From: Nathan Shan <nathanielcrush51@gmail.com>
Date: Sun, 25 Oct 2026 01:34:30 +0800
Subject: [PATCH 4/6] =?UTF-8?q?fix(web):=20=E6=81=A2=E5=A4=8D=E7=A6=BB?=
 =?UTF-8?q?=E5=BC=80=E7=BA=BF=E7=A8=8B=E5=90=8E=E8=BF=87=E6=9C=9F=E7=9A=84?=
 =?UTF-8?q?=E6=8E=92=E9=98=9F=E6=B6=88=E6=81=AF=E8=8D=89=E7=A8=BF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 返回线程时检查保留的排队消息编辑，并沿用现有草稿冲突处理策略。\n- 等待投影加载完成后恢复内容，避免覆盖独立草稿或其他线程的编辑。\n- 补齐浏览器回归测试；82 项针对性测试与受影响检查通过，并验证隔离客户端前后表现。
---
 .../chat/useQueuedRunEdit.browser.test.tsx    | 121 +++++++++++++++++-
 .../src/components/chat/useQueuedRunEdit.ts   |  63 +++++----
 2 files changed, 152 insertions(+), 32 deletions(-)

diff --git a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
index 9041127470fea..cef95838ea2f7 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
+++ b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
@@ -1,10 +1,11 @@
 import { EnvironmentId, MessageId, RunId, ThreadId } from "@t3tools/contracts";
-import { scopeThreadRef } from "@t3tools/client-runtime/environment";
+import { scopedThreadKey, scopeThreadRef } from "@t3tools/client-runtime/environment";
 import { useRef } from "react";
 import { expect, it, vi } from "vite-plus/test";
 import { render } from "../../../test/render";
 import {
   partializeComposerDraftStoreState,
+  DraftId,
   useComposerDraftStore,
   useComposerThreadDraft,
 } from "../../composerDraftStore";
@@ -18,7 +19,13 @@ vi.mock(import("../../state/use-atom-command"), () => ({
 }));
 vi.mock(import("../../assets/assetUrls"), () => ({ useAssetUrls: () => [] }));
 
-function Editor({ text = "Original message" }: { readonly text?: string }) {
+function Editor({
+  text = "Original message",
+  queueState = null,
+}: {
+  readonly text?: string;
+  readonly queueState?: "queued" | "running" | "missing" | null;
+}) {
   const environmentId = EnvironmentId.make("environment:queue-edit");
   const threadId = ThreadId.make("thread:queue-edit");
   const threadRef = scopeThreadRef(environmentId, threadId);
@@ -28,7 +35,17 @@ function Editor({ text = "Original message" }: { readonly text?: string }) {
     routeThreadRef: threadRef,
     threadDraftTarget: threadRef,
     activeThreadId: threadId,
-    serverProjection: null,
+    // This hook only reads run membership and message context from the projection.
+    serverProjection:
+      queueState === null
+        ? null
+        : ({
+            runs:
+              queueState === "missing"
+                ? []
+                : [{ id: RunId.make("run:queued"), status: queueState }],
+            messages: [],
+          } as unknown as NonNullable<Parameters<typeof useQueuedRunEdit>[0]["serverProjection"]>),
     promptRef,
     composerRef: { current: null },
   });
@@ -73,11 +90,16 @@ function Editor({ text = "Original message" }: { readonly text?: string }) {
   );
 }
 
+function setup() {
+  commands.save.mockClear();
+  useComposerDraftStore.setState({ draftsByThreadKey: {}, draftThreadsByThreadKey: {} });
+}
+
 it.each(["Updated message", ""])(
   "restores the unsaved edit %j and attachment removals after leaving the thread",
   async (text) => {
-    commands.save.mockClear();
-    useComposerDraftStore.setState({ draftsByThreadKey: {}, draftThreadsByThreadKey: {} });
+    setup();
+    // Navigation is simulated by rerendering, without route consumers.
     await using screen = await render(<Editor />, { router: false });
     await screen.getByRole("textbox", { name: "Message" }).fill("Separate draft");
     await screen.getByRole("button", { name: "Edit queued message" }).click();
@@ -126,7 +148,8 @@ it.each(["Updated message", ""])(
 );
 
 it("reopens an untouched edit with the queued message saved by another client", async () => {
-  useComposerDraftStore.setState({ draftsByThreadKey: {}, draftThreadsByThreadKey: {} });
+  setup();
+  // Navigation is simulated by rerendering, without route consumers.
   await using screen = await render(<Editor />, { router: false });
   await screen.getByRole("button", { name: "Edit queued message" }).click();
   await screen.rerender(<div>Another thread</div>);
@@ -136,3 +159,89 @@ it("reopens an untouched edit with the queued message saved by another client",
     .element(screen.getByRole("textbox", { name: "Message" }))
     .toHaveValue("Updated message");
 });
+
+it.each(["running", "missing"] as const)(
+  "recovers a retained edit when its run became %s while the user was away",
+  async (queueState) => {
+    setup();
+    // Navigation is simulated by rerendering, without route consumers.
+    await using screen = await render(<Editor />, { router: false });
+    await screen.getByRole("button", { name: "Edit queued message" }).click();
+    await screen.getByRole("textbox", { name: "Message" }).fill("Keep this unsaved edit");
+    await screen.rerender(<div>Another thread</div>);
+    await screen.rerender(<Editor />);
+    await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue("");
+    await screen.rerender(<Editor queueState={queueState} />);
+    await expect
+      .element(screen.getByRole("textbox", { name: "Message" }))
+      .toHaveValue("Keep this unsaved edit");
+  },
+);
+
+it("keeps a separate composer draft and leaves other threads' retained edits alone", async () => {
+  setup();
+  const otherRef = scopeThreadRef(
+    EnvironmentId.make("environment:queue-edit"),
+    ThreadId.make("thread:other"),
+  );
+  const otherTarget = DraftId.make(`queued-edit:${scopedThreadKey(otherRef)}:run:other`);
+  const store = useComposerDraftStore.getState();
+  store.setPrompt(otherTarget, "Other thread edit");
+  store.setQueuedMessageEdit(otherTarget, {
+    messageId: MessageId.make("message:other"),
+    originalText: "Original",
+    removedAttachmentIds: [],
+  });
+  // Navigation is simulated by rerendering, without route consumers.
+  await using screen = await render(<Editor />, { router: false });
+  await screen.getByRole("textbox", { name: "Message" }).fill("Separate draft");
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await screen.getByRole("textbox", { name: "Message" }).fill("Unsaved edit");
+  await screen.rerender(<div>Another thread</div>);
+  await screen.rerender(<Editor queueState="running" />);
+  await expect
+    .element(screen.getByRole("textbox", { name: "Message" }))
+    .toHaveValue("Separate draft");
+  const editRef = scopeThreadRef(
+    EnvironmentId.make("environment:queue-edit"),
+    ThreadId.make("thread:queue-edit"),
+  );
+  expect(
+    store.getComposerDraft(DraftId.make(`queued-edit:${scopedThreadKey(editRef)}:run:queued`)),
+  ).toBeNull();
+  expect(store.getComposerDraft(otherTarget)?.prompt).toBe("Other thread edit");
+});
+
+it("retains the edit while its run is still queued", async () => {
+  setup();
+  // Navigation is simulated by rerendering, without route consumers.
+  await using screen = await render(<Editor queueState="queued" />, { router: false });
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await screen.getByRole("textbox", { name: "Message" }).fill("Still queued");
+  await screen.rerender(<div>Another thread</div>);
+  await screen.rerender(<Editor queueState="queued" />);
+  await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue("");
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await expect
+    .element(screen.getByRole("textbox", { name: "Message" }))
+    .toHaveValue("Still queued");
+});
+
+it("does not copy an untouched queued message back into the composer", async () => {
+  setup();
+  // Navigation is simulated by rerendering, without route consumers.
+  await using screen = await render(<Editor />, { router: false });
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await screen.rerender(<div>Another thread</div>);
+  await screen.rerender(<Editor queueState="running" />);
+  await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue("");
+  const ref = scopeThreadRef(
+    EnvironmentId.make("environment:queue-edit"),
+    ThreadId.make("thread:queue-edit"),
+  );
+  expect(
+    useComposerDraftStore
+      .getState()
+      .getComposerDraft(DraftId.make(`queued-edit:${scopedThreadKey(ref)}:run:queued`)),
+  ).toBeNull();
+});
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.ts b/apps/web/src/components/chat/useQueuedRunEdit.ts
index b98297df94a38..1c91541343e97 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.ts
+++ b/apps/web/src/components/chat/useQueuedRunEdit.ts
@@ -280,34 +280,45 @@ export function useQueuedRunEdit(input: {
     );
   });
 
-  // Exit edit mode when the edited run leaves the queue (it started, or was
-  // cancelled from another client). A dirty edit moves into the thread's own
-  // draft when that draft is empty; otherwise it is dropped with a toast.
+  // Recover retained edits too: their run may have left the queue while this
+  // thread was unmounted. A dirty edit uses the same keep-or-discard path.
+  const runs = serverProjection?.runs;
   useEffect(() => {
-    if (editing === null || activeThreadId !== editing.threadId) return;
-    if (serverProjection === null) return;
-    const run = serverProjection.runs.find((candidate) => candidate.id === editing.runId);
-    if (run !== undefined && run.status === "queued") return;
-    const recovery = recoverQueuedMessageEdit({
-      editTarget: queuedEditDraftTarget(routeThreadRef, editing.runId),
-      threadTarget: threadDraftTarget,
-      originalText: editing.originalText,
-    });
-    if (recovery !== "clean") {
-      toastManager.add(
-        stackedThreadToast({
-          type: recovery === "kept" ? "info" : "warning",
-          title: "Queued message is no longer queued",
-          description:
-            recovery === "kept"
-              ? "Your unsaved edit was kept in the composer."
-              : "Your unsaved edit was discarded.",
-        }),
-      );
+    if (activeThreadId === null || runs === undefined) return;
+    const prefix = `queued-edit:${scopedThreadKey(routeThreadRef)}:`;
+    const queuedTargets = new Set(
+      runs
+        .filter((run) => run.status === "queued")
+        .map((run) => queuedEditDraftTarget(routeThreadRef, run.id)),
+    );
+    const drafts = useComposerDraftStore.getState().draftsByThreadKey;
+    for (const [key, draft] of Object.entries(drafts)) {
+      if (!key.startsWith(prefix) || draft.queuedMessageEdit === undefined) continue;
+      const editTarget = DraftId.make(key);
+      if (queuedTargets.has(editTarget)) continue;
+      const recovery = recoverQueuedMessageEdit({
+        editTarget,
+        threadTarget: threadDraftTarget,
+        originalText: draft.queuedMessageEdit.originalText,
+      });
+      if (recovery !== "clean") {
+        toastManager.add(
+          stackedThreadToast({
+            type: recovery === "kept" ? "info" : "warning",
+            title: "Queued message is no longer queued",
+            description:
+              recovery === "kept"
+                ? "Your unsaved edit was kept in the composer."
+                : "Your unsaved edit was discarded.",
+          }),
+        );
+      }
+      if (editing !== null && editTarget === queuedEditDraftTarget(routeThreadRef, editing.runId)) {
+        // oxlint-disable-next-line react/set-state-in-effect -- Leaving edit mode follows recovery and its notification after commit.
+        setEditing(null);
+      }
     }
-    // oxlint-disable-next-line react/set-state-in-effect -- Leaving edit mode follows the draft recovery and toast above, which must run once after commit.
-    setEditing(null);
-  }, [activeThreadId, editing, routeThreadRef, serverProjection, threadDraftTarget]);
+  }, [activeThreadId, editing, routeThreadRef, runs, threadDraftTarget]);
 
   /**
    * Saves the composer content into the queued message being edited. Reports

From 6024c49afab3ed42bfcda9ab446739d798d3988b Mon Sep 17 00:00:00 2001
From: Nathan Shan <nathanielcrush51@gmail.com>
Date: Sun, 25 Oct 2026 02:02:33 +0800
Subject: [PATCH 5/6] =?UTF-8?q?fix(web):=20=E5=90=8C=E6=AD=A5=E5=AE=8C?=
 =?UTF-8?q?=E6=88=90=E5=90=8E=E5=86=8D=E6=81=A2=E5=A4=8D=E6=8E=92=E9=98=9F?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E8=8D=89=E7=A8=BF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 从聊天页传入线程实时状态，避免把缓存投影误当成完整队列而提前恢复或丢弃编辑。
- 增加缺失、运行中缓存及同步完成后的恢复回归；三个新用例先失败后通过。
- 16 项直接相关测试与受影响检查通过，保留原有独立草稿冲突处理策略。
---
 apps/web/src/components/ChatView.tsx          |  3 +-
 .../chat/useQueuedRunEdit.browser.test.tsx    | 48 +++++++++++++++++++
 .../src/components/chat/useQueuedRunEdit.ts   |  6 ++-
 3 files changed, 54 insertions(+), 3 deletions(-)

diff --git a/apps/web/src/components/ChatView.tsx b/apps/web/src/components/ChatView.tsx
index 62223ba82096a..9410ecb7c1262 100644
--- a/apps/web/src/components/ChatView.tsx
+++ b/apps/web/src/components/ChatView.tsx
@@ -480,10 +480,12 @@ export default function ChatView(props: ChatViewProps) {
   const promptRef = useRef("");
   const localComposerRef = useRef<ChatComposerHandle | null>(null);
   const composerRef = useComposerHandleContext() ?? localComposerRef;
+  const threadStatus = useThreadStatus(routeThreadDetailRef);
   const queuedRunEdit = useQueuedRunEdit({
     environmentId,
     routeThreadRef,
     threadDraftTarget: baseComposerDraftTarget,
+    threadIsLive: threadStatus === "live",
     activeThreadId: serverThread !== null || draftThread !== null ? threadId : null,
     serverProjection,
     promptRef,
@@ -493,7 +495,6 @@ export default function ChatView(props: ChatViewProps) {
   const reportedModelSelection = serverProjection
     ? deriveReportedModelSelection(serverProjection)
     : null;
-  const threadStatus = useThreadStatus(routeThreadDetailRef);
   const threadSyncPhase = resolveThreadSyncPhase({
     detailExists: serverProjection !== null,
     shellExists: serverThread !== null,
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
index cef95838ea2f7..b8da55136037a 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
+++ b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
@@ -22,9 +22,11 @@ vi.mock(import("../../assets/assetUrls"), () => ({ useAssetUrls: () => [] }));
 function Editor({
   text = "Original message",
   queueState = null,
+  threadIsLive = true,
 }: {
   readonly text?: string;
   readonly queueState?: "queued" | "running" | "missing" | null;
+  readonly threadIsLive?: boolean;
 }) {
   const environmentId = EnvironmentId.make("environment:queue-edit");
   const threadId = ThreadId.make("thread:queue-edit");
@@ -35,6 +37,7 @@ function Editor({
     routeThreadRef: threadRef,
     threadDraftTarget: threadRef,
     activeThreadId: threadId,
+    threadIsLive,
     // This hook only reads run membership and message context from the projection.
     serverProjection:
       queueState === null
@@ -227,6 +230,51 @@ it("retains the edit while its run is still queued", async () => {
     .toHaveValue("Still queued");
 });
 
+it.each(["missing", "running"] as const)(
+  "does not recover a retained edit from a stale %s projection before synchronization",
+  async (queueState) => {
+    setup();
+    // Navigation is simulated by rerendering, without route consumers.
+    await using screen = await render(<Editor />, { router: false });
+    await screen.getByRole("button", { name: "Edit queued message" }).click();
+    await screen.getByRole("textbox", { name: "Message" }).fill("Keep the queued edit");
+    await screen.rerender(<div>Another thread</div>);
+    await screen.rerender(<Editor queueState={queueState} threadIsLive={false} />);
+    await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue("");
+    const ref = scopeThreadRef(
+      EnvironmentId.make("environment:queue-edit"),
+      ThreadId.make("thread:queue-edit"),
+    );
+    await vi.waitFor(() =>
+      expect(
+        useComposerDraftStore
+          .getState()
+          .getComposerDraft(DraftId.make(`queued-edit:${scopedThreadKey(ref)}:run:queued`))?.prompt,
+      ).toBe("Keep the queued edit"),
+    );
+    await screen.rerender(<Editor queueState="queued" />);
+    await screen.getByRole("button", { name: "Edit queued message" }).click();
+    await expect
+      .element(screen.getByRole("textbox", { name: "Message" }))
+      .toHaveValue("Keep the queued edit");
+  },
+);
+
+it("recovers an expired edit only after the cached projection becomes live", async () => {
+  setup();
+  // Navigation is simulated by rerendering, without route consumers.
+  await using screen = await render(<Editor />, { router: false });
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await screen.getByRole("textbox", { name: "Message" }).fill("Recover after sync");
+  await screen.rerender(<div>Another thread</div>);
+  await screen.rerender(<Editor queueState="missing" threadIsLive={false} />);
+  await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue("");
+  await screen.rerender(<Editor queueState="missing" />);
+  await expect
+    .element(screen.getByRole("textbox", { name: "Message" }))
+    .toHaveValue("Recover after sync");
+});
+
 it("does not copy an untouched queued message back into the composer", async () => {
   setup();
   // Navigation is simulated by rerendering, without route consumers.
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.ts b/apps/web/src/components/chat/useQueuedRunEdit.ts
index 1c91541343e97..d5b69580edbef 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.ts
+++ b/apps/web/src/components/chat/useQueuedRunEdit.ts
@@ -169,6 +169,7 @@ export function useQueuedRunEdit(input: {
   readonly environmentId: EnvironmentId;
   readonly routeThreadRef: ScopedThreadRef;
   readonly threadDraftTarget: ComposerThreadTarget;
+  readonly threadIsLive: boolean;
   // Null while the route has no thread yet; an edit needs one to target.
   readonly activeThreadId: ThreadId | null;
   readonly serverProjection: ThreadStructure | null;
@@ -179,6 +180,7 @@ export function useQueuedRunEdit(input: {
     environmentId,
     routeThreadRef,
     threadDraftTarget,
+    threadIsLive,
     activeThreadId,
     serverProjection,
     promptRef,
@@ -284,7 +286,7 @@ export function useQueuedRunEdit(input: {
   // thread was unmounted. A dirty edit uses the same keep-or-discard path.
   const runs = serverProjection?.runs;
   useEffect(() => {
-    if (activeThreadId === null || runs === undefined) return;
+    if (!threadIsLive || activeThreadId === null || runs === undefined) return;
     const prefix = `queued-edit:${scopedThreadKey(routeThreadRef)}:`;
     const queuedTargets = new Set(
       runs
@@ -318,7 +320,7 @@ export function useQueuedRunEdit(input: {
         setEditing(null);
       }
     }
-  }, [activeThreadId, editing, routeThreadRef, runs, threadDraftTarget]);
+  }, [activeThreadId, editing, routeThreadRef, runs, threadDraftTarget, threadIsLive]);
 
   /**
    * Saves the composer content into the queued message being edited. Reports

From 2b2f6fd187b4471e77999310ed68279c62af0bb4 Mon Sep 17 00:00:00 2001
From: Nathan Shan <nathanielcrush51@gmail.com>
Date: Sun, 25 Oct 2026 02:08:29 +0800
Subject: [PATCH 6/6] =?UTF-8?q?fix(web):=20=E5=B0=86=E4=BB=85=E5=88=A0?=
 =?UTF-8?q?=E9=99=A4=E9=99=84=E4=BB=B6=E7=9A=84=E6=8E=92=E9=98=9F=E7=BC=96?=
 =?UTF-8?q?=E8=BE=91=E8=A7=86=E4=B8=BA=E6=9C=AA=E4=BF=9D=E5=AD=98=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 排队运行离队时不再静默清除只删除原附件的编辑，沿用现有恢复及冲突提示策略。
- 旧消息的附件标识不会进入普通输入框，避免把过期编辑信息绑定到新消息。
- 补齐删除附件的回归及空文本编辑持久化后保存的浏览器验证；133 项受影响测试与检查通过。
---
 .../components/chat/queuedMessageEdit.test.ts | 25 +++++++++++++-
 .../src/components/chat/queuedMessageEdit.ts  |  6 +++-
 .../chat/useQueuedRunEdit.browser.test.tsx    | 34 +++++++++++++++++++
 3 files changed, 63 insertions(+), 2 deletions(-)

diff --git a/apps/web/src/components/chat/queuedMessageEdit.test.ts b/apps/web/src/components/chat/queuedMessageEdit.test.ts
index fd5cc6ac17062..dbd3e25e834e4 100644
--- a/apps/web/src/components/chat/queuedMessageEdit.test.ts
+++ b/apps/web/src/components/chat/queuedMessageEdit.test.ts
@@ -1,4 +1,4 @@
-import { EnvironmentId, ThreadId } from "@t3tools/contracts";
+import { EnvironmentId, MessageId, ThreadId } from "@t3tools/contracts";
 import { scopeThreadRef } from "@t3tools/client-runtime/environment";
 import { beforeEach, describe, expect, it } from "vite-plus/test";
 import {
@@ -86,6 +86,29 @@ describe("queued message file edits", () => {
     expect(store.getComposerDraft(editTarget)).toBeNull();
   });
 
+  it.each(["", "Separate draft"])(
+    "handles attachment-only removals without overwriting composer %j",
+    (separateDraft) => {
+      const store = useComposerDraftStore.getState();
+      store.setPrompt(threadTarget, separateDraft);
+      store.setPrompt(editTarget, "Original message");
+      store.setQueuedMessageEdit(editTarget, {
+        messageId: MessageId.make("message:queued"),
+        originalText: "Original message",
+        removedAttachmentIds: ["attachment:removed"],
+      });
+      expect(
+        recoverQueuedMessageEdit({ editTarget, threadTarget, originalText: "Original message" }),
+      ).toBe(separateDraft ? "discarded" : "kept");
+      expect(store.getComposerDraft(threadTarget)?.prompt).toBe(
+        separateDraft || "Original message",
+      );
+      expect(store.getComposerDraft(threadTarget)?.files).toEqual([]);
+      expect(store.getComposerDraft(threadTarget)?.queuedMessageEdit).toBeUndefined();
+      expect(store.getComposerDraft(editTarget)).toBeNull();
+    },
+  );
+
   it("does not overwrite a separate draft when the queued run leaves", () => {
     const store = useComposerDraftStore.getState();
     store.setPrompt(threadTarget, "Separate draft");
diff --git a/apps/web/src/components/chat/queuedMessageEdit.ts b/apps/web/src/components/chat/queuedMessageEdit.ts
index 193643cb1a58b..5692868690151 100644
--- a/apps/web/src/components/chat/queuedMessageEdit.ts
+++ b/apps/web/src/components/chat/queuedMessageEdit.ts
@@ -16,9 +16,13 @@ export function recoverQueuedMessageEdit(input: {
   const draft = store.getComposerDraft(input.editTarget);
   const dirty =
     draft !== null &&
-    (draft.prompt !== input.originalText || draft.images.length > 0 || draft.files.length > 0);
+    (draft.prompt !== input.originalText ||
+      draft.images.length > 0 ||
+      draft.files.length > 0 ||
+      (draft.queuedMessageEdit?.removedAttachmentIds.length ?? 0) > 0);
   if (dirty && !composerDraftHasUserContent(store.getComposerDraft(input.threadTarget))) {
     store.moveComposerPromptAndImages(input.editTarget, input.threadTarget);
+    // A new composer draft keeps the edited content, not IDs belonging to the old queued message.
     store.setQueuedMessageEdit(input.editTarget, undefined);
     return "kept";
   }
diff --git a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
index b8da55136037a..0cb4a5cea8ac7 100644
--- a/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
+++ b/apps/web/src/components/chat/useQueuedRunEdit.browser.test.tsx
@@ -1,5 +1,6 @@
 import { EnvironmentId, MessageId, RunId, ThreadId } from "@t3tools/contracts";
 import { scopedThreadKey, scopeThreadRef } from "@t3tools/client-runtime/environment";
+import { ATTACHMENT_ONLY_BOOTSTRAP_PROMPT } from "@t3tools/shared/composerContextReferences";
 import { useRef } from "react";
 import { expect, it, vi } from "vite-plus/test";
 import { render } from "../../../test/render";
@@ -150,6 +151,39 @@ it.each(["Updated message", ""])(
   },
 );
 
+it("saves an empty restored edit that keeps its attachment", async () => {
+  setup();
+  // Navigation is simulated by rerendering, without route consumers.
+  await using screen = await render(<Editor />, { router: false });
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await screen.getByRole("textbox", { name: "Message" }).fill("");
+  await screen.rerender(<div>Another thread</div>);
+  const persisted = JSON.parse(
+    JSON.stringify(partializeComposerDraftStoreState(useComposerDraftStore.getState())),
+  );
+  useComposerDraftStore.setState(
+    useComposerDraftStore.persist.getOptions().merge!(
+      persisted,
+      useComposerDraftStore.getInitialState(),
+    ),
+  );
+  await screen.rerender(<Editor />);
+  await screen.getByRole("button", { name: "Edit queued message" }).click();
+  await expect.element(screen.getByRole("textbox", { name: "Message" })).toHaveValue("");
+  await expect.element(screen.getByRole("button", { name: "Remove report.pdf" })).toBeVisible();
+  await screen.getByRole("button", { name: "Save edit" }).click();
+  await vi.waitFor(() =>
+    expect(commands.save).toHaveBeenCalledWith(
+      expect.objectContaining({
+        input: expect.objectContaining({
+          text: ATTACHMENT_ONLY_BOOTSTRAP_PROMPT,
+          edit: expect.objectContaining({ attachments: [expect.anything()] }),
+        }),
+      }),
+    ),
+  );
+});
+
 it("reopens an untouched edit with the queued message saved by another client", async () => {
   setup();
   // Navigation is simulated by rerendering, without route consumers.