Finish custom batch orders api for future

Author: liumiao

.rustfmt.toml

@@ -1,4 +1,4 @@
 binop_separator = "Back"
-fn_args_layout = "Compressed"
+fn_params_layout = "Compressed"
 newline_style = "Unix"
 reorder_imports = false

src/api.rs

@@ -75,6 +75,7 @@ pub enum Futures {
     AllOrders,
     UserTrades,
     Order,
+    BatchOrders,
     PositionRisk,
     Balance,
     PositionSide,
@@ -153,6 +154,7 @@ impl From<API> for String {
                 Futures::UserTrades => "/fapi/v1/userTrades",
                 Futures::PositionSide => "/fapi/v1/positionSide/dual",
                 Futures::Order => "/fapi/v1/order",
+                Futures::BatchOrders => "/fapi/v1/batchOrders",
                 Futures::PositionRisk => "/fapi/v2/positionRisk",
                 Futures::Balance => "/fapi/v2/balance",
                 Futures::OpenInterest => "/fapi/v1/openInterest",

src/errors.rs

@@ -1,7 +1,7 @@
 use serde::Deserialize;
 use error_chain::error_chain;
 
-#[derive(Debug, Deserialize)]
+#[derive(Debug, Deserialize, Clone)]
 pub struct BinanceContentError {
     pub code: i16,
     pub msg: String,

src/futures/account.rs

@@ -1,6 +1,6 @@
 use std::collections::BTreeMap;
 use std::fmt::Display;
-use crate::util::build_signed_request;
+use crate::util::{build_list_of_json, build_signed_request};
 use crate::errors::Result;
 use crate::client::Client;
 use crate::api::{API, Futures};
@@ -9,8 +9,8 @@ use crate::account::OrderSide;
 use crate::futures::model::{Order, TradeHistory};
 
 use super::model::{
-    ChangeLeverageResponse, Transaction, CanceledOrder, PositionRisk, AccountBalance,
-    AccountInformation,
+    AccountBalance, AccountInformation, CanceledOrder, ChangeLeverageResponse, PositionRisk,
+    Transaction, TransactionOrError,
 };
 
 #[derive(Clone)]
@@ -422,9 +422,13 @@ impl FuturesAccount {
 
     // Custom order for for professional traders
     pub fn custom_batch_orders(
-        &self, _order_count: u64, order_requests: Vec<CustomOrderRequest>,
-    ) -> Result<Transaction> {
-        let request = String::new();
+        &self, order_requests: Vec<CustomOrderRequest>,
+    ) -> Result<Vec<TransactionOrError>> {
+        if order_requests.is_empty() {
+            return Ok(Vec::new());
+        }
+        let mut parameters = BTreeMap::new();
+        let mut orders = Vec::new();
         for order_request in order_requests {
             let order = OrderRequest {
                 symbol: order_request.symbol,
@@ -442,12 +446,13 @@ impl FuturesAccount {
                 working_type: order_request.working_type,
                 price_protect: order_request.price_protect,
             };
-            let _order = self.build_order(order);
-            // TODO : make a request string for batch orders api
-            // let request = build_signed_request(order, self.recv_window)?;
+            let order = self.build_order(order);
+            orders.push(order);
         }
+        parameters.insert("batchOrders".into(), build_list_of_json(orders));
+        let request = build_signed_request(parameters, self.recv_window)?;
         self.client
-            .post_signed(API::Futures(Futures::Order), request)
+            .post_signed(API::Futures(Futures::BatchOrders), request)
     }
 
     pub fn get_all_orders<S, F, N>(

src/futures/model.rs

@@ -1,5 +1,8 @@
 use serde::{Deserialize, Serialize};
-use crate::model::{string_or_float, string_or_float_opt, string_or_bool};
+use crate::{
+    errors::BinanceContentError,
+    model::{string_or_bool, string_or_float, string_or_float_opt},
+};
 
 pub use crate::model::{
     Asks, Bids, BookTickers, Filters, KlineSummaries, KlineSummary, RateLimit, ServerTime,
@@ -282,6 +285,13 @@ pub struct Transaction {
     price_protect: bool,
 }
 
+#[derive(Debug, Deserialize, Clone)]
+#[serde(untagged)]
+pub enum TransactionOrError {
+    Transaction(Transaction),
+    Error(BinanceContentError),
+}
+
 #[derive(Debug, Serialize, Deserialize, Clone)]
 #[serde(rename_all = "camelCase")]
 pub struct CanceledOrder {

src/util.rs

@@ -14,6 +14,23 @@ pub fn build_request(parameters: BTreeMap<String, String>) -> String {
     request
 }
 
+pub fn build_list_of_json(parameters: Vec<BTreeMap<String, String>>) -> String {
+    let mut request = String::new();
+    for param in parameters {
+        let mut request_inner = String::new();
+        for (key, value) in param {
+            let param = format!("\"{}\":\"{}\",", key, value);
+            request_inner.push_str(param.as_ref());
+        }
+        request_inner.pop();
+        let param = format!("{{{}}},", request_inner);
+        request.push_str(param.as_ref());
+    }
+    request.pop();
+    request = format!("[{}]", request);
+    url::form_urlencoded::byte_serialize(request.as_bytes()).collect::<String>()
+}
+
 pub fn build_signed_request(
     parameters: BTreeMap<String, String>, recv_window: u64,
 ) -> Result<String> {