logos-messaging/logos-messaging-go
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go.git synced 2026-01-07 00:13:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: setting peerId for store query (#1278)

Browse Source
This commit is contained in:
gabrielmer 2025-03-20 15:47:51 +02:00 committed by GitHub
parent e68fcdb554
commit fdf03de179
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
waku/v2/protocol/store/client.go
View File

@ -10,6 +10,7 @@ import (
"github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/host"
"github.com/libp2p/go-libp2p/core/peer" "github.com/libp2p/go-libp2p/core/peer"
libp2pPeerstore "github.com/libp2p/go-libp2p/core/peerstore"
libp2pProtocol "github.com/libp2p/go-libp2p/core/protocol" libp2pProtocol "github.com/libp2p/go-libp2p/core/protocol"
"github.com/libp2p/go-msgio/pbio" "github.com/libp2p/go-msgio/pbio"
"github.com/waku-org/go-waku/logging" "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 var params Parameters
params.peerAddr = peerInfo.Addrs params.peerAddr = peerInfo.Addrs
if len(params.peerAddr) == 0 { params.selectedPeer = peerInfo.ID
if len(params.peerAddr) == 0 || params.selectedPeer == "" {
return nil, ErrMustSelectPeer return nil, ErrMustSelectPeer
} }
//Add Peer to peerstore.
s.h.Peerstore().AddAddrs(peerInfo.ID, peerInfo.Addrs, libp2pPeerstore.AddressTTL)
response, err := s.queryFrom(ctx, storeRequest, &params) response, err := s.queryFrom(ctx, storeRequest, &params)
if err != nil { if err != nil {
return nil, err return nil, err