okx_swap_test.rs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411
  1. // use std::collections::BTreeMap;
  2. // use std::sync::Arc;
  3. // use std::sync::atomic::AtomicBool;
  4. //
  5. // use futures_util::StreamExt;
  6. // use tokio::sync::Mutex;
  7. // use tracing::trace;
  8. //
  9. // use exchanges::okx_swap_rest::OkxSwapRest;
  10. // use exchanges::okx_swap_ws::{OkxSwapLogin, OkxSwapSubscribeType, OkxSwapWs, OkxSwapWsType};
  11. //
  12. // const ACCESS_KEY: &str = "";
  13. // const SECRET_KEY: &str = "";
  14. // const PASS_KEY: &str = "";
  15. //
  16. //
  17. // //ws-订阅公共频道信息
  18. // #[tokio::test(flavor = "multi_thread", worker_threads = 5)]
  19. // async fn ws_custom_subscribe_pu() {
  20. // global::log_utils::init_log_with_trace();
  21. //
  22. //
  23. // let (write_tx, write_rx) = futures_channel::mpsc::unbounded();
  24. // let (read_tx, mut read_rx) = futures_channel::mpsc::unbounded();
  25. //
  26. //
  27. // let mut ws = get_ws(None, OkxSwapWsType::Public).await;
  28. // ws.set_symbols(vec!["BTC_USDT".to_string()]);
  29. // ws.set_subscribe(vec![
  30. // // OkxSwapSubscribeType::PuBooks5,
  31. // // OkxSwapSubscribeType::Putrades,
  32. // OkxSwapSubscribeType::PuBooks50L2tbt,
  33. // // OkxSwapSubscribeType::PuIndexTickers,
  34. // ]);
  35. //
  36. //
  37. // let write_tx_am = Arc::new(Mutex::new(write_tx));
  38. // let is_shutdown_arc = Arc::new(AtomicBool::new(true));
  39. //
  40. // //读取
  41. // let _is_shutdown_arc_clone = Arc::clone(&is_shutdown_arc);
  42. // let _tr = tokio::spawn(async move {
  43. // trace!("线程-数据读取-开启");
  44. // loop {
  45. // if let Some(data) = read_rx.next().await {
  46. // trace!("读取数据data:{:?}",data)
  47. // }
  48. // }
  49. // // trace!("线程-数据读取-结束");
  50. // });
  51. //
  52. // //写数据
  53. // // let bool_v2_clone = Arc::clone(&is_shutdown_arc);
  54. // // let write_tx_clone = Arc::clone(&write_tx_am);
  55. // // let su = ws.get_subscription();
  56. // // let tw = tokio::spawn(async move {
  57. // // trace!("线程-数据写入-开始");
  58. // // loop {
  59. // // tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
  60. // // // let close_frame = CloseFrame {
  61. // // // code: CloseCode::Normal,
  62. // // // reason: Cow::Borrowed("Bye bye"),
  63. // // // };
  64. // // // let message = Message::Close(Some(close_frame));
  65. // //
  66. // //
  67. // // let message = Message::Text(su.clone());
  68. // // AbstractWsMode::send_subscribe(write_tx_clone.clone(), message.clone()).await;
  69. // // trace!("发送指令成功");
  70. // // }
  71. // // trace!("线程-数据写入-结束");
  72. // // });
  73. //
  74. // let t1 = tokio::spawn(async move {
  75. // //链接
  76. // let bool_v3_clone = Arc::clone(&is_shutdown_arc);
  77. // ws.ws_connect_async(bool_v3_clone, &write_tx_am, write_rx, read_tx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
  78. // trace!("test 唯一线程结束--");
  79. // });
  80. // tokio::try_join!(t1).unwrap();
  81. // trace!("当此结束");
  82. // trace!("重启!");
  83. // trace!("参考交易所关闭");
  84. // return;
  85. // }
  86. //
  87. // //ws-订阅私有频道信息
  88. // #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
  89. // async fn ws_custom_subscribe_bu() {
  90. // global::log_utils::init_log_with_trace();
  91. //
  92. // let (write_tx, write_rx) = futures_channel::mpsc::unbounded();
  93. // let (read_tx, mut read_rx) = futures_channel::mpsc::unbounded();
  94. //
  95. // let mut ws = get_ws(None, OkxSwapWsType::Business).await;
  96. // ws.set_symbols(vec!["BTC-USD".to_string()]);
  97. // ws.set_subscribe(vec![
  98. // OkxSwapSubscribeType::BuIndexCandle30m,
  99. // ]);
  100. //
  101. // let write_tx_am = Arc::new(Mutex::new(write_tx));
  102. // let is_shutdown_arc = Arc::new(AtomicBool::new(true));
  103. //
  104. // //读取
  105. // let _is_shutdown_arc_clone = Arc::clone(&is_shutdown_arc);
  106. // let _tr = tokio::spawn(async move {
  107. // trace!("线程-数据读取-开启");
  108. // loop {
  109. // if let Some(data) = read_rx.next().await {
  110. // trace!("读取数据data:{:?}",data)
  111. // }
  112. // }
  113. // // trace!("线程-数据读取-结束");
  114. // });
  115. //
  116. // //写数据
  117. // // let bool_v2_clone = Arc::clone(&is_shutdown_arc);
  118. // // let write_tx_clone = Arc::clone(&write_tx_am);
  119. // // let su = ws.get_subscription();
  120. // // let tw = tokio::spawn(async move {
  121. // // trace!("线程-数据写入-开始");
  122. // // loop {
  123. // // tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
  124. // // // let close_frame = CloseFrame {
  125. // // // code: CloseCode::Normal,
  126. // // // reason: Cow::Borrowed("Bye bye"),
  127. // // // };
  128. // // // let message = Message::Close(Some(close_frame));
  129. // //
  130. // //
  131. // // let message = Message::Text(su.clone());
  132. // // AbstractWsMode::send_subscribe(write_tx_clone.clone(), message.clone()).await;
  133. // // trace!("发送指令成功");
  134. // // }
  135. // // trace!("线程-数据写入-结束");
  136. // // });
  137. //
  138. // let t1 = tokio::spawn(async move {
  139. // //链接
  140. // let bool_v3_clone = Arc::clone(&is_shutdown_arc);
  141. // ws.ws_connect_async(bool_v3_clone, &write_tx_am, write_rx, read_tx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
  142. // trace!("test 唯一线程结束--");
  143. // });
  144. // tokio::try_join!(t1).unwrap();
  145. // trace!("当此结束");
  146. // trace!("重启!");
  147. // trace!("参考交易所关闭");
  148. // return;
  149. // }
  150. //
  151. // //ws-订阅私有频道信息
  152. // #[tokio::test(flavor = "multi_thread", worker_threads = 5)]
  153. // async fn ws_custom_subscribe_pr() {
  154. // global::log_utils::init_log_with_trace();
  155. //
  156. // let (write_tx, write_rx) = futures_channel::mpsc::unbounded();
  157. // let (read_tx, mut read_rx) = futures_channel::mpsc::unbounded();
  158. //
  159. // let btree_map = OkxSwapLogin {
  160. // api_key: ACCESS_KEY.to_string(),
  161. // secret_key: SECRET_KEY.to_string(),
  162. // passphrase: PASS_KEY.to_string(),
  163. // };
  164. // let mut ws = get_ws(Option::from(btree_map), OkxSwapWsType::Private).await;
  165. // ws.set_symbols(vec!["BTC-USDT".to_string()]);
  166. // ws.set_subscribe(vec![
  167. // OkxSwapSubscribeType::PrAccount("USDT".to_string()),
  168. // OkxSwapSubscribeType::PrOrders,
  169. // OkxSwapSubscribeType::PrPositions,
  170. // OkxSwapSubscribeType::PrBalanceAndPosition,
  171. // ]);
  172. //
  173. //
  174. // let write_tx_am = Arc::new(Mutex::new(write_tx));
  175. // let is_shutdown_arc = Arc::new(AtomicBool::new(true));
  176. //
  177. // //读取
  178. // let _is_shutdown_arc_clone = Arc::clone(&is_shutdown_arc);
  179. // let _tr = tokio::spawn(async move {
  180. // trace!("线程-数据读取-开启");
  181. // loop {
  182. // if let Some(data) = read_rx.next().await {
  183. // trace!("读取数据data:{:?}",data)
  184. // }
  185. // }
  186. // // trace!("线程-数据读取-结束");
  187. // });
  188. //
  189. // //写数据
  190. // // let bool_v2_clone = Arc::clone(&is_shutdown_arc);
  191. // // let write_tx_clone = Arc::clone(&write_tx_am);
  192. // // let su = ws.get_subscription();
  193. // // let tw = tokio::spawn(async move {
  194. // // trace!("线程-数据写入-开始");
  195. // // loop {
  196. // // tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
  197. // // // let close_frame = CloseFrame {
  198. // // // code: CloseCode::Normal,
  199. // // // reason: Cow::Borrowed("Bye bye"),
  200. // // // };
  201. // // // let message = Message::Close(Some(close_frame));
  202. // //
  203. // //
  204. // // let message = Message::Text(su.clone());
  205. // // AbstractWsMode::send_subscribe(write_tx_clone.clone(), message.clone()).await;
  206. // // trace!("发送指令成功");
  207. // // }
  208. // // trace!("线程-数据写入-结束");
  209. // // });
  210. //
  211. // let t1 = tokio::spawn(async move {
  212. // //链接
  213. // let bool_v3_clone = Arc::clone(&is_shutdown_arc);
  214. // ws.ws_connect_async(bool_v3_clone, &write_tx_am, write_rx, read_tx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
  215. // trace!("test 唯一线程结束--");
  216. // });
  217. // tokio::try_join!(t1).unwrap();
  218. // trace!("当此结束");
  219. // trace!("重启!");
  220. // trace!("参考交易所关闭");
  221. // return;
  222. // //
  223. // // let mut is_shutdown_arc = Arc::new(AtomicBool::new(true));
  224. // // let mut btree_map: BTreeMap<String, String> = BTreeMap::new();
  225. // //
  226. // // btree_map.insert("access_key".to_string(), ACCESS_KEY.to_string());
  227. // // btree_map.insert("secret_key".to_string(), SECRET_KEY.to_string());
  228. // // btree_map.insert("pass_key".to_string(), PASS_KEY.to_string());
  229. // //
  230. // // let (tx, mut rx) = channel(1024);
  231. // // let mut ws = get_ws(btree_map, OkxWsType::Private, tx).await;
  232. // // ws.set_subscribe(vec![
  233. // // OkxSubscribeType::PrBalanceAndPosition,
  234. // // // OkxSubscribeType::PrAccount("USDT".to_string()),
  235. // // OkxSubscribeType::PrOrders,
  236. // // OkxSubscribeType::PrPositions,
  237. // // ]);
  238. // //
  239. // // let t1 = tokio::spawn(async move {
  240. // // ws.custom_subscribe(is_shutdown_arc, vec!["BTC-USDT".to_string()]).await;
  241. // // });
  242. // //
  243. // // let t2 = tokio::spawn(async move {
  244. // // loop {
  245. // // if let Ok(received) = rx.try_recv() {
  246. // // trace!( "age: {:?}", received);
  247. // // }
  248. // // }
  249. // // });
  250. // // try_join!(t1,t2).unwrap();
  251. // }
  252. //
  253. //
  254. // //rest-订单查询
  255. // #[tokio::test]
  256. // async fn rest_get_order_test() {
  257. // global::log_utils::init_log_with_trace();
  258. //
  259. // let mut ret = get_rest();
  260. // let req_data = ret.get_order("BTC-USDT".to_string(), "3333".to_string(), "".to_string()).await;
  261. // println!("okx--订单查询--{:?}", req_data);
  262. // }
  263. //
  264. //
  265. // //rest-未完成的订单
  266. // #[tokio::test]
  267. // async fn rest_get_incomplete_order_test() {
  268. // global::log_utils::init_log_with_trace();
  269. //
  270. // let mut ret = get_rest();
  271. // let req_data = ret.get_incomplete_order("BTC-USDT".to_string()).await;
  272. // println!("okx--未完成的订单--{:?}", req_data);
  273. // }
  274. //
  275. // //rest-获取系统时间
  276. // #[tokio::test]
  277. // async fn rest_get_server_time_test() {
  278. // global::log_utils::init_log_with_trace();
  279. //
  280. // let mut ret = get_rest();
  281. // let req_data = ret.get_server_time().await;
  282. // println!("okx--获取系统时间--{:?}", req_data);
  283. // }
  284. //
  285. // //rest-查看持仓信息
  286. // #[tokio::test]
  287. // async fn rest_get_positions_test() {
  288. // global::log_utils::init_log_with_trace();
  289. //
  290. // let mut ret = get_rest();
  291. // let req_data = ret.get_positions("SWA1P".to_string()).await;
  292. // println!("okx--查看持仓信息--{:?}", req_data);
  293. // }
  294. //
  295. // //rest-获取单个产品行情信息
  296. // #[tokio::test]
  297. // async fn rest_get_ticker_test() {
  298. // global::log_utils::init_log_with_trace();
  299. //
  300. // let mut ret = get_rest();
  301. // let req_data = ret.get_ticker("BTC-USDT".to_string()).await;
  302. // println!("okx--获取单个产品行情信息--{:?}", req_data);
  303. // }
  304. //
  305. // //rest-查看账户余额
  306. // #[tokio::test]
  307. // async fn rest_get_balance_test() {
  308. // global::log_utils::init_log_with_trace();
  309. //
  310. // let mut ret = get_rest();
  311. // let req_data = ret.get_balance("BTC,ETH".to_string()).await;
  312. // println!("okx--查看账户余额--{:?}", req_data);
  313. // }
  314. //
  315. // //rest-获取交易产品基础信息
  316. // #[tokio::test]
  317. // async fn rest_get_instruments_test() {
  318. // global::log_utils::init_log_with_trace();
  319. //
  320. // let mut ret = get_rest();
  321. // let req_data = ret.get_instruments().await;
  322. // println!("okx--获取交易产品基础信息--{:?}", req_data);
  323. // }
  324. //
  325. // //rest-获取成交明细(近三天)
  326. // #[tokio::test]
  327. // async fn rest_get_trade_fills_test() {
  328. // global::log_utils::init_log_with_trace();
  329. //
  330. // let mut ret = get_rest();
  331. // let req_data = ret.get_trade_fills("".to_string()).await;
  332. // println!("okx--获取成交明细(近三天)--{:?}", req_data);
  333. // }
  334. //
  335. // //rest-撤单
  336. // #[tokio::test]
  337. // async fn rest_cancel_order_test() {
  338. // global::log_utils::init_log_with_trace();
  339. //
  340. // let mut ret = get_rest();
  341. // let req_data = ret.cancel_order("BTC-USD".to_string(), "1111".to_string(), "".to_string()).await;
  342. // println!("okx--撤单--{:?}", req_data);
  343. // }
  344. //
  345. // //rest-设置杠杆倍数
  346. // #[tokio::test]
  347. // async fn rest_set_leverage_test() {
  348. // global::log_utils::init_log_with_trace();
  349. //
  350. // let mut ret = get_rest();
  351. // let req_data = ret.set_leverage("BTC-USDT".to_string(), "5".to_string()).await;
  352. // println!("okx--设置杠杆倍数--{:?}", req_data);
  353. // }
  354. //
  355. // //rest-设置持仓模式
  356. // #[tokio::test]
  357. // async fn rest_set_position_mode_test() {
  358. // global::log_utils::init_log_with_trace();
  359. //
  360. // let mut ret = get_rest();
  361. // let req_data = ret.set_position_mode().await;
  362. // println!("okx--设置持仓模式--{:?}", req_data);
  363. // }
  364. //
  365. // //rest-获取历史订单记录(近七天)
  366. // #[tokio::test]
  367. // async fn rest_get_orders_history_test() {
  368. // global::log_utils::init_log_with_trace();
  369. //
  370. // let mut ret = get_rest();
  371. // let req_data = ret.get_orders_history("".to_string(),
  372. // "".to_string(),
  373. // "filled".to_string(),
  374. // "".to_string(),
  375. // "".to_string(),
  376. // "".to_string(),
  377. // ).await;
  378. // println!("okx--获取历史订单记录--{:?}", req_data);
  379. // }
  380. //
  381. // //rest-获取历史成交数据(近七天)
  382. // #[tokio::test]
  383. // async fn rest_get_trades_test() {
  384. // global::log_utils::init_log_with_trace();
  385. //
  386. // let mut ret = get_rest();
  387. // let req_data = ret.get_trades("".to_string(),
  388. // "".to_string(),
  389. // "".to_string(),
  390. // "".to_string(),
  391. // "".to_string(),
  392. // "100".to_string(),
  393. // ).await;
  394. // println!("okx--获取历史成交数据--{:?}", req_data);
  395. // }
  396. //
  397. //
  398. // async fn get_ws(btree_map: Option<OkxSwapLogin>, type_v: OkxSwapWsType) -> OkxSwapWs {
  399. // let ku_ws = OkxSwapWs::new(false, btree_map, type_v);
  400. // ku_ws
  401. // }
  402. //
  403. // fn get_rest() -> OkxSwapRest {
  404. // let mut btree_map: BTreeMap<String, String> = BTreeMap::new();
  405. // btree_map.insert("access_key".to_string(), ACCESS_KEY.to_string());
  406. // btree_map.insert("secret_key".to_string(), SECRET_KEY.to_string());
  407. // btree_map.insert("pass_key".to_string(), PASS_KEY.to_string());
  408. //
  409. // let okx_exc = OkxSwapRest::new(false, btree_map.clone());
  410. // okx_exc
  411. // }