From e0ba66791dcfaf4c1e6e13648128890905591ff7 Mon Sep 17 00:00:00 2001 From: Vitaliy Vlasov Date: Fri, 22 Sep 2023 15:15:26 +0300 Subject: [PATCH] fix: only allow adding unique topics --- waku/v2/peerstore/waku_peer_store.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/waku/v2/peerstore/waku_peer_store.go b/waku/v2/peerstore/waku_peer_store.go index df80df88..5d2f28e0 100644 --- 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) }