kucoin_spot_test.rs 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
  1. // mod exchange_test;
  2. //
  3. // use std::collections::BTreeMap;
  4. // use std::env;
  5. // use std::io::Error;
  6. // use rust_decimal_macros::dec;
  7. // use tokio::sync::mpsc;
  8. // use tracing::{instrument, trace};
  9. // use standard::exchange::{Exchange, ExchangeEnum};
  10. // use standard::{Order, OrderCommand, Platform, utils};
  11. // use crate::exchange_test::{test_new_exchange};
  12. //
  13. // const SYMBOL: &str = "BLZ_USDT";
  14. //
  15. // // 测试获取Exchange实体
  16. // #[tokio::test]
  17. // #[instrument(level = "TRACE")]
  18. // async fn test_get_self_exchange() {
  19. // global::log_utils::init_log_with_trace();
  20. //
  21. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  22. // let kucoin_get_self_exchange = kucoin_spot_exchange.get_self_exchange();
  23. // trace!(?kucoin_get_self_exchange);
  24. // }
  25. //
  26. // // 测试获取交易对信息
  27. // #[tokio::test]
  28. // #[instrument(level = "TRACE")]
  29. // async fn test_get_self_symbol() {
  30. // global::log_utils::init_log_with_trace();
  31. //
  32. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  33. // let kucoin_get_self_symbol = kucoin_spot_exchange.get_self_symbol();
  34. // trace!(?kucoin_get_self_symbol);
  35. // }
  36. //
  37. // // 测试获取是否使用高速通道
  38. // #[tokio::test]
  39. // #[instrument(level = "TRACE")]
  40. // async fn test_get_self_is_colo() {
  41. // global::log_utils::init_log_with_trace();
  42. //
  43. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  44. // let kucoin_get_self_is_colo = kucoin_spot_exchange.get_self_is_colo();
  45. // trace!(?kucoin_get_self_is_colo);
  46. // }
  47. //
  48. // // 测试获取登录params信息
  49. // #[tokio::test]
  50. // #[instrument(level = "TRACE")]
  51. // async fn test_get_self_params() {
  52. // global::log_utils::init_log_with_trace();
  53. //
  54. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  55. // let kucoin_get_self_params = kucoin_spot_exchange.get_self_params();
  56. // trace!("kucoin_get_self_params={:?}",kucoin_get_self_params);
  57. // }
  58. //
  59. // // 测试获取Market信息
  60. // #[tokio::test]
  61. // #[instrument(level = "TRACE")]
  62. // async fn test_get_self_market() {
  63. // global::log_utils::init_log_with_trace();
  64. //
  65. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  66. // let kucoin_get_self_market = kucoin_spot_exchange.get_self_market();
  67. // trace!(?kucoin_get_self_market);
  68. // }
  69. //
  70. // // 测试获取请求时间信息
  71. // #[tokio::test]
  72. // #[instrument(level = "TRACE")]
  73. // async fn test_get_request_delays() {
  74. // global::log_utils::init_log_with_trace();
  75. //
  76. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  77. // let kucoin_get_request_delays = kucoin_spot_exchange.get_request_delays();
  78. // trace!(?kucoin_get_request_delays);
  79. // }
  80. //
  81. // // 测试获取请求平均时间信息
  82. // #[tokio::test]
  83. // #[instrument(level = "TRACE")]
  84. // async fn test_get_request_avg_delay() {
  85. // global::log_utils::init_log_with_trace();
  86. //
  87. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  88. // let kucoin_get_request_avg_delay = kucoin_spot_exchange.get_request_avg_delay();
  89. // trace!(?kucoin_get_request_avg_delay);
  90. // }
  91. //
  92. // // 测试获取最大请求时间信息
  93. // #[tokio::test]
  94. // #[instrument(level = "TRACE")]
  95. // async fn test_get_request_max_delay() {
  96. // global::log_utils::init_log_with_trace();
  97. //
  98. // let kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  99. // let kucoin_get_request_max_delay = kucoin_spot_exchange.get_request_max_delay();
  100. // trace!(?kucoin_get_request_max_delay);
  101. // }
  102. //
  103. // // 测试获取服务器时间
  104. // #[tokio::test]
  105. // #[instrument(level = "TRACE")]
  106. // async fn test_get_server_time() {
  107. // global::log_utils::init_log_with_trace();
  108. //
  109. // let mut kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  110. // let kucoin_get_server_time = kucoin_spot_exchange.get_server_time().await;
  111. // trace!(?kucoin_get_server_time);
  112. // }
  113. //
  114. // // 测试获取账号信息
  115. // #[tokio::test]
  116. // #[instrument(level = "TRACE")]
  117. // async fn test_get_account() {
  118. // global::log_utils::init_log_with_trace();
  119. //
  120. // let mut kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  121. // let kucoin_get_account = kucoin_spot_exchange.get_account().await;
  122. // trace!(?kucoin_get_account);
  123. // }
  124. //
  125. // // 测试获取Ticker信息
  126. // #[tokio::test]
  127. // #[instrument(level = "TRACE")]
  128. // async fn test_get_ticker() {
  129. // global::log_utils::init_log_with_trace();
  130. //
  131. // let mut kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  132. // let kucoin_get_ticker = kucoin_spot_exchange.get_ticker().await;
  133. // trace!(?kucoin_get_ticker);
  134. // }
  135. //
  136. // // 测试获取Market信息
  137. // #[tokio::test]
  138. // #[instrument(level = "TRACE")]
  139. // async fn test_get_market() {
  140. // global::log_utils::init_log_with_trace();
  141. //
  142. // let mut kucoin_spot_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::KucoinSpot, SYMBOL).await;
  143. // let kucoin_get_market = kucoin_spot_exchange.get_market().await;
  144. // trace!(?kucoin_get_market);
  145. // }