From 841bdbb90e731e92d1ec619b18b3dfea400b47ed Mon Sep 17 00:00:00 2001
From: SionoiS <simvivier@status.im>
Date: Tue, 19 Sep 2023 09:00:29 -0400
Subject: [PATCH] Fix

---
 packages/tests/tests/filter/subscribe.node.spec.ts   | 3 +++
 packages/tests/tests/filter/unsubscribe.node.spec.ts | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/packages/tests/tests/filter/subscribe.node.spec.ts b/packages/tests/tests/filter/subscribe.node.spec.ts
index 8dfdda677e..0ded20d724 100644
--- a/packages/tests/tests/filter/subscribe.node.spec.ts
+++ b/packages/tests/tests/filter/subscribe.node.spec.ts
@@ -42,6 +42,9 @@ describe("Waku Filter V2: Subscribe", function () {
     [nwaku, waku] = await runNodes(this);
     subscription = await waku.filter.createSubscription();
     messageCollector = new MessageCollector(TestContentTopic);
+
+    // Nwaku subscribe to the default pubsub topic
+    await nwaku.ensureSubscriptions();
   });
 
   this.afterEach(async function () {
diff --git a/packages/tests/tests/filter/unsubscribe.node.spec.ts b/packages/tests/tests/filter/unsubscribe.node.spec.ts
index df73ec59c7..b1591c2911 100644
--- a/packages/tests/tests/filter/unsubscribe.node.spec.ts
+++ b/packages/tests/tests/filter/unsubscribe.node.spec.ts
@@ -28,6 +28,9 @@ describe("Waku Filter V2: Unsubscribe", function () {
     [nwaku, waku] = await runNodes(this);
     subscription = await waku.filter.createSubscription();
     messageCollector = new MessageCollector(TestContentTopic);
+
+    // Nwaku subscribe to the default pubsub topic
+    await nwaku.ensureSubscriptions();
   });
 
   this.afterEach(async function () {