Skip to content

Commit 18cd55e

Browse files
committed
track latest block immediately on start
1 parent f757184 commit 18cd55e

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

internal/orchestrator/chain_tracker.go

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -29,19 +29,25 @@ func (ct *ChainTracker) Start(ctx context.Context) {
2929
defer ticker.Stop()
3030

3131
log.Debug().Msgf("Chain tracker running")
32+
ct.trackLatestBlockNumber(ctx)
33+
3234
for {
3335
select {
3436
case <-ctx.Done():
3537
log.Info().Msg("Chain tracker shutting down")
3638
return
3739
case <-ticker.C:
38-
latestBlockNumber, err := ct.rpc.GetLatestBlockNumber(ctx)
39-
if err != nil {
40-
log.Error().Err(err).Msg("Error getting latest block number")
41-
continue
42-
}
43-
latestBlockNumberFloat, _ := latestBlockNumber.Float64()
44-
metrics.ChainHead.Set(latestBlockNumberFloat)
40+
ct.trackLatestBlockNumber(ctx)
4541
}
4642
}
4743
}
44+
45+
func (ct *ChainTracker) trackLatestBlockNumber(ctx context.Context) {
46+
latestBlockNumber, err := ct.rpc.GetLatestBlockNumber(ctx)
47+
if err != nil {
48+
log.Error().Err(err).Msg("Error getting latest block number")
49+
return
50+
}
51+
latestBlockNumberFloat, _ := latestBlockNumber.Float64()
52+
metrics.ChainHead.Set(latestBlockNumberFloat)
53+
}

0 commit comments

Comments
 (0)