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) {
29
29
defer ticker .Stop ()
30
30
31
31
log .Debug ().Msgf ("Chain tracker running" )
32
+ ct .trackLatestBlockNumber (ctx )
33
+
32
34
for {
33
35
select {
34
36
case <- ctx .Done ():
35
37
log .Info ().Msg ("Chain tracker shutting down" )
36
38
return
37
39
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 )
45
41
}
46
42
}
47
43
}
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