Fix deleting pubsub topics; only allow adding unique topics

waku-org · Sep 22, 2023 · a3d1203 · a3d1203
1 parent 9f4754d
commit a3d1203
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/waku/v2/peerstore/waku_peer_store.go b/waku/v2/peerstore/waku_peer_store.go
@@ -155,6 +155,11 @@ func (ps *WakuPeerstoreImpl) AddPubSubTopic(p peer.ID, topic string) error {
 	if err != nil {
 		return err
 	}
+	for _, t := range existingTopics {
+		if t == topic {
+			return nil
+		}
+	}
 	existingTopics = append(existingTopics, topic)
 	return ps.peerStore.Put(p, peerPubSubTopics, existingTopics)
 }