cargo fmt

Author: Aaron Blankstein

src/chainstate/coordinator/mod.rs

@@ -20,7 +20,7 @@ use std::time::Duration;
 
 use burnchains::{
     db::{BurnchainBlockData, BurnchainDB},
-    Txid, Burnchain, BurnchainBlockHeader, BurnchainHeaderHash, Error as BurnchainError,
+    Burnchain, BurnchainBlockHeader, BurnchainHeaderHash, Error as BurnchainError, Txid,
 };
 use chainstate::burn::{
     db::sortdb::{PoxId, SortitionDB, SortitionId},
@@ -107,7 +107,7 @@ pub trait BlockEventDispatcher {
         metadata: StacksHeaderInfo,
         receipts: Vec<StacksTransactionReceipt>,
         parent: &StacksBlockId,
-        winner_txid: Txid
+        winner_txid: Txid,
     );
 
     fn dispatch_boot_receipts(&mut self, receipts: Vec<StacksTransactionReceipt>);
@@ -581,21 +581,24 @@ impl<'a, T: BlockEventDispatcher, N: CoordinatorNotices, U: RewardSetProvider>
                         "FAIL: could not find data for the canonical sortition {}",
                         canonical_sortition_tip
                     ));
-                    let new_canonical_stacks_block = new_canonical_block_snapshot
-                        .get_canonical_stacks_block_id();
+                    let new_canonical_stacks_block =
+                        new_canonical_block_snapshot.get_canonical_stacks_block_id();
                     self.canonical_chain_tip = Some(new_canonical_stacks_block);
                     debug!("Bump blocks processed");
                     self.notifier.notify_stacks_block_processed();
                     increment_stx_blocks_processed_counter();
                     let block_hash = block_receipt.header.anchored_header.block_hash();
 
                     if let Some(dispatcher) = self.dispatcher {
-                        let metadata = &block_receipt.header;                        
+                        let metadata = &block_receipt.header;
                         let winner_txid = SortitionDB::get_block_snapshot_for_winning_stacks_block(
-                            &self.sortition_db.index_conn(), canonical_sortition_tip, &block_hash)
-                            .expect("FAIL: could not find block snapshot for winning block hash")
-                            .expect("FAIL: could not find block snapshot for winning block hash")
-                            .winning_block_txid;
+                            &self.sortition_db.index_conn(),
+                            canonical_sortition_tip,
+                            &block_hash,
+                        )
+                        .expect("FAIL: could not find block snapshot for winning block hash")
+                        .expect("FAIL: could not find block snapshot for winning block hash")
+                        .winning_block_txid;
 
                         let block: StacksBlock = {
                             let block_path = StacksChainState::get_block_path(
@@ -617,7 +620,7 @@ impl<'a, T: BlockEventDispatcher, N: CoordinatorNotices, U: RewardSetProvider>
                             block_receipt.header,
                             block_receipt.tx_receipts,
                             &parent,
-                            winner_txid
+                            winner_txid,
                         );
                     }
 

src/chainstate/coordinator/tests.rs

@@ -228,7 +228,7 @@ impl BlockEventDispatcher for NullEventDispatcher {
         _metadata: StacksHeaderInfo,
         _receipts: Vec<StacksTransactionReceipt>,
         _parent: &StacksBlockId,
-        _winner_txid: Txid
+        _winner_txid: Txid,
     ) {
         assert!(
             false,

testnet/stacks-node/src/event_dispatcher.rs

@@ -265,7 +265,12 @@ impl EventDispatcher {
         }
     }
 
-    pub fn process_chain_tip(&self, chain_tip: &ChainTip, parent_index_hash: &StacksBlockId, winner_txid: Txid) {
+    pub fn process_chain_tip(
+        &self,
+        chain_tip: &ChainTip,
+        parent_index_hash: &StacksBlockId,
+        winner_txid: Txid,
+    ) {
         let mut dispatch_matrix: Vec<HashSet<usize>> = self
             .registered_observers
             .iter()
@@ -351,7 +356,7 @@ impl EventDispatcher {
                 chain_tip,
                 parent_index_hash,
                 boot_receipts,
-                &winner_txid
+                &winner_txid,
             );
         }
     }

testnet/stacks-node/src/tests/neon_integrations.rs

@@ -495,23 +495,11 @@ fn microblock_integration_test() {
 
         eprintln!("{}", block);
 
-        let _burn_block_hash = block
-            .get("burn_block_hash")
-            .unwrap()
-            .as_str()
-            .unwrap();
+        let _burn_block_hash = block.get("burn_block_hash").unwrap().as_str().unwrap();
 
-        let _burn_block_height = block
-            .get("burn_block_height")
-            .unwrap()
-            .as_u64()
-            .unwrap();
+        let _burn_block_height = block.get("burn_block_height").unwrap().as_u64().unwrap();
 
-        let _miner_txid = block
-            .get("miner_txid")
-            .unwrap()
-            .as_str()
-            .unwrap();
+        let _miner_txid = block.get("miner_txid").unwrap().as_str().unwrap();
 
         prior = Some(my_index_hash);
     }