fix build

Author: oldGreg5

src/jormungandr/jormungandr/src/blockchain/candidate.rs

@@ -78,7 +78,10 @@ mod chain_landing {
                     stream,
                 } = state;
 
-                let pre_checked = blockchain.pre_check_header(header, false).await.map_err(|e| Error::Blockchain(Box::new(e)))?;
+                let pre_checked = blockchain
+                    .pre_check_header(header, false)
+                    .await
+                    .map_err(|e| Error::Blockchain(Box::new(e)))?;
 
                 match pre_checked {
                     PreCheckedHeader::AlreadyPresent { .. } => {

src/jormungandr/jormungandr/src/blockchain/tip.rs

@@ -93,7 +93,8 @@ impl TipUpdater {
         while let Some(block) = stream.next().await {
             let block = block?;
             let fragment_ids = block.fragments().map(|f| f.id()).collect();
-            self.try_request_fragment_removal(fragment_ids, block.header()).map_err(|e| Error::from(*e))?;
+            self.try_request_fragment_removal(fragment_ids, block.header())
+                .map_err(|e| Error::from(*e))?;
         }
 
         self.blockchain
@@ -116,7 +117,8 @@ impl TipUpdater {
             .put_tag(MAIN_BRANCH_TAG, candidate_hash)?;
 
         let fragment_ids = block.fragments().map(|f| f.id()).collect();
-        self.try_request_fragment_removal(fragment_ids, block.header()).map_err(|e| Error::from(*e))?;
+        self.try_request_fragment_removal(fragment_ids, block.header())
+            .map_err(|e| Error::from(*e))?;
 
         self.tip.update_ref(candidate).await;
         Ok(())

src/jormungandr/jormungandr/src/rest/v0/logic.rs

@@ -164,7 +164,12 @@ pub async fn post_message(
         fail_fast: true,
         reply_handle,
     };
-    context.try_full()?.transaction_task.clone().try_send(msg).map_err(|e| Error::TxMsgSendError(Box::new(e)))?;
+    context
+        .try_full()?
+        .transaction_task
+        .clone()
+        .try_send(msg)
+        .map_err(|e| Error::TxMsgSendError(Box::new(e)))?;
     let reply = reply_future.await?;
     if reply.is_error() {
         Err(Error::Fragment(reply))

src/jormungandr/jormungandr/src/rest/v1/logic.rs

@@ -103,7 +103,9 @@ pub async fn post_fragments(
         fail_fast: batch.fail_fast,
         reply_handle,
     };
-    msgbox.try_send(msg).map_err(|e| Error::TxMsgSend(Box::new(e)))?;
+    msgbox
+        .try_send(msg)
+        .map_err(|e| Error::TxMsgSend(Box::new(e)))?;
     let reply = reply_future.await?;
     if reply.is_error() {
         Err(Error::Fragments(reply))

src/jormungandr/testing/mjolnir/src/mjolnir_lib/bootstrap/mod.rs

@@ -60,7 +60,9 @@ impl ClientLoadCommand {
 
         let config = self.build_config();
 
-        PassiveBootstrapLoad::new(config).exec(scenario_type.unwrap()).map_err(|e| ClientLoadCommandError::ClientError(Box::new(e)))
+        PassiveBootstrapLoad::new(config)
+            .exec(scenario_type.unwrap())
+            .map_err(|e| ClientLoadCommandError::ClientError(Box::new(e)))
     }
 
     fn get_block0_hash(&self) -> Hash {

src/jormungandr/testing/mjolnir/src/mjolnir_lib/fragment/batch/adversary/votes_only.rs

@@ -80,7 +80,8 @@ impl VotesOnly {
             Some(self.faucet_spending_counter.into()),
             Discrimination::from_testing_bool(self.testing),
         );
-        let block0 = get_block(&self.block0_path).map_err(|e| MjolnirError::Block0Error(Box::new(e)))?;
+        let block0 =
+            get_block(&self.block0_path).map_err(|e| MjolnirError::Block0Error(Box::new(e)))?;
         let vote_plans = block0.vote_plans();
 
         let remote_jormungandr = RemoteJormungandrBuilder::new("node".to_owned())

src/jormungandr/testing/mjolnir/src/mjolnir_lib/fragment/standard/adversary/votes_only.rs

@@ -80,7 +80,8 @@ impl VotesOnly {
             Some(self.faucet_spending_counter.into()),
             Discrimination::from_testing_bool(self.testing),
         );
-        let block0 = get_block(&self.block0_path).map_err(|e| MjolnirError::Block0Error(Box::new(e)))?;
+        let block0 =
+            get_block(&self.block0_path).map_err(|e| MjolnirError::Block0Error(Box::new(e)))?;
         let vote_plans = block0.vote_plans();
 
         let remote_jormungandr = RemoteJormungandrBuilder::new("node".to_owned())

src/vit-testing/vitup/src/cli/diff.rs

@@ -46,7 +46,8 @@ impl DiffCommand {
 
         let remote_genesis_yaml = remote.path().join("genesis_remote.yaml");
 
-        decode_block0(remote_client.block0()?, remote_genesis_yaml.clone()).map_err(|e| crate::error::Error::Block0Error(Box::new(e)))?;
+        decode_block0(remote_client.block0()?, remote_genesis_yaml.clone())
+            .map_err(|e| crate::error::Error::Block0Error(Box::new(e)))?;
 
         let local_genesis_content = read_file(&local_genesis_yaml)?;
         let remote_genesis_content = read_file(remote_genesis_yaml)?;

src/vit-testing/vitup/src/cli/generate/snapshot.rs

@@ -125,7 +125,8 @@ impl SnapshotCommandArgs {
         }
 
         // write snapshot.json
-        let config = read_genesis_yaml(&genesis_yaml).map_err(|e| crate::error::Error::Block0Error(Box::new(e)))?;
+        let config = read_genesis_yaml(&genesis_yaml)
+            .map_err(|e| crate::error::Error::Block0Error(Box::new(e)))?;
 
         let initials: Vec<Initial> = config
             .initial