status-im
/
js-waku
mirror of https://github.com/status-im/js-waku.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

updated wrong cursor test

This commit is contained in:
fbarbu15 2023-10-10 08:51:41 +03:00
parent 94d63f4548
commit 1d1c7a28a8
No known key found for this signature in database
GPG Key ID: D75221C8DEA22501
1 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
packages/tests/tests/store/cursor.node.spec.ts
View File

@ -169,8 +169,7 @@ describe("Waku Store, cursor", function () {
} }
}); });
// PubsubTopic is ignored in the cursor: https://github.com/waku-org/js-waku/pull/1640 it("Passing cursor with wrong pubSubTopic", async function () {
it.skip("Passing cursor with wrong pubSubTopic", async function () {
await sendMessages(nwaku, totalMsgs, TestContentTopic, DefaultPubSubTopic); await sendMessages(nwaku, totalMsgs, TestContentTopic, DefaultPubSubTopic);
waku = await startAndConnectLightNode(nwaku); waku = await startAndConnectLightNode(nwaku);
@ -180,18 +179,25 @@ describe("Waku Store, cursor", function () {
messages.push(msg as DecodedMessage); messages.push(msg as DecodedMessage);
} }
} }
const cursor = await createCursor(messages[5], customPubSubTopic); messages[5].pubSubTopic = customPubSubTopic;
const cursor = await createCursor(messages[5]);
const messagesAfterCursor: DecodedMessage[] = []; try {
for await (const page of waku.store.queryGenerator([TestDecoder], { for await (const page of waku.store.queryGenerator([TestDecoder], {
cursor cursor
})) { })) {
for await (const msg of page.reverse()) { page;
if (msg) { }
messagesAfterCursor.push(msg as DecodedMessage); throw new Error("Cursor with wrong pubsubtopic was accepted");
} } catch (err) {
if (
!(err instanceof Error) ||
!err.message.includes(
`Cursor pubsub topic (${customPubSubTopic}) does not match decoder pubsub topic (${DefaultPubSubTopic})`
)
) {
throw err;
} }
} }
expect(messagesAfterCursor.length).be.eql(0);
}); });
}); });