PR fixes

Author: notonamap

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "openlimits"
-version = "0.1.7"
+version = "0.1.6"
 authors = ["steffel <2143646+steffenix@users.noreply.github.com>", "Ethan Fast <ethan@nash.io>"]
 edition = "2018"
 description = "A open source Rust high performance cryptocurrency trading API with support for multiple exchanges and language wrappers. Focused in safety, correctness and speed."

src/coinbase/prelude.rs

@@ -1 +1 @@
-pub type Result<T> = std::result::Result<T, OpenLimitsError>;
+pub type Result<T> = std::result::Result<T, OpenLimitsError>;

src/nash/mod.rs

@@ -467,13 +467,12 @@ impl From<nash_protocol::types::Trade> for Trade {
         let price = Decimal::from_str(&resp.limit_price.to_string())
             .expect("Couldn't parse Decimal from string.");
 
-        let (fees, _order_id) = match resp.account_side {
-            nash_protocol::types::AccountTradeSide::Taker => (
+        let fees = match resp.account_side {
+            nash_protocol::types::AccountTradeSide::Taker => {
                 Decimal::from_str(&resp.taker_fee.to_string())
-                    .expect("Couldn't parse Decimal from string."),
-                resp.taker_order_id.clone(),
-            ),
-            _ => (Decimal::from(0), resp.maker_order_id.clone()),
+                    .expect("Couldn't parse Decimal from string.")
+            }
+            _ => Decimal::from(0),
         };
 
         let (buyer_order_id, seller_order_id) = match resp.direction {

tests/nash/account.rs

@@ -14,7 +14,6 @@ use openlimits::{
 };
 use rust_decimal::prelude::{Decimal, FromStr};
 use std::env;
-use std::sync::Arc;
 use std::time::Duration as NativeDuration;
 
 // FIXME: https://github.com/nash-io/openlimits/issues/157
@@ -197,7 +196,6 @@ async fn get_order_history() {
     let exchange = init().await;
     let req = GetOrderHistoryRequest {
         market_pair: Some(String::from("eth_btc")),
-        order_status: None,
         paginator: None,
     };
 
@@ -208,23 +206,6 @@ async fn get_order_history() {
     println!("{:?}", resp);
 }
 
-#[tokio::test]
-async fn test_concurrent_requests() {
-    let exchange = init().await;
-    let client = Arc::new(exchange);
-    async fn make_request(client: Arc<Nash>, i: u64) {
-        let req = client.get_account_balances(None).await;
-        if !req.is_err() {
-            println!("completed req {}", i);
-        }
-    }
-    let mut tasks = Vec::new();
-    for i in 0..10 {
-        tasks.push(tokio::spawn(make_request(client.clone(), i)));
-    }
-    futures::future::join_all(tasks).await;
-}
-
 // #[tokio::test]
 // async fn get_all_open_orders() {
 //     let mut exchange = init().await;