chore: fmt

Author: rswanson

bin/builder.rs

@@ -14,7 +14,10 @@ async fn main() -> eyre::Result<()> {
     let config = BuilderConfig::load_from_env()?;
     let provider = config.connect_provider().await?;
 
-    tracing::debug!(rpc_url = config.host_rpc_url.as_ref(), "instantiated provider");
+    tracing::debug!(
+        rpc_url = config.host_rpc_url.as_ref(),
+        "instantiated provider"
+    );
 
     let sequencer_signer = config.connect_sequencer_signer().await?;
     let zenith = config.connect_zenith(provider.clone());

src/config.rs

@@ -154,7 +154,9 @@ impl BuilderConfig {
     }
 
     pub async fn connect_builder_signer(&self) -> Result<LocalOrAws, ConfigError> {
-        LocalOrAws::load(&self.builder_key, Some(self.host_chain_id)).await.map_err(Into::into)
+        LocalOrAws::load(&self.builder_key, Some(self.host_chain_id))
+            .await
+            .map_err(Into::into)
     }
 
     pub async fn connect_sequencer_signer(&self) -> Result<Option<LocalOrAws>, ConfigError> {

src/service.rs

@@ -30,18 +30,27 @@ pub struct AppError {
 impl AppError {
     /// Instantiate a new error with the bad request status code.
     pub fn bad_req<E: std::error::Error + Send + Sync + 'static>(e: E) -> Self {
-        Self { code: StatusCode::BAD_REQUEST, eyre: e.into() }
+        Self {
+            code: StatusCode::BAD_REQUEST,
+            eyre: e.into(),
+        }
     }
 
     /// Instantiate a new error with the bad request status code and an error
     /// string.
     pub fn bad_req_str(e: &str) -> Self {
-        Self { code: StatusCode::BAD_REQUEST, eyre: eyre::eyre!(e.to_owned()) }
+        Self {
+            code: StatusCode::BAD_REQUEST,
+            eyre: eyre::eyre!(e.to_owned()),
+        }
     }
 
     /// Instantiate a new error with the internal server error status code.
     pub fn server_err<E: std::error::Error + Send + Sync + 'static>(e: E) -> Self {
-        Self { code: StatusCode::INTERNAL_SERVER_ERROR, eyre: e.into() }
+        Self {
+            code: StatusCode::INTERNAL_SERVER_ERROR,
+            eyre: e.into(),
+        }
     }
 }
 

src/signer.rs

@@ -50,7 +50,9 @@ impl LocalOrAws {
     async fn aws_signer(key_id: &str, chain_id: Option<u64>) -> Result<AwsSigner, SignerError> {
         let config = aws_config::load_defaults(BehaviorVersion::latest()).await;
         let client = aws_sdk_kms::Client::new(&config);
-        AwsSigner::new(client, key_id.to_string(), chain_id).await.map_err(Into::into)
+        AwsSigner::new(client, key_id.to_string(), chain_id)
+            .await
+            .map_err(Into::into)
     }
 }
 

src/tasks/block.rs

@@ -19,7 +19,11 @@ pub struct InProgressBlock {
 impl InProgressBlock {
     /// Create a new `InProgressBlock`
     pub fn new() -> Self {
-        Self { transactions: Vec::new(), raw_encoding: OnceLock::new(), hash: OnceLock::new() }
+        Self {
+            transactions: Vec::new(),
+            raw_encoding: OnceLock::new(),
+            hash: OnceLock::new(),
+        }
     }
 
     /// Get the number of transactions in the block.
@@ -40,8 +44,10 @@ impl InProgressBlock {
 
     /// Seal the block by encoding the transactions and calculating the contentshash.
     fn seal(&self) {
-        self.raw_encoding.get_or_init(|| encode_txns::<Alloy2718Coder>(&self.transactions).into());
-        self.hash.get_or_init(|| keccak256(self.raw_encoding.get().unwrap().as_ref()));
+        self.raw_encoding
+            .get_or_init(|| encode_txns::<Alloy2718Coder>(&self.transactions).into());
+        self.hash
+            .get_or_init(|| keccak256(self.raw_encoding.get().unwrap().as_ref()));
     }
 
     /// Ingest a transaction into the in-progress block. Fails

src/tasks/submit.rs

@@ -109,9 +109,18 @@ impl SubmitTask {
         s: FixedBytes<32>,
         in_progress: &InProgressBlock,
     ) -> eyre::Result<TransactionRequest> {
-        let data = Zenith::submitBlockCall { header, v, r, s, _4: Default::default() }.abi_encode();
+        let data = Zenith::submitBlockCall {
+            header,
+            v,
+            r,
+            s,
+            _4: Default::default(),
+        }
+        .abi_encode();
         let sidecar = in_progress.encode_blob::<SimpleCoder>().build()?;
-        Ok(TransactionRequest::default().with_blob_sidecar(sidecar).with_input(data))
+        Ok(TransactionRequest::default()
+            .with_blob_sidecar(sidecar)
+            .with_input(data))
     }
 
     async fn host_block_height(&self) -> eyre::Result<u64> {
@@ -191,7 +200,10 @@ impl SubmitTask {
                 sig = hex::encode(sig.as_bytes()),
                 "acquired signature from local signer"
             );
-            SignResponse { req: sig_request, sig }
+            SignResponse {
+                req: sig_request,
+                sig,
+            }
         } else {
             let resp: SignResponse = self.sup_quincey(&sig_request).await?;
             tracing::debug!(

src/tasks/tx_poller.rs

@@ -32,7 +32,11 @@ pub struct TxPoller {
 impl TxPoller {
     /// returns a new TxPoller with the given config.
     pub fn new(config: &BuilderConfig) -> Self {
-        Self { config: config.clone(), client: Client::new(), seen_txns: HashMap::new() }
+        Self {
+            config: config.clone(),
+            client: Client::new(),
+            seen_txns: HashMap::new(),
+        }
     }
 
     /// polls the tx-pool for unique transactions and evicts expired transactions.
@@ -66,15 +70,13 @@ impl TxPoller {
         let expired_keys: Vec<TxHash> = self
             .seen_txns
             .iter()
-            .filter_map(
-                |(key, &expiration)| {
-                    if !expiration.elapsed().is_zero() {
-                        Some(*key)
-                    } else {
-                        None
-                    }
-                },
-            )
+            .filter_map(|(key, &expiration)| {
+                if !expiration.elapsed().is_zero() {
+                    Some(*key)
+                } else {
+                    None
+                }
+            })
             .collect();
 
         for key in expired_keys {