Function update_client_config_json

src/apps/cli/src/acp_cli.rs:454–501

(
    mut value: Value,
    client_id: &str,
    default_config: Option<AcpClientConfig>,
    enabled: bool,
    permission_mode: Option<AcpClientPermissionMode>,
)

}

fn update_client_config_json(
    mut value: Value,
    client_id: &str,
    default_config: Option<AcpClientConfig>,
    enabled: bool,
    permission_mode: Option<AcpClientPermissionMode>,
) -> Result<Value> {
    ensure_acp_clients_object(&mut value)?;
    let acp_clients = value
        .get_mut("acpClients")
        .and_then(Value::as_object_mut)
        .ok_or_else(|| anyhow!("ACP client config must contain an acpClients object"))?;

    let entry = acp_clients.entry(client_id.to_string()).or_insert_with(|| {
        default_config
            .as_ref()
            .and_then(|config| serde_json::to_value(config).ok())
            .unwrap_or_else(|| json!({}))
    });
    if !entry.is_object() {
        *entry = json!({});
    }
    let entry_object = entry
        .as_object_mut()
        .ok_or_else(|| anyhow!("ACP client '{}' config must be an object", client_id))?;

    if let Some(default_config) = default_config {
        let default_value = serde_json::to_value(default_config)?;
        let default_object = default_value
            .as_object()
            .ok_or_else(|| anyhow!("Default ACP client config must be an object"))?;
        for (key, value) in default_object {
            entry_object
                .entry(key.clone())
                .or_insert_with(|| value.clone());
        }
    }

    entry_object.insert("enabled".to_string(), json!(enabled));
    if let Some(permission_mode) = permission_mode {
        entry_object.insert(
            "permissionMode".to_string(),
            serde_json::to_value(permission_mode)?,
        );
    }

    Ok(value)
}

fn ensure_acp_clients_object(value: &mut Value) -> Result<()> {
    if value.get("acpClients").is_none() {