From e12638a2e71010c7bfd5d30be7babe9a4df209e8 Mon Sep 17 00:00:00 2001 From: Gabriel mermelstein Date: Thu, 20 Mar 2025 15:40:16 +0200 Subject: [PATCH] fix: store query --- waku/v2/protocol/store/client.go | 15 +++------------ 1 file changed, 3 insertions(+), 12 deletions(-) diff --git a/waku/v2/protocol/store/client.go b/waku/v2/protocol/store/client.go index a7e167d9..0dd3f73b 100644 --- a/waku/v2/protocol/store/client.go +++ b/waku/v2/protocol/store/client.go @@ -205,22 +205,13 @@ func (s *WakuStore) RequestRaw(ctx context.Context, peerInfo peer.AddrInfo, stor var params Parameters params.peerAddr = peerInfo.Addrs - if len(params.peerAddr) == 0 { + params.selectedPeer = peerInfo.ID + if len(params.peerAddr) == 0 || params.selectedPeer == "" { return nil, ErrMustSelectPeer } //Add Peer to peerstore. - if s.pm != nil && params.peerAddr != nil { - infoArr, err := peer.AddrInfosFromP2pAddrs(params.peerAddr...) - if err != nil { - return nil, err - } - for _, info := range infoArr { - s.h.Peerstore().AddAddrs(info.ID, info.Addrs, libp2pPeerstore.AddressTTL) - - } - params.selectedPeer = infoArr[0].ID - } + s.h.Peerstore().AddAddrs(peerInfo.ID, peerInfo.Addrs, libp2pPeerstore.AddressTTL) response, err := s.queryFrom(ctx, storeRequest, ¶ms) if err != nil {