logos-messaging/logos-delivery-go
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery-go.git synced 2026-05-17 12:39:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: improving approach

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

10
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/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"
@ -210,12 +211,15 @@ func (s *WakuStore) RequestRaw(ctx context.Context, peerInfo peer.AddrInfo, stor
//Add Peer to peerstore.
if s.pm != nil && params.peerAddr != nil {
pData, err := s.pm.AddPeer(params.peerAddr, peerstore.Static, []string{}, StoreQueryID_v300)
infoArr, err := peer.AddrInfosFromP2pAddrs(params.peerAddr...)
if err != nil {
return nil, err
}
s.pm.Connect(pData)
params.selectedPeer = pData.AddrInfo.ID
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)