fix: start meterer

Layr-Labs · Jan 8, 2025 · 2dcd77e · 2dcd77e
1 parent 731e01d
commit 2dcd77e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/core/meterer/meterer.go b/core/meterer/meterer.go
@@ -54,7 +54,7 @@ func NewMeterer(
 // Start starts to periodically refreshing the on-chain state
 func (m *Meterer) Start(ctx context.Context) {
 	go func() {
-		ticker := time.NewTicker(m.UpdateInterval)
+		ticker := time.NewTicker(m.Config.UpdateInterval)
 		defer ticker.Stop()
 
 		for {
@@ -63,6 +63,7 @@ func (m *Meterer) Start(ctx context.Context) {
 				if err := m.ChainPaymentState.RefreshOnchainPaymentState(ctx); err != nil {
 					m.logger.Error("Failed to refresh on-chain state", "error", err)
 				}
+				m.logger.Info("Refreshed on-chain state")
 			case <-ctx.Done():
 				return
 			}

diff --git a/disperser/cmd/apiserver/main.go b/disperser/cmd/apiserver/main.go
@@ -129,6 +129,7 @@ func RunDisperserServer(ctx *cli.Context) error {
 			logger,
 			// metrics.NewNoopMetrics(),
 		)
+		meterer.Start(context.Background())
 	}
 
 	var ratelimiter common.RateLimiter
-Original file line number
+Diff line change
@@ Expand Up / @@ -129,6 +129,7 @@ func RunDisperserServer(ctx *cli.Context) error { @@
     			logger,
     			// metrics.NewNoopMetrics(),
     		)
+    		meterer.Start(context.Background())
     	}
     	var ratelimiter common.RateLimiter
@@ Expand Down @@