/*
* Futures (COIN-M) REST API
*
* Access market data, manage accounts, and trade COIN-M perpetual and delivery futures.
*
* The version of the OpenAPI document: 1.0.0
*
*
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
* https://openapi-generator.tech
* Do not edit the class manually.
*/
#![allow(unused_imports)]
use async_trait::async_trait;
use derive_builder::Builder;
use reqwest;
use rust_decimal::prelude::*;
use serde::{Deserialize, Serialize};
use serde_json::{Value, json};
use std::collections::BTreeMap;
use crate::common::{
config::ConfigurationRestApi,
models::{ParamBuildError, RestApiResponse},
utils::send_request,
};
use crate::derivatives_trading_coin_futures::rest_api::models;
const HAS_TIME_UNIT: bool = false;
#[async_trait]
pub trait AccountApi: Send + Sync {
async fn account_information(
&self,
params: AccountInformationParams,
) -> anyhow::Result<RestApiResponse<models::AccountInformationResponse>>;
async fn futures_account_balance(
&self,
params: FuturesAccountBalanceParams,
) -> anyhow::Result<RestApiResponse<Vec<models::FuturesAccountBalanceResponseInner>>>;
async fn get_current_position_mode(
&self,
params: GetCurrentPositionModeParams,
) -> anyhow::Result<RestApiResponse<models::GetCurrentPositionModeResponse>>;
async fn get_download_id_for_futures_order_history(
&self,
params: GetDownloadIdForFuturesOrderHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesOrderHistoryResponse>>;
async fn get_download_id_for_futures_trade_history(
&self,
params: GetDownloadIdForFuturesTradeHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesTradeHistoryResponse>>;
async fn get_download_id_for_futures_transaction_history(
&self,
params: GetDownloadIdForFuturesTransactionHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesTransactionHistoryResponse>>;
async fn get_futures_order_history_download_link_by_id(
&self,
params: GetFuturesOrderHistoryDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesOrderHistoryDownloadLinkByIdResponse>>;
async fn get_futures_trade_download_link_by_id(
&self,
params: GetFuturesTradeDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesTradeDownloadLinkByIdResponse>>;
async fn get_futures_transaction_history_download_link_by_id(
&self,
params: GetFuturesTransactionHistoryDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesTransactionHistoryDownloadLinkByIdResponse>>;
async fn get_income_history(
&self,
params: GetIncomeHistoryParams,
) -> anyhow::Result<RestApiResponse<Vec<models::GetIncomeHistoryResponseInner>>>;
async fn notional_bracket_for_pair(
&self,
params: NotionalBracketForPairParams,
) -> anyhow::Result<RestApiResponse<Vec<models::NotionalBracketForPairResponseInner>>>;
async fn notional_bracket_for_symbol(
&self,
params: NotionalBracketForSymbolParams,
) -> anyhow::Result<RestApiResponse<Vec<models::NotionalBracketForSymbolResponseInner>>>;
async fn user_commission_rate(
&self,
params: UserCommissionRateParams,
) -> anyhow::Result<RestApiResponse<models::UserCommissionRateResponse>>;
}
#[derive(Debug, Clone)]
pub struct AccountApiClient {
configuration: ConfigurationRestApi,
}
impl AccountApiClient {
pub fn new(configuration: ConfigurationRestApi) -> Self {
Self { configuration }
}
}
#[allow(non_camel_case_types)]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum GetIncomeHistoryIncomeTypeEnum {
#[serde(rename = "TRANSFER")]
Transfer,
#[serde(rename = "WELCOME_BONUS")]
WelcomeBonus,
#[serde(rename = "FUNDING_FEE")]
FundingFee,
#[serde(rename = "REALIZED_PNL")]
RealizedPnl,
#[serde(rename = "COMMISSION")]
Commission,
#[serde(rename = "INSURANCE_CLEAR")]
InsuranceClear,
#[serde(rename = "DELIVERED_SETTELMENT")]
DeliveredSettelment,
}
impl GetIncomeHistoryIncomeTypeEnum {
#[must_use]
pub fn as_str(&self) -> &'static str {
match self {
Self::Transfer => "TRANSFER",
Self::WelcomeBonus => "WELCOME_BONUS",
Self::FundingFee => "FUNDING_FEE",
Self::RealizedPnl => "REALIZED_PNL",
Self::Commission => "COMMISSION",
Self::InsuranceClear => "INSURANCE_CLEAR",
Self::DeliveredSettelment => "DELIVERED_SETTELMENT",
}
}
}
impl std::str::FromStr for GetIncomeHistoryIncomeTypeEnum {
type Err = Box<dyn std::error::Error + Send + Sync>;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s {
"TRANSFER" => Ok(Self::Transfer),
"WELCOME_BONUS" => Ok(Self::WelcomeBonus),
"FUNDING_FEE" => Ok(Self::FundingFee),
"REALIZED_PNL" => Ok(Self::RealizedPnl),
"COMMISSION" => Ok(Self::Commission),
"INSURANCE_CLEAR" => Ok(Self::InsuranceClear),
"DELIVERED_SETTELMENT" => Ok(Self::DeliveredSettelment),
other => Err(format!("invalid GetIncomeHistoryIncomeTypeEnum: {}", other).into()),
}
}
}
/// Request parameters for the [`account_information`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`account_information`](#method.account_information).
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct AccountInformationParams {
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl AccountInformationParams {
/// Create a builder for [`account_information`].
///
#[must_use]
pub fn builder() -> AccountInformationParamsBuilder {
AccountInformationParamsBuilder::default()
}
}
/// Request parameters for the [`futures_account_balance`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`futures_account_balance`](#method.futures_account_balance).
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct FuturesAccountBalanceParams {
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl FuturesAccountBalanceParams {
/// Create a builder for [`futures_account_balance`].
///
#[must_use]
pub fn builder() -> FuturesAccountBalanceParamsBuilder {
FuturesAccountBalanceParamsBuilder::default()
}
}
/// Request parameters for the [`get_current_position_mode`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_current_position_mode`](#method.get_current_position_mode).
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetCurrentPositionModeParams {
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetCurrentPositionModeParams {
/// Create a builder for [`get_current_position_mode`].
///
#[must_use]
pub fn builder() -> GetCurrentPositionModeParamsBuilder {
GetCurrentPositionModeParamsBuilder::default()
}
}
/// Request parameters for the [`get_download_id_for_futures_order_history`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_download_id_for_futures_order_history`](#method.get_download_id_for_futures_order_history).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetDownloadIdForFuturesOrderHistoryParams {
/// Timestamp in ms
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "startTime")]
pub start_time: i64,
/// Timestamp in ms
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "endTime")]
pub end_time: i64,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetDownloadIdForFuturesOrderHistoryParams {
/// Create a builder for [`get_download_id_for_futures_order_history`].
///
/// Required parameters:
///
/// * `start_time` — Timestamp in ms
/// * `end_time` — Timestamp in ms
///
#[must_use]
pub fn builder(
start_time: i64,
end_time: i64,
) -> GetDownloadIdForFuturesOrderHistoryParamsBuilder {
GetDownloadIdForFuturesOrderHistoryParamsBuilder::default()
.start_time(start_time)
.end_time(end_time)
}
}
/// Request parameters for the [`get_download_id_for_futures_trade_history`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_download_id_for_futures_trade_history`](#method.get_download_id_for_futures_trade_history).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetDownloadIdForFuturesTradeHistoryParams {
/// Timestamp in ms
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "startTime")]
pub start_time: i64,
/// Timestamp in ms
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "endTime")]
pub end_time: i64,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetDownloadIdForFuturesTradeHistoryParams {
/// Create a builder for [`get_download_id_for_futures_trade_history`].
///
/// Required parameters:
///
/// * `start_time` — Timestamp in ms
/// * `end_time` — Timestamp in ms
///
#[must_use]
pub fn builder(
start_time: i64,
end_time: i64,
) -> GetDownloadIdForFuturesTradeHistoryParamsBuilder {
GetDownloadIdForFuturesTradeHistoryParamsBuilder::default()
.start_time(start_time)
.end_time(end_time)
}
}
/// Request parameters for the [`get_download_id_for_futures_transaction_history`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_download_id_for_futures_transaction_history`](#method.get_download_id_for_futures_transaction_history).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetDownloadIdForFuturesTransactionHistoryParams {
/// Timestamp in ms
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "startTime")]
pub start_time: i64,
/// Timestamp in ms
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "endTime")]
pub end_time: i64,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetDownloadIdForFuturesTransactionHistoryParams {
/// Create a builder for [`get_download_id_for_futures_transaction_history`].
///
/// Required parameters:
///
/// * `start_time` — Timestamp in ms
/// * `end_time` — Timestamp in ms
///
#[must_use]
pub fn builder(
start_time: i64,
end_time: i64,
) -> GetDownloadIdForFuturesTransactionHistoryParamsBuilder {
GetDownloadIdForFuturesTransactionHistoryParamsBuilder::default()
.start_time(start_time)
.end_time(end_time)
}
}
/// Request parameters for the [`get_futures_order_history_download_link_by_id`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_futures_order_history_download_link_by_id`](#method.get_futures_order_history_download_link_by_id).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetFuturesOrderHistoryDownloadLinkByIdParams {
/// get by download id api
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "downloadId")]
pub download_id: String,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetFuturesOrderHistoryDownloadLinkByIdParams {
/// Create a builder for [`get_futures_order_history_download_link_by_id`].
///
/// Required parameters:
///
/// * `download_id` — get by download id api
///
#[must_use]
pub fn builder(download_id: String) -> GetFuturesOrderHistoryDownloadLinkByIdParamsBuilder {
GetFuturesOrderHistoryDownloadLinkByIdParamsBuilder::default().download_id(download_id)
}
}
/// Request parameters for the [`get_futures_trade_download_link_by_id`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_futures_trade_download_link_by_id`](#method.get_futures_trade_download_link_by_id).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetFuturesTradeDownloadLinkByIdParams {
/// get by download id api
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "downloadId")]
pub download_id: String,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetFuturesTradeDownloadLinkByIdParams {
/// Create a builder for [`get_futures_trade_download_link_by_id`].
///
/// Required parameters:
///
/// * `download_id` — get by download id api
///
#[must_use]
pub fn builder(download_id: String) -> GetFuturesTradeDownloadLinkByIdParamsBuilder {
GetFuturesTradeDownloadLinkByIdParamsBuilder::default().download_id(download_id)
}
}
/// Request parameters for the [`get_futures_transaction_history_download_link_by_id`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_futures_transaction_history_download_link_by_id`](#method.get_futures_transaction_history_download_link_by_id).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetFuturesTransactionHistoryDownloadLinkByIdParams {
/// get by download id api
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "downloadId")]
pub download_id: String,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetFuturesTransactionHistoryDownloadLinkByIdParams {
/// Create a builder for [`get_futures_transaction_history_download_link_by_id`].
///
/// Required parameters:
///
/// * `download_id` — get by download id api
///
#[must_use]
pub fn builder(
download_id: String,
) -> GetFuturesTransactionHistoryDownloadLinkByIdParamsBuilder {
GetFuturesTransactionHistoryDownloadLinkByIdParamsBuilder::default()
.download_id(download_id)
}
}
/// Request parameters for the [`get_income_history`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`get_income_history`](#method.get_income_history).
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct GetIncomeHistoryParams {
/// Symbol
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "symbol", default)]
pub symbol: Option<String>,
/// Income type.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "incomeType", default)]
pub income_type: Option<GetIncomeHistoryIncomeTypeEnum>,
/// Timestamp in ms to get funding from INCLUSIVE.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "startTime", default)]
pub start_time: Option<i64>,
/// Timestamp in ms to get funding until INCLUSIVE.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "endTime", default)]
pub end_time: Option<i64>,
/// Page number
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "page", default)]
pub page: Option<i64>,
/// Maximum number of records to return.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "limit", default)]
pub limit: Option<i64>,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl GetIncomeHistoryParams {
/// Create a builder for [`get_income_history`].
///
#[must_use]
pub fn builder() -> GetIncomeHistoryParamsBuilder {
GetIncomeHistoryParamsBuilder::default()
}
}
/// Request parameters for the [`notional_bracket_for_pair`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`notional_bracket_for_pair`](#method.notional_bracket_for_pair).
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct NotionalBracketForPairParams {
///
/// The `pair` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "pair", default)]
pub pair: Option<String>,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl NotionalBracketForPairParams {
/// Create a builder for [`notional_bracket_for_pair`].
///
#[must_use]
pub fn builder() -> NotionalBracketForPairParamsBuilder {
NotionalBracketForPairParamsBuilder::default()
}
}
/// Request parameters for the [`notional_bracket_for_symbol`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`notional_bracket_for_symbol`](#method.notional_bracket_for_symbol).
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct NotionalBracketForSymbolParams {
///
/// The `symbol` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "symbol", default)]
pub symbol: Option<String>,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl NotionalBracketForSymbolParams {
/// Create a builder for [`notional_bracket_for_symbol`].
///
#[must_use]
pub fn builder() -> NotionalBracketForSymbolParamsBuilder {
NotionalBracketForSymbolParamsBuilder::default()
}
}
/// Request parameters for the [`user_commission_rate`] operation.
///
/// This struct holds all of the inputs you can pass when calling
/// [`user_commission_rate`](#method.user_commission_rate).
#[derive(Clone, Debug, Builder, Deserialize)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct UserCommissionRateParams {
/// Symbol
///
/// This field is **required.
#[builder(setter(into))]
#[serde(rename = "symbol")]
pub symbol: String,
///
/// The `recv_window` parameter.
///
/// This field is **optional.
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl UserCommissionRateParams {
/// Create a builder for [`user_commission_rate`].
///
/// Required parameters:
///
/// * `symbol` — Symbol
///
#[must_use]
pub fn builder(symbol: String) -> UserCommissionRateParamsBuilder {
UserCommissionRateParamsBuilder::default().symbol(symbol)
}
}
#[async_trait]
impl AccountApi for AccountApiClient {
async fn account_information(
&self,
params: AccountInformationParams,
) -> anyhow::Result<RestApiResponse<models::AccountInformationResponse>> {
let AccountInformationParams { recv_window } = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::AccountInformationResponse>(
&self.configuration,
"/dapi/v1/account",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn futures_account_balance(
&self,
params: FuturesAccountBalanceParams,
) -> anyhow::Result<RestApiResponse<Vec<models::FuturesAccountBalanceResponseInner>>> {
let FuturesAccountBalanceParams { recv_window } = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<Vec<models::FuturesAccountBalanceResponseInner>>(
&self.configuration,
"/dapi/v1/balance",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_current_position_mode(
&self,
params: GetCurrentPositionModeParams,
) -> anyhow::Result<RestApiResponse<models::GetCurrentPositionModeResponse>> {
let GetCurrentPositionModeParams { recv_window } = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetCurrentPositionModeResponse>(
&self.configuration,
"/dapi/v1/positionSide/dual",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_download_id_for_futures_order_history(
&self,
params: GetDownloadIdForFuturesOrderHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesOrderHistoryResponse>> {
let GetDownloadIdForFuturesOrderHistoryParams {
start_time,
end_time,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("startTime".to_string(), json!(start_time));
query_params.insert("endTime".to_string(), json!(end_time));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetDownloadIdForFuturesOrderHistoryResponse>(
&self.configuration,
"/dapi/v1/order/asyn",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_download_id_for_futures_trade_history(
&self,
params: GetDownloadIdForFuturesTradeHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesTradeHistoryResponse>> {
let GetDownloadIdForFuturesTradeHistoryParams {
start_time,
end_time,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("startTime".to_string(), json!(start_time));
query_params.insert("endTime".to_string(), json!(end_time));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetDownloadIdForFuturesTradeHistoryResponse>(
&self.configuration,
"/dapi/v1/trade/asyn",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_download_id_for_futures_transaction_history(
&self,
params: GetDownloadIdForFuturesTransactionHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesTransactionHistoryResponse>>
{
let GetDownloadIdForFuturesTransactionHistoryParams {
start_time,
end_time,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("startTime".to_string(), json!(start_time));
query_params.insert("endTime".to_string(), json!(end_time));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetDownloadIdForFuturesTransactionHistoryResponse>(
&self.configuration,
"/dapi/v1/income/asyn",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_futures_order_history_download_link_by_id(
&self,
params: GetFuturesOrderHistoryDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesOrderHistoryDownloadLinkByIdResponse>>
{
let GetFuturesOrderHistoryDownloadLinkByIdParams {
download_id,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("downloadId".to_string(), json!(download_id));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetFuturesOrderHistoryDownloadLinkByIdResponse>(
&self.configuration,
"/dapi/v1/order/asyn/id",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_futures_trade_download_link_by_id(
&self,
params: GetFuturesTradeDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesTradeDownloadLinkByIdResponse>> {
let GetFuturesTradeDownloadLinkByIdParams {
download_id,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("downloadId".to_string(), json!(download_id));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetFuturesTradeDownloadLinkByIdResponse>(
&self.configuration,
"/dapi/v1/trade/asyn/id",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_futures_transaction_history_download_link_by_id(
&self,
params: GetFuturesTransactionHistoryDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesTransactionHistoryDownloadLinkByIdResponse>>
{
let GetFuturesTransactionHistoryDownloadLinkByIdParams {
download_id,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("downloadId".to_string(), json!(download_id));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::GetFuturesTransactionHistoryDownloadLinkByIdResponse>(
&self.configuration,
"/dapi/v1/income/asyn/id",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn get_income_history(
&self,
params: GetIncomeHistoryParams,
) -> anyhow::Result<RestApiResponse<Vec<models::GetIncomeHistoryResponseInner>>> {
let GetIncomeHistoryParams {
symbol,
income_type,
start_time,
end_time,
page,
limit,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = symbol {
query_params.insert("symbol".to_string(), json!(rw));
}
if let Some(rw) = income_type {
query_params.insert("incomeType".to_string(), json!(rw));
}
if let Some(rw) = start_time {
query_params.insert("startTime".to_string(), json!(rw));
}
if let Some(rw) = end_time {
query_params.insert("endTime".to_string(), json!(rw));
}
if let Some(rw) = page {
query_params.insert("page".to_string(), json!(rw));
}
if let Some(rw) = limit {
query_params.insert("limit".to_string(), json!(rw));
}
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<Vec<models::GetIncomeHistoryResponseInner>>(
&self.configuration,
"/dapi/v1/income",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn notional_bracket_for_pair(
&self,
params: NotionalBracketForPairParams,
) -> anyhow::Result<RestApiResponse<Vec<models::NotionalBracketForPairResponseInner>>> {
let NotionalBracketForPairParams { pair, recv_window } = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = pair {
query_params.insert("pair".to_string(), json!(rw));
}
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<Vec<models::NotionalBracketForPairResponseInner>>(
&self.configuration,
"/dapi/v1/leverageBracket",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn notional_bracket_for_symbol(
&self,
params: NotionalBracketForSymbolParams,
) -> anyhow::Result<RestApiResponse<Vec<models::NotionalBracketForSymbolResponseInner>>> {
let NotionalBracketForSymbolParams {
symbol,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = symbol {
query_params.insert("symbol".to_string(), json!(rw));
}
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<Vec<models::NotionalBracketForSymbolResponseInner>>(
&self.configuration,
"/dapi/v2/leverageBracket",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
async fn user_commission_rate(
&self,
params: UserCommissionRateParams,
) -> anyhow::Result<RestApiResponse<models::UserCommissionRateResponse>> {
let UserCommissionRateParams {
symbol,
recv_window,
} = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
query_params.insert("symbol".to_string(), json!(symbol));
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::UserCommissionRateResponse>(
&self.configuration,
"/dapi/v1/commissionRate",
reqwest::Method::GET,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
true,
)
.await
}
}
#[cfg(all(test, feature = "derivatives_trading_coin_futures"))]
mod tests {
use super::*;
use crate::TOKIO_SHARED_RT;
use crate::{errors::ConnectorError, models::DataFuture, models::RestApiRateLimit};
use async_trait::async_trait;
use std::collections::HashMap;
struct DummyRestApiResponse<T> {
inner: Box<dyn FnOnce() -> DataFuture<Result<T, ConnectorError>> + Send + Sync>,
status: u16,
headers: HashMap<String, String>,
rate_limits: Option<Vec<RestApiRateLimit>>,
}
impl<T> From<DummyRestApiResponse<T>> for RestApiResponse<T> {
fn from(dummy: DummyRestApiResponse<T>) -> Self {
Self {
data_fn: dummy.inner,
status: dummy.status,
headers: dummy.headers,
rate_limits: dummy.rate_limits,
}
}
}
struct MockAccountApiClient {
force_error: bool,
}
#[async_trait]
impl AccountApi for MockAccountApiClient {
async fn account_information(
&self,
_params: AccountInformationParams,
) -> anyhow::Result<RestApiResponse<models::AccountInformationResponse>> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"{"assets":[{"asset":"BTC","walletBalance":"0.00241969","unrealizedProfit":"0.00000000","marginBalance":"0.00241969","maintMargin":"0.00000000","initialMargin":"0.00000000","positionInitialMargin":"0.00000000","openOrderInitialMargin":"0.00000000","maxWithdrawAmount":"0.00241969","crossWalletBalance":"0.00241969","crossUnPnl":"0.00000000","availableBalance":"0.00241969","updateTime":1625474304765}],"positions":[{"symbol":"BTCUSD_201225","positionAmt":"0","initialMargin":"0","maintMargin":"0","unrealizedProfit":"0.00000000","positionInitialMargin":"0","openOrderInitialMargin":"0","leverage":"125","isolated":false,"positionSide":"BOTH","entryPrice":"0.0","breakEvenPrice":"0.0","maxQty":"50","updateTime":0,"notionalValue":"0"}],"canDeposit":true,"canTrade":true,"canWithdraw":true,"feeTier":2,"updateTime":0}"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::AccountInformationResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::AccountInformationResponse");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn futures_account_balance(
&self,
_params: FuturesAccountBalanceParams,
) -> anyhow::Result<RestApiResponse<Vec<models::FuturesAccountBalanceResponseInner>>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"[{"accountAlias":"SgsR","asset":"BTC","balance":"0.00250000","withdrawAvailable":"0.00250000","crossWalletBalance":"0.00241969","crossUnPnl":"0.00000000","availableBalance":"0.00241969","updateTime":1592468353979}]"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: Vec<models::FuturesAccountBalanceResponseInner> =
serde_json::from_value(resp_json.clone())
.expect("should parse into Vec<models::FuturesAccountBalanceResponseInner>");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_current_position_mode(
&self,
_params: GetCurrentPositionModeParams,
) -> anyhow::Result<RestApiResponse<models::GetCurrentPositionModeResponse>> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"{"dualSidePosition":true}"#)
.unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::GetCurrentPositionModeResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::GetCurrentPositionModeResponse");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_download_id_for_futures_order_history(
&self,
_params: GetDownloadIdForFuturesOrderHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesOrderHistoryResponse>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::GetDownloadIdForFuturesOrderHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesOrderHistoryResponse",
);
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_download_id_for_futures_trade_history(
&self,
_params: GetDownloadIdForFuturesTradeHistoryParams,
) -> anyhow::Result<RestApiResponse<models::GetDownloadIdForFuturesTradeHistoryResponse>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::GetDownloadIdForFuturesTradeHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesTradeHistoryResponse",
);
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_download_id_for_futures_transaction_history(
&self,
_params: GetDownloadIdForFuturesTransactionHistoryParams,
) -> anyhow::Result<
RestApiResponse<models::GetDownloadIdForFuturesTransactionHistoryResponse>,
> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::GetDownloadIdForFuturesTransactionHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesTransactionHistoryResponse",
);
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_futures_order_history_download_link_by_id(
&self,
_params: GetFuturesOrderHistoryDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesOrderHistoryDownloadLinkByIdResponse>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::GetFuturesOrderHistoryDownloadLinkByIdResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetFuturesOrderHistoryDownloadLinkByIdResponse",
);
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_futures_trade_download_link_by_id(
&self,
_params: GetFuturesTradeDownloadLinkByIdParams,
) -> anyhow::Result<RestApiResponse<models::GetFuturesTradeDownloadLinkByIdResponse>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::GetFuturesTradeDownloadLinkByIdResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::GetFuturesTradeDownloadLinkByIdResponse");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_futures_transaction_history_download_link_by_id(
&self,
_params: GetFuturesTransactionHistoryDownloadLinkByIdParams,
) -> anyhow::Result<
RestApiResponse<models::GetFuturesTransactionHistoryDownloadLinkByIdResponse>,
> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response : models::GetFuturesTransactionHistoryDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesTransactionHistoryDownloadLinkByIdResponse");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn get_income_history(
&self,
_params: GetIncomeHistoryParams,
) -> anyhow::Result<RestApiResponse<Vec<models::GetIncomeHistoryResponseInner>>> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"[{"symbol":"","incomeType":"TRANSFER","income":"-0.37500000","asset":"BTC","info":"WITHDRAW","time":1570608000000,"tranId":"9689322392","tradeId":""}]"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: Vec<models::GetIncomeHistoryResponseInner> =
serde_json::from_value(resp_json.clone())
.expect("should parse into Vec<models::GetIncomeHistoryResponseInner>");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn notional_bracket_for_pair(
&self,
_params: NotionalBracketForPairParams,
) -> anyhow::Result<RestApiResponse<Vec<models::NotionalBracketForPairResponseInner>>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"[{"pair":"BTCUSD","brackets":[{"bracket":1,"initialLeverage":125,"qtyCap":50,"qtylFloor":0,"maintMarginRatio":0.004,"cum":0}]}]"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: Vec<models::NotionalBracketForPairResponseInner> =
serde_json::from_value(resp_json.clone())
.expect("should parse into Vec<models::NotionalBracketForPairResponseInner>");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn notional_bracket_for_symbol(
&self,
_params: NotionalBracketForSymbolParams,
) -> anyhow::Result<RestApiResponse<Vec<models::NotionalBracketForSymbolResponseInner>>>
{
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"[{"symbol":"BTCUSD_PERP","notionalCoef":1.5,"brackets":[{"bracket":1,"initialLeverage":125,"qtyCap":50,"qtylFloor":0,"maintMarginRatio":0.004,"cum":0}]}]"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: Vec<models::NotionalBracketForSymbolResponseInner> =
serde_json::from_value(resp_json.clone())
.expect("should parse into Vec<models::NotionalBracketForSymbolResponseInner>");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
async fn user_commission_rate(
&self,
_params: UserCommissionRateParams,
) -> anyhow::Result<RestApiResponse<models::UserCommissionRateResponse>> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(r#"{"symbol":"BTCUSD_PERP","makerCommissionRate":"0.00015","takerCommissionRate":"0.00040"}"#).unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::UserCommissionRateResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::UserCommissionRateResponse");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
}
#[test]
fn account_information_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = AccountInformationParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"assets":[{"asset":"BTC","walletBalance":"0.00241969","unrealizedProfit":"0.00000000","marginBalance":"0.00241969","maintMargin":"0.00000000","initialMargin":"0.00000000","positionInitialMargin":"0.00000000","openOrderInitialMargin":"0.00000000","maxWithdrawAmount":"0.00241969","crossWalletBalance":"0.00241969","crossUnPnl":"0.00000000","availableBalance":"0.00241969","updateTime":1625474304765}],"positions":[{"symbol":"BTCUSD_201225","positionAmt":"0","initialMargin":"0","maintMargin":"0","unrealizedProfit":"0.00000000","positionInitialMargin":"0","openOrderInitialMargin":"0","leverage":"125","isolated":false,"positionSide":"BOTH","entryPrice":"0.0","breakEvenPrice":"0.0","maxQty":"50","updateTime":0,"notionalValue":"0"}],"canDeposit":true,"canTrade":true,"canWithdraw":true,"feeTier":2,"updateTime":0}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::AccountInformationResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::AccountInformationResponse");
let resp = client.account_information(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn account_information_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = AccountInformationParams::builder().recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"assets":[{"asset":"BTC","walletBalance":"0.00241969","unrealizedProfit":"0.00000000","marginBalance":"0.00241969","maintMargin":"0.00000000","initialMargin":"0.00000000","positionInitialMargin":"0.00000000","openOrderInitialMargin":"0.00000000","maxWithdrawAmount":"0.00241969","crossWalletBalance":"0.00241969","crossUnPnl":"0.00000000","availableBalance":"0.00241969","updateTime":1625474304765}],"positions":[{"symbol":"BTCUSD_201225","positionAmt":"0","initialMargin":"0","maintMargin":"0","unrealizedProfit":"0.00000000","positionInitialMargin":"0","openOrderInitialMargin":"0","leverage":"125","isolated":false,"positionSide":"BOTH","entryPrice":"0.0","breakEvenPrice":"0.0","maxQty":"50","updateTime":0,"notionalValue":"0"}],"canDeposit":true,"canTrade":true,"canWithdraw":true,"feeTier":2,"updateTime":0}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::AccountInformationResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::AccountInformationResponse");
let resp = client.account_information(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn account_information_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = AccountInformationParams::builder().build().unwrap();
match client.account_information(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn futures_account_balance_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = FuturesAccountBalanceParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"accountAlias":"SgsR","asset":"BTC","balance":"0.00250000","withdrawAvailable":"0.00250000","crossWalletBalance":"0.00241969","crossUnPnl":"0.00000000","availableBalance":"0.00241969","updateTime":1592468353979}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::FuturesAccountBalanceResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::FuturesAccountBalanceResponseInner>");
let resp = client.futures_account_balance(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn futures_account_balance_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = FuturesAccountBalanceParams::builder().recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"accountAlias":"SgsR","asset":"BTC","balance":"0.00250000","withdrawAvailable":"0.00250000","crossWalletBalance":"0.00241969","crossUnPnl":"0.00000000","availableBalance":"0.00241969","updateTime":1592468353979}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::FuturesAccountBalanceResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::FuturesAccountBalanceResponseInner>");
let resp = client.futures_account_balance(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn futures_account_balance_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = FuturesAccountBalanceParams::builder().build().unwrap();
match client.futures_account_balance(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_current_position_mode_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetCurrentPositionModeParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"dualSidePosition":true}"#)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetCurrentPositionModeResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::GetCurrentPositionModeResponse");
let resp = client
.get_current_position_mode(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_current_position_mode_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetCurrentPositionModeParams::builder()
.recv_window(5000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(r#"{"dualSidePosition":true}"#)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetCurrentPositionModeResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::GetCurrentPositionModeResponse");
let resp = client
.get_current_position_mode(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_current_position_mode_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = GetCurrentPositionModeParams::builder().build().unwrap();
match client.get_current_position_mode(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_download_id_for_futures_order_history_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params =
GetDownloadIdForFuturesOrderHistoryParams::builder(1623319461670, 1641782889000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetDownloadIdForFuturesOrderHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesOrderHistoryResponse",
);
let resp = client
.get_download_id_for_futures_order_history(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_download_id_for_futures_order_history_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params =
GetDownloadIdForFuturesOrderHistoryParams::builder(1623319461670, 1641782889000)
.recv_window(5000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetDownloadIdForFuturesOrderHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesOrderHistoryResponse",
);
let resp = client
.get_download_id_for_futures_order_history(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_download_id_for_futures_order_history_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params =
GetDownloadIdForFuturesOrderHistoryParams::builder(1623319461670, 1641782889000)
.build()
.unwrap();
match client
.get_download_id_for_futures_order_history(params)
.await
{
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_download_id_for_futures_trade_history_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params =
GetDownloadIdForFuturesTradeHistoryParams::builder(1623319461670, 1641782889000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetDownloadIdForFuturesTradeHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesTradeHistoryResponse",
);
let resp = client
.get_download_id_for_futures_trade_history(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_download_id_for_futures_trade_history_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params =
GetDownloadIdForFuturesTradeHistoryParams::builder(1623319461670, 1641782889000)
.recv_window(5000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetDownloadIdForFuturesTradeHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesTradeHistoryResponse",
);
let resp = client
.get_download_id_for_futures_trade_history(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_download_id_for_futures_trade_history_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params =
GetDownloadIdForFuturesTradeHistoryParams::builder(1623319461670, 1641782889000)
.build()
.unwrap();
match client
.get_download_id_for_futures_trade_history(params)
.await
{
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_download_id_for_futures_transaction_history_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetDownloadIdForFuturesTransactionHistoryParams::builder(
1623319461670,
1641782889000,
)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetDownloadIdForFuturesTransactionHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesTransactionHistoryResponse",
);
let resp = client
.get_download_id_for_futures_transaction_history(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_download_id_for_futures_transaction_history_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetDownloadIdForFuturesTransactionHistoryParams::builder(
1623319461670,
1641782889000,
)
.recv_window(5000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"avgCostTimestampOfLast30d":7241837,"downloadId":"546975389218332672"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::GetDownloadIdForFuturesTransactionHistoryResponse =
serde_json::from_value(resp_json.clone()).expect(
"should parse into models::GetDownloadIdForFuturesTransactionHistoryResponse",
);
let resp = client
.get_download_id_for_futures_transaction_history(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_download_id_for_futures_transaction_history_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = GetDownloadIdForFuturesTransactionHistoryParams::builder(
1623319461670,
1641782889000,
)
.build()
.unwrap();
match client
.get_download_id_for_futures_transaction_history(params)
.await
{
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_futures_order_history_download_link_by_id_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetFuturesOrderHistoryDownloadLinkByIdParams::builder("545923594199212032".to_string(),).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::GetFuturesOrderHistoryDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesOrderHistoryDownloadLinkByIdResponse");
let resp = client.get_futures_order_history_download_link_by_id(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_futures_order_history_download_link_by_id_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetFuturesOrderHistoryDownloadLinkByIdParams::builder("545923594199212032".to_string(),).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::GetFuturesOrderHistoryDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesOrderHistoryDownloadLinkByIdResponse");
let resp = client.get_futures_order_history_download_link_by_id(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_futures_order_history_download_link_by_id_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = GetFuturesOrderHistoryDownloadLinkByIdParams::builder(
"545923594199212032".to_string(),
)
.build()
.unwrap();
match client
.get_futures_order_history_download_link_by_id(params)
.await
{
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_futures_trade_download_link_by_id_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetFuturesTradeDownloadLinkByIdParams::builder("545923594199212032".to_string(),).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::GetFuturesTradeDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesTradeDownloadLinkByIdResponse");
let resp = client.get_futures_trade_download_link_by_id(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_futures_trade_download_link_by_id_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetFuturesTradeDownloadLinkByIdParams::builder("545923594199212032".to_string(),).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::GetFuturesTradeDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesTradeDownloadLinkByIdResponse");
let resp = client.get_futures_trade_download_link_by_id(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_futures_trade_download_link_by_id_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params =
GetFuturesTradeDownloadLinkByIdParams::builder("545923594199212032".to_string())
.build()
.unwrap();
match client.get_futures_trade_download_link_by_id(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_futures_transaction_history_download_link_by_id_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetFuturesTransactionHistoryDownloadLinkByIdParams::builder("545923594199212032".to_string(),).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::GetFuturesTransactionHistoryDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesTransactionHistoryDownloadLinkByIdResponse");
let resp = client.get_futures_transaction_history_download_link_by_id(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_futures_transaction_history_download_link_by_id_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetFuturesTransactionHistoryDownloadLinkByIdParams::builder("545923594199212032".to_string(),).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"downloadId":"545923594199212032","status":"processing","url":"","notified":false,"expirationTimestamp":-1,"isExpired":"null"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::GetFuturesTransactionHistoryDownloadLinkByIdResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::GetFuturesTransactionHistoryDownloadLinkByIdResponse");
let resp = client.get_futures_transaction_history_download_link_by_id(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_futures_transaction_history_download_link_by_id_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = GetFuturesTransactionHistoryDownloadLinkByIdParams::builder(
"545923594199212032".to_string(),
)
.build()
.unwrap();
match client
.get_futures_transaction_history_download_link_by_id(params)
.await
{
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn get_income_history_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetIncomeHistoryParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"symbol":"","incomeType":"TRANSFER","income":"-0.37500000","asset":"BTC","info":"WITHDRAW","time":1570608000000,"tranId":"9689322392","tradeId":""}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::GetIncomeHistoryResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::GetIncomeHistoryResponseInner>");
let resp = client.get_income_history(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_income_history_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = GetIncomeHistoryParams::builder().symbol("BTCUSDT".to_string()).income_type(GetIncomeHistoryIncomeTypeEnum::Transfer).start_time(1623319461670).end_time(1641782889000).page(1).limit(30).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"symbol":"","incomeType":"TRANSFER","income":"-0.37500000","asset":"BTC","info":"WITHDRAW","time":1570608000000,"tranId":"9689322392","tradeId":""}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::GetIncomeHistoryResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::GetIncomeHistoryResponseInner>");
let resp = client.get_income_history(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn get_income_history_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = GetIncomeHistoryParams::builder().build().unwrap();
match client.get_income_history(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn notional_bracket_for_pair_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = NotionalBracketForPairParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"pair":"BTCUSD","brackets":[{"bracket":1,"initialLeverage":125,"qtyCap":50,"qtylFloor":0,"maintMarginRatio":0.004,"cum":0}]}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::NotionalBracketForPairResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::NotionalBracketForPairResponseInner>");
let resp = client.notional_bracket_for_pair(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn notional_bracket_for_pair_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = NotionalBracketForPairParams::builder().pair("BTCUSD".to_string()).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"pair":"BTCUSD","brackets":[{"bracket":1,"initialLeverage":125,"qtyCap":50,"qtylFloor":0,"maintMarginRatio":0.004,"cum":0}]}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::NotionalBracketForPairResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::NotionalBracketForPairResponseInner>");
let resp = client.notional_bracket_for_pair(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn notional_bracket_for_pair_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = NotionalBracketForPairParams::builder().build().unwrap();
match client.notional_bracket_for_pair(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn notional_bracket_for_symbol_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = NotionalBracketForSymbolParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"symbol":"BTCUSD_PERP","notionalCoef":1.5,"brackets":[{"bracket":1,"initialLeverage":125,"qtyCap":50,"qtylFloor":0,"maintMarginRatio":0.004,"cum":0}]}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::NotionalBracketForSymbolResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::NotionalBracketForSymbolResponseInner>");
let resp = client.notional_bracket_for_symbol(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn notional_bracket_for_symbol_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = NotionalBracketForSymbolParams::builder().symbol("BTCUSD_PERP".to_string()).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"[{"symbol":"BTCUSD_PERP","notionalCoef":1.5,"brackets":[{"bracket":1,"initialLeverage":125,"qtyCap":50,"qtylFloor":0,"maintMarginRatio":0.004,"cum":0}]}]"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : Vec<models::NotionalBracketForSymbolResponseInner> = serde_json::from_value(resp_json.clone()).expect("should parse into Vec<models::NotionalBracketForSymbolResponseInner>");
let resp = client.notional_bracket_for_symbol(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn notional_bracket_for_symbol_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = NotionalBracketForSymbolParams::builder().build().unwrap();
match client.notional_bracket_for_symbol(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
#[test]
fn user_commission_rate_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = UserCommissionRateParams::builder("BTCUSD_PERP".to_string(),).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"symbol":"BTCUSD_PERP","makerCommissionRate":"0.00015","takerCommissionRate":"0.00040"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::UserCommissionRateResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::UserCommissionRateResponse");
let resp = client.user_commission_rate(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn user_commission_rate_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: false };
let params = UserCommissionRateParams::builder("BTCUSD_PERP".to_string(),).recv_window(5000).build().unwrap();
let resp_json: Value = serde_json::from_str(r#"{"symbol":"BTCUSD_PERP","makerCommissionRate":"0.00015","takerCommissionRate":"0.00040"}"#).unwrap_or_else(|_| serde_json::json!({}));
let expected_response : models::UserCommissionRateResponse = serde_json::from_value(resp_json.clone()).expect("should parse into models::UserCommissionRateResponse");
let resp = client.user_commission_rate(params).await.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn user_commission_rate_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockAccountApiClient { force_error: true };
let params = UserCommissionRateParams::builder("BTCUSD_PERP".to_string())
.build()
.unwrap();
match client.user_commission_rate(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
}