log

Author: ninaiiad

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,17 +131,26 @@ pub async fn get_header<S: BuilderApiState>(
                     .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),
             Err(err) => error!(%err, relay_id),
         }
     }
 
-    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,