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: add missing ensureSubscriptions call (#1628) 

Co-authored-by: Sasha <118575614+weboko@users.noreply.github.com>
This commit is contained in:
Florin Barbu 2023-10-02 23:32:18 +03:00 committed by GitHub
parent d02838164f
commit 856d3de265
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
packages/tests/tests/filter/multiple_pubsub.node.spec.ts
View File

@ -113,7 +113,7 @@ describe("Waku Filter V2: Multiple PubSubtopics", function () {
DefaultPubSubTopic, DefaultPubSubTopic,
await nwaku2.getPeerId() await nwaku2.getPeerId()
); );
await nwaku.ensureSubscriptions([DefaultPubSubTopic]); await nwaku2.ensureSubscriptions([DefaultPubSubTopic]);
const messageCollector2 = new MessageCollector(); const messageCollector2 = new MessageCollector();

1
packages/tests/tests/filter/subscribe.node.spec.ts
View File

@ -327,6 +327,7 @@ describe("Waku Filter V2: Subscribe", function () {
DefaultPubSubTopic, DefaultPubSubTopic,
await nwaku2.getPeerId() await nwaku2.getPeerId()
); );
await nwaku2.ensureSubscriptions([DefaultPubSubTopic]);
// Send a message using the new subscription // Send a message using the new subscription
const newContentTopic = "/test/2/waku-filter"; const newContentTopic = "/test/2/waku-filter";
const newEncoder = createEncoder({ contentTopic: newContentTopic }); const newEncoder = createEncoder({ contentTopic: newContentTopic });

1
packages/tests/tests/light-push/multiple_pubsub.node.spec.ts
View File

@ -112,6 +112,7 @@ describe("Waku Light Push : Multiple PubSubtopics", function () {
relay: true, relay: true,
topic: [DefaultPubSubTopic] topic: [DefaultPubSubTopic]
}); });
await nwaku2.ensureSubscriptions([DefaultPubSubTopic]);
await waku.dial(await nwaku2.getMultiaddrWithId()); await waku.dial(await nwaku2.getMultiaddrWithId());
await waitForRemotePeer(waku, [Protocols.LightPush]); await waitForRemotePeer(waku, [Protocols.LightPush]);