fmt

Author: SWvheerden

base_layer/wallet/src/output_manager_service/storage/sqlite_db/mod.rs

@@ -32,7 +32,6 @@ use tari_common_sqlite::{
     sqlite_connection_pool::PooledDbConnection,
     util::{diesel_ext::ExpectedRowsExtension, retry::retry_db},
 };
-use tokio::runtime::Handle;
 use tari_common_types::{
     transaction::TxId,
     types::{CompressedCommitment, CompressedPublicKey, CompressedSignature, FixedHash, PrivateKey},
@@ -45,7 +44,7 @@ use tari_transaction_components::{
     transaction_components::{OutputType, TransactionOutput},
 };
 use tari_transaction_key_manager::legacy_key_manager::{LegacyTariKeyId, LegacyTransactionKeyManagerInterface};
-use tokio::time::Instant;
+use tokio::{runtime::Handle, time::Instant};
 
 use crate::{
     output_manager_service::{
@@ -1406,23 +1405,24 @@ impl OutputManagerBackend for OutputManagerSqliteDatabase {
         tip_height: Option<u64>,
         key_manager: &KM,
     ) -> Result<Vec<DbWalletOutput>, OutputManagerStorageError> {
-        let outputs: Vec<OutputSql> = Handle::current().block_on(retry_db("fetch_unspent_outputs_for_spending", || {
-            let start = Instant::now();
-            let mut conn = self.database_connection.get_pooled_connection()?;
-            let acquire_lock = start.elapsed();
+        let outputs: Vec<OutputSql> =
+            Handle::current().block_on(retry_db("fetch_unspent_outputs_for_spending", || {
+                let start = Instant::now();
+                let mut conn = self.database_connection.get_pooled_connection()?;
+                let acquire_lock = start.elapsed();
 
-            let outputs =
-                OutputSql::fetch_unspent_outputs_for_spending(selection_criteria, amount, tip_height, &mut conn)?;
+                let outputs =
+                    OutputSql::fetch_unspent_outputs_for_spending(selection_criteria, amount, tip_height, &mut conn)?;
 
-            trace!(
-                target: LOG_TARGET,
-                "sqlite profile - fetch_unspent_outputs_for_spending: lock {} + db_op {} = {} ms",
-                acquire_lock.as_millis(),
-                (start.elapsed() - acquire_lock).as_millis(),
-                start.elapsed().as_millis()
-            );
-            Ok::<_, OutputManagerStorageError>(outputs)
-        }))?;
+                trace!(
+                    target: LOG_TARGET,
+                    "sqlite profile - fetch_unspent_outputs_for_spending: lock {} + db_op {} = {} ms",
+                    acquire_lock.as_millis(),
+                    (start.elapsed() - acquire_lock).as_millis(),
+                    start.elapsed().as_millis()
+                );
+                Ok::<_, OutputManagerStorageError>(outputs)
+            }))?;
         outputs
             .iter()
             .map(|o| o.clone().to_db_wallet_output(key_manager))