From e4482d7be7f271b5b5ecb4e8c3b26d616f51a5a3 Mon Sep 17 00:00:00 2001
From: danisharora099 <danisharora099@gmail.com>
Date: Tue, 2 May 2023 18:09:46 +0530
Subject: [PATCH] set `pubSubTopic` in the constructor

---
 packages/core/src/lib/filter/v2/index.ts | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/packages/core/src/lib/filter/v2/index.ts b/packages/core/src/lib/filter/v2/index.ts
index 09b486fd73..9a3b8ccbfa 100644
--- a/packages/core/src/lib/filter/v2/index.ts
+++ b/packages/core/src/lib/filter/v2/index.ts
@@ -54,6 +54,7 @@ const FilterV2Codecs = {
 class FilterV2 extends BaseProtocol implements IFilterV2 {
   options: ProtocolCreateOptions;
   private subscriptions: Map<RequestID, unknown>;
+  public pubSubTopic: string;
 
   constructor(public libp2p: Libp2p, options?: ProtocolCreateOptions) {
     super(
@@ -66,6 +67,9 @@ class FilterV2 extends BaseProtocol implements IFilterV2 {
 
     this.options = options ?? {};
     this.subscriptions = new Map();
+
+    const { pubSubTopic = DefaultPubSubTopic } = this.options;
+    this.pubSubTopic = pubSubTopic;
   }
 
   /**
@@ -80,12 +84,11 @@ class FilterV2 extends BaseProtocol implements IFilterV2 {
     opts?: ProtocolOptions
   ): Promise<UnsubscribeFunction> {
     const decodersArray = Array.isArray(decoders) ? decoders : [decoders];
-    const { pubSubTopic = DefaultPubSubTopic } = this.options;
 
     const contentTopics = Array.from(groupByContentTopic(decodersArray).keys());
 
     const request = FilterSubscribeRpc.createSubscribeRequest(
-      pubSubTopic,
+      this.pubSubTopic,
       contentTopics
     );
 
@@ -134,12 +137,12 @@ class FilterV2 extends BaseProtocol implements IFilterV2 {
     const subscription: Subscription<T> = {
       callback,
       decoders: decodersArray,
-      pubSubTopic,
+      pubSubTopic: this.pubSubTopic,
     };
     this.subscriptions.set(requestId, subscription);
 
     return async () => {
-      await this.unsubscribe(pubSubTopic, contentTopics, requestId, peer);
+      await this.unsubscribe(this.pubSubTopic, contentTopics, requestId, peer);
       this.subscriptions.delete(requestId);
     };
   }