futu_mcp/handlers/trade/
helpers.rs

1//! mcp/handlers/trade/helpers — parse_* + build_header_* (跨 trade sub-mod 共用)
2//! (v1.4.110 CC Batch O: 拆自 trade.rs L26-110)
3
4use anyhow::{Result, bail};
5use futu_core::{trade_market, trade_parsing};
6use futu_trd::types::{TrdEnv, TrdHeader, TrdMarket};
7
8use crate::trd_sdk_adapter;
9
10pub fn parse_trd_market(s: &str) -> Result<TrdMarket> {
11    let market = trade_market::parse_trd_market_id(s).ok_or_else(|| {
12        anyhow::anyhow!(
13            "unknown trd market {:?} ({})",
14            s.trim().to_ascii_uppercase(),
15            trade_market::TRD_MARKET_PARSE_CHOICES
16        )
17    })?;
18    trd_sdk_adapter::trd_market_from_id(market).ok_or_else(|| {
19        anyhow::anyhow!("unknown trd market id {market} after core parser accepted it")
20    })
21}
22
23pub fn parse_trd_env(s: &str) -> Result<TrdEnv> {
24    let env = trade_parsing::parse_trd_env_id(s).ok_or_else(|| {
25        anyhow::anyhow!(
26            "unknown trd env {:?} ({})",
27            s.trim().to_ascii_lowercase(),
28            trade_parsing::TRD_ENV_PARSE_CHOICES
29        )
30    })?;
31    trd_sdk_adapter::trd_env_from_id(env)
32        .ok_or_else(|| anyhow::anyhow!("unknown trd env id {env} after core parser accepted it"))
33}
34
35/// v1.4.102 codex 38 F4 / 41 F2 / 41 F3 / 42 F3 (P2): 严格 env → i32
36/// 共享 helper, 替换 cash_flow / margin_info / account_flag / bond 4 处
37/// 旧"non-real => 0 silent"模式. typo (e.g. "reel" / "prod") 现在 reject
38/// at MCP boundary (BUG-005 反 silent wrong-env).
39pub fn parse_trd_env_int(s: &str) -> Result<i32> {
40    Ok(parse_trd_env(s)? as i32)
41}
42
43/// v1.4.102 codex 33 F5 / 34 F4 / 35 F4 (P2): 拒 fund market 在 calculation /
44/// active trade-read path. 用于 max_trd_qtys / margin_ratio / order_fee /
45/// orders / deals 等 active backend call (区别于 view-only positions/funds/
46/// cash-log/history 真机 verified).
47pub fn parse_trd_market_strict_no_fund(s: &str) -> Result<TrdMarket> {
48    let m = parse_trd_market(s)?;
49    if let Some(label) = trade_market::canonical_fund_trd_market_label(m as i32) {
50        bail!(
51            "trd market {label} 仅 view-only read endpoints \
52             (positions/funds/cash-log/history-orders/history-fills) 真机 verified; \
53             active/calculation path (orders/deals/max_trd_qtys/margin_ratio/order_fee) \
54             用主市场. v1.4.102 audit 33 F5 / 34 F4 / 35 F4 fix."
55        );
56    }
57    Ok(m)
58}
59
60/// v1.4.102 codex 35 F4: build_header for active/calculation MCP tools.
61/// view-only read tools (positions/funds/cash-log/history) 用普通 build_header
62/// 接受 fund market.
63pub fn build_header_strict_no_fund(env: &str, acc_id: u64, market: &str) -> Result<TrdHeader> {
64    build_header_strict_no_fund_with_jp_acc_type(env, acc_id, market, None)
65}
66
67pub fn build_header_strict_no_fund_with_jp_acc_type(
68    env: &str,
69    acc_id: u64,
70    market: &str,
71    jp_acc_type: Option<i32>,
72) -> Result<TrdHeader> {
73    Ok(TrdHeader {
74        trd_env: parse_trd_env(env)?,
75        acc_id,
76        trd_market: parse_trd_market_strict_no_fund(market)?,
77        jp_acc_type,
78    })
79}
80
81pub fn build_header(env: &str, acc_id: u64, market: &str) -> Result<TrdHeader> {
82    Ok(TrdHeader {
83        trd_env: parse_trd_env(env)?,
84        acc_id,
85        trd_market: parse_trd_market(market)?,
86        jp_acc_type: None,
87    })
88}
futu_mcp/handlers/trade/helpers.rs

futu_mcp/handlers/trade/
helpers.rs
