akshare 0.1.6

100% pure Rust implementation of akshare — unified access to Chinese and global financial market data APIs
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

//! Crypto spot prices from Jin10 (金十数据).

use crate::client::AkShareClient;
use crate::error::{Error, Result};
use crate::types::CryptoSpot;

impl AkShareClient {
    /// Fetch crypto spot prices from JS (金十数据) — Python-compatible name.
    pub async fn crypto_js_spot(&self) -> Result<Vec<CryptoSpot>> {
        self.crypto_spot().await
    }

    /// Fetch crypto spot prices from Jin10 data center.
    pub async fn crypto_spot(&self) -> Result<Vec<CryptoSpot>> {
        let url = "https://cdn.jin10.com/data_center/reports/exchange_rate.json";
        let resp = self
            .get(url)
            .header("Referer", "https://www.jin10.com")
            .send()
            .await?;

        if !resp.status().is_success() {
            return Err(Error::upstream(format!(
                "jin10 crypto: HTTP {}",
                resp.status()
            )));
        }

        let body: serde_json::Value = resp.json().await?;

        // The response format varies; try to extract an array of crypto items
        let items_raw = body
            .as_array()
            .cloned()
            .or_else(|| body.get("data").and_then(|d| d.as_array()).cloned())
            .unwrap_or_default();

        let mut items = Vec::with_capacity(items_raw.len());
        for v in &items_raw {
            let symbol = v
                .get("symbol")
                .or_else(|| v.get("code"))
                .and_then(|x| x.as_str())
                .unwrap_or("")
                .to_string();
            let name = v
                .get("name")
                .and_then(|x| x.as_str())
                .unwrap_or("")
                .to_string();

            if symbol.is_empty() {
                continue;
            }

            let price_usd = v
                .get("price")
                .or_else(|| v.get("price_usd"))
                .and_then(serde_json::Value::as_f64)
                .unwrap_or(0.0);
            let price_cny = v
                .get("cny_price")
                .or_else(|| v.get("price_cny"))
                .and_then(serde_json::Value::as_f64)
                .unwrap_or(0.0);
            let change_24h_pct = v
                .get("change")
                .or_else(|| v.get("change_24h"))
                .and_then(serde_json::Value::as_f64)
                .unwrap_or(0.0);
            let volume_24h = v
                .get("volume")
                .or_else(|| v.get("volume_24h"))
                .and_then(serde_json::Value::as_f64)
                .unwrap_or(0.0);
            let market_cap = v
                .get("market_cap")
                .and_then(serde_json::Value::as_f64)
                .unwrap_or(0.0);

            items.push(CryptoSpot {
                symbol,
                name,
                price_usd,
                price_cny,
                change_24h_pct,
                volume_24h,
                market_cap,
            });
        }
        Ok(items)
    }
}