diff --git a/crates/pbs/src/mev_boost/get_header.rs b/crates/pbs/src/mev_boost/get_header.rs index 86743703..c1d2f511 100644 --- a/crates/pbs/src/mev_boost/get_header.rs +++ b/crates/pbs/src/mev_boost/get_header.rs @@ -27,7 +27,7 @@ use futures::future::join_all; use parking_lot::RwLock; use reqwest::{StatusCode, header::USER_AGENT}; use tokio::time::sleep; -use tracing::{Instrument, debug, error, warn}; +use tracing::{Instrument, debug, error, info, warn}; use tree_hash::TreeHash; use url::Url; @@ -131,7 +131,7 @@ pub async fn get_header( .unwrap_or_default(); RELAY_HEADER_VALUE.with_label_values(&[relay_id]).set(value_gwei); - relay_bids.push(res) + relay_bids.push((relay_id, res)) } Ok(_) => {} Err(err) if err.is_timeout() => error!(err = "Timed Out", relay_id), @@ -139,9 +139,18 @@ pub async fn get_header( } } - let max_bid = relay_bids.into_iter().max_by_key(|bid| *bid.value()); + let max_bid = relay_bids.into_iter().max_by_key(|(_, bid)| *bid.value()); - Ok(max_bid) + if let Some((winning_relay_id, ref bid)) = max_bid { + info!( + relay_id = winning_relay_id, + value_eth = format_ether(*bid.value()), + block_hash = %bid.block_hash(), + "auction winner" + ); + } + + Ok(max_bid.map(|(_, bid)| bid)) } /// Fetch the parent block from the RPC URL for extra validation of the header. @@ -373,7 +382,7 @@ async fn send_one_get_header( } }; - debug!( + info!( relay_id = relay.id.as_ref(), header_size_bytes, latency = ?request_latency,