From e0cdf6d8d332861cc12c2266c30c4c9b407afd3e Mon Sep 17 00:00:00 2001 From: tbjump Date: Thu, 22 Jun 2023 04:02:18 +0000 Subject: [PATCH] node/watchers/mock: add l1finalizer --- node/pkg/watchers/mock/config.go | 3 ++- node/pkg/watchers/mock/watcher.go | 5 +++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/node/pkg/watchers/mock/config.go b/node/pkg/watchers/mock/config.go index 2668d25ed..8d4a34897 100644 --- a/node/pkg/watchers/mock/config.go +++ b/node/pkg/watchers/mock/config.go @@ -20,6 +20,7 @@ type WatcherConfig struct { ObservationDb ObservationDb // If the watcher receives a re-observation request with a TxHash in this map, it will make the corresponding observation in this map. MockSetC <-chan *common.GuardianSet L1FinalizerRequired watchers.NetworkID // (optional) + l1Finalizer interfaces.L1Finalizer } func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID { @@ -35,7 +36,7 @@ func (wc *WatcherConfig) RequiredL1Finalizer() watchers.NetworkID { } func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer) { - // empty + wc.l1Finalizer = l1finalizer } func (wc *WatcherConfig) Create( diff --git a/node/pkg/watchers/mock/watcher.go b/node/pkg/watchers/mock/watcher.go index 314d438d8..ba33926c0 100644 --- a/node/pkg/watchers/mock/watcher.go +++ b/node/pkg/watchers/mock/watcher.go @@ -19,6 +19,11 @@ func NewWatcherRunnable( return func(ctx context.Context) error { logger := supervisor.Logger(ctx) supervisor.Signal(ctx, supervisor.SignalHealthy) + + if c.L1FinalizerRequired != "" && c.l1Finalizer == nil { + logger.Fatal("Mock watcher: L1FinalizerRequired but not set.") + } + logger.Info("Mock Watcher running.") for {