@@ -25,7 +25,7 @@ use url::Url;
25
25
26
26
use crate :: {
27
27
constants:: { GET_HEADER_ENDPOINT_TAG , TIMEOUT_ERROR_CODE , TIMEOUT_ERROR_CODE_STR } ,
28
- metrics:: { RELAY_LAST_SLOT , RELAY_LATENCY , RELAY_STATUS_CODE } ,
28
+ metrics:: { RELAY_HEADER_VALUE , RELAY_LAST_SLOT , RELAY_LATENCY , RELAY_STATUS_CODE } ,
29
29
state:: { BuilderApiState , PbsState } ,
30
30
} ;
31
31
@@ -76,11 +76,15 @@ pub async fn get_header<S: BuilderApiState>(
76
76
let results = join_all ( handles) . await ;
77
77
let mut relay_bids = Vec :: with_capacity ( relays. len ( ) ) ;
78
78
for ( i, res) in results. into_iter ( ) . enumerate ( ) {
79
- let relay_id = relays[ i] . id . as_ref ( ) ;
79
+ let relay_id = relays[ i] . id . as_str ( ) ;
80
80
81
81
match res {
82
82
Ok ( Some ( res) ) => {
83
83
RELAY_LAST_SLOT . with_label_values ( & [ relay_id] ) . set ( params. slot as i64 ) ;
84
+ let value_gwei =
85
+ ( res. value ( ) / U256 :: from ( 1_000_000_000 ) ) . try_into ( ) . unwrap_or_default ( ) ;
86
+ RELAY_HEADER_VALUE . with_label_values ( & [ relay_id] ) . set ( value_gwei) ;
87
+
84
88
relay_bids. push ( res)
85
89
}
86
90
Ok ( _) => { }
@@ -276,8 +280,8 @@ async fn send_one_get_header(
276
280
277
281
debug ! (
278
282
latency = ?request_latency,
279
- block_hash = %get_header_response. block_hash( ) ,
280
283
value_eth = format_ether( get_header_response. value( ) ) ,
284
+ block_hash = %get_header_response. block_hash( ) ,
281
285
"received new header"
282
286
) ;
283
287
0 commit comments