status-im
/
status-go
mirror of https://github.com/status-im/status-go.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: use minPeers when initializing relay

This commit is contained in:
Richard Ramos 2022-10-04 13:54:13 -04:00 committed by RichΛrd
parent 7272bf0d91
commit 571ab4c88d
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
wakuv2/waku.go
View File

@ -252,7 +252,7 @@ func New(nodeKey string, cfg *Config, logger *zap.Logger, appDB *sql.DB) (*Waku,
relayOpts = append(relayOpts, pubsub.WithPeerExchange(true)) relayOpts = append(relayOpts, pubsub.WithPeerExchange(true))
} }
opts = append(opts, node.WithWakuRelay(relayOpts...)) opts = append(opts, node.WithWakuRelayAndMinPeers(waku.settings.MinPeersForRelay, relayOpts...))
} }
if cfg.EnableStore { if cfg.EnableStore {
@ -856,11 +856,6 @@ func (w *Waku) UnsubscribeMany(ids []string) error {
return nil return nil
} }
func (w *Waku) notEnoughPeers() bool {
numPeers := len(w.node.Relay().PubSub().ListPeers(relay.DefaultWakuTopic))
return numPeers <= w.settings.MinPeersForRelay
}
func (w *Waku) broadcast() { func (w *Waku) broadcast() {
for { for {
select { select {
@ -872,7 +867,7 @@ func (w *Waku) broadcast() {
continue continue
} }
if w.settings.LightClient || w.notEnoughPeers() { if w.settings.LightClient {
log.Debug("publishing message via lightpush", zap.Any("hash", hexutil.Encode(hash))) log.Debug("publishing message via lightpush", zap.Any("hash", hexutil.Encode(hash)))
_, err = w.node.Lightpush().Publish(context.Background(), msg) _, err = w.node.Lightpush().Publish(context.Background(), msg)
} else { } else {