ek-ui 0.9.4

//! 无界面一次性写档共用面(0.9.0;BD-APP-2/4):`ekapp add-account` CLI 与
//! **等效判据**(tests/ui_app_contract.rs)共用同一构造函数 —— 判据钉的
//! 就是「CLI 写出的段,喂给**真受理方法** `apply_config` 必被全采纳」。
//!
//! 段形对齐真实受理面(`ek-cta::dump_config`):明文键 + `secret://` 引用行,
//! 密码**值**先进密库(Windows 凭据管理器)再出引用;值永不落文件。
//! 形态常量(`gw_td_password`/`gw_md_password`)与 ek-cta 单源同拼写 —— 改名
//! 必须双动(判据钉 willcatch 漂移)。

use ek_core::{Field, SectionMap};

/// CLI 一次提交的账户档要素(密码不入结构面:与本进程 stdin 通道分开)。
#[derive(Debug, Clone)]
pub struct AcctSpec {
    pub broker_id: String,
    pub user: String,
    pub td_addr: String,
    pub md_addr: String,
    pub app_id: String,
    pub auth_code: String,
    /// 收录产品类(单字符 CTP 码逗号分隔;空 = 不写档,交给缺省)。
    pub classes: String,
    pub md_user: String,
    /// 行情侧独立密码(缺省 = None → 段里不出 md_password,行情会话回落 td 凭据)。
    pub md_password: Option<String>,
}

/// 派生注册名(ek-cta 单源;形 `ctp_<broker>_<账号>`)。
pub fn derived_name(spec: &AcctSpec) -> Result<String, String> {
    ek_ctp::derived_gateway_name(&spec.broker_id, &spec.user).ok_or_else(|| {
        format!(
            "派生注册名失败(broker={:?} 账号={:?}):字符不合名纪律",
            spec.broker_id, spec.user
        )
    })
}

/// 组段(校验 + 秘面登记 + 段构造;**store 由调用方给**,判据用临时根,
/// CLI 用生态缺省根 —— 同一函数,一字不差)。
///
/// 返回:网关派生名;调用方即将其拼 `ns = "ctp.<gw>"` 存档。
///
/// # Errors
/// 派生名/必填项/product_classes 形制不合;密库登记失败(缺后端面)。
pub fn write_account(
    store: &ek_cfg::Store,
    spec: &AcctSpec,
    password: &str,
) -> Result<String, String> {
    if spec.broker_id.is_empty()
        || spec.user.is_empty()
        || spec.td_addr.is_empty()
        || spec.app_id.is_empty()
        || spec.auth_code.is_empty()
    {
        return Err("缺必填要素(broker/user/td 前置/app_id/auth_code)".to_string());
    }
    if password.trim().is_empty() {
        return Err("密码为空:档案不接受无密码账户(受理校验同款)".to_string());
    }
    let gw = derived_name(spec)?;
    let ns = format!("ctp.{gw}");
    ek_cfg::secret::set(
        &ns,
        "gw_td_password",
        ek_cfg::SecretValue::from_bytes(password.trim().to_owned()),
    )
    .map_err(|e| format!("密码登记密库失败: {e:?}"))?;
    let mut map = SectionMap::new(1)
        .set("broker_id", Field::plain(spec.broker_id.trim()))
        .set("td_addr", Field::plain(spec.td_addr.trim()))
        .set("td_user", Field::plain(spec.user.trim()))
        .set("td_app_id", Field::plain(spec.app_id.trim()))
        .set("td_auth_code", Field::plain(spec.auth_code.trim()))
        .set("td_password", Field::secret("gw_td_password"));
    if !spec.md_addr.trim().is_empty() {
        map = map.set("md_addr", Field::plain(spec.md_addr.trim()));
        if !spec.md_user.trim().is_empty() {
            map = map.set("md_user", Field::plain(spec.md_user.trim()));
        }
        if let Some(mp) = spec.md_password.as_deref() {
            let mp = mp.trim();
            if !mp.is_empty() {
                ek_cfg::secret::set(&ns, "gw_md_password", ek_cfg::SecretValue::from_bytes(mp))
                    .map_err(|e| format!("行情密码登记密库失败: {e:?}"))?;
                map = map.set("md_password", Field::secret("gw_md_password"));
            }
        }
    }
    let classes = spec.classes.trim();
    if !classes.is_empty() {
        for c in classes.split(',').map(str::trim) {
            if c.chars().count() != 1 {
                return Err(format!(
                    "product_classes 项 {c:?} 非单字符 CTP 码(D-PC-FILTER)"
                ));
            }
        }
        map = map.set("product_classes", Field::plain(classes));
    }
    store
        .store(&ns, &map)
        .map_err(|e| format!("档案落盘失败: {e:?}"))?;
    Ok(gw)
}