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

fix: return no peers available

Browse Source
This commit is contained in:
Igor Sirotin 2025-11-27 10:27:30 +00:00
parent 99b3ab5b2a
commit 0c4ee98c7d
No known key found for this signature in database
GPG Key ID: 0EABBCB40CB9AD4A
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
waku/v2/peermanager/peer_selection.go
View File

@ -73,7 +73,10 @@ func (pm *PeerManager) SelectRandom(criteria PeerSelectionCriteria) (peer.IDSlic
if err != nil { if err != nil {
return nil, err return nil, err
} }
if len(criteria.PubsubTopics) > 0 && len(filteredPeers) > 0 { if len(filteredPeers) == 0 {
return nil, utils.ErrNoPeersAvailable
}
if len(criteria.PubsubTopics) > 0 {
filteredPeers = pm.host.Peerstore().(wps.WakuPeerstore).PeersByPubSubTopics(criteria.PubsubTopics, filteredPeers...) filteredPeers = pm.host.Peerstore().(wps.WakuPeerstore).PeersByPubSubTopics(criteria.PubsubTopics, filteredPeers...)
} }
//Not passing excludePeers as filterPeers are already considering excluded ones. //Not passing excludePeers as filterPeers are already considering excluded ones.