fix tedious logging (#96)

* fix issue #94

* cargo clippy

Co-authored-by: Weifan <weifan@blackapi.com>
Co-authored-by: HAOYUatHZ <haoyu@protonmail.com>

src/matchengine/market.rs

@@ -517,10 +517,10 @@ impl Market {
             ask_order_state,
             bid_order_state,
             balance: VerboseBalanceState {
-                ask_user_base,
-                ask_user_quote,
                 bid_user_base,
                 bid_user_quote,
+                ask_user_base,
+                ask_user_quote,
             },
         }
     }
@@ -723,8 +723,8 @@ impl Market {
         let price = order_input.price.round_dp(quote_prec);
         //println!("decimal {} {} {} {} ", self.base, base_prec, self.quote, quote_prec);
         let order_input = OrderInput {
-            price,
             amount,
+            price,
             ..order_input
         };
         if order_input.type_ == OrderType::MARKET {
@@ -734,11 +734,10 @@ impl Market {
             if order_input.side == OrderSide::ASK && self.bids.is_empty() || order_input.side == OrderSide::BID && self.asks.is_empty() {
                 return Err(anyhow!("no counter orders"));
             }
-        } else {
-            if order_input.price.is_zero() {
-                return Err(anyhow!("invalid price for limit order"));
-            }
+        } else if order_input.price.is_zero() {
+            return Err(anyhow!("invalid price for limit order"));
         }
+
         if order_input.side == OrderSide::ASK {
             if balance_manager
                 .balance_get(order_input.user_id, BalanceType::AVAILABLE, &self.base)

src/storage/database.rs

@@ -1,6 +1,6 @@
 use std::collections::{hash_map, HashMap, VecDeque};
 use std::marker::PhantomData;
-use std::time::Instant;
+use std::time::{Duration, Instant};
 use tokio::sync::mpsc::error::TrySendError;
 use tokio::{sync, task};
 
@@ -269,6 +269,7 @@ struct DatabaseWriterTask<T> {
     data: Vec<T>,
     notify_flag: Option<TaskNotifyFlag>,
     benchmark: Option<(Instant, u32)>,
+    err_count: u32,
 }
 
 impl<T> DatabaseWriterTask<T> {
@@ -277,6 +278,7 @@ impl<T> DatabaseWriterTask<T> {
             data: Vec::new(),
             notify_flag: None,
             benchmark: None,
+            err_count: 0,
         }
     }
 
@@ -338,6 +340,9 @@ where
                 ret.send(WriterMsg::Done(self)).await
             }
             Err((resident, e)) => {
+                //TODO: we can adjust waiting time by err_count
+                tokio::time::sleep(Duration::from_secs(1)).await;
+                self.err_count += 1;
                 self.data = resident;
                 ret.send(WriterMsg::Fail(e, self)).await
             }

src/storage/sqlxextend.rs

@@ -149,10 +149,7 @@ where
             }
             None => self.0.next(),
         };
-        match ret {
-            Some(i) => Some(Some(i)),
-            None => None,
-        }
+        ret.map(Some)
     }
 }
 

src/types/mod.rs

@@ -1,5 +1,3 @@
-//#![macro_use]
-
 use num_enum::TryFromPrimitive;
 use serde::{Deserialize, Serialize};