crypto-ws-client 4.12.11

A versatile websocket client that supports many cryptocurrency exchanges.
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

use std::collections::HashMap;

use reqwest::{header, Result};
use serde_json::Value;

async fn http_get(url: &str) -> Result<String> {
    let mut headers = header::HeaderMap::new();
    headers.insert(header::CONTENT_TYPE, header::HeaderValue::from_static("application/json"));

    let client = reqwest::Client::builder()
         .default_headers(headers)
         .user_agent("Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.88 Safari/537.36")
         .gzip(true)
         .build()?;
    let response = client.get(url).send().await?;

    match response.error_for_status() {
        Ok(resp) => Ok(resp.text().await?),
        Err(error) => Err(error),
    }
}

// See https://zbgapi.github.io/docs/spot/v1/en/#public-get-all-supported-trading-symbols
pub(super) async fn fetch_symbol_id_map_spot() -> HashMap<String, i64> {
    let mut symbol_id_map: HashMap<String, i64> =
        vec![("btc_usdt", 329), ("eth_usdt", 330), ("eos_usdt", 333), ("zb_usdt", 321)]
            .into_iter()
            .map(|x| (x.0.to_string(), x.1))
            .collect();

    if let Ok(txt) = http_get("https://www.zbg.com/exchange/api/v1/common/symbols").await {
        if let Ok(obj) = serde_json::from_str::<HashMap<String, Value>>(&txt) {
            if obj
                .get("resMsg")
                .unwrap()
                .as_object()
                .unwrap()
                .get("code")
                .unwrap()
                .as_str()
                .unwrap()
                == "1"
            {
                let arr = obj.get("datas").unwrap().as_array().unwrap();
                for v in arr.iter() {
                    let obj = v.as_object().unwrap();
                    let symbol = obj.get("symbol").unwrap().as_str().unwrap();
                    let id = obj.get("id").unwrap().as_str().unwrap();

                    symbol_id_map.insert(symbol.to_string(), id.parse::<i64>().unwrap());
                }
            }
        }
    }

    symbol_id_map
}

// See https://zbgapi.github.io/docs/future/v1/en/#public-get-contracts
pub(super) async fn fetch_symbol_contract_id_map_swap() -> HashMap<String, i64> {
    let mut symbol_contract_id_map: HashMap<String, i64> = vec![
        ("BTC_USDT", 1000000),
        ("BTC_USD-R", 1000001),
        ("ETH_USDT", 1000002),
        ("ETH_USD-R", 1000003),
    ]
    .into_iter()
    .map(|x| (x.0.to_string(), x.1))
    .collect();

    if let Ok(txt) = http_get("https://www.zbg.com/exchange/api/v1/future/common/contracts").await {
        if let Ok(obj) = serde_json::from_str::<HashMap<String, Value>>(&txt) {
            if obj
                .get("resMsg")
                .unwrap()
                .as_object()
                .unwrap()
                .get("code")
                .unwrap()
                .as_str()
                .unwrap()
                == "1"
            {
                let arr = obj.get("datas").unwrap().as_array().unwrap();
                for v in arr.iter() {
                    let obj = v.as_object().unwrap();
                    let symbol = obj.get("symbol").unwrap().as_str().unwrap();
                    let contract_id = obj.get("contractId").unwrap().as_i64().unwrap();

                    symbol_contract_id_map.insert(symbol.to_string(), contract_id);
                }
            }
        }
    }

    symbol_contract_id_map
}