waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-02-22 09:08:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: lightpush 5 times instead of 30

Browse Source
This commit is contained in:
Danish Arora 2025-01-22 18:15:34 +05:30
parent 9127637151
commit b7c60a2332
No known key found for this signature in database
GPG Key ID: 1C6EF37CDAE1426E
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/tests/tests/light-push/index.node.spec.ts
View File

@ -65,24 +65,24 @@ const runTests = (strictNodeCheck: boolean): void => {
}); });
}); });
it("Push 30 different messages", async function () { it("Push 5 different messages", async function () {
const generateMessageText = (index: number): string => `M${index}`; const generateMessageText = (index: number): string => `M${index}`;
for (let i = 0; i < 30; i++) { for (let i = 0; i < 5; i++) {
const pushResponse = await waku.lightPush.send(TestEncoder, { const pushResponse = await waku.lightPush.send(TestEncoder, {
payload: utf8ToBytes(generateMessageText(i)) payload: utf8ToBytes(generateMessageText(i))
}); });
if (pushResponse.failures.length > 0) console.log(i + 1);
expect(pushResponse.successes.length).to.equal(numServiceNodes); expect(pushResponse.successes.length).to.equal(numServiceNodes);
} }
expect( expect(
await serviceNodes.messageCollector.waitForMessages(30, { await serviceNodes.messageCollector.waitForMessages(5, {
pubsubTopic: TestPubsubTopic pubsubTopic: TestPubsubTopic
}) })
).to.eq(true); ).to.eq(true);
for (let i = 0; i < 30; i++) { for (let i = 0; i < 5; i++) {
serviceNodes.messageCollector.verifyReceivedMessage(i, { serviceNodes.messageCollector.verifyReceivedMessage(i, {
expectedMessageText: generateMessageText(i), expectedMessageText: generateMessageText(i),
expectedContentTopic: TestContentTopic, expectedContentTopic: TestContentTopic,