chore: cargo fmt

dashpay · Sep 8, 2023 · a4732cc · a4732cc
1 parent 0ee91ef
commit a4732cc
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 12 deletions.
diff --git a/abci/src/server/generic.rs b/abci/src/server/generic.rs
@@ -106,15 +106,15 @@ where
         let mut codec = Codec::new(listener, cancel_token.clone(), &self.runtime);
         while !cancel_token.is_cancelled() {
             let Some(request) = codec.next() else {
-            tracing::error!("client terminated stream");
-            return Ok(())
-        };
-
-            let Some(response) = self.app.handle(request.clone())  else {
-            // `RequestDispatcher` decided to stop receiving new requests:
-            info!("ABCI Application is shutting down");
-            return Ok(());
-        };
+                tracing::error!("client terminated stream");
+                return Ok(());
+            };
+
+            let Some(response) = self.app.handle(request.clone()) else {
+                // `RequestDispatcher` decided to stop receiving new requests:
+                info!("ABCI Application is shutting down");
+                return Ok(());
+            };
 
             if let Some(crate::proto::abci::response::Value::Exception(ex)) = response.value.clone()
             {

diff --git a/abci/tests/kvstore.rs b/abci/tests/kvstore.rs
@@ -227,7 +227,9 @@ impl Application for KVStoreABCI<'_> {
             .collect::<Option<BTreeSet<Operation>>>()
         else {
             error!("Cannot decode transactions");
-            return Err(abci::ResponseException {error:"cannot decode transactions".to_string()});
+            return Err(abci::ResponseException {
+                error: "cannot decode transactions".to_string(),
+            });
         };
 
         // Mark transactions that should be added to the proposed transactions
@@ -253,7 +255,9 @@ impl Application for KVStoreABCI<'_> {
 
         let Some(tx_records) = tx_records_encoded else {
             error!("cannot encode transactions");
-            return Err(ResponseException{error:"cannot encode transactions".to_string()});
+            return Err(ResponseException {
+                error: "cannot encode transactions".to_string(),
+            });
         };
 
         // Put both local and proposed transactions into staging area
@@ -286,7 +290,9 @@ impl Application for KVStoreABCI<'_> {
             .map(decode_transaction)
             .collect::<Option<BTreeSet<Operation>>>()
         else {
-            return Err(ResponseException{error:"cannot decode transactions".to_string()});
+            return Err(ResponseException {
+                error: "cannot decode transactions".to_string(),
+            });
         };
 
         let tx_results = tx_results_accept(td_proposed_transactions.len());