digdigdig3 0.3.23

Unified async Rust API for 47 exchange connectors (REST + WebSocket). The core layer — pure ExchangeHub + connectors. Higher-level builder, persistence, replay, OB tracker live in `digdigdig3-station`.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145

//! # V5 Core Traits
//!
//! ## Architecture
//!
//! ```text
//! CoreConnector<C>           - universal methods (Identity + MarketData + Trading + Account + Positions)
//!      │
//!      └── BinanceConnector  - core + all Binance-specific directly
//!      └── KuCoinConnector   - core + all KuCoin-specific directly
//! ```
//!
//! ## Principles
//!
//! 1. **Core traits are minimal** — only what 100% of exchanges support
//! 2. **No NotImplemented in core** — all core methods work everywhere
//! 3. **Extensions in exchange connectors** — directly as struct methods
//!
//! ## Core traits
//!
//! | Trait | Methods | Description |
//! |-------|---------|-------------|
//! | `ExchangeIdentity` | 5 | Basic identification |
//! | `MarketData` | 5 | Public data (price, orderbook, klines, ticker, ping) |
//! | `Trading` | 5 | Trading (place_order, cancel_order, get_order, get_open_orders, get_order_history) |
//! | `Account` | 3 | Account (balance, account_info, fees) |
//! | `Positions` | 3 | Futures (positions, funding_rate, modify_position) |
//!
//! ## Optional operation traits (part of CoreConnector)
//!
//! - `CancelAll` - native cancel-all endpoint
//! - `AmendOrder` - native amend/modify order
//! - `BatchOrders` - native batch placement/cancellation
//! - `AccountTransfers` - internal account transfers
//! - `CustodialFunds` - deposits and withdrawals
//! - `SubAccounts` - sub-account management
//! - `FundingHistory` - historical funding payments
//! - `AccountLedger` - full account ledger
//! - `Authenticated` - credential-aware connectors

mod identity;
mod market_data;
mod market_data_public;
mod market_data_public_stubs;
mod trading;
mod account;
mod positions;
mod websocket;
mod auth;
mod operations;
mod operations_stubs;
mod has_capabilities;
pub mod has_capabilities_stubs;

pub use identity::ExchangeIdentity;
pub use market_data::MarketData;
pub use market_data_public::MarketDataPublic;
pub use trading::Trading;
pub use account::Account;
pub use positions::Positions;
pub use websocket::{WebSocketConnector, WebSocketExt};
pub use auth::{
    Authenticated, CredentialKind,
    // Backward compat — used by connector constructors and auth implementations
    Credentials, AuthRequest, SignatureLocation, ExchangeAuth,
};
pub use operations::{
    CancelAll, AmendOrder, BatchOrders,
    AccountTransfers, CustodialFunds, SubAccounts,
    FundingHistory, AccountLedger,
};
pub use has_capabilities::HasCapabilities;
pub use crate::core::websocket::CapabilityProvider;
// ═══════════════════════════════════════════════════════════════════════════════
// COMPOSITE TRAIT
// ═══════════════════════════════════════════════════════════════════════════════

/// Full core connector
///
/// Combines all core traits.
/// Used for generic code that works with any exchange.
///
/// # Example
/// ```ignore
/// async fn check_balance<C: CoreConnector>(conn: &C) -> Result<()> {
///     let balance = conn.get_balance(BalanceQuery { asset: None, account_type: AccountType::Spot }).await?;
///     let price = conn.get_price(Symbol::new("BTC", "USDT"), AccountType::Spot).await?;
///     Ok(())
/// }
/// ```
pub trait CoreConnector:
    ExchangeIdentity
    + MarketData
    + MarketDataPublic
    + Trading
    + Account
    + Positions
    + CancelAll
    + AmendOrder
    + BatchOrders
    + AccountTransfers
    + CustodialFunds
    + SubAccounts
    + FundingHistory
    + AccountLedger
    + HasCapabilities
    + Send
    + Sync
    + 'static
{
    /// Downcast to a concrete connector for exchange-specific inherent methods.
    ///
    /// Example:
    /// ```ignore
    /// let conn = pool.get(&ExchangeId::Binance)?;
    /// if let Some(binance) = conn.as_any().downcast_ref::<BinanceConnector>() {
    ///     let basis = binance.get_basis_history("BTCUSDT", "PERPETUAL", "5m", None, None, None).await?;
    /// }
    /// ```
    fn as_any(&self) -> &dyn std::any::Any;
}

impl<T> CoreConnector for T where
    T: ExchangeIdentity
        + MarketData
        + MarketDataPublic
        + Trading
        + Account
        + Positions
        + CancelAll
        + AmendOrder
        + BatchOrders
        + AccountTransfers
        + CustodialFunds
        + SubAccounts
        + FundingHistory
        + AccountLedger
        + HasCapabilities
        + Send
        + Sync
        + 'static
{
    fn as_any(&self) -> &dyn std::any::Any {
        self
    }
}