binan 接口提交

src/exchange_libs.rs

@@ -502,8 +502,7 @@ impl SocketTool {
     pub fn new(request_url: &str,
                is_login: bool,
                login_param: BTreeMap<String, String>,
-               subscription: serde_json::Value,
-    ) -> SocketTool {
+               subscription: serde_json::Value, ) -> SocketTool {
         let mut ip_v = "";
         let mut port_v = 8080;
         let mut v_str = String::from("");
@@ -735,32 +734,32 @@ impl SocketTool {
 
     //币安--自定义-订阅
     pub fn binance_run_custom(b_array: Vec<&str>, parse_fn: impl Fn()) {}
-}
-
-//币安--深度信息
-pub fn binance_run_kline(b_array: Vec<&str>, parse_fn: impl Fn()) {
-    SocketTool::binance_run(b_array, "kline_1s".to_string(), parse_fn);
-}
 
-//币安--深度信息
-pub fn binance_run_depth(b_array: Vec<&str>, levels: String, parse_fn: impl Fn()) {
-    let str = format!("depth{}@100ms", levels);
-    SocketTool::binance_run(b_array, str.to_string(), parse_fn);
-}
 
-//币安--订阅
-pub fn binance_run(b_array: Vec<&str>, subscription_name: String, parse_fn: ParseFn) {
-    let mut params = vec![];
+    //币安--深度信息
+    pub fn binance_run_kline(b_array: Vec<&str>, parse_fn: impl Fn()) {
+        SocketTool::binance_run(b_array, "kline_1s".to_string(), parse_fn);
+    }
 
-    for item in &b_array {
-        let mut b_name = item.to_lowercase();
-        b_name = format!("{}@{}", b_name, subscription_name);
-        println!("-订阅频道--{0}", b_name);
-        params.push(b_name);
+    //币安--深度信息
+    pub fn binance_run_depth(b_array: Vec<&str>, levels: String, parse_fn: impl Fn()) {
+        let str = format!("depth{}@100ms", levels);
+        SocketTool::binance_run(b_array, str.to_string(), parse_fn);
     }
 
-    // 币安----socket
-    let subscription = json!({
+    //币安--订阅
+    pub fn binance_run(b_array: Vec<&str>, subscription_name: String, parse_fn: ParseFn) {
+        let mut params = vec![];
+
+        for item in &b_array {
+            let mut b_name = item.to_lowercase();
+            b_name = format!("{}@{}", b_name, subscription_name);
+            println!("-订阅频道--{0}", b_name);
+            params.push(b_name);
+        }
+
+        // 币安----socket
+        let subscription = json!({
         "method": "SUBSCRIBE",
         "params":params,
             // [
@@ -769,23 +768,23 @@ pub fn binance_run(b_array: Vec<&str>, subscription_name: String, parse_fn: Pars
             // ],
                 "id": 1
         });
-    let mut btree_map: BTreeMap<String, String> = BTreeMap::new();
-    btree_map.insert("lable".parse().unwrap(), "binance".parse().unwrap());//产品Id
-    let biance_socke = SocketTool::new("wss://stream.binance.com:443/ws",
-                                       false,
-                                       btree_map,
-                                       subscription,
-    );
-    biance_socke.run("binance".to_string(), parse_fn);
-}
+        let mut btree_map: BTreeMap<String, String> = BTreeMap::new();
+        btree_map.insert("lable".parse().unwrap(), "binance".parse().unwrap());//产品Id
+        let biance_socke = SocketTool::new("wss://stream.binance.com:443/ws",
+                                           false,
+                                           btree_map,
+                                           subscription,
+        );
+        biance_socke.run("binance".to_string(), parse_fn);
+    }
 
-fn hook_fn_binance(message: String, parse_fn: ParseFn) {
-    println!("币安--回调函数:响应: {}", message);
-    parse_fn(message);
-}
+    fn hook_fn_binance(message: String, parse_fn: ParseFn) {
+        println!("币安--回调函数:响应: {}", message);
+        parse_fn(message);
+    }
 
 
-//OKX--订阅
+    //OKX--订阅
 // pub fn okx_run(b_array: Vec<&str>, subscription_name: String, parse_fn: ParseFn) {
 //     let mut params = vec![];
 //
@@ -841,10 +840,10 @@ fn hook_fn_binance(message: String, parse_fn: ParseFn) {
 //     );
 //     biance_socke.run("binance".to_string(), parse_fn);
 // }
-fn hook_fn_okx(message: String, parse_fn: ParseFn) {
-    println!("OKX--回调函数:响应: {}", message);
-    parse_fn(message);
-}
+    fn hook_fn_okx(message: String, parse_fn: ParseFn) {
+        println!("OKX--回调函数:响应: {}", message);
+        parse_fn(message);
+    }
 }