node: fix nil reference in evm watcher (#1758)
This commit is contained in:
parent
206d10cacf
commit
c31776c345
|
@ -254,12 +254,12 @@ func (w *Watcher) Run(ctx context.Context) error {
|
||||||
// will keep running. Other connectors will use a timeout internally if appropriate.
|
// will keep running. Other connectors will use a timeout internally if appropriate.
|
||||||
messageC := make(chan *ethabi.AbiLogMessagePublished, 2)
|
messageC := make(chan *ethabi.AbiLogMessagePublished, 2)
|
||||||
messageSub, err := w.ethConn.WatchLogMessagePublished(ctx, messageC)
|
messageSub, err := w.ethConn.WatchLogMessagePublished(ctx, messageC)
|
||||||
defer messageSub.Unsubscribe()
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ethConnectionErrors.WithLabelValues(w.networkName, "subscribe_error").Inc()
|
ethConnectionErrors.WithLabelValues(w.networkName, "subscribe_error").Inc()
|
||||||
p2p.DefaultRegistry.AddErrorCount(w.chainID, 1)
|
p2p.DefaultRegistry.AddErrorCount(w.chainID, 1)
|
||||||
return fmt.Errorf("failed to subscribe to message publication events: %w", err)
|
return fmt.Errorf("failed to subscribe to message publication events: %w", err)
|
||||||
}
|
}
|
||||||
|
defer messageSub.Unsubscribe()
|
||||||
|
|
||||||
// Fetch initial guardian set
|
// Fetch initial guardian set
|
||||||
if err := w.fetchAndUpdateGuardianSet(logger, ctx, w.ethConn); err != nil {
|
if err := w.fetchAndUpdateGuardianSet(logger, ctx, w.ethConn); err != nil {
|
||||||
|
|
Loading…
Reference in New Issue