bitget_spot_test.rs 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195
  1. // use rust_decimal_macros::dec;
  2. // use tracing::{instrument, trace};
  3. // use standard::exchange::ExchangeEnum;
  4. // use standard::Platform;
  5. // use crate::exchange_test::test_new_exchange;
  6. //
  7. // mod exchange_test;
  8. //
  9. // const SYMBOL: &str = "BLZ_USDT";
  10. //
  11. // // 测试获取Exchange实体
  12. // #[tokio::test]
  13. // async fn test_get_self_exchange() {
  14. // global::log_utils::init_log_with_trace();
  15. //
  16. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  17. // let bitget_get_self_exchange = bitget_swap_exchange.get_self_exchange();
  18. // trace!(?bitget_get_self_exchange);
  19. // }
  20. //
  21. // // 测试获取交易对信息
  22. // #[tokio::test]
  23. // #[instrument(level = "TRACE")]
  24. // async fn test_get_self_symbol() {
  25. // global::log_utils::init_log_with_trace();
  26. //
  27. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  28. // let bitget_get_self_symbol = bitget_swap_exchange.get_self_symbol();
  29. // trace!(?bitget_get_self_symbol);
  30. // }
  31. //
  32. // // 测试获取是否使用高速通道
  33. // #[tokio::test]
  34. // #[instrument(level = "TRACE")]
  35. // async fn test_get_self_is_colo() {
  36. // global::log_utils::init_log_with_trace();
  37. //
  38. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  39. // let bitget_get_self_is_colo = bitget_swap_exchange.get_self_is_colo();
  40. // trace!(?bitget_get_self_is_colo);
  41. // }
  42. //
  43. // // 测试获取登录params信息
  44. // #[tokio::test]
  45. // #[instrument(level = "TRACE")]
  46. // async fn test_get_self_params() {
  47. // global::log_utils::init_log_with_trace();
  48. //
  49. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  50. // let bitget_get_self_params = bitget_swap_exchange.get_self_params();
  51. // trace!("bitget_get_self_params={:?}",bitget_get_self_params);
  52. // }
  53. //
  54. // // 测试获取Market信息
  55. // #[tokio::test]
  56. // #[instrument(level = "TRACE")]
  57. // async fn test_get_self_market() {
  58. // global::log_utils::init_log_with_trace();
  59. //
  60. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  61. // let bitget_get_self_market = bitget_swap_exchange.get_self_market();
  62. // trace!(?bitget_get_self_market);
  63. // }
  64. //
  65. // // 测试获取请求时间信息
  66. // #[tokio::test]
  67. // #[instrument(level = "TRACE")]
  68. // async fn test_get_request_delays() {
  69. // global::log_utils::init_log_with_trace();
  70. //
  71. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  72. // let bitget_get_request_delays = bitget_swap_exchange.get_request_delays();
  73. // trace!(?bitget_get_request_delays);
  74. // }
  75. //
  76. // // 测试获取请求平均时间信息
  77. // #[tokio::test]
  78. // #[instrument(level = "TRACE")]
  79. // async fn test_get_request_avg_delay() {
  80. // global::log_utils::init_log_with_trace();
  81. //
  82. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  83. // let bitget_get_request_avg_delay = bitget_swap_exchange.get_request_avg_delay();
  84. // trace!(?bitget_get_request_avg_delay);
  85. // }
  86. //
  87. // // 测试获取最大请求时间信息
  88. // #[tokio::test]
  89. // #[instrument(level = "TRACE")]
  90. // async fn test_get_request_max_delay() {
  91. // global::log_utils::init_log_with_trace();
  92. //
  93. // let bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  94. // let bitget_get_request_max_delay = bitget_swap_exchange.get_request_max_delay();
  95. // trace!(?bitget_get_request_max_delay);
  96. // }
  97. //
  98. // // 测试获取服务器时间
  99. // #[tokio::test]
  100. // #[instrument(level = "TRACE")]
  101. // async fn test_get_server_time() {
  102. // global::log_utils::init_log_with_trace();
  103. //
  104. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  105. // let bitget_get_server_time = bitget_swap_exchange.get_server_time().await;
  106. // trace!(?bitget_get_server_time);
  107. // }
  108. //
  109. // // 测试获取账号信息
  110. // #[tokio::test]
  111. // #[instrument(level = "TRACE")]
  112. // async fn test_get_spot_account() {
  113. // global::log_utils::init_log_with_trace();
  114. //
  115. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  116. // let bitget_get_spot_account = bitget_swap_exchange.get_spot_account().await;
  117. // trace!(?bitget_get_spot_account);
  118. // }
  119. //
  120. // // 测试获取Ticker信息
  121. // #[tokio::test]
  122. // #[instrument(level = "TRACE")]
  123. // async fn test_get_ticker() {
  124. // global::log_utils::init_log_with_trace();
  125. //
  126. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  127. // let bitget_get_ticker = bitget_swap_exchange.get_ticker().await;
  128. // trace!(?bitget_get_ticker);
  129. // }
  130. //
  131. // // 测试获取Market信息
  132. // #[tokio::test]
  133. // #[instrument(level = "TRACE")]
  134. // async fn test_get_market() {
  135. // global::log_utils::init_log_with_trace();
  136. //
  137. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  138. // let bitget_get_market = bitget_swap_exchange.get_market().await;
  139. // trace!(?bitget_get_market);
  140. // }
  141. //
  142. // // 测试获取Order详情信息
  143. // #[tokio::test]
  144. // #[instrument(level = "TRACE")]
  145. // async fn test_get_order_detail() {
  146. // global::log_utils::init_log_with_trace();
  147. //
  148. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  149. // let bitget_get_order_detail = bitget_swap_exchange.get_order_detail("", "999998").await;
  150. // trace!(?bitget_get_order_detail);
  151. // }
  152. //
  153. // // 测试获取Order列表信息
  154. // #[tokio::test]
  155. // #[instrument(level = "TRACE")]
  156. // async fn test_get_orders_list() {
  157. // global::log_utils::init_log_with_trace();
  158. //
  159. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  160. // let bitget_get_orders_list = bitget_swap_exchange.get_orders_list("").await;
  161. // trace!(?bitget_get_orders_list);
  162. // }
  163. //
  164. // // 测试下单
  165. // #[tokio::test]
  166. // #[instrument(level = "TRACE")]
  167. // async fn test_take_order() {
  168. // global::log_utils::init_log_with_trace();
  169. //
  170. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  171. // let bitget_take_order = bitget_swap_exchange.take_order("9999922", "kd", dec!(0.21), dec!(30)).await;
  172. // trace!(?bitget_take_order);
  173. // }
  174. //
  175. // // 测试撤销订单
  176. // #[tokio::test]
  177. // #[instrument(level = "TRACE")]
  178. // async fn test_cancel_order() {
  179. // global::log_utils::init_log_with_trace();
  180. //
  181. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  182. // let bitget_cancel_order = bitget_swap_exchange.cancel_order("", "999997").await;
  183. // trace!(?bitget_cancel_order);
  184. // }
  185. //
  186. // // 测试撤销订单
  187. // #[tokio::test]
  188. // #[instrument(level = "TRACE")]
  189. // async fn test_cancel_orders() {
  190. // global::log_utils::init_log_with_trace();
  191. //
  192. // let mut bitget_swap_exchange: Box<dyn Platform> = test_new_exchange(ExchangeEnum::BitgetSpot, SYMBOL).await;
  193. // let bitget_cancel_order = bitget_swap_exchange.cancel_orders().await;
  194. // trace!(?bitget_cancel_order);
  195. // }