|
|
@@ -9,7 +9,6 @@ use tokio_tungstenite::tungstenite::{Error, Message};
|
|
|
use tracing::{info, trace};
|
|
|
|
|
|
use ring::hmac;
|
|
|
-use tracing_subscriber::fmt::format;
|
|
|
|
|
|
use crate::response_base::ResponseData;
|
|
|
use crate::socket_tool::{AbstractWsMode, HeartbeatType};
|
|
|
@@ -200,7 +199,7 @@ impl BybitSwapWs {
|
|
|
let label = self.label.clone();
|
|
|
let timestamp = Utc::now().timestamp_millis();
|
|
|
let login_param = self.login_param.clone();
|
|
|
- let (api_key, secret_key) = match self.login_param.clone() {
|
|
|
+ let (api_key, secret_key) = match login_param {
|
|
|
None => { ("".to_string(), "".to_string()) }
|
|
|
Some(p) => {
|
|
|
(p.api_key.clone().to_string(), p.secret_key.clone().to_string())
|
|
|
@@ -279,7 +278,7 @@ impl BybitSwapWs {
|
|
|
if json_value.get("success").is_some() {
|
|
|
//订阅内容
|
|
|
let success = json_value["success"].as_bool().unwrap();
|
|
|
- let ret_msg = json_value["ret_msg"].as_str().unwrap();
|
|
|
+ // let ret_msg = json_value["ret_msg"].as_str().unwrap();
|
|
|
let op = json_value["op"].as_str().unwrap();
|
|
|
let success_error = if success {
|
|
|
"成功"
|
JiahengHe