diff --git a/extensions/whatsapp/src/monitor-inbox.delivery-and-dedupe.test.ts b/extensions/whatsapp/src/monitor-inbox.delivery-and-dedupe.test.ts index b609bc677c8c..2c503782d9c2 100644 --- a/extensions/whatsapp/src/monitor-inbox.delivery-and-dedupe.test.ts +++ b/extensions/whatsapp/src/monitor-inbox.delivery-and-dedupe.test.ts @@ -605,7 +605,7 @@ describe("web monitor inbox delivery and dedupe", () => { await listener.close(); }); - it("delivery coordinator retries redelivery after an explicit retryable failure", async () => { + it("delivery coordinator automatically retries after an explicit retryable failure", async () => { let attempts = 0; const onMessage = vi.fn(async () => { attempts += 1; @@ -624,10 +624,6 @@ describe("web monitor inbox delivery and dedupe", () => { pushName: "Tester", }); - sock.ev.emit("messages.upsert", upsert); - await waitForMessageCalls(onMessage, 1); - expect(sock.readMessages).not.toHaveBeenCalled(); - sock.ev.emit("messages.upsert", upsert); await waitForMessageCalls(onMessage, 2); await vi.waitFor(() => { @@ -637,7 +633,7 @@ describe("web monitor inbox delivery and dedupe", () => { await listener.close(); }); - it("delivery coordinator retries redelivery after reply session conflicts", async () => { + it("delivery coordinator automatically retries after reply session conflicts", async () => { let attempts = 0; const onMessage = vi.fn(async () => { attempts += 1; @@ -657,10 +653,6 @@ describe("web monitor inbox delivery and dedupe", () => { pushName: "Tester", }); - sock.ev.emit("messages.upsert", upsert); - await waitForMessageCalls(onMessage, 1); - expect(sock.readMessages).not.toHaveBeenCalled(); - sock.ev.emit("messages.upsert", upsert); await waitForMessageCalls(onMessage, 2); await vi.waitFor(() => {