fmt

Author: ltitanb

crates/common/src/config/pbs.rs

@@ -173,8 +173,9 @@ pub struct PbsModuleConfig {
     pub pbs_config: Arc<PbsConfig>,
     /// List of default relays
     pub relays: Vec<RelayClient>,
-    /// List of all default relays plus additional relays from muxes (based on URL)
-    /// DO NOT use this for get_header calls, use `relays` or `muxes` instead
+    /// List of all default relays plus additional relays from muxes (based on
+    /// URL) DO NOT use this for get_header calls, use `relays` or `muxes`
+    /// instead
     pub all_relays: Vec<RelayClient>,
     /// Signer client to call Signer API
     pub signer_client: Option<SignerClient>,
@@ -222,8 +223,9 @@ pub async fn load_pbs_config() -> Result<PbsModuleConfig> {
     }
 
     // insert default relays after to make sure we keep these as defaults,
-    // this means we override timing games which is ok since this won't be used for get_header
-    // we also override headers if the same relays has two definitions (in muxes and default)
+    // this means we override timing games which is ok since this won't be used for
+    // get_header we also override headers if the same relays has two
+    // definitions (in muxes and default)
     for relay in relay_clients.iter() {
         all_relays.insert(&relay.config.entry.url, relay.clone());
     }
@@ -297,8 +299,9 @@ pub async fn load_pbs_custom_config<T: DeserializeOwned>() -> Result<(PbsModuleC
     }
 
     // insert default relays after to make sure we keep these as defaults,
-    // this also means we override timing games which is ok since this won't be used for get header
-    // we also override headers if the same relays has two definitions (in muxes and default)
+    // this also means we override timing games which is ok since this won't be used
+    // for get header we also override headers if the same relays has two
+    // definitions (in muxes and default)
     for relay in relay_clients.iter() {
         all_relays.insert(&relay.config.entry.url, relay.clone());
     }

crates/common/src/pbs/relay.rs

@@ -50,7 +50,8 @@ impl<'de> Deserialize<'de> for RelayEntry {
     }
 }
 
-/// A client to interact with a relay, safe to share across threads and cheaply cloneable
+/// A client to interact with a relay, safe to share across threads and cheaply
+/// cloneable
 #[derive(Debug, Clone)]
 pub struct RelayClient {
     /// ID of the relay

crates/pbs/src/mev_boost/submit_block.rs

@@ -177,9 +177,9 @@ async fn send_submit_block(
 
     if let Some(blobs) = &block_response.data.blobs_bundle {
         let expected_committments = &signed_blinded_block.message.body.blob_kzg_commitments;
-        if expected_committments.len() != blobs.blobs.len()
-            || expected_committments.len() != blobs.commitments.len()
-            || expected_committments.len() != blobs.proofs.len()
+        if expected_committments.len() != blobs.blobs.len() ||
+            expected_committments.len() != blobs.commitments.len() ||
+            expected_committments.len() != blobs.proofs.len()
         {
             return Err(PbsError::Validation(ValidationError::KzgCommitments {
                 expected_blobs: expected_committments.len(),

crates/pbs/src/state.rs

@@ -44,7 +44,8 @@ where
     }
 
     /// Returns all the relays (including those in muxes)
-    /// DO NOT use this through the PBS module, use [`PbsState::mux_config_and_relays`] instead
+    /// DO NOT use this through the PBS module, use
+    /// [`PbsState::mux_config_and_relays`] instead
     pub fn all_relays(&self) -> &[RelayClient] {
         &self.config.all_relays
     }