From a6532a853da7332b8562ba80e78b4620fbe6be6c Mon Sep 17 00:00:00 2001 From: Praying Date: Tue, 20 Jan 2026 13:15:41 +0800 Subject: [PATCH] fix: resolve clippy warnings and compilation errors --- ccxt-exchanges/src/bitget/ws.rs | 6 +++--- ccxt-exchanges/src/bybit/ws.rs | 4 ++-- ccxt-exchanges/src/okx/ws.rs | 6 +++--- tests/integration/common/assertions.rs | 8 ++++++++ 4 files changed, 16 insertions(+), 8 deletions(-) diff --git a/ccxt-exchanges/src/bitget/ws.rs b/ccxt-exchanges/src/bitget/ws.rs index f9bd4dc..48d9da6 100644 --- a/ccxt-exchanges/src/bitget/ws.rs +++ b/ccxt-exchanges/src/bitget/ws.rs @@ -126,7 +126,7 @@ impl BitgetWs { /// /// # Arguments /// - /// * `symbols` - List of trading pair symbols (e.g., ["BTCUSDT", "ETHUSDT"]) + /// * `symbols` - List of trading pair symbols (e.g., `["BTCUSDT", "ETHUSDT"]`) pub async fn subscribe_tickers(&self, symbols: &[String]) -> Result<()> { let mut args = Vec::new(); for symbol in symbols { @@ -141,7 +141,7 @@ impl BitgetWs { ); arg_map.insert( "instId".to_string(), - serde_json::Value::String(symbol.to_string()), + serde_json::Value::String(symbol.clone()), ); args.push(serde_json::Value::Object(arg_map)); } @@ -170,7 +170,7 @@ impl BitgetWs { /// /// # Arguments /// - /// * `symbols` - List of trading pair symbols (e.g., ["BTCUSDT", "ETHUSDT"]) + /// * `symbols` - List of trading pair symbols (e.g., `["BTCUSDT", "ETHUSDT"]`) /// /// # Returns /// diff --git a/ccxt-exchanges/src/bybit/ws.rs b/ccxt-exchanges/src/bybit/ws.rs index 10f493a..1f1bdc9 100644 --- a/ccxt-exchanges/src/bybit/ws.rs +++ b/ccxt-exchanges/src/bybit/ws.rs @@ -114,7 +114,7 @@ impl BybitWs { /// /// # Arguments /// - /// * `symbols` - List of trading pair symbols (e.g., ["BTCUSDT", "ETHUSDT"]) + /// * `symbols` - List of trading pair symbols (e.g., `["BTCUSDT", "ETHUSDT"]`) pub async fn subscribe_tickers(&self, symbols: &[String]) -> Result<()> { let topics: Vec = symbols.iter().map(|s| format!("tickers.{}", s)).collect(); @@ -141,7 +141,7 @@ impl BybitWs { /// /// # Arguments /// - /// * `symbols` - List of trading pair symbols (e.g., ["BTCUSDT", "ETHUSDT"]) + /// * `symbols` - List of trading pair symbols (e.g., `["BTCUSDT", "ETHUSDT"]`) /// /// # Returns /// diff --git a/ccxt-exchanges/src/okx/ws.rs b/ccxt-exchanges/src/okx/ws.rs index f273372..c9b6ec3 100644 --- a/ccxt-exchanges/src/okx/ws.rs +++ b/ccxt-exchanges/src/okx/ws.rs @@ -115,7 +115,7 @@ impl OkxWs { /// /// # Arguments /// - /// * `symbols` - List of trading pair symbols (e.g., ["BTC-USDT", "ETH-USDT"]) + /// * `symbols` - List of trading pair symbols (e.g., `["BTC-USDT", "ETH-USDT"]`) pub async fn subscribe_tickers(&self, symbols: &[String]) -> Result<()> { let mut args = Vec::new(); for symbol in symbols { @@ -126,7 +126,7 @@ impl OkxWs { ); arg_map.insert( "instId".to_string(), - serde_json::Value::String(symbol.to_string()), + serde_json::Value::String(symbol.clone()), ); args.push(serde_json::Value::Object(arg_map)); } @@ -154,7 +154,7 @@ impl OkxWs { /// /// # Arguments /// - /// * `symbols` - List of trading pair symbols (e.g., ["BTC-USDT", "ETH-USDT"]) + /// * `symbols` - List of trading pair symbols (e.g., `["BTC-USDT", "ETH-USDT"]`) /// /// # Returns /// diff --git a/tests/integration/common/assertions.rs b/tests/integration/common/assertions.rs index 4322f49..4d98ad7 100644 --- a/tests/integration/common/assertions.rs +++ b/tests/integration/common/assertions.rs @@ -394,6 +394,10 @@ pub fn create_test_ticker(symbol: &str) -> Ticker { percentage: None, average: None, vwap: None, + funding_rate: None, + open_interest: None, + index_price: None, + mark_price: None, info: HashMap::new(), } } @@ -561,6 +565,10 @@ mod tests { percentage: None, average: None, vwap: None, + funding_rate: None, + open_interest: None, + index_price: None, + mark_price: None, info: HashMap::new(), };