bybit rest新增 接口

exchanges/src/bybit_swap_rest.rs

@@ -62,7 +62,7 @@ impl BybitSwapRest {
     /*******************************************************************************************************/
     //服務器時間
     pub async fn get_server_time(&mut self) -> ResponseData {
-        let  params = serde_json::json!({
+        let params = serde_json::json!({
          });
         let data = self.request("GET".to_string(),
                                 "/v5".to_string(),
@@ -72,9 +72,39 @@ impl BybitSwapRest {
         ).await;
         data
     }
+    //查詢最新行情信息
+    pub async fn get_tickers(&mut self, symbol: String) -> ResponseData {
+        let params = serde_json::json!({
+               "category":"linear",
+                "symbol":symbol
+         });
+        let data = self.request("GET".to_string(),
+                                "/v5".to_string(),
+                                "/market/tickers".to_string(),
+                                false,
+                                params.to_string(),
+        ).await;
+        data
+    }
+    //查詢最新行情信息
+    pub async fn get_kline(&mut self, symbol: String) -> ResponseData {
+        let params = serde_json::json!({
+               "category":"linear",
+                "symbol":symbol,
+                "interval":"1",
+                "limit":"200"
+         });
+        let data = self.request("GET".to_string(),
+                                "/v5".to_string(),
+                                "/market/kline".to_string(),
+                                false,
+                                params.to_string(),
+        ).await;
+        data
+    }
     //查詢公告
     pub async fn get_announcements(&mut self) -> ResponseData {
-        let  params = serde_json::json!({
+        let params = serde_json::json!({
             "locale":"zh-TW"
          });
         let data = self.request("GET".to_string(),
@@ -87,7 +117,7 @@ impl BybitSwapRest {
     }
     //查詢可交易產品的規格信息
     pub async fn get_instruments_info(&mut self, symbol: String) -> ResponseData {
-        let  params = serde_json::json!({
+        let params = serde_json::json!({
             "category":"linear",
             "symbol":symbol
          });
@@ -153,7 +183,7 @@ impl BybitSwapRest {
 
     //查詢錢包餘額
     pub async fn get_account_balance(&mut self, symbol: String) -> ResponseData {
-        let  params = serde_json::json!({
+        let params = serde_json::json!({
             "accountType":"UNIFIED",
             "coin":symbol
          });
@@ -338,7 +368,7 @@ impl BybitSwapRest {
     pub fn sign(access_key: String,
                 secret_key: String,
                 method: String,
-                params: String,   timestamp: String) -> String
+                params: String, timestamp: String) -> String
     {
         /*签名生成*/
         let url_param_str = RestTool::parse_params_to_str(params.clone());

exchanges/tests/bybit_swap_test.rs

@@ -168,6 +168,25 @@ async fn rest_get_server_time_test() {
     let req_data = ret.get_server_time().await;
     println!("Bybit--服務器時間--{:?}", req_data);
 }
+//rest-查詢最新行情信息
+#[tokio::test]
+async fn rest_get_tickers_test() {
+    global::log_utils::init_log_with_trace();
+
+    let mut ret = get_rest();
+    let req_data = ret.get_tickers("DOGEUSDT".to_string()).await;
+    println!("Bybit--查詢最新行情信息--{:?}", req_data);
+}
+//rest-查詢最新行情信息
+#[tokio::test]
+async fn rest_get_kline_test() {
+    global::log_utils::init_log_with_trace();
+
+    let mut ret = get_rest();
+    let req_data = ret.get_kline("DOGEUSDT".to_string()).await;
+    println!("Bybit--查詢最新行情信息--{:?}", req_data);
+}
+
 
 //rest-查詢公告
 #[tokio::test]