From 856d3de265b7afaedbaf68181efd348fe002344b Mon Sep 17 00:00:00 2001 From: Florin Barbu Date: Mon, 2 Oct 2023 23:32:18 +0300 Subject: [PATCH] chore: add missing ensureSubscriptions call (#1628) Co-authored-by: Sasha <118575614+weboko@users.noreply.github.com> --- packages/tests/tests/filter/multiple_pubsub.node.spec.ts | 2 +- packages/tests/tests/filter/subscribe.node.spec.ts | 1 + packages/tests/tests/light-push/multiple_pubsub.node.spec.ts | 1 + 3 files changed, 3 insertions(+), 1 deletion(-) diff --git a/packages/tests/tests/filter/multiple_pubsub.node.spec.ts b/packages/tests/tests/filter/multiple_pubsub.node.spec.ts index 03050db036..bd38430794 100644 --- a/packages/tests/tests/filter/multiple_pubsub.node.spec.ts +++ b/packages/tests/tests/filter/multiple_pubsub.node.spec.ts @@ -113,7 +113,7 @@ describe("Waku Filter V2: Multiple PubSubtopics", function () { DefaultPubSubTopic, await nwaku2.getPeerId() ); - await nwaku.ensureSubscriptions([DefaultPubSubTopic]); + await nwaku2.ensureSubscriptions([DefaultPubSubTopic]); const messageCollector2 = new MessageCollector(); diff --git a/packages/tests/tests/filter/subscribe.node.spec.ts b/packages/tests/tests/filter/subscribe.node.spec.ts index 22d63b1e3f..540c1391fa 100644 --- a/packages/tests/tests/filter/subscribe.node.spec.ts +++ b/packages/tests/tests/filter/subscribe.node.spec.ts @@ -327,6 +327,7 @@ describe("Waku Filter V2: Subscribe", function () { DefaultPubSubTopic, await nwaku2.getPeerId() ); + await nwaku2.ensureSubscriptions([DefaultPubSubTopic]); // Send a message using the new subscription const newContentTopic = "/test/2/waku-filter"; const newEncoder = createEncoder({ contentTopic: newContentTopic }); diff --git a/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts b/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts index f942b654a6..87712ad431 100644 --- a/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts +++ b/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts @@ -112,6 +112,7 @@ describe("Waku Light Push : Multiple PubSubtopics", function () { relay: true, topic: [DefaultPubSubTopic] }); + await nwaku2.ensureSubscriptions([DefaultPubSubTopic]); await waku.dial(await nwaku2.getMultiaddrWithId()); await waitForRemotePeer(waku, [Protocols.LightPush]);