ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-27 21:07:01 -06:00
Code Issues Packages Projects Releases Wiki Activity

test(whatsapp): await automatic redelivery retries (#130101)

Browse Source 
Amp-Thread-ID: https://ampcode.com/threads/T-01a03d6a-d790-77bf-852b-65c57440ac84

Co-authored-by: Amp <amp@ampcode.com>
This commit is contained in:
Peter Steinberger
2026-08-26 05:49:06 -07:00
committed by GitHub
parent 5f26065146
commit 8e1e566ab6
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
extensions/whatsapp/src/monitor-inbox.delivery-and-dedupe.test.ts
+2 -10
View File
@@ -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(() => {