matrix/matrix-js-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-js-sdk.git synced 2025-08-07 23:02:56 +03:00
Code Activity

Attempt deflaking of queueToDevice test (#4936)

Browse Source
This commit is contained in:
Richard van der Hoff
2025-07-24 10:20:54 +01:00
committed by GitHub
parent bf3b4e81b2
commit 556494b8f0
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spec/unit/queueToDevice.spec.ts
View File

@@ -126,13 +126,15 @@ describe.each([[StoreType.Memory], [StoreType.IndexedDB]])("queueToDevice (%s st
eventType: "org.example.foo", eventType: "org.example.foo",
batch: [FAKE_MSG], batch: [FAKE_MSG],
}); });
expect(await httpBackend.flush(undefined, 1, 1)).toEqual(1); // flush the 500 response
expect(await httpBackend.flush("/sendToDevice/org.example.foo/", 1, 20)).toEqual(1);
await flushPromises(); await flushPromises();
client.retryImmediately(); client.retryImmediately();
// flush the 200 response
// longer timeout here to try & avoid flakiness // longer timeout here to try & avoid flakiness
expect(await httpBackend.flush(undefined, 1, 3000)).toEqual(1); expect(await httpBackend.flush("/sendToDevice/org.example.foo/", 1, 3000)).toEqual(1);
}); });
it("retries on when client is started", async function () { it("retries on when client is started", async function () {
@@ -150,13 +152,15 @@ describe.each([[StoreType.Memory], [StoreType.IndexedDB]])("queueToDevice (%s st
eventType: "org.example.foo", eventType: "org.example.foo",
batch: [FAKE_MSG], batch: [FAKE_MSG],
}); });
expect(await httpBackend.flush(undefined, 1, 1)).toEqual(1); // flush the 500 response
expect(await httpBackend.flush("/sendToDevice/org.example.foo/", 1, 20)).toEqual(1);
await flushPromises(); await flushPromises();
client.stopClient(); client.stopClient();
await Promise.all([client.startClient(), httpBackend.flush("/_matrix/client/versions", 1, 20)]); await Promise.all([client.startClient(), httpBackend.flush("/_matrix/client/versions", 1, 20)]);
expect(await httpBackend.flush(undefined, 1, 20)).toEqual(1); // flush the 200 response
expect(await httpBackend.flush("/sendToDevice/org.example.foo/", 1, 20)).toEqual(1);
}); });
it("retries when a message is retried", async function () { it("retries when a message is retried", async function () {