From fdf03de179a75cbdce8cedb722d7866374bb2d0f Mon Sep 17 00:00:00 2001 From: gabrielmer <101006718+gabrielmer@users.noreply.github.com> Date: Thu, 20 Mar 2025 15:47:51 +0200 Subject: [PATCH] fix: setting peerId for store query (#1278) --- waku/v2/protocol/store/client.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/waku/v2/protocol/store/client.go b/waku/v2/protocol/store/client.go index 2cb3d58b..0dd3f73b 100644 --- a/waku/v2/protocol/store/client.go +++ b/waku/v2/protocol/store/client.go @@ -10,6 +10,7 @@ import ( "github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/peer" + libp2pPeerstore "github.com/libp2p/go-libp2p/core/peerstore" libp2pProtocol "github.com/libp2p/go-libp2p/core/protocol" "github.com/libp2p/go-msgio/pbio" "github.com/waku-org/go-waku/logging" @@ -204,10 +205,14 @@ 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. + s.h.Peerstore().AddAddrs(peerInfo.ID, peerInfo.Addrs, libp2pPeerstore.AddressTTL) + response, err := s.queryFrom(ctx, storeRequest, ¶ms) if err != nil { return nil, err