From be960734949384b44c86f8966a8a974b70899fc5 Mon Sep 17 00:00:00 2001 From: Evan Gray Date: Sat, 23 Sep 2023 12:12:14 -0400 Subject: [PATCH] node/evm: fix Base safe block support --- node/pkg/watchers/evm/watcher.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/node/pkg/watchers/evm/watcher.go b/node/pkg/watchers/evm/watcher.go index a98eae1ce..00d051ec4 100644 --- a/node/pkg/watchers/evm/watcher.go +++ b/node/pkg/watchers/evm/watcher.go @@ -321,13 +321,15 @@ func (w *Watcher) Run(parentCtx context.Context) error { return fmt.Errorf("failed to create polygon connector: %w", err) } } else if w.chainID == vaa.ChainIDBase && !w.unsafeDevMode { + useFinalizedBlocks = true + safeBlocksSupported = true baseConnector, err := connectors.NewEthereumConnector(timeout, w.networkName, w.url, w.contract, logger) if err != nil { ethConnectionErrors.WithLabelValues(w.networkName, "dial_error").Inc() p2p.DefaultRegistry.AddErrorCount(w.chainID, 1) return fmt.Errorf("dialing eth client failed: %w", err) } - w.ethConn, err = connectors.NewBlockPollConnector(ctx, baseConnector, finalizers.NewDefaultFinalizer(), 250*time.Millisecond, true, true) + w.ethConn, err = connectors.NewBlockPollConnector(ctx, baseConnector, finalizers.NewDefaultFinalizer(), 250*time.Millisecond, useFinalizedBlocks, safeBlocksSupported) if err != nil { ethConnectionErrors.WithLabelValues(w.networkName, "dial_error").Inc() p2p.DefaultRegistry.AddErrorCount(w.chainID, 1)