akshare-mcp 0.1.3

MCP server for akshare-rs — financial market data via Model Context Protocol
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
146
147
148
149
150
151
152
153
154
155
156
157
158

use rmcp::schemars;

// ── Existing (kept as-is) ───────────────────────────────────────────────

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyParams {
    pub symbol: String,
    pub start_date: String,
    pub end_date: String,
}

// ── New param types ────────────────────────────────────────────────────

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct ForexHistEmParams {
    /// Eastmoney forex secid, e.g. "133.USDCNY" or "119.EURCNY"
    pub symbol: String,
    /// Kline period: "daily", "weekly", or "monthly"
    #[serde(default = "default_period")]
    pub period: String,
    /// Start date in YYYYMMDD format (currently unused by API but forwarded)
    #[serde(default)]
    pub start_date: String,
    /// End date in YYYYMMDD format (currently unused by API but forwarded)
    #[serde(default)]
    pub end_date: String,
    /// Price adjustment: "qfq" (forward), "hfq" (backward), or "" (none)
    #[serde(default)]
    pub adjust: String,
}

fn default_period() -> String {
    "daily".to_string()
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct ForexEmHistParams {
    /// Eastmoney forex secid, e.g. "133.USDCNY" or "119.EURCNY"
    pub symbol: String,
    /// Number of data points to return
    #[serde(default = "default_forex_limit")]
    pub limit: usize,
}

fn default_forex_limit() -> usize {
    60
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyLatestParams {
    /// Base currency code, e.g. "USD"
    pub base: String,
    /// Comma-separated target currency codes, e.g. "EUR,GBP,CNY"
    pub symbols: String,
    /// CurrencyBeacon API key
    #[serde(default)]
    pub api_key: String,
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyHistoryParams {
    /// Base currency code, e.g. "USD"
    pub base: String,
    /// Date in YYYY-MM-DD format
    pub date: String,
    /// Comma-separated target currency codes
    pub symbols: String,
    /// CurrencyBeacon API key
    #[serde(default)]
    pub api_key: String,
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyTimeSeriesParams {
    /// Base currency code, e.g. "USD"
    pub base: String,
    /// Start date in YYYY-MM-DD format
    pub start_date: String,
    /// End date in YYYY-MM-DD format
    pub end_date: String,
    /// Comma-separated target currency codes
    pub symbols: String,
    /// CurrencyBeacon API key
    #[serde(default)]
    pub api_key: String,
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyCurrenciesParams {
    /// Currency type filter (e.g. "fiat")
    #[serde(default)]
    pub c_type: String,
    /// CurrencyBeacon API key
    #[serde(default)]
    pub api_key: String,
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyConvertParams {
    /// Source currency code, e.g. "USD"
    pub from: String,
    /// Target currency code, e.g. "CNY"
    pub to: String,
    /// Amount to convert
    pub amount: f64,
    /// CurrencyBeacon API key
    #[serde(default)]
    pub api_key: String,
}

#[derive(serde::Deserialize, schemars::JsonSchema)]
pub struct CurrencyPairParams {
    /// FX currency pair code, e.g. "USDCNY"
    pub pair: String,
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_currency_params() {
        let json = r#"{"symbol": "美元", "start_date": "20240101", "end_date": "20240601"}"#;
        let params: CurrencyParams = serde_json::from_str(json).unwrap();
        assert_eq!(params.symbol, "美元");
        assert_eq!(params.start_date, "20240101");
        assert_eq!(params.end_date, "20240601");
    }

    #[test]
    fn test_forex_hist_em_params_defaults() {
        let json = r#"{"symbol": "133.USDCNY"}"#;
        let params: ForexHistEmParams = serde_json::from_str(json).unwrap();
        assert_eq!(params.symbol, "133.USDCNY");
        assert_eq!(params.period, "daily");
        assert_eq!(params.start_date, "");
        assert_eq!(params.end_date, "");
        assert_eq!(params.adjust, "");
    }

    #[test]
    fn test_forex_em_hist_params_defaults() {
        let json = r#"{"symbol": "133.USDCNY"}"#;
        let params: ForexEmHistParams = serde_json::from_str(json).unwrap();
        assert_eq!(params.symbol, "133.USDCNY");
        assert_eq!(params.limit, 60);
    }

    #[test]
    fn test_currency_convert_params() {
        let json = r#"{"from": "USD", "to": "CNY", "amount": 100.0, "api_key": "test"}"#;
        let params: CurrencyConvertParams = serde_json::from_str(json).unwrap();
        assert_eq!(params.from, "USD");
        assert_eq!(params.to, "CNY");
        assert!((params.amount - 100.0).abs() < f64::EPSILON);
        assert_eq!(params.api_key, "test");
    }
}