Release v33.0.0

### Changed (1)

- The crate no longer auto-initializes a global `tracing` subscriber. Logging configuration is now opt-in and must be performed by the application. The existing helper `logger::init()` is still available, but it is no longer called automatically by the library.

  - If you previously relied on the connector to set up logging for you, call this once in your application before creating any clients:

    ```rust
    use binance_sdk::logger;

    fn main() {
      logger::init();
    }
    ```

  - If your application already configures a global `tracing` subscriber, nothing changes: `logger::init()` is not called by the library and if you call it yourself it will early-return when a subscriber is already set.

**Derivatives Trading Usds Futures**

### Added (2)

#### REST API

- `rpi_order_book()` (`GET /fapi/v1/rpiDepth`)

#### WebSocket Streams

- `rpi_diff_book_depth_streams()` (`<symbol>@rpiDepth@500ms` stream)

### Changed (2)

#### REST API

- Modified response for `user_commission_rate()` (`GET /dapi/v1/commissionRate`):
  - property `rpi_commission_rate` added

#### WebSocket Streams

- Modified `UserDataStreamEventsResponse` for `AlgoUpdate`:
  - `o`: property `rm` added

**Simple Earn**

### Changed (2)

- Modified response for `get_bfusd_account()` (`GET /sapi/v1/bfusd/account`):
  - property `usdt_profit` added
  - property `bfusd_profit` added
  - property `total_profit` removed

- Modified response for `get_bfusd_rewards_history()` (`GET /sapi/v1/bfusd/history/rewardsHistory`):
  - `rows`.items: property `reward_asset` added

Author: github-actions

CHANGELOG.md

@@ -1,5 +1,59 @@
 # Changelog
 
+## 33.0.0 - 2025-11-27
+
+### Changed (1)
+
+- The crate no longer auto-initializes a global `tracing` subscriber. Logging configuration is now opt-in and must be performed by the application. The existing helper `logger::init()` is still available, but it is no longer called automatically by the library.
+
+  - If you previously relied on the connector to set up logging for you, call this once in your application before creating any clients:
+
+    ```rust
+    use binance_sdk::logger;
+
+    fn main() {
+      logger::init();
+    }
+    ```
+
+  - If your application already configures a global `tracing` subscriber, nothing changes: `logger::init()` is not called by the library and if you call it yourself it will early-return when a subscriber is already set.
+
+**Derivatives Trading Usds Futures**
+
+### Added (2)
+
+#### REST API
+
+- `rpi_order_book()` (`GET /fapi/v1/rpiDepth`)
+
+#### WebSocket Streams
+
+- `rpi_diff_book_depth_streams()` (`<symbol>@rpiDepth@500ms` stream)
+
+### Changed (2)
+
+#### REST API
+
+- Modified response for `user_commission_rate()` (`GET /dapi/v1/commissionRate`):
+  - property `rpi_commission_rate` added
+
+#### WebSocket Streams
+
+- Modified `UserDataStreamEventsResponse` for `AlgoUpdate`:
+  - `o`: property `rm` added
+
+**Simple Earn**
+
+### Changed (2)
+
+- Modified response for `get_bfusd_account()` (`GET /sapi/v1/bfusd/account`):
+  - property `usdt_profit` added
+  - property `bfusd_profit` added
+  - property `total_profit` removed
+
+- Modified response for `get_bfusd_rewards_history()` (`GET /sapi/v1/bfusd/history/rewardsHistory`):
+  - `rows`.items: property `reward_asset` added
+
 ## 32.0.0 - 2025-11-20
 
 **Derivatives Trading Portfolio Margin Pro**

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "binance-sdk"
-version = "32.0.0"
+version = "33.0.0"
 authors = [ "Binance" ]
 edition = "2024"
 resolver = "3"
@@ -1954,6 +1954,11 @@ name = "derivatives_trading_usds_futures_rest_api_market_data_api_recent_trades_
 path = "examples/derivatives_trading_usds_futures/rest_api/market_data_api/recent_trades_list.rs"
 required-features = [ "derivatives_trading_usds_futures" ]
 
+[[example]]
+name = "derivatives_trading_usds_futures_rest_api_market_data_api_rpi_order_book"
+path = "examples/derivatives_trading_usds_futures/rest_api/market_data_api/rpi_order_book.rs"
+required-features = [ "derivatives_trading_usds_futures" ]
+
 [[example]]
 name = "derivatives_trading_usds_futures_rest_api_market_data_api_symbol_order_book_ticker"
 path = "examples/derivatives_trading_usds_futures/rest_api/market_data_api/symbol_order_book_ticker.rs"
@@ -2349,6 +2354,11 @@ name = "derivatives_trading_usds_futures_websocket_streams_partial_book_depth_st
 path = "examples/derivatives_trading_usds_futures/websocket_streams/partial_book_depth_streams.rs"
 required-features = [ "derivatives_trading_usds_futures" ]
 
+[[example]]
+name = "derivatives_trading_usds_futures_websocket_streams_rpi_diff_book_depth_streams"
+path = "examples/derivatives_trading_usds_futures/websocket_streams/rpi_diff_book_depth_streams.rs"
+required-features = [ "derivatives_trading_usds_futures" ]
+
 [[example]]
 name = "dual_investment_rest_api_market_data_api_get_dual_investment_product_list"
 path = "examples/dual_investment/rest_api/market_data_api/get_dual_investment_product_list.rs"
@@ -2694,36 +2704,6 @@ name = "margin_trading_rest_api_trade_api_small_liability_exchange"
 path = "examples/margin_trading/rest_api/trade_api/small_liability_exchange.rs"
 required-features = [ "margin_trading" ]
 
-[[example]]
-name = "margin_trading_rest_api_trade_data_stream_api_close_isolated_margin_user_data_stream"
-path = "examples/margin_trading/rest_api/trade_data_stream_api/close_isolated_margin_user_data_stream.rs"
-required-features = [ "margin_trading" ]
-
-[[example]]
-name = "margin_trading_rest_api_trade_data_stream_api_close_margin_user_data_stream"
-path = "examples/margin_trading/rest_api/trade_data_stream_api/close_margin_user_data_stream.rs"
-required-features = [ "margin_trading" ]
-
-[[example]]
-name = "margin_trading_rest_api_trade_data_stream_api_keepalive_isolated_margin_user_data_stream"
-path = "examples/margin_trading/rest_api/trade_data_stream_api/keepalive_isolated_margin_user_data_stream.rs"
-required-features = [ "margin_trading" ]
-
-[[example]]
-name = "margin_trading_rest_api_trade_data_stream_api_keepalive_margin_user_data_stream"
-path = "examples/margin_trading/rest_api/trade_data_stream_api/keepalive_margin_user_data_stream.rs"
-required-features = [ "margin_trading" ]
-
-[[example]]
-name = "margin_trading_rest_api_trade_data_stream_api_start_isolated_margin_user_data_stream"
-path = "examples/margin_trading/rest_api/trade_data_stream_api/start_isolated_margin_user_data_stream.rs"
-required-features = [ "margin_trading" ]
-
-[[example]]
-name = "margin_trading_rest_api_trade_data_stream_api_start_margin_user_data_stream"
-path = "examples/margin_trading/rest_api/trade_data_stream_api/start_margin_user_data_stream.rs"
-required-features = [ "margin_trading" ]
-
 [[example]]
 name = "margin_trading_rest_api_transfer_api_get_cross_margin_transfer_history"
 path = "examples/margin_trading/rest_api/transfer_api/get_cross_margin_transfer_history.rs"

examples/derivatives_trading_usds_futures/rest_api/market_data_api/rpi_order_book.rs

@@ -0,0 +1,39 @@
+use anyhow::{Context, Result};
+use std::env;
+use tracing::info;
+
+use binance_sdk::config::ConfigurationRestApi;
+use binance_sdk::derivatives_trading_usds_futures::{
+    DerivativesTradingUsdsFuturesRestApi, rest_api::RpiOrderBookParams,
+};
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    // Load credentials from env
+    let api_key = env::var("API_KEY").context("API_KEY must be set")?;
+    let api_secret = env::var("API_SECRET").context("API_SECRET must be set")?;
+
+    // Build REST config
+    let rest_conf = ConfigurationRestApi::builder()
+        .api_key(api_key)
+        .api_secret(api_secret)
+        .build()?;
+
+    // Create the DerivativesTradingUsdsFutures REST API client
+    let rest_client = DerivativesTradingUsdsFuturesRestApi::production(rest_conf);
+
+    // Setup the API parameters
+    let params = RpiOrderBookParams::builder("symbol_example".to_string()).build()?;
+
+    // Make the API call
+    let response = rest_client
+        .rpi_order_book(params)
+        .await
+        .context("rpi_order_book request failed")?;
+
+    info!(?response.rate_limits, "rpi_order_book rate limits");
+    let data = response.data().await?;
+    info!(?data, "rpi_order_book data");
+
+    Ok(())
+}

examples/derivatives_trading_usds_futures/websocket_streams/rpi_diff_book_depth_streams.rs

@@ -0,0 +1,47 @@
+// Class name: websocket_market_streams_api
+use anyhow::{Context, Result};
+use tokio::time::{Duration, sleep};
+use tracing::info;
+
+use binance_sdk::config::ConfigurationWebsocketStreams;
+use binance_sdk::derivatives_trading_usds_futures::{
+    DerivativesTradingUsdsFuturesWsStreams, websocket_streams::RpiDiffBookDepthStreamsParams,
+};
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    // Build WebSocket Streams config
+    let ws_streams_conf = ConfigurationWebsocketStreams::builder().build()?;
+
+    // Create the DerivativesTradingUsdsFutures WebSocket Streams client
+    let ws_streams_client = DerivativesTradingUsdsFuturesWsStreams::production(ws_streams_conf);
+
+    // Connect to WebSocket
+    let connection = ws_streams_client
+        .connect()
+        .await
+        .context("Failed to connect to WebSocket Streams")?;
+
+    // Setup the stream parameters
+    let params = RpiDiffBookDepthStreamsParams::builder("btcusdt".to_string()).build()?;
+
+    // Subscribe to the stream
+    let stream = connection
+        .rpi_diff_book_depth_streams(params)
+        .await
+        .context("Failed to subscribe to the stream")?;
+
+    // Register callback for incoming messages
+    stream.on_message(|data| {
+        info!("{:?}", data);
+    });
+
+    // Disconnect after 20 seconds
+    sleep(Duration::from_secs(20)).await;
+    connection
+        .disconnect()
+        .await
+        .context("Failed to disconnect WebSocket client")?;
+
+    Ok(())
+}

src/algo/README.md

@@ -15,6 +15,7 @@ This module provides the official Rust client for Binance's Algo Trading REST AP
 - [Installation](#installation)
 - [Documentation](#documentation)
 - [REST APIs](#rest-apis)
+- [Logging](#logging)
 - [Testing](#testing)
 - [Migration Guide](#migration-guide)
 - [Contributing](#contributing)
@@ -137,6 +138,26 @@ Errors are represented by the following types:
 
 See the [Error Handling example](./docs/rest_api/error-handling.md) for detailed usage. Refer to the [`error`](../common/errors.rs) module for more information.
 
+## Logging
+
+This crate ships with an optional default logger that you can enable with a single call:
+
+```rust
+use binance_sdk::logger;
+
+fn main() {
+    // Initialize the default logger once at the start of your application
+    logger::init();
+
+    // ... rest of your code
+}
+```
+
+The logger integrates with the Rust `tracing` ecosystem and behaves as follows:
+
+- If **another global subscriber is already set**, `logger::init()` is a no-op and does not override your existing logging setup.
+- If **no subscriber is set yet**, it installs the crate’s default global subscriber (with sensible defaults) so you immediately get structured logs from the connector.
+
 ## Testing
 
 To run the tests for the Algo module:

src/algo/mod.rs

@@ -1,8 +1,7 @@
 pub mod rest_api;
 
 use crate::common::{
-    config::ConfigurationRestApi, constants::ALGO_REST_API_PROD_URL, logger,
-    utils::build_user_agent,
+    config::ConfigurationRestApi, constants::ALGO_REST_API_PROD_URL, utils::build_user_agent,
 };
 
 /// Represents the Algo REST API client for interacting with the Binance Algo REST API.
@@ -24,8 +23,6 @@ impl AlgoRestApi {
     /// A new REST API client configured with the provided settings
     #[must_use]
     pub fn from_config(mut config: ConfigurationRestApi) -> rest_api::RestApi {
-        logger::init();
-
         config.user_agent = build_user_agent("algo");
         if config.base_path.is_none() {
             config.base_path = Some(ALGO_REST_API_PROD_URL.to_string());

src/c2c/README.md

@@ -15,6 +15,7 @@ This module provides the official Rust client for Binance's C2C API, enabling de
 - [Installation](#installation)
 - [Documentation](#documentation)
 - [REST APIs](#rest-apis)
+- [Logging](#logging)
 - [Testing](#testing)
 - [Migration Guide](#migration-guide)
 - [Contributing](#contributing)
@@ -137,6 +138,26 @@ Errors are represented by the following types:
 
 See the [Error Handling example](./docs/rest_api/error-handling.md) for detailed usage. Refer to the [`error`](../common/errors.rs) module for more information.
 
+## Logging
+
+This crate ships with an optional default logger that you can enable with a single call:
+
+```rust
+use binance_sdk::logger;
+
+fn main() {
+    // Initialize the default logger once at the start of your application
+    logger::init();
+
+    // ... rest of your code
+}
+```
+
+The logger integrates with the Rust `tracing` ecosystem and behaves as follows:
+
+- If **another global subscriber is already set**, `logger::init()` is a no-op and does not override your existing logging setup.
+- If **no subscriber is set yet**, it installs the crate’s default global subscriber (with sensible defaults) so you immediately get structured logs from the connector.
+
 ## Testing
 
 To run the tests for the C2C module:

src/c2c/mod.rs

@@ -1,7 +1,7 @@
 pub mod rest_api;
 
 use crate::common::{
-    config::ConfigurationRestApi, constants::C2C_REST_API_PROD_URL, logger, utils::build_user_agent,
+    config::ConfigurationRestApi, constants::C2C_REST_API_PROD_URL, utils::build_user_agent,
 };
 
 /// Represents the C2C REST API client for interacting with the Binance C2C REST API.
@@ -23,8 +23,6 @@ impl C2CRestApi {
     /// A new REST API client configured with the provided settings
     #[must_use]
     pub fn from_config(mut config: ConfigurationRestApi) -> rest_api::RestApi {
-        logger::init();
-
         config.user_agent = build_user_agent("c2c");
         if config.base_path.is_none() {
             config.base_path = Some(C2C_REST_API_PROD_URL.to_string());

src/common/logger.rs

@@ -12,14 +12,18 @@ static INIT_LOG: Once = Once::new();
 /// The initialization is performed only once using a `Once` synchronization primitive
 /// to ensure thread-safe global subscriber setup.
 pub fn init() {
-    let filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info"));
+    INIT_LOG.call_once(|| {
+        if tracing::dispatcher::has_been_set() {
+            return;
+        }
 
-    let fmt_layer = fmt::layer()
-        .with_target(false)
-        .with_thread_ids(true)
-        .with_thread_names(true);
+        let filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info"));
+
+        let fmt_layer = fmt::layer()
+            .with_target(false)
+            .with_thread_ids(true)
+            .with_thread_names(true);
 
-    INIT_LOG.call_once(|| {
         let subscriber = Registry::default().with(filter).with(fmt_layer);
         let _ = tracing::subscriber::set_global_default(subscriber);
     });