fix fmt

applications/tari_indexer/src/dry_run/processor.rs

@@ -71,8 +71,14 @@ pub struct DryRunTransactionProcessor<TSubstateCache> {
         TariSignatureService,
     >,
     template_manager: TemplateManager<PeerAddress>,
-    substate_scanner:
-        Arc<SubstateScanner<EpochManagerHandle<PeerAddress>, TariValidatorNodeRpcClientFactory, TSubstateCache, TariSignatureService>>,
+    substate_scanner: Arc<
+        SubstateScanner<
+            EpochManagerHandle<PeerAddress>,
+            TariValidatorNodeRpcClientFactory,
+            TSubstateCache,
+            TariSignatureService,
+        >,
+    >,
     network: Network,
 }
 

applications/tari_indexer/src/lib.rs

@@ -111,7 +111,7 @@ pub async fn run_indexer(config: ApplicationConfig, mut shutdown_signal: Shutdow
         services.validator_node_client_factory.clone(),
         substate_cache,
         signing_service,
-        config.network
+        config.network,
     ));
 
     let substate_manager = Arc::new(SubstateManager::new(

applications/tari_validator_node/src/bootstrap.rs

@@ -271,7 +271,7 @@ pub async fn spawn_services(
         validator_node_client_factory.clone(),
         substate_cache,
         signing_service,
-        config.network
+        config.network,
     );
     let substate_resolver = TariSubstateResolver::new(
         state_store.clone(),

applications/tari_validator_node/src/consensus/spec.rs

@@ -10,10 +10,7 @@ use tari_rpc_state_sync::RpcStateSyncManager;
 use tari_state_store_sqlite::SqliteStateStore;
 
 use crate::{
-    consensus::{
-        leader_selection::RoundRobinLeaderStrategy,
-        state_manager::TariStateManager,
-    },
+    consensus::{leader_selection::RoundRobinLeaderStrategy, state_manager::TariStateManager},
     p2p::services::messaging::{ConsensusInboundMessaging, ConsensusOutboundMessaging},
 };
 

clients/validator_node_client/src/types.rs

@@ -27,7 +27,15 @@ use serde::{Deserialize, Serialize};
 use tari_common_types::{transaction::TxId, types::PublicKey};
 use tari_dan_common_types::{committee::CommitteeShard, shard::Shard, Epoch, SubstateAddress};
 use tari_dan_storage::{
-    consensus_models::{Block, BlockId, Decision, ExecutedTransaction, QuorumCertificate, QuorumDecision, SubstateRecord},
+    consensus_models::{
+        Block,
+        BlockId,
+        Decision,
+        ExecutedTransaction,
+        QuorumCertificate,
+        QuorumDecision,
+        SubstateRecord,
+    },
     global::models::ValidatorNode,
     Ordering,
 };

dan_layer/consensus/src/block_validations.rs

@@ -7,7 +7,9 @@ use tari_dan_storage::consensus_models::Block;
 use tari_epoch_manager::EpochManagerReader;
 
 use crate::{
-    hotstuff::{HotStuffError, ProposalValidationError}, quorum_certificate_validations::validate_quorum_certificate, traits::{ConsensusSpec, LeaderStrategy}
+    hotstuff::{HotStuffError, ProposalValidationError},
+    quorum_certificate_validations::validate_quorum_certificate,
+    traits::{ConsensusSpec, LeaderStrategy},
 };
 
 pub fn check_network(candidate_block: &Block, network: Network) -> Result<(), ProposalValidationError> {
@@ -99,17 +101,15 @@ pub async fn check_quorum_certificate<TConsensusSpec: ConsensusSpec>(
     }
 
     let committee_shard = epoch_manager
-        .get_committee_shard_by_validator_public_key(
-            candidate_block.epoch(), candidate_block.proposed_by(),
-        )
+        .get_committee_shard_by_validator_public_key(candidate_block.epoch(), candidate_block.proposed_by())
         .await?;
 
     validate_quorum_certificate(
         candidate_block.justify(),
         &committee_shard,
         vote_signing_service,
         epoch_manager,
-        candidate_block.network()
+        candidate_block.network(),
     )
     .await
     .map_err(ProposalValidationError::QuorumCertificateValidationError)?;

dan_layer/consensus/src/hotstuff/error.rs

@@ -10,9 +10,10 @@ use tari_epoch_manager::EpochManagerError;
 use tari_mmr::BalancedBinaryMerkleProofError;
 use tari_transaction::TransactionId;
 
-use crate::quorum_certificate_validations::QuorumCertificateValidationError;
-
-use crate::traits::{InboundMessagingError, OutboundMessagingError};
+use crate::{
+    quorum_certificate_validations::QuorumCertificateValidationError,
+    traits::{InboundMessagingError, OutboundMessagingError},
+};
 
 #[derive(Debug, thiserror::Error)]
 pub enum HotStuffError {

dan_layer/indexer_lib/src/substate_scanner.rs

@@ -22,8 +22,8 @@
 
 use log::*;
 use rand::{prelude::*, rngs::OsRng};
-use tari_consensus::{quorum_certificate_validations::validate_quorum_certificate, traits::VoteSignatureService};
 use tari_common::configuration::Network;
+use tari_consensus::{quorum_certificate_validations::validate_quorum_certificate, traits::VoteSignatureService};
 use tari_dan_common_types::{DerivableFromPublicKey, SubstateAddress};
 use tari_dan_storage::consensus_models::QuorumCertificate;
 use tari_engine_types::{
@@ -347,15 +347,26 @@ where
     }
 
     /// Validates Quorum Certificates associated with a substate
-    async fn validate_substate_qcs(&self, qcs: &[QuorumCertificate], shard_id: SubstateAddress) -> Result<(), IndexerError> {
+    async fn validate_substate_qcs(
+        &self,
+        qcs: &[QuorumCertificate],
+        shard_id: SubstateAddress,
+    ) -> Result<(), IndexerError> {
         let qc = qcs.last().ok_or(IndexerError::MissingQuorumCertificate)?;
 
         let committee_shard = self
             .committee_provider
             .get_committee_shard(qc.epoch(), shard_id)
             .await?;
 
-        validate_quorum_certificate(qc, &committee_shard, &self.signing_service, &self.committee_provider, self.network).await?;
+        validate_quorum_certificate(
+            qc,
+            &committee_shard,
+            &self.signing_service,
+            &self.committee_provider,
+            self.network,
+        )
+        .await?;
 
         Ok(())
     }