futu_rest/routes/trd/

cancel_all.rs

//! REST `/api/cancel-all-order` 便捷写入口。
//!
//! 该 route 是 `ModifyOrder(Cancel)` 的 REST convenience wrapper，负责 flat body
//! promote、强制 cancel-all 字段和写路径限额检查；通用交易 route 不再承载这些局部细节。

use std::sync::Arc;

use axum::Json;
use axum::extract::{Extension, State};
use axum::http::HeaderMap;
use serde_json::Value;

use futu_auth::{CheckCtx, KeyRecord};
use futu_core::proto_id;
use futu_proto::trd_modify_order;

use crate::adapter::{self, RestState};

use super::ApiResult;
use super::card_num::normalize_and_resolve_card_num_for_route;
use super::validation::{authorize_trade_write, trd_market_str, validate_header_trd_market_write};
use super::write_pipeline::{
    idempotency_key_from_headers, limit_reject_response, surface_spec_or_internal_error,
};

/// v1.4.96 BUG #006 helper (external reviewer 6-round cross-verify, real env data corruption risk fix).
///
/// REST `/api/cancel-all-order` 支持两种 body 格式: c2s wrapper 和 flat.
/// flat body (`{"acc_id":..., "trd_market":1}`) 之前直接传给 adapter, 跳过
/// handler 的 `c2s.insert("modify_order_op", 2)` 强制覆盖 → daemon 收到
/// modify_op=0 (ModifyOrder) → real env 真 modify 匹配订单风险.
///
/// 本 helper 检测 flat body (顶层有 `acc_id` / `trd_market` / `header` 等
/// 业务字段, 但无 `c2s` key), 把它包装成 `{"c2s": {"header": {...原字段}}}`
/// 让强制字段 override 走原 c2s 路径, **避免重复 fix path / silent regression**.
///
/// 不动已 c2s wrapper 的 body (`{"c2s": {...}}`).
///
/// ## 与 `adapter::maybe_wrap_flat_body_as_c2s` 的关系 (audit follow-up):
///
/// `crates/futu-rest/src/adapter.rs::maybe_wrap_flat_body_as_c2s` 已经在
/// adapter `proto_request` 入口做 flat → c2s wrap, 所以理论上 promote 是
/// 重复. **但**: cancel-all-order handler 在 `adapter::proto_request` **之前**
/// 跑 `c2s.insert("modify_order_op", 2)` 强制覆盖, 此时 c2s 必须已存在.
/// 顺序: handler → `promote_flat_body_to_c2s` → `c2s.insert(...)` →
/// `adapter::proto_request(body, ...)` → `maybe_wrap_flat_body_as_c2s` (已经
/// 是 c2s wrapper, no-op).
///
/// 因此 `promote_flat_body_to_c2s` 是 cancel-all-order handler 局部需要的,
/// 不是 adapter 通用 wrap 的替代.
pub(crate) fn promote_flat_body_to_c2s(body: &mut Value) {
    // 已有 c2s 则直接返回 (尊重显式 wrapper)
    if body.get("c2s").is_some() {
        return;
    }
    let Some(map) = body.as_object_mut() else {
        return;
    };
    if map.is_empty() {
        return;
    }
    // 把所有字段下沉到 c2s.header (业务字段 acc_id / trd_market / 等都属
    // header). 注意: c2s 自己不能在 map 里, 上面已 guard.
    let header: serde_json::Map<String, Value> = std::mem::take(map).into_iter().collect();
    let mut c2s = serde_json::Map::new();
    c2s.insert("header".to_string(), Value::Object(header));
    map.insert("c2s".to_string(), Value::Object(c2s));
}

/// POST /api/cancel-all-order — 全部撤单（v1.4.30 新加）
///
/// 这是 `/api/modify-order` 的便捷端点，内部强制 `forAll=true` +
/// `modifyOrderOp=2 (Cancel)` + `orderID=0`，用户只需传 `trdHeader` 和
/// 可选的 `trdMarket`（不指定市场时撤整个账户全部）。
///
/// 风险提示：**对真实账户下发后立即撤销该账户指定市场所有 pending 订单**，
/// 不可恢复。scope 要求 `trade:real`（同 modify-order），限额按 market
/// 白名单 + rate 检查。
pub async fn cancel_all_order(
    State(state): State<RestState>,
    rec: Option<Extension<Arc<KeyRecord>>>,
    headers: HeaderMap,
    Json(mut body): Json<Value>,
) -> ApiResult {
    crate::adapter::normalize_json_keys_snake_case(&mut body);
    authorize_trade_write(
        &state,
        rec.as_ref().map(|Extension(rec)| rec.as_ref()),
        &body,
        "/api/cancel-all-order",
    )?;
    // v1.4.45: normalize camelCase → snake_case（在强制字段覆盖前做）
    // v1.4.105 D12 (Phase 2): card_num → acc_id 解析 (与 place_order 一致).
    // 注意: cancel_all_order 走 flat-body promote 路径, helper 在 normalize 后
    // 提取 card_num + 写 acc_id 到 top-level (header 不存在则 fallback top),
    // promote_flat 之后下沉到 c2s.header — 顺序兼容.
    // v1.4.105 D12 contract-hardening 补丁: 同 place_order, 加 rec 做 string-level
    // allowed_card_nums whitelist 校验.
    normalize_and_resolve_card_num_for_route(&state, &rec, &mut body, "/api/cancel-all-order")?;
    // v1.4.96 BUG #003 hotfix (external reviewer matrix-double-confirmed): trd_market=999
    // silent accept 200 OK 已修. 在 c2s 强制字段覆盖前 validate, 让用户知道
    // trd_market 不合法.
    // v1.4.102 codex 26 F1 (P1): write 路径用更窄 allowlist (无 fund markets)
    validate_header_trd_market_write(&body, "/api/cancel-all-order")?;
    // v1.4.96 BUG #006 hotfix (external reviewer 6-round cross-verify 2026-04-26):
    // flat body (无 c2s wrapper) → 之前 c2s.insert 不命中 → daemon 收到
    // modify_op=0 (ModifyOrder) 而非 2 (Cancel) → real env 风险真 modify
    // 匹配的订单. fix: 检测 flat body, 若 acc_id 在顶层而 c2s 不存在, 把
    // header 字段下沉到 c2s.header 让 adapter 看到统一形态. 然后正常跑
    // 原有 c2s.insert 强制字段覆盖逻辑.
    promote_flat_body_to_c2s(&mut body);
    // 覆盖 c2s 里的强制字段（这里用 snake_case，normalize 后和原代码的 camelCase 等价）
    if let Some(c2s) = body.get_mut("c2s").and_then(|c| c.as_object_mut()) {
        c2s.insert("order_id".to_string(), Value::from(0u64));
        // v1.4.47 P0.2 修（external reviewer 验收报告 §2 跨 5 版未修）：modify_order_op 应为 2 (Cancel)
        // 不是 4。Trd_Common.ModifyOrderOp: 1=Normal, 2=Cancel, 3=Disable, 4=Enable, 5=DeleteOutofdate.
        // 之前写 4 (Enable) → handler `if modify_op == 2` 不命中 → 走 ReplaceOrder 分支 →
        // 错误文案硬编码 "ModifyOrder:"（不是 "CancelAllOrder:"）。修为 2 后 handler 正确
        // 命中 cancel_all 分支 → op_name = "CancelAllOrder"。
        c2s.insert("modify_order_op".to_string(), Value::from(2));
        c2s.insert("for_all".to_string(), Value::from(true));
    } else {
        // v1.4.96 BUG #006: 经 promote_flat_body_to_c2s 后 c2s **必须**存在.
        // 若仍不存在 = body 完全 empty (如 `{}`), 显式构造让强制字段生效.
        let mut c2s = serde_json::Map::new();
        c2s.insert("order_id".to_string(), Value::from(0u64));
        c2s.insert("modify_order_op".to_string(), Value::from(2));
        c2s.insert("for_all".to_string(), Value::from(true));
        if let Some(map) = body.as_object_mut() {
            map.insert("c2s".to_string(), Value::Object(c2s));
        }
    }

    // 限额检查（symbol/value/side 空，仅 market 白名单 + rate）
    if let Some(Extension(rec)) = rec
        && let Ok(parsed) = serde_json::from_value::<trd_modify_order::Request>(body.clone())
    {
        let market = trd_market_str(parsed.c2s.header.trd_market);
        let ctx = CheckCtx {
            market: market.to_string(),
            symbol: String::new(),
            order_value: None,
            trd_side: None,
            acc_id: Some(parsed.c2s.header.acc_id), // v1.4.35
            mutation_no_exposure: false,
            currency: None,
        };
        let now = chrono::Utc::now();
        // v1.4.36 Bug #1：Whitelist → 403
        let outcome = state
            .counters
            .check_full_skip_rate(&rec.id, rec.as_ref(), &ctx, now);
        if let Some(reason) = outcome.reason() {
            return Err(limit_reject_response(
                "/api/cancel-all-order",
                &rec,
                &reason,
                outcome.http_status_code(),
            ));
        }
    }

    let cancel_all_spec =
        surface_spec_or_internal_error("/api/cancel-all-order", "CancelAllOrder")?;
    let idem_key = idempotency_key_from_headers(&headers);
    adapter::proto_request_with_surface_spec_and_idempotency::<
        trd_modify_order::Request,
        trd_modify_order::Response,
    >(
        &state,
        proto_id::TRD_MODIFY_ORDER,
        Some(body),
        idem_key,
        cancel_all_spec,
    )
    .await
}

#[cfg(test)]
mod flat_body_promotion_tests;