data-center/standard/tests/bitget_spot_test.rs

use rust_decimal_macros::dec;
use tracing::{instrument, trace};
use standard::exchange::ExchangeEnum;
use standard::Platform;
use crate::exchange_test::test_new_exchange;

mod exchange_test;

const SYMBOL: &str = "BLZ_USDT";

// 测试获取Exchange实体
#[tokio::test]
async fn test_get_self_exchange() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_self_exchange = bitget_swap_exchange.get_self_exchange();
    trace!(?bitget_get_self_exchange);
}

// 测试获取交易对信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_self_symbol() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_self_symbol = bitget_swap_exchange.get_self_symbol();
    trace!(?bitget_get_self_symbol);
}

// 测试获取是否使用高速通道
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_self_is_colo() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_self_is_colo = bitget_swap_exchange.get_self_is_colo();
    trace!(?bitget_get_self_is_colo);
}

// 测试获取登录params信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_self_params() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_self_params = bitget_swap_exchange.get_self_params();
    trace!("bitget_get_self_params={:?}",bitget_get_self_params);
}

// 测试获取Market信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_self_market() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_self_market = bitget_swap_exchange.get_self_market();
    trace!(?bitget_get_self_market);
}

// 测试获取请求时间信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_request_delays() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_request_delays = bitget_swap_exchange.get_request_delays();
    trace!(?bitget_get_request_delays);
}

// 测试获取请求平均时间信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_request_avg_delay() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_request_avg_delay = bitget_swap_exchange.get_request_avg_delay();
    trace!(?bitget_get_request_avg_delay);
}

// 测试获取最大请求时间信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_request_max_delay() {
    global::log_utils::init_log_with_trace();

    let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_request_max_delay = bitget_swap_exchange.get_request_max_delay();
    trace!(?bitget_get_request_max_delay);
}

// 测试获取服务器时间
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_server_time() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_server_time = bitget_swap_exchange.get_server_time().await;
    trace!(?bitget_get_server_time);
}

// 测试获取账号信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_spot_account() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_spot_account = bitget_swap_exchange.get_spot_account().await;
    trace!(?bitget_get_spot_account);
}

// 测试获取Ticker信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_ticker() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_ticker = bitget_swap_exchange.get_ticker().await;
    trace!(?bitget_get_ticker);
}

// 测试获取Market信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_market() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_market = bitget_swap_exchange.get_market().await;
    trace!(?bitget_get_market);
}

// 测试获取Order详情信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_order_detail() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_order_detail = bitget_swap_exchange.get_order_detail("", "999998").await;
    trace!(?bitget_get_order_detail);
}

// 测试获取Order列表信息
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_get_orders_list() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_get_orders_list = bitget_swap_exchange.get_orders_list("").await;
    trace!(?bitget_get_orders_list);
}

// 测试下单
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_take_order() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_take_order = bitget_swap_exchange.take_order("9999922", "kd", dec!(0.21), dec!(30)).await;
    trace!(?bitget_take_order);
}

// 测试撤销订单
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_cancel_order() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_cancel_order = bitget_swap_exchange.cancel_order("", "999997").await;
    trace!(?bitget_cancel_order);
}

// 测试撤销订单
#[tokio::test]
#[instrument(level = "TRACE")]
async fn test_cancel_orders() {
    global::log_utils::init_log_with_trace();

    let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
    let bitget_cancel_order = bitget_swap_exchange.cancel_orders().await;
    trace!(?bitget_cancel_order);
}