Add local PWA chat reset

Author: code4bones

pwa/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@code4bones/branch-pwa",
-  "version": "0.1.0-beta.140",
+  "version": "0.1.0-beta.141",
   "private": true,
   "type": "module",
   "scripts": {

pwa/package.json

@@ -41,6 +41,7 @@ export function PocDebugPanel({ contactId, contactName, enabled, attachedRelayEn
   const [selectedTraceCategories, setSelectedTraceCategories] = useState<TraceCategory[]>(defaultTraceCategories);
   const outbox = useAppStore((state) => state.outbox);
   const settleOutboxMessage = useAppStore((state) => state.settleOutboxMessage);
+  const clearLocalConversation = useAppStore((state) => state.clearLocalConversation);
   const recordTransportTrace = useAppStore((state) => state.recordTransportTrace);
   const { awaitingDeliveryCount, deliveredAwaitingReadCount } = useMemo(() => {
     const localOutbox = outbox.filter((entry) => entry.contactId === contactId);
@@ -69,6 +70,10 @@ export function PocDebugPanel({ contactId, contactName, enabled, attachedRelayEn
     }
     if (purgeableMessageIds.length > 0) recordTransportTrace(`outbox: delivery_mapping_purged ${String(purgeableMessageIds.length)}`);
   };
+  const resetChat = (): void => {
+    clearLocalConversation(contactId);
+    recordTransportTrace("outbox: local_chat_reset");
+  };
   const recentTrace = transportTrace
     .filter((entry) => selectedTraceCategories.includes(traceCategory(entry.detail)))
     .slice(-12)
@@ -112,6 +117,16 @@ export function PocDebugPanel({ contactId, contactName, enabled, attachedRelayEn
         >
           <Button danger disabled={purgeableMessageIds.length === 0} icon={<DeleteOutlined />} size="small">Purge mapping</Button>
         </Popconfirm>
+        <Popconfirm
+          cancelText="Keep"
+          description="This device only: removes this chat's messages, local outbox, Read work and delivery mappings. Contact, identity and relay stay intact."
+          okButtonProps={{ danger: true }}
+          okText="Reset local chat"
+          onConfirm={resetChat}
+          title={`Reset all local test messages with ${contactName}?`}
+        >
+          <Button danger icon={<DeleteOutlined />} size="small">Reset chat</Button>
+        </Popconfirm>
       </div>
       <p className="pwa-poc-debug-note">Burst is local pacing into the normal outbox; it creates no special relay traffic or retry policy.</p>
       <Checkbox.Group

pwa/src/app/PocDebugPanel.tsx

@@ -1,8 +1,12 @@
 import type { StateCreator } from "zustand";
 
 import type { AppStore } from "../store.js";
-import { deleteStoredMessagesLocally, maxConversationTimelineEntries, replaceStoredMessageForRetry, saveStoredMessage } from "../../storage/messages-store.js";
-import { deleteStoredImageMessages } from "../../storage/image-media-store.js";
+import { deleteStoredMessagesForContact, deleteStoredMessagesLocally, maxConversationTimelineEntries, replaceStoredMessageForRetry, saveStoredMessage } from "../../storage/messages-store.js";
+import { deleteStoredImageMessages, deleteStoredImageMessagesForContact } from "../../storage/image-media-store.js";
+import { deleteStoredMessageDeliveryTargetsForContact } from "../../storage/message-delivery-target-store.js";
+import { deleteStoredOutboxForContact } from "../../storage/message-outbox-store.js";
+import { deleteStoredReadReceiptsForContact } from "../../storage/read-receipt-outbox-store.js";
+import { deleteStoredReadState } from "../../storage/read-state-store.js";
 
 // `received` remains an inbound/local compatibility value. Remote user-facing
 // outcomes for an outgoing message are explicit: a relay may say Relayed, but
@@ -33,6 +37,9 @@ export interface ConversationsSlice {
   readonly setMessageDeliveryState: (contactId: string, messageId: string, deliveryState: MessageDeliveryState) => void;
   // UI-initiated device-local removal. It has no transport/control side effect.
   readonly deleteMessagesLocally: (contactId: string, messageIds: readonly string[]) => readonly MessageSummary[];
+  // Debug-only local test cleanup. It preserves the contact, identity, and
+  // relay attachment while clearing this chat's visible history and work.
+  readonly clearLocalConversation: (contactId: string) => void;
 }
 
 export const createConversationsSlice: StateCreator<AppStore, [], [], ConversationsSlice> = (set, get) => ({
@@ -141,6 +148,37 @@ export const createConversationsSlice: StateCreator<AppStore, [], [], Conversati
       // removal can retry local byte cleanup when IndexedDB was unavailable.
     });
     return deleted;
+  },
+  clearLocalConversation: (contactId) => {
+    // Do not reuse contact removal: a test reset must leave the user-owned
+    // contact card and all live relay attachment state intact.
+    get().clearImageMessageProjectionsForContact(contactId);
+    set((state) => {
+      const { [contactId]: removedMessages, ...messagesByContactId } = state.messagesByContactId;
+      const { [contactId]: removedReadState, ...lastReadAtByContactId } = state.lastReadAtByContactId;
+      const { [contactId]: removedTyping, ...typingExpiresAtByContactId } = state.typingExpiresAtByContactId;
+      void removedMessages;
+      void removedReadState;
+      void removedTyping;
+      return {
+        messagesByContactId,
+        outbox: state.outbox.filter((entry) => entry.contactId !== contactId),
+        readReceiptOutbox: state.readReceiptOutbox.filter((entry) => entry.contactId !== contactId),
+        lastReadAtByContactId,
+        typingExpiresAtByContactId
+      };
+    });
+    void Promise.all([
+      deleteStoredMessagesForContact(contactId),
+      deleteStoredReadState(contactId),
+      deleteStoredOutboxForContact(contactId),
+      deleteStoredReadReceiptsForContact(contactId),
+      deleteStoredMessageDeliveryTargetsForContact(contactId),
+      deleteStoredImageMessagesForContact(contactId)
+    ]).catch(() => {
+      // The current tab has already reset its local projection. No reset
+      // action emits transport traffic or retries storage failures.
+    });
   }
 });
 

pwa/src/state/slices/conversations-slice.ts

@@ -216,21 +216,35 @@ export async function replaceStoredMessageForRetry(previousMessageId: string, re
   }
 }
 
-export async function deleteStoredMessagesForContact(contactId: string): Promise<void> {
+export async function deleteStoredMessagesForContact(contactId: string, deletedAt: number = Date.now()): Promise<void> {
   const db = await openDatabase();
   try {
     await new Promise<void>((resolve, reject) => {
-      const transaction = db.transaction([MESSAGES_STORE, CHAT_TIMELINE_STORE], "readwrite");
+      const transaction = db.transaction([MESSAGES_STORE, CHAT_TIMELINE_STORE, LOCALLY_DELETED_MESSAGES_STORE], "readwrite");
       const request = transaction.objectStore(MESSAGES_STORE).index("byContactId").openCursor(IDBKeyRange.only(contactId));
       const timeline = transaction.objectStore(CHAT_TIMELINE_STORE);
+      const tombstones = transaction.objectStore(LOCALLY_DELETED_MESSAGES_STORE);
       request.onsuccess = () => {
         const cursor = request.result;
         if (cursor !== null) {
-          if (typeof cursor.primaryKey === "string") timeline.delete(cursor.primaryKey);
+          if (typeof cursor.primaryKey === "string") {
+            timeline.delete(cursor.primaryKey);
+            tombstones.put({ messageId: cursor.primaryKey, deletedAt });
+          }
           cursor.delete();
           cursor.continue();
         }
       };
+      let retained = 0;
+      const trimRequest = tombstones.index("byDeletedAt").openCursor(null, "prev");
+      trimRequest.onsuccess = () => {
+        const cursor = trimRequest.result;
+        if (cursor === null) return;
+        retained += 1;
+        if (retained > maxStoredLocalDeletionTombstones) cursor.delete();
+        cursor.continue();
+      };
+      trimRequest.onerror = () => { reject(trimRequest.error ?? new Error("failed to trim local deletion markers")); };
       request.onerror = () => { reject(request.error ?? new Error("failed to delete contact messages")); };
       transaction.oncomplete = () => { resolve(); };
       transaction.onerror = () => { reject(transaction.error ?? new Error("failed to delete contact messages")); };

pwa/src/storage/messages-store.ts

@@ -826,6 +826,18 @@ void test("PWA persists active-chat read presentation locally and drains opted-i
   assert.match(transport, /stopReadReceiptRuntime\(\)/);
 });
 
+void test("PWA debug chat reset clears only one local conversation and preserves its contact boundary", async () => {
+  const conversations = await readFile(conversationsSlicePath, "utf8");
+  const panel = await readFile(resolve(process.cwd(), "src/app/PocDebugPanel.tsx"), "utf8");
+  assert.match(conversations, /clearLocalConversation/);
+  assert.match(conversations, /deleteStoredReadReceiptsForContact/);
+  assert.match(conversations, /deleteStoredMessageDeliveryTargetsForContact/);
+  assert.match(conversations, /deleteStoredMessagesForContact/);
+  assert.match(conversations, /identity, and[\s\S]*relay attachment state intact/);
+  assert.match(panel, /Reset chat/);
+  assert.match(panel, /Contact, identity and relay stay intact/);
+});
+
 void test("PWA persists sender receipt targets beyond outbox settlement", async () => {
   const database = await readFile(databasePath, "utf8");
   const targets = await readFile(messageDeliveryTargetStorePath, "utf8");

pwa/tests/app-shell.test.ts

@@ -79,6 +79,13 @@ void test("PoC purge is explicitly labelled as dropping the local correlation, n
   assert.doesNotMatch(panel, /Purge delivered/);
 });
 
+void test("PoC reset chat is an explicit local test cleanup", async () => {
+  const panel = await readFile(resolve(process.cwd(), "src/app/PocDebugPanel.tsx"), "utf8");
+  assert.match(panel, /clearLocalConversation\(contactId\)/);
+  assert.match(panel, /outbox: local_chat_reset/);
+  assert.match(panel, /Reset local chat/);
+});
+
 class Timers implements PocBurstTimerPort {
   readonly callbacks: Array<() => void> = [];