fix(filter-subscribe): params.selectedPeer not set

waku-org · Oct 25, 2023 · 0b5d133 · 0b5d133
1 parent 18c16de
commit 0b5d133
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/waku/v2/protocol/filter/client.go b/waku/v2/protocol/filter/client.go
@@ -306,7 +306,12 @@ func (wf *WakuFilterLightNode) Subscribe(ctx context.Context, contentFilter prot
 		cFilter.PubsubTopic = pubSubTopic
 		cFilter.ContentTopics = protocol.NewContentTopicSet(cTopics...)
 
-		err := wf.request(ctx, params, pb.FilterSubscribeRequest_SUBSCRIBE, cFilter)
+		err := wf.request(
+			ctx,
+			&FilterSubscribeParameters{selectedPeer: selectedPeer, requestID: params.requestID},
+			pb.FilterSubscribeRequest_SUBSCRIBE,
+			cFilter,
+		)
 		if err != nil {
 			wf.log.Error("Failed to subscribe", zap.String("pubSubTopic", pubSubTopic), zap.Strings("contentTopics", cTopics),
 				zap.Error(err))