grpctestify 1.8.6

//! Helper utilities for the test runner.
//!
//! Contains pure functions and static helpers used by the test runner
//! that don't require `self` access: variable substitution, TLS defaults,
//! JSON formatting, and metadata conversion.

use crate::grpc::{CompressionMode, ProtoConfig, TlsConfig};
use crate::parser::ast::GctfDocument;
use crate::polyfill::runtime;
use crate::utils::file::FileUtils;
use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::collections::HashMap;
use std::path::Path;

/// Convert apif-execution CallStreamItem + CallError to gRPC StreamItem + tonic::Status.
/// Used by the CallClient factory path in the runner to maintain compatibility
/// with the existing gRPC-centric error and stream handling code.
pub fn convert_call_item(
    item: Result<apif_execution::CallStreamItem, apif_execution::CallError>,
) -> Result<crate::grpc::client::StreamItem, tonic::Status> {
    match item {
        Ok(apif_execution::CallStreamItem::Message(msg)) => {
            Ok(crate::grpc::client::StreamItem::Message(msg))
        }
        Ok(apif_execution::CallStreamItem::Trailers(t)) => {
            Ok(crate::grpc::client::StreamItem::Trailers(t))
        }
        Err(err) => {
            let code = match err.code {
                0 => tonic::Code::Ok,
                1 => tonic::Code::Cancelled,
                2 => tonic::Code::Unknown,
                3 => tonic::Code::InvalidArgument,
                4 => tonic::Code::DeadlineExceeded,
                5 => tonic::Code::NotFound,
                6 => tonic::Code::AlreadyExists,
                7 => tonic::Code::PermissionDenied,
                8 => tonic::Code::ResourceExhausted,
                9 => tonic::Code::FailedPrecondition,
                10 => tonic::Code::Aborted,
                11 => tonic::Code::OutOfRange,
                12 => tonic::Code::Unimplemented,
                13 => tonic::Code::Internal,
                14 => tonic::Code::Unavailable,
                15 => tonic::Code::DataLoss,
                16 => tonic::Code::Unauthenticated,
                _ => tonic::Code::Unknown,
            };
            Err(tonic::Status::new(code, err.message))
        }
    }
}

/// Buffer size for the request message channel.
/// Controls back-pressure for client streaming: larger values allow more
/// buffered requests but consume more memory.
pub const REQUEST_CHANNEL_BUFFER: usize = 100;

/// Default TLS configuration from environment variables.
pub fn tls_env_defaults() -> HashMap<String, String> {
    let mut defaults = HashMap::new();

    if let Ok(value) = std::env::var(crate::config::ENV_GRPCTESTIFY_TLS_CA_FILE)
        && !value.trim().is_empty()
    {
        defaults.insert("ca_cert".to_string(), value);
    }
    if let Ok(value) = std::env::var(crate::config::ENV_GRPCTESTIFY_TLS_CERT_FILE)
        && !value.trim().is_empty()
    {
        defaults.insert("client_cert".to_string(), value);
    }
    if let Ok(value) = std::env::var(crate::config::ENV_GRPCTESTIFY_TLS_KEY_FILE)
        && !value.trim().is_empty()
    {
        defaults.insert("client_key".to_string(), value);
    }
    if let Ok(value) = std::env::var(crate::config::ENV_GRPCTESTIFY_TLS_SERVER_NAME)
        && !value.trim().is_empty()
    {
        defaults.insert("server_name".to_string(), value);
    }

    defaults
}

/// Parse truthy values from config-style strings.
pub fn parse_bool_flag(value: &str) -> bool {
    matches!(
        value.trim().to_ascii_lowercase().as_str(),
        "true" | "1" | "yes" | "on"
    )
}

/// Resolve effective address using ADDRESS section, env var, then default.
pub fn effective_address(document: &GctfDocument) -> String {
    document
        .get_address(
            std::env::var(crate::config::ENV_GRPCTESTIFY_ADDRESS)
                .ok()
                .as_deref(),
        )
        .unwrap_or_else(crate::config::default_address)
}

/// Resolve compression setting from OPTIONS section with env fallback.
pub fn parse_compression_option(options: &HashMap<String, String>) -> CompressionMode {
    options
        .get("compression")
        .map(|v| v.trim().to_ascii_lowercase())
        .and_then(|v| match v.as_str() {
            "gzip" => Some(CompressionMode::Gzip),
            "none" | "" => Some(CompressionMode::None),
            _ => None,
        })
        .unwrap_or_else(CompressionMode::from_env)
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum RuntimeOptionSource {
    SectionAttribute,
    FileOptions,
    CliDefaults,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RuntimeOptionWithSource<T> {
    pub value: T,
    pub source: RuntimeOptionSource,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct EffectiveRuntimeOptions {
    pub timeout_seconds: RuntimeOptionWithSource<u64>,
    pub retry: RuntimeOptionWithSource<u32>,
    pub retry_delay_seconds: RuntimeOptionWithSource<f64>,
    pub no_retry: RuntimeOptionWithSource<bool>,
    pub compression: RuntimeOptionWithSource<String>,
}

#[derive(Debug, Clone, Copy)]
pub struct CliRuntimeDefaults {
    pub timeout_seconds: u64,
    pub retry: u32,
    pub retry_delay_seconds: f64,
    pub no_retry: bool,
}

pub fn resolve_effective_runtime_options(
    document: &GctfDocument,
    cli: CliRuntimeDefaults,
) -> Result<EffectiveRuntimeOptions, String> {
    let options = document.get_options().unwrap_or_default();

    let timeout_from_attr = document
        .sections
        .iter()
        .filter_map(|s| s.get_timeout())
        .find(|&v| v > 0);
    let timeout_seconds = if let Some(v) = timeout_from_attr {
        RuntimeOptionWithSource {
            value: v,
            source: RuntimeOptionSource::SectionAttribute,
        }
    } else if let Some(value) = options.get("timeout") {
        match value.trim().parse::<u64>() {
            Ok(v) if v > 0 => RuntimeOptionWithSource {
                value: v,
                source: RuntimeOptionSource::FileOptions,
            },
            _ => {
                return Err(format!(
                    "OPTIONS.timeout must be a positive integer, got '{}'",
                    value
                ));
            }
        }
    } else {
        RuntimeOptionWithSource {
            value: cli.timeout_seconds,
            source: RuntimeOptionSource::CliDefaults,
        }
    };

    let no_retry_from_attr = document
        .sections
        .iter()
        .filter_map(|s| {
            s.get_attribute("no_retry")
                .or_else(|| s.get_attribute("no-retry"))
        })
        .filter_map(|a| a.parse_bool())
        .next();
    let no_retry = if let Some(v) = no_retry_from_attr {
        RuntimeOptionWithSource {
            value: v,
            source: RuntimeOptionSource::SectionAttribute,
        }
    } else if let Some(value) = options.get("no_retry").or_else(|| options.get("no-retry")) {
        let parsed = match value.trim().to_ascii_lowercase().as_str() {
            "true" | "1" | "yes" | "on" => Some(true),
            "false" | "0" | "no" | "off" => Some(false),
            _ => None,
        };
        match parsed {
            Some(v) => RuntimeOptionWithSource {
                value: v,
                source: RuntimeOptionSource::FileOptions,
            },
            None => {
                return Err(format!(
                    "OPTIONS.no_retry must be a boolean, got '{}'",
                    value
                ));
            }
        }
    } else {
        RuntimeOptionWithSource {
            value: cli.no_retry,
            source: RuntimeOptionSource::CliDefaults,
        }
    };

    let retry_from_attr = document
        .sections
        .iter()
        .filter_map(|s| s.get_retry())
        .next();
    let retry = if let Some(v) = retry_from_attr {
        RuntimeOptionWithSource {
            value: v,
            source: RuntimeOptionSource::SectionAttribute,
        }
    } else if let Some(value) = options.get("retry") {
        match value.trim().parse::<u32>() {
            Ok(v) => RuntimeOptionWithSource {
                value: v,
                source: RuntimeOptionSource::FileOptions,
            },
            Err(_) => {
                return Err(format!(
                    "OPTIONS.retry must be a non-negative integer, got '{}'",
                    value
                ));
            }
        }
    } else {
        RuntimeOptionWithSource {
            value: cli.retry,
            source: RuntimeOptionSource::CliDefaults,
        }
    };

    let retry_delay_from_attr = document
        .sections
        .iter()
        .filter_map(|s| {
            s.get_attribute("retry_delay")
                .or_else(|| s.get_attribute("retry-delay"))
        })
        .filter_map(|a| a.parse_f64())
        .find(|v| *v >= 0.0);
    let retry_delay_seconds = if let Some(v) = retry_delay_from_attr {
        RuntimeOptionWithSource {
            value: v,
            source: RuntimeOptionSource::SectionAttribute,
        }
    } else if let Some(value) = options
        .get("retry_delay")
        .or_else(|| options.get("retry-delay"))
    {
        match value.trim().parse::<f64>() {
            Ok(v) if v >= 0.0 => RuntimeOptionWithSource {
                value: v,
                source: RuntimeOptionSource::FileOptions,
            },
            _ => {
                return Err(format!(
                    "OPTIONS.retry_delay must be a non-negative number, got '{}'",
                    value
                ));
            }
        }
    } else {
        RuntimeOptionWithSource {
            value: cli.retry_delay_seconds,
            source: RuntimeOptionSource::CliDefaults,
        }
    };

    let compression_from_attr = document
        .sections
        .iter()
        .filter_map(|s| s.get_compression())
        .next();
    let compression = if let Some(v) = compression_from_attr {
        RuntimeOptionWithSource {
            value: v,
            source: RuntimeOptionSource::SectionAttribute,
        }
    } else if options.contains_key("compression") {
        RuntimeOptionWithSource {
            value: match parse_compression_option(&options) {
                CompressionMode::Gzip => "gzip".to_string(),
                CompressionMode::None => "none".to_string(),
            },
            source: RuntimeOptionSource::FileOptions,
        }
    } else {
        RuntimeOptionWithSource {
            value: match CompressionMode::from_env() {
                CompressionMode::Gzip => "gzip".to_string(),
                CompressionMode::None => "none".to_string(),
            },
            source: RuntimeOptionSource::CliDefaults,
        }
    };

    Ok(EffectiveRuntimeOptions {
        timeout_seconds,
        retry,
        retry_delay_seconds,
        no_retry,
        compression,
    })
}

/// Resolve a TLS file path relative to document or CWD.
pub fn resolve_tls_path(value: &str, from_env: bool, document_path: &Path) -> String {
    let path = Path::new(value);
    if path.is_absolute() {
        return path.to_string_lossy().to_string();
    }

    if from_env {
        if runtime::supports(runtime::Capability::IsolatedFsIo)
            && let Ok(cwd) = std::env::current_dir()
        {
            return cwd.join(path).to_string_lossy().to_string();
        }
        return path.to_string_lossy().to_string();
    }

    FileUtils::resolve_relative_path(document_path, value)
        .to_string_lossy()
        .to_string()
}

/// Build TLS config using TLS section and env defaults, matching run behavior.
pub fn build_tls_config(document: &GctfDocument, document_path: &Path) -> Option<TlsConfig> {
    let tls_defaults = tls_env_defaults();
    let tls_section = document.get_tls_config();

    let pick_tls_value = |keys: &[&str]| -> Option<(String, bool)> {
        if let Some(section_map) = tls_section.as_ref() {
            for key in keys {
                if let Some(value) = section_map.get(*key) {
                    return Some((value.clone(), false));
                }
            }
        }

        for key in keys {
            if let Some(value) = tls_defaults.get(*key) {
                return Some((value.clone(), true));
            }
        }

        None
    };

    let ca_cert_path = pick_tls_value(&["ca_cert", "ca_file"])
        .map(|(v, from_env)| resolve_tls_path(&v, from_env, document_path));
    let client_cert_path = pick_tls_value(&["client_cert", "cert", "cert_file"])
        .map(|(v, from_env)| resolve_tls_path(&v, from_env, document_path));
    let client_key_path = pick_tls_value(&["client_key", "key", "key_file"])
        .map(|(v, from_env)| resolve_tls_path(&v, from_env, document_path));
    let server_name = pick_tls_value(&["server_name"]).map(|(v, _)| v);
    let insecure_skip_verify = tls_section
        .as_ref()
        .and_then(|m| m.get("insecure"))
        .is_some_and(|s| parse_bool_flag(s));

    if ca_cert_path.is_some()
        || client_cert_path.is_some()
        || client_key_path.is_some()
        || server_name.is_some()
        || insecure_skip_verify
    {
        Some(TlsConfig {
            ca_cert_path,
            client_cert_path,
            client_key_path,
            server_name,
            insecure_skip_verify,
        })
    } else {
        None
    }
}

/// Build proto config with document-relative path resolution, matching run behavior.
pub fn build_proto_config(document: &GctfDocument, document_path: &Path) -> Option<ProtoConfig> {
    document.get_proto_config().map(|proto_map| {
        let files = proto_map
            .get("files")
            .map(|s| {
                s.split(',')
                    .map(|p| {
                        FileUtils::resolve_relative_path(document_path, p.trim())
                            .to_string_lossy()
                            .to_string()
                    })
                    .collect()
            })
            .unwrap_or_default();

        let import_paths = proto_map
            .get("import_paths")
            .map(|s| {
                s.split(',')
                    .map(|p| {
                        FileUtils::resolve_relative_path(document_path, p.trim())
                            .to_string_lossy()
                            .to_string()
                    })
                    .collect()
            })
            .unwrap_or_default();

        let descriptor = proto_map.get("descriptor").map(|p| {
            FileUtils::resolve_relative_path(document_path, p)
                .to_string_lossy()
                .to_string()
        });

        ProtoConfig {
            files,
            import_paths,
            descriptor,
        }
    })
}

/// Build full service name from package and service.
pub fn full_service_name(package: &str, service: &str) -> String {
    if package.is_empty() {
        service.to_string()
    } else {
        format!("{}.{}", package, service)
    }
}

/// Format JSON value for display.
pub fn format_json_pretty(value: &Value) -> String {
    serde_json::to_string_pretty(value).unwrap_or_else(|_| value.to_string())
}

/// Interpolate variables in a string template.
/// Replaces `{{var}}` patterns with values from the variables map.
/// Returns `None` if no substitutions were made.
pub fn interpolate_variables(template: &str, variables: &HashMap<String, Value>) -> Option<String> {
    let mut out = String::with_capacity(template.len());
    let mut cursor = 0usize;
    let mut changed = false;

    while let Some(open_rel) = template[cursor..].find("{{") {
        let open = cursor + open_rel;
        out.push_str(&template[cursor..open]);

        let after_open = open + 2;
        if let Some(close_rel) = template[after_open..].find("}}") {
            let close = after_open + close_rel;
            let var_name = template[after_open..close].trim();

            if let Some(var_value) = variables.get(var_name) {
                if let Value::String(s) = var_value {
                    out.push_str(s);
                } else {
                    out.push_str(&var_value.to_string());
                }
                changed = true;
            } else {
                out.push_str(&template[open..close + 2]);
            }
            cursor = close + 2;
        } else {
            out.push_str(&template[cursor..]);
            break;
        }
    }

    if cursor < template.len() {
        out.push_str(&template[cursor..]);
    }

    if changed { Some(out) } else { None }
}

/// Recursively substitute variables in a JSON value.
/// If a string is exactly `{{var}}`, it's replaced with the actual Value type.
/// Otherwise, string interpolation is performed.
pub fn substitute_variables(value: &mut Value, variables: &HashMap<String, Value>) {
    match value {
        Value::String(s) => {
            let original = s.clone();
            if s.starts_with("{{") && s.ends_with("}}") {
                let inner = s[2..s.len() - 2].trim();
                if !inner.contains("{{")
                    && let Some(val) = variables.get(inner)
                {
                    *value = val.clone();
                    return;
                }
            }
            if let Some(replaced) = interpolate_variables(s, variables) {
                *s = replaced;
            }
            // If nothing changed, restore original (type-preserving)
            if *s == original {
                // No change
            }
        }
        Value::Array(items) => {
            for item in items {
                substitute_variables(item, variables);
            }
        }
        Value::Object(map) => {
            for (_, val) in map.iter_mut() {
                substitute_variables(val, variables);
            }
        }
        _ => {}
    }
}

/// Convert tonic metadata map to HashMap.
pub fn metadata_map_to_hashmap(metadata: &tonic::metadata::MetadataMap) -> HashMap<String, String> {
    let mut out = HashMap::new();
    for kv in metadata.iter() {
        if let tonic::metadata::KeyAndValueRef::Ascii(key, value) = kv {
            if let Ok(v) = value.to_str() {
                out.insert(key.to_string(), v.to_string());
            }
        } else if let tonic::metadata::KeyAndValueRef::Binary(key, value) = kv {
            out.insert(key.to_string(), format!("{:?}", value));
        }
    }
    out
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::parser::ast::{GctfAttribute, GctfDocument, Section, SectionContent, SectionType};

    fn make_doc(sections: Vec<Section>) -> GctfDocument {
        GctfDocument {
            file_path: "test.gctf".to_string(),
            sections,
            metadata: Default::default(),
            next_document: None,
        }
    }

    fn make_section(section_type: SectionType, content: SectionContent) -> Section {
        Section {
            section_type,
            content,
            inline_options: Default::default(),
            raw_content: String::new(),
            start_line: 0,
            end_line: 0,
            attributes: Vec::new(),
        }
    }

    fn make_section_with_attrs(
        section_type: SectionType,
        content: SectionContent,
        attrs: Vec<GctfAttribute>,
    ) -> Section {
        let mut s = make_section(section_type, content);
        s.attributes = attrs;
        s
    }

    fn cli_defaults() -> CliRuntimeDefaults {
        CliRuntimeDefaults {
            timeout_seconds: 30,
            retry: 0,
            retry_delay_seconds: 1.0,
            no_retry: false,
        }
    }

    fn kv(map: &[(&str, &str)]) -> SectionContent {
        SectionContent::KeyValues(
            map.iter()
                .map(|(k, v)| (k.to_string(), v.to_string()))
                .collect(),
        )
    }

    #[test]
    fn test_resolve_defaults_only() {
        let doc = make_doc(vec![
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
            make_section(SectionType::Request, SectionContent::Empty),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.timeout_seconds.value, 30);
        assert_eq!(
            result.timeout_seconds.source,
            RuntimeOptionSource::CliDefaults
        );
        assert_eq!(result.retry.value, 0);
        assert_eq!(result.retry.source, RuntimeOptionSource::CliDefaults);
        assert_eq!(result.retry_delay_seconds.value, 1.0);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::CliDefaults
        );
        assert!(!result.no_retry.value);
        assert_eq!(result.no_retry.source, RuntimeOptionSource::CliDefaults);
    }

    #[test]
    fn test_resolve_file_options_override_defaults() {
        let doc = make_doc(vec![
            make_section(
                SectionType::Options,
                kv(&[
                    ("timeout", "10"),
                    ("retry", "3"),
                    ("retry_delay", "0.5"),
                    ("no_retry", "true"),
                ]),
            ),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
            make_section(SectionType::Request, SectionContent::Empty),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.timeout_seconds.value, 10);
        assert_eq!(
            result.timeout_seconds.source,
            RuntimeOptionSource::FileOptions
        );
        assert_eq!(result.retry.value, 3);
        assert_eq!(result.retry.source, RuntimeOptionSource::FileOptions);
        assert_eq!(result.retry_delay_seconds.value, 0.5);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::FileOptions
        );
        assert!(result.no_retry.value);
        assert_eq!(result.no_retry.source, RuntimeOptionSource::FileOptions);
    }

    #[test]
    fn test_resolve_section_attribute_overrides_file_options() {
        let doc = make_doc(vec![
            make_section(
                SectionType::Options,
                kv(&[("timeout", "10"), ("retry", "3"), ("retry_delay", "0.5")]),
            ),
            make_section_with_attrs(
                SectionType::Request,
                SectionContent::Empty,
                vec![
                    GctfAttribute::new("timeout", "5"),
                    GctfAttribute::new("retry", "7"),
                    GctfAttribute::new("retry_delay", "2.0"),
                    GctfAttribute::flag("no_retry"),
                ],
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.timeout_seconds.value, 5);
        assert_eq!(
            result.timeout_seconds.source,
            RuntimeOptionSource::SectionAttribute
        );
        assert_eq!(result.retry.value, 7);
        assert_eq!(result.retry.source, RuntimeOptionSource::SectionAttribute);
        assert_eq!(result.retry_delay_seconds.value, 2.0);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::SectionAttribute
        );
        assert!(result.no_retry.value);
        assert_eq!(
            result.no_retry.source,
            RuntimeOptionSource::SectionAttribute
        );
    }

    #[test]
    fn test_resolve_attribute_overrides_options_only_for_present_fields() {
        let doc = make_doc(vec![
            make_section(
                SectionType::Options,
                kv(&[("timeout", "10"), ("retry", "3")]),
            ),
            make_section_with_attrs(
                SectionType::Request,
                SectionContent::Empty,
                vec![GctfAttribute::new("retry", "5")],
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.timeout_seconds.value, 10);
        assert_eq!(
            result.timeout_seconds.source,
            RuntimeOptionSource::FileOptions
        );
        assert_eq!(result.retry.value, 5);
        assert_eq!(result.retry.source, RuntimeOptionSource::SectionAttribute);
        assert_eq!(result.retry_delay_seconds.value, 1.0);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::CliDefaults
        );
    }

    #[test]
    fn test_resolve_kebab_alias_in_options() {
        let doc = make_doc(vec![
            make_section(
                SectionType::Options,
                kv(&[("retry-delay", "0.2"), ("no-retry", "true")]),
            ),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
            make_section(SectionType::Request, SectionContent::Empty),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.retry_delay_seconds.value, 0.2);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::FileOptions
        );
        assert!(result.no_retry.value);
        assert_eq!(result.no_retry.source, RuntimeOptionSource::FileOptions);
    }

    #[test]
    fn test_resolve_kebab_alias_in_attributes() {
        let doc = make_doc(vec![make_section_with_attrs(
            SectionType::Request,
            SectionContent::Empty,
            vec![
                GctfAttribute::new("retry-delay", "0.3"),
                GctfAttribute::new("no-retry", "true"),
            ],
        )]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.retry_delay_seconds.value, 0.3);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::SectionAttribute
        );
        assert!(result.no_retry.value);
        assert_eq!(
            result.no_retry.source,
            RuntimeOptionSource::SectionAttribute
        );
    }

    #[test]
    fn test_resolve_error_invalid_timeout() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("timeout", "abc")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults());
        assert!(result.is_err());
        assert!(result.unwrap_err().contains("timeout"));
    }

    #[test]
    fn test_resolve_error_zero_timeout() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("timeout", "0")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults());
        assert!(result.is_err());
    }

    #[test]
    fn test_resolve_error_invalid_retry() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("retry", "abc")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults());
        assert!(result.is_err());
        assert!(result.unwrap_err().contains("retry"));
    }

    #[test]
    fn test_resolve_error_invalid_retry_delay() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("retry_delay", "abc")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults());
        assert!(result.is_err());
        assert!(result.unwrap_err().contains("retry_delay"));
    }

    #[test]
    fn test_resolve_error_negative_retry_delay() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("retry_delay", "-1.0")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults());
        assert!(result.is_err());
    }

    #[test]
    fn test_resolve_error_invalid_no_retry() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("no_retry", "maybe")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults());
        assert!(result.is_err());
        assert!(result.unwrap_err().contains("no_retry"));
    }

    #[test]
    fn test_resolve_zero_timeout_attribute_ignored() {
        let doc = make_doc(vec![make_section_with_attrs(
            SectionType::Request,
            SectionContent::Empty,
            vec![GctfAttribute::new("timeout", "0")],
        )]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.timeout_seconds.value, 30);
        assert_eq!(
            result.timeout_seconds.source,
            RuntimeOptionSource::CliDefaults
        );
    }

    #[test]
    fn test_resolve_negative_retry_delay_attribute_ignored() {
        let doc = make_doc(vec![make_section_with_attrs(
            SectionType::Request,
            SectionContent::Empty,
            vec![GctfAttribute::new("retry_delay", "-0.5")],
        )]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.retry_delay_seconds.value, 1.0);
        assert_eq!(
            result.retry_delay_seconds.source,
            RuntimeOptionSource::CliDefaults
        );
    }

    #[test]
    fn test_resolve_compression_from_options() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("compression", "gzip")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.compression.value, "gzip");
        assert_eq!(result.compression.source, RuntimeOptionSource::FileOptions);
    }

    #[test]
    fn test_resolve_compression_defaults() {
        let doc = make_doc(vec![make_section(
            SectionType::Endpoint,
            SectionContent::Single("svc/Method".into()),
        )]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.compression.source, RuntimeOptionSource::CliDefaults);
    }

    #[test]
    fn test_resolve_json_serialization() {
        let doc = make_doc(vec![
            make_section(
                SectionType::Options,
                kv(&[("timeout", "10"), ("retry", "3")]),
            ),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        let json = serde_json::to_value(&result).unwrap();
        let obj = json.as_object().unwrap();
        assert!(obj.contains_key("timeout_seconds"));
        assert!(obj.contains_key("retry"));
        assert!(obj.contains_key("retry_delay_seconds"));
        assert!(obj.contains_key("no_retry"));
        assert!(obj.contains_key("compression"));

        let ts = &obj["timeout_seconds"];
        assert_eq!(ts["value"], 10);
        assert_eq!(ts["source"], "file_options");
    }

    #[test]
    fn test_runtime_option_source_serde_roundtrip() {
        let sources = vec![
            RuntimeOptionSource::SectionAttribute,
            RuntimeOptionSource::FileOptions,
            RuntimeOptionSource::CliDefaults,
        ];
        for source in sources {
            let json = serde_json::to_string(&source).unwrap();
            let back: RuntimeOptionSource = serde_json::from_str(&json).unwrap();
            assert_eq!(source, back);
        }
    }

    #[test]
    fn test_effective_runtime_options_clone_roundtrip() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("timeout", "10")])),
            make_section(
                SectionType::Endpoint,
                SectionContent::Single("svc/Method".into()),
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();
        let cloned = result.clone();
        assert_eq!(cloned.timeout_seconds.value, 10);
        assert_eq!(
            cloned.timeout_seconds.source,
            RuntimeOptionSource::FileOptions
        );
    }

    #[test]
    fn test_resolve_compression_from_section_attribute() {
        let doc = make_doc(vec![make_section_with_attrs(
            SectionType::Request,
            SectionContent::Empty,
            vec![GctfAttribute::new("compression", "gzip")],
        )]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.compression.value, "gzip");
        assert_eq!(
            result.compression.source,
            RuntimeOptionSource::SectionAttribute
        );
    }

    #[test]
    fn test_resolve_compression_attribute_overrides_file_options() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("compression", "none")])),
            make_section_with_attrs(
                SectionType::Request,
                SectionContent::Empty,
                vec![GctfAttribute::new("compression", "gzip")],
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.compression.value, "gzip");
        assert_eq!(
            result.compression.source,
            RuntimeOptionSource::SectionAttribute
        );
    }

    #[test]
    fn test_resolve_compression_attribute_none_value() {
        let doc = make_doc(vec![make_section_with_attrs(
            SectionType::Request,
            SectionContent::Empty,
            vec![GctfAttribute::new("compression", "none")],
        )]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.compression.value, "none");
        assert_eq!(
            result.compression.source,
            RuntimeOptionSource::SectionAttribute
        );
    }

    #[test]
    fn test_resolve_compression_invalid_attribute_value_falls_back() {
        let doc = make_doc(vec![
            make_section(SectionType::Options, kv(&[("compression", "gzip")])),
            make_section_with_attrs(
                SectionType::Request,
                SectionContent::Empty,
                vec![GctfAttribute::new("compression", "invalid")],
            ),
        ]);
        let result = resolve_effective_runtime_options(&doc, cli_defaults()).unwrap();

        assert_eq!(result.compression.value, "gzip");
        assert_eq!(result.compression.source, RuntimeOptionSource::FileOptions);
    }
}