Fix issue with pubsub topic removal

waku-org · Sep 22, 2023 · 7d77b67 · 7d77b67
1 parent 035dc75
commit 7d77b67
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/waku/v2/peerstore/waku_peer_store.go b/waku/v2/peerstore/waku_peer_store.go
@@ -171,7 +171,10 @@ func (ps *WakuPeerstoreImpl) RemovePubSubTopic(p peer.ID, topic string) error {
 	}
 
 	for i := range existingTopics {
-		existingTopics = append(existingTopics[:i], existingTopics[i+1:]...)
+		if existingTopics[i] == topic {
+			existingTopics = append(existingTopics[:i], existingTopics[i+1:]...)
+			break
+		}
 	}
 	err = ps.SetPubSubTopics(p, existingTopics)
 	if err != nil {