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 crashes on mobile

This commit is contained in:
Vitaly Vlasov 2024-02-16 18:52:40 +02:00 committed by frank
parent 16b3e99205
commit 81be9ea190
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
wakuv2/waku.go
View File

@ -219,13 +219,13 @@ func New(nodeKey string, fleet string, cfg *Config, logger *zap.Logger, appDB *s
onPeerStats: onPeerStats, onPeerStats: onPeerStats,
} }
enablePeerExchange := false enablePeerExchange := false
enabledDiscv5 := false enableDiscv5 := false
if cfg.LightClient { if cfg.LightClient {
enablePeerExchange = true enablePeerExchange = true
enabledDiscv5 = false enableDiscv5 = false
} else { } else {
enablePeerExchange = false enablePeerExchange = false
enabledDiscv5 = true enableDiscv5 = true
} }
waku.settings = settings{ waku.settings = settings{
@ -237,7 +237,7 @@ func New(nodeKey string, fleet string, cfg *Config, logger *zap.Logger, appDB *s
DiscoveryLimit: cfg.DiscoveryLimit, DiscoveryLimit: cfg.DiscoveryLimit,
Nameserver: cfg.Nameserver, Nameserver: cfg.Nameserver,
Resolver: cfg.Resolver, Resolver: cfg.Resolver,
EnableDiscV5: enabledDiscv5, EnableDiscV5: enableDiscv5,
} }
waku.settings.DefaultPubsubTopic = cfg.DefaultShardPubsubTopic waku.settings.DefaultPubsubTopic = cfg.DefaultShardPubsubTopic
@ -282,7 +282,7 @@ func New(nodeKey string, fleet string, cfg *Config, logger *zap.Logger, appDB *s
node.WithMaxMsgSize(1024 * 1024), node.WithMaxMsgSize(1024 * 1024),
} }
if enabledDiscv5 { if enableDiscv5 {
bootnodes, err := waku.getDiscV5BootstrapNodes(waku.ctx, cfg.DiscV5BootstrapNodes) bootnodes, err := waku.getDiscV5BootstrapNodes(waku.ctx, cfg.DiscV5BootstrapNodes)
if err != nil { if err != nil {
logger.Error("failed to get bootstrap nodes", zap.Error(err)) logger.Error("failed to get bootstrap nodes", zap.Error(err))
@ -1221,14 +1221,14 @@ func (w *Waku) Start() error {
return fmt.Errorf("failed to add wakuv2 peers: %v", err) return fmt.Errorf("failed to add wakuv2 peers: %v", err)
} }
if w.cfg.EnableDiscV5 { if w.settings.EnableDiscV5 {
err := w.node.DiscV5().Start(w.ctx) err := w.node.DiscV5().Start(w.ctx)
if err != nil { if err != nil {
return err return err
} }
} }
if w.cfg.PeerExchange { if w.settings.PeerExchange {
err := w.node.PeerExchange().Start(w.ctx) err := w.node.PeerExchange().Start(w.ctx)
if err != nil { if err != nil {
return err return err
@ -1261,7 +1261,7 @@ func (w *Waku) Start() error {
w.onPeerStats(latestConnStatus) w.onPeerStats(latestConnStatus)
} }
if w.cfg.EnableDiscV5 { if w.settings.EnableDiscV5 {
// Restarting DiscV5 // Restarting DiscV5
if !latestConnStatus.IsOnline && isConnected { if !latestConnStatus.IsOnline && isConnected {
w.logger.Info("Restarting DiscV5: offline and is connected") w.logger.Info("Restarting DiscV5: offline and is connected")