@@ -26,7 +26,7 @@ import { confirmDestructive, promptText } from '@/lib/confirm';
 import { useDebates } from '@/lib/debate-context';
 import { haptics } from '@/lib/haptics';
 import { LIBRARY_ROOMY_WIDTH, LIST_WIDTH, useContentWidth, useLayoutClass } from '@/lib/layout';
-import { currentSourceId, discardQueuedForDebate, waitingSourceIds, withQueuedWrites } from '@/lib/offline-queue';
+import { clearQueuedDebate, currentSourceId, waitingSourceIds, withQueuedWrites } from '@/lib/offline-queue';
 import { openRowId } from '@/lib/open-pane';
 import { pickSourceFile } from '@/lib/pick-source-file';
 import { useSourceActions } from '@/lib/source-actions';
@@ -103,9 +103,8 @@ function LibraryView({ debateId, layout }: { debateId: string | null; layout: Re
     const confirmed = await confirmDestructive({ title: t('libraryPage.clearAll'), message: t('libraryPage.clearConfirm'), confirm: t('libraryPage.clearAll'), cancel: t('common.cancel') });
     if (!confirmed) return;
     try {
-      // Notes and changes still waiting to sync would come back after the clear; they go first.
-      await discardQueuedForDebate(userId, debateId);
-      await clearLibrary(userId, debateId);
+      // Notes and changes still waiting to sync would come back after the clear; they go once it succeeds.
+      await clearQueuedDebate(userId, debateId, () => clearLibrary(userId, debateId));
       setSelected(null);
       library.setSources([]);
       toast({ tone: 'success', title: t('common.deleted'), message: t('libraryPage.clearSuccess') });
 
@@ -85,7 +85,8 @@ export function CaseDocument({
     const chips = chipsByArgument[index];
     const pieces = chips.length || (argument.evidence ? 1 : 0);
     return {
-      key: argument.id || `${index}`,
+      // By position: a model can repeat an id, and two arguments must never open and close together.
+      key: `${index}`,
       title: argument.title ?? argument.point,
       summary: pieces > 0
         ? t('mobile.results.evidenceCount', { count: pieces })
 
@@ -152,14 +152,18 @@ describe('offline queue', () => {
     expect(queue.getQueueSnapshot().items).toEqual([]);
   });
 
-  it('clears every write queued for a debate before Clear all, so none comes back', async () => {
+  it('drops the writes queued for a debate once Clear all succeeds, and keeps them when it fails', async () => {
     const queue = await load();
     copies.set('sources:d1', [row('s1', { title: 'Kept', content: 'Text', debateId: 'd1' })]);
     net.offline = true;
     const note = queue.queueAddSource('user-a', { title: 'Waiting note', content: 'Text', type: 'text', debateId: 'd1' });
     await note;
     await queue.queueUpdateSource('user-a', 'd2', 's9', { title: 'Other debate' });
-    await queue.discardQueuedForDebate('user-a', 'd1');
+    // A clear the server refuses keeps everything queued.
+    await expect(queue.clearQueuedDebate('user-a', 'd1', async () => { throw new Error('clear failed'); })).rejects.toThrow('clear failed');
+    expect(queue.getQueueSnapshot().items).toHaveLength(2);
+    net.offline = true;
+    await queue.clearQueuedDebate('user-a', 'd1', async () => undefined);
     await cache.copiesWritten();
     expect(queue.getQueueSnapshot().items.map((item) => item.kind === 'add' ? item.input.debateId : item.debateId)).toEqual(['d2']);
     expect((copies.get('sources:d1') as Source[]).map((item) => item.id)).toEqual(['s1']);
 
@@ -123,6 +123,8 @@ let waiters = new Map<string, Waiter[]>();
 let inFlight: string | null = null;
 let snapshot: QueueSnapshot = { owner, items, synced };
 let running: Promise<void> | null = null;
+// While Clear all asks the server, nothing replays: a queued note must not land in a Library being cleared.
+let paused = 0;
 let again = false;
 let keys = 0;
 
@@ -487,14 +489,24 @@ export async function queueSetSourcesActive(userId: string, debateId: string, so
 }
 
 /**
- * Clear all for a debate: lets a replay that is running finish, then drops every write still
- * queued for that debate (its waiting notes, edits and switches), so none comes back after the
- * server clears the Library. Call it before clearLibrary.
+ * Clear all for a debate: lets a replay that is running finish and holds the queue while `clear`
+ * asks the server; only once it succeeds are the debate's queued writes (its waiting notes, edits
+ * and switches) dropped, so none comes back. A clear that fails keeps them, and the queue resumes.
  */
-export async function discardQueuedForDebate(userId: string, debateId: string): Promise<void> {
+export async function clearQueuedDebate(userId: string, debateId: string, clear: () => Promise<void>): Promise<void> {
   await adopt(userId);
-  if (running) await running.catch(() => undefined);
-  if (owner !== userId) return;
+  paused += 1;
+  try {
+    if (running) await running.catch(() => undefined);
+    await clear();
+    if (owner === userId) dropDebateWrites(userId, debateId);
+  } finally {
+    paused -= 1;
+    void replayOfflineQueue();
+  }
+}
+
+function dropDebateWrites(userId: string, debateId: string) {
   const debateOf = (item: QueuedWrite) => (item.kind === 'add' ? item.input.debateId : item.debateId);
   const dropped = items.filter((item) => debateOf(item) === debateId);
   if (dropped.length === 0) return;
@@ -626,9 +638,9 @@ function describe(item: QueuedWrite): QueueReport['dropped'][number] {
 async function drain() {
   const userId = owner;
   const gen = generation;
-  if (!userId) return;
+  if (!userId || paused > 0) return;
   await ready;
-  if (gen !== generation || items.length === 0) return;
+  if (gen !== generation || items.length === 0 || paused > 0) return;
   if (isKnownOffline() || !(await signedInAs(userId))) {
     if (gen === generation) parkAll();
     return;