File tree Expand file tree Collapse file tree 1 file changed +13
-7
lines changed Expand file tree Collapse file tree 1 file changed +13
-7
lines changed Original file line number Diff line number Diff 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+ }
You can’t perform that action at this time.
0 commit comments