rust-okx 0.5.1

Async Rust client for the OKX v5 REST API
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

use http::Method;

use crate::test_util::MockTransport;

use super::signed_client;

#[tokio::test]
async fn get_currencies_sends_signed_get() {
    let body = r#"{"code":"0","msg":"","data":[{
        "ccy":"BTC","name":"Bitcoin","chain":"BTC-Bitcoin",
        "minWd":"0.001","minDep":"0.001","minFee":"0.0005",
        "canDep":true,"canWd":true,"canInternal":true}]}"#;
    let mock = MockTransport::new(body);
    let client = signed_client(mock.clone());

    let rows = client.funding().get_currencies(Some("BTC")).await.unwrap();
    assert_eq!(rows[0].ccy, "BTC");
    assert_eq!(rows[0].name, "Bitcoin");
    assert!(rows[0].can_dep);

    let req = mock.captured();
    assert_eq!(req.method, Method::GET);
    assert_eq!(req.query(), Some("ccy=BTC"));
    assert!(req.is_signed());
}

#[tokio::test]
async fn get_currencies_omits_ccy_when_absent() {
    let body = r#"{"code":"0","msg":"","data":[]}"#;
    let mock = MockTransport::new(body);
    let client = signed_client(mock.clone());

    client.funding().get_currencies(None).await.unwrap();

    let req = mock.captured();
    assert_eq!(req.query(), None);
    assert!(req.is_signed());
}

#[tokio::test]
async fn get_balances_sends_signed_get() {
    let body = r#"{"code":"0","msg":"","data":[{
        "ccy":"USDT","bal":"1000","frozenBal":"0","availBal":"1000"}]}"#;
    let mock = MockTransport::new(body);
    let client = signed_client(mock.clone());

    let rows = client.funding().get_balances(Some("USDT")).await.unwrap();
    assert_eq!(rows[0].ccy, "USDT");
    assert_eq!(rows[0].bal.as_str(), "1000");
    assert_eq!(rows[0].avail_bal.as_str(), "1000");

    let req = mock.captured();
    assert_eq!(req.method, Method::GET);
    assert_eq!(req.query(), Some("ccy=USDT"));
    assert!(req.is_signed());
}

#[tokio::test]
async fn get_non_tradable_assets_sends_signed_get() {
    let body = r#"{"code":"0","msg":"","data":[{"ccy":"OKB","amt":"10","type":"1"}]}"#;
    let mock = MockTransport::new(body);
    let client = signed_client(mock.clone());

    let rows = client
        .funding()
        .get_non_tradable_assets(None)
        .await
        .unwrap();
    assert_eq!(rows[0].ccy, "OKB");
    assert_eq!(rows[0].amt.as_str(), "10");

    let req = mock.captured();
    assert_eq!(req.method, Method::GET);
    assert!(req.uri.ends_with("/api/v5/asset/non-tradable-assets"));
    assert_eq!(req.query(), None);
    assert!(req.is_signed());
}

#[tokio::test]
async fn get_deposit_address_queries_required_currency() {
    let body = r#"{"code":"0","msg":"","data":[{
        "ccy":"USDT","chain":"USDT-TRC20",
        "addr":"TN4E3PsU3YfEYvJW7i5YQKQ5P5y3YPAXB","tag":"","selected":true}]}"#;
    let mock = MockTransport::new(body);
    let client = signed_client(mock.clone());

    let rows = client.funding().get_deposit_address("USDT").await.unwrap();
    assert_eq!(rows[0].ccy, "USDT");
    assert_eq!(rows[0].chain, "USDT-TRC20");
    assert!(rows[0].selected);

    let req = mock.captured();
    assert_eq!(req.method, Method::GET);
    assert_eq!(req.query(), Some("ccy=USDT"));
    assert!(req.is_signed());
}

#[tokio::test]
async fn get_asset_valuation_omits_currency_when_absent() {
    let body = r#"{"code":"0","msg":"","data":[{
        "details":{"funding":"500","trading":"1000","earn":"200","classic":"0"},
        "totalBal":"1700"}]}"#;
    let mock = MockTransport::new(body);
    let client = signed_client(mock.clone());

    let rows = client.funding().get_asset_valuation(None).await.unwrap();
    assert_eq!(rows[0].total_bal.as_str(), "1700");
    assert_eq!(rows[0].details.funding.as_str(), "500");

    let req = mock.captured();
    assert_eq!(req.method, Method::GET);
    assert!(req.uri.ends_with("/api/v5/asset/asset-valuation"));
    assert_eq!(req.query(), None);
    assert!(req.is_signed());
}