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

fix: store query

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-03-20 15:40:16 +02:00
parent 1a0011177b
commit e12638a2e7
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 3 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -205,22 +205,13 @@ 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. //Add Peer to peerstore.
if s.pm != nil && params.peerAddr != nil { s.h.Peerstore().AddAddrs(peerInfo.ID, peerInfo.Addrs, libp2pPeerstore.AddressTTL)
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
}
response, err := s.queryFrom(ctx, storeRequest, &params) response, err := s.queryFrom(ctx, storeRequest, &params)
if err != nil { if err != nil {