maxt 0.1.0

One Rust API for Upbit, Bithumb, Binance, and Hyperliquid market data, accounts, and orders.
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

//! Binding-facing inventories and adapter error classification.

use std::collections::HashSet;

use maxt::{Error, Exchange, Feature};

#[test]
fn binding_inventories_are_complete_stable_and_duplicate_free() {
    assert_eq!(
        Exchange::ALL,
        [
            Exchange::Upbit,
            Exchange::Bithumb,
            Exchange::Binance,
            Exchange::Hyperliquid,
        ]
    );
    assert_eq!(
        Feature::ALL,
        [
            Feature::Markets,
            Feature::Trades,
            Feature::OrderBook,
            Feature::Ticker,
            Feature::Candles,
            Feature::TradeStream,
            Feature::OrderBookStream,
            Feature::TickerStream,
            Feature::CandleStream,
            Feature::Balances,
            Feature::OpenOrders,
            Feature::AccountStream,
            Feature::Trading,
            Feature::Positions,
            Feature::Margin,
            Feature::FundingRates,
            Feature::FundingPayments,
            Feature::MarginConfig,
            Feature::ReduceOnlyOrders,
        ]
    );

    let exchange_ids: HashSet<_> = Exchange::ALL.map(Exchange::id).into_iter().collect();
    let feature_ids: HashSet<_> = Feature::ALL.map(Feature::id).into_iter().collect();
    assert_eq!(exchange_ids.len(), Exchange::ALL.len());
    assert_eq!(feature_ids.len(), Feature::ALL.len());
    assert_eq!(
        Feature::ALL.map(Feature::id),
        [
            "markets",
            "trades",
            "order_book",
            "ticker",
            "candles",
            "trade_stream",
            "order_book_stream",
            "ticker_stream",
            "candle_stream",
            "balances",
            "open_orders",
            "account_stream",
            "trading",
            "positions",
            "margin",
            "funding_rates",
            "funding_payments",
            "margin_config",
            "reduce_only_orders",
        ]
    );
}

#[test]
fn adapter_contract_errors_are_public_non_retryable_and_readable() {
    let error = Error::adapter("foreign dispatcher returned Ticker for trades");

    assert_eq!(
        error,
        Error::Adapter {
            detail: "foreign dispatcher returned Ticker for trades".to_string(),
        }
    );
    assert_eq!(
        error.to_string(),
        "adapter failed: foreign dispatcher returned Ticker for trades"
    );
    assert!(!error.is_retryable());
    assert!(!error.is_rate_limited());
}