waku-org
/
js-waku
mirror of https://github.com/waku-org/js-waku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore: update tests

This commit is contained in:
Danish Arora 2024-09-13 15:28:39 +05:30
parent c0e6e05de8
commit 6b58f08bc1
No known key found for this signature in database
GPG Key ID: 1C6EF37CDAE1426E
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
packages/tests/tests/light-push/peer_management.spec.ts
View File

@ -1,5 +1,6 @@
import { LightNode } from "@waku/interfaces"; import { LightNode } from "@waku/interfaces";
import { createEncoder, utf8ToBytes } from "@waku/sdk"; import { createEncoder, utf8ToBytes } from "@waku/sdk";
import { delay } from "@waku/utils";
import { expect } from "chai"; import { expect } from "chai";
import { describe } from "mocha"; import { describe } from "mocha";
@ -78,18 +79,21 @@ describe("Waku Light Push: Peer Management: E2E", function () {
expect(response2.failures).to.have.length(1); expect(response2.failures).to.have.length(1);
expect(response2.failures?.[0].peerId).to.equal(peerToDisconnect); expect(response2.failures?.[0].peerId).to.equal(peerToDisconnect);
// send another lightpush request -- renewal should have triggerred and new peer should be used instead of the disconnected one // send another lightpush request
// reattempts to send should be triggerred
// then renewal should happen
// so one failure should exist
const response3 = await waku.lightPush.send(encoder, { const response3 = await waku.lightPush.send(encoder, {
payload: utf8ToBytes("Hello_World") payload: utf8ToBytes("Hello_World")
}); });
// wait for reattempts to finish as they are async and not awaited
await delay(500);
expect(response3.successes.length).to.be.equal( expect(response3.successes.length).to.be.equal(
waku.lightPush.numPeersToUse waku.lightPush.numPeersToUse - 1
); );
expect(response3.successes).to.not.include(peerToDisconnect); expect(response3.successes).to.not.include(peerToDisconnect);
if (response3.failures) {
expect(response3.failures.length).to.equal(0);
}
}); });
}); });