allure-rust-commons 1.3.0

//! Runtime and Cargo metadata configuration helpers.

use std::{
    collections::HashMap,
    env, fs,
    path::{Path, PathBuf},
    sync::{Mutex, OnceLock},
};

use crate::{
    writer::{ALLURE_RESULTS_DIR_ENV, DEFAULT_RESULTS_DIR},
    AllureFacade,
};

static GLOBAL_CONFIG: OnceLock<GlobalAllureConfig> = OnceLock::new();
static CONFIGS: OnceLock<Mutex<HashMap<String, AllureConfig>>> = OnceLock::new();

/// Process-wide Allure configuration loaded from environment variables.
#[derive(Clone, Debug)]
pub struct GlobalAllureConfig {
    results_dir: PathBuf,
    global_labels: Vec<(String, String)>,
    host_name: Option<String>,
    thread_name_override: Option<String>,
    log_asserts_override: Option<bool>,
}

impl GlobalAllureConfig {
    /// Returns the configured results directory.
    pub fn results_dir(&self) -> &Path {
        &self.results_dir
    }

    /// Returns labels configured through environment variables.
    pub fn global_labels(&self) -> &[(String, String)] {
        &self.global_labels
    }

    /// Returns the configured or detected host name.
    pub fn host_name(&self) -> Option<&str> {
        self.host_name.as_deref()
    }

    /// Returns the configured thread name override.
    pub fn thread_name_override(&self) -> Option<&str> {
        self.thread_name_override.as_deref()
    }

    /// Returns the environment override for assertion logging.
    pub fn log_asserts_override(&self) -> Option<bool> {
        self.log_asserts_override
    }

    fn from_environment() -> Self {
        Self {
            results_dir: env::var_os(ALLURE_RESULTS_DIR_ENV)
                .map(PathBuf::from)
                .unwrap_or_else(|| PathBuf::from(DEFAULT_RESULTS_DIR)),
            global_labels: global_labels_from_env_vars(env::vars()),
            host_name: env_string("ALLURE_HOST_NAME").or_else(resolve_host_name),
            thread_name_override: env_string("ALLURE_THREAD_NAME"),
            log_asserts_override: env::var("ALLURE_LOG_ASSERTS")
                .ok()
                .or_else(|| env::var("allure.log_asserts").ok())
                .and_then(|value| parse_bool(&value)),
        }
    }
}

/// Returns the lazily initialized process-wide Allure configuration.
pub fn global_config() -> &'static GlobalAllureConfig {
    GLOBAL_CONFIG.get_or_init(GlobalAllureConfig::from_environment)
}

/// Adds common runtime labels to an active test.
pub fn apply_common_runtime_labels(allure: &AllureFacade) {
    allure.label("language", "rust");

    if let Some(host) = global_config().host_name() {
        allure.label("host", host);
    }

    allure.label("thread", detect_thread_name());
}

/// Applies labels configured in Cargo package metadata for a test source location.
pub fn apply_config_labels(
    allure: &AllureFacade,
    manifest_dir: &str,
    module_path: &str,
    title_path: &[String],
) {
    let config = config_for(manifest_dir);
    let title_path = title_path.join("/");

    for (name, value) in &config.labels {
        allure.label(name, value);
    }

    for module in &config.modules {
        if module.matches(module_path, &title_path) {
            for (name, value) in &module.labels {
                allure.label(name, value);
            }
        }
    }
}

/// Returns whether assertion logging is enabled for a Cargo package.
///
/// Assertion logging is enabled by default. Set `ALLURE_LOG_ASSERTS=false` or
/// `[package.metadata.allure] log_asserts = false` to disable it.
pub fn log_asserts_enabled(manifest_dir: &str) -> bool {
    global_config()
        .log_asserts_override()
        .unwrap_or_else(|| config_for(manifest_dir).log_asserts)
}

fn env_string(name: &str) -> Option<String> {
    env::var(name)
        .ok()
        .map(|value| value.trim().to_string())
        .filter(|value| !value.is_empty())
}

fn resolve_host_name() -> Option<String> {
    #[cfg(unix)]
    {
        use std::os::raw::{c_char, c_int};

        unsafe extern "C" {
            fn gethostname(name: *mut c_char, len: usize) -> c_int;
        }

        let mut buf = [0_u8; 256];
        // SAFETY: `buf` is a valid writable buffer and its length is correctly provided.
        let result = unsafe { gethostname(buf.as_mut_ptr().cast(), buf.len()) };
        if result == 0 {
            let len = buf.iter().position(|b| *b == 0).unwrap_or(buf.len());
            let host_name = String::from_utf8_lossy(&buf[..len]).trim().to_string();
            if !host_name.is_empty() {
                return Some(host_name);
            }
        }
    }

    env::var("HOSTNAME")
        .ok()
        .or_else(|| env::var("COMPUTERNAME").ok())
        .map(|value| value.trim().to_string())
        .filter(|value| !value.is_empty())
}

fn detect_thread_name() -> String {
    if let Some(thread_name) = global_config().thread_name_override() {
        return thread_name.to_string();
    }

    std::thread::current()
        .name()
        .map(ToString::to_string)
        .unwrap_or_else(|| format!("{:?}", std::thread::current().id()))
}

/// Returns labels configured through environment variables.
pub fn global_labels_from_environment() -> Vec<(String, String)> {
    global_config().global_labels().to_vec()
}

fn global_labels_from_env_vars<I>(vars: I) -> Vec<(String, String)>
where
    I: IntoIterator<Item = (String, String)>,
{
    let mut labels = Vec::new();

    for (key, value) in vars {
        if let Some(name) = key.strip_prefix("ALLURE_LABEL_") {
            if !name.is_empty() && !value.is_empty() {
                labels.push((name.to_string(), value.clone()));
            }
        }

        if let Some(name) = key.strip_prefix("allure.label.") {
            if !name.is_empty() && !value.is_empty() {
                labels.push((name.to_string(), value));
            }
        }
    }

    labels
}

fn config_for(manifest_dir: &str) -> AllureConfig {
    let manifest_dir = normalize_path(manifest_dir);
    let cache = CONFIGS.get_or_init(|| Mutex::new(HashMap::new()));

    if let Some(config) = cache
        .lock()
        .expect("poisoned allure config cache")
        .get(&manifest_dir)
        .cloned()
    {
        return config;
    }

    let config = read_config(&manifest_dir);
    cache
        .lock()
        .expect("poisoned allure config cache")
        .entry(manifest_dir)
        .or_insert_with(|| config.clone())
        .clone()
}

fn read_config(manifest_dir: &str) -> AllureConfig {
    let manifest = Path::new(manifest_dir).join("Cargo.toml");
    fs::read_to_string(manifest)
        .map(|source| parse_config(&source))
        .unwrap_or_default()
}

#[derive(Clone, Debug)]
struct AllureConfig {
    log_asserts: bool,
    labels: Vec<(String, String)>,
    modules: Vec<ModuleConfig>,
}

impl Default for AllureConfig {
    fn default() -> Self {
        Self {
            log_asserts: true,
            labels: Vec::new(),
            modules: Vec::new(),
        }
    }
}

#[derive(Clone, Debug, Default)]
struct ModuleConfig {
    path: Option<String>,
    module: Option<String>,
    title_path: Option<Vec<String>>,
    labels: Vec<(String, String)>,
}

impl ModuleConfig {
    fn matches(&self, module_path: &str, title_path: &str) -> bool {
        let path_matches = self.path.as_ref().is_some_and(|path| {
            if path.ends_with('/') {
                title_path.starts_with(path)
            } else {
                title_path == path
            }
        });

        let title_path_matches = self
            .title_path
            .as_ref()
            .is_some_and(|expected| expected.join("/") == title_path);

        let module_matches = self.module.as_ref().is_some_and(|module| {
            module_path == module || module_path.starts_with(&format!("{module}::"))
        });

        path_matches || title_path_matches || module_matches
    }
}

#[derive(Clone, Copy)]
enum ConfigSection {
    Ignore,
    Root,
    Labels,
    Module(usize),
    ModuleLabels(usize),
}

fn parse_config(source: &str) -> AllureConfig {
    let mut config = AllureConfig::default();
    let mut section = ConfigSection::Ignore;

    for raw_line in source.lines() {
        let line = strip_comment(raw_line);
        let line = line.trim();
        if line.is_empty() {
            continue;
        }

        if let Some(header) = table_header(line) {
            section = match header.as_str() {
                "[package.metadata.allure]" => ConfigSection::Root,
                "[package.metadata.allure.labels]" => ConfigSection::Labels,
                "[[package.metadata.allure.modules]]" => {
                    config.modules.push(ModuleConfig::default());
                    ConfigSection::Module(config.modules.len() - 1)
                }
                "[package.metadata.allure.modules.labels]" => {
                    if config.modules.is_empty() {
                        ConfigSection::Ignore
                    } else {
                        ConfigSection::ModuleLabels(config.modules.len() - 1)
                    }
                }
                _ => ConfigSection::Ignore,
            };
            continue;
        }

        let Some((key, value)) = split_key_value(line) else {
            continue;
        };
        let key = normalize_key(key);

        match section {
            ConfigSection::Root if key == "log_asserts" => {
                if let Some(value) = parse_bool(value) {
                    config.log_asserts = value;
                }
            }
            ConfigSection::Root if key == "labels" => {
                config.labels.extend(parse_inline_labels(value));
            }
            ConfigSection::Labels => {
                config.labels.extend(parse_label_values(key, value));
            }
            ConfigSection::Module(index) => {
                let Some(module) = config.modules.get_mut(index) else {
                    continue;
                };
                match key.as_str() {
                    "path" => module.path = parse_string(value).map(|value| normalize_path(&value)),
                    "module" => module.module = parse_string(value),
                    "title_path" => module.title_path = parse_string_array(value),
                    "labels" => module.labels.extend(parse_inline_labels(value)),
                    _ => {}
                }
            }
            ConfigSection::ModuleLabels(index) => {
                if let Some(module) = config.modules.get_mut(index) {
                    module.labels.extend(parse_label_values(key, value));
                }
            }
            ConfigSection::Ignore | ConfigSection::Root => {}
        }
    }

    config
}

fn parse_bool(value: &str) -> Option<bool> {
    let normalized = value
        .trim()
        .trim_matches('"')
        .trim_matches('\'')
        .to_ascii_lowercase();
    match normalized.as_str() {
        "true" | "1" | "yes" | "on" => Some(true),
        "false" | "0" | "no" | "off" => Some(false),
        _ => None,
    }
}

fn table_header(line: &str) -> Option<String> {
    let line = line.trim();
    if line.starts_with("[[") && line.ends_with("]]") {
        return Some(line.to_string());
    }
    if line.starts_with('[') && line.ends_with(']') {
        return Some(line.to_string());
    }
    None
}

fn strip_comment(line: &str) -> &str {
    let mut quote = None;
    let mut escaped = false;

    for (idx, ch) in line.char_indices() {
        if let Some(active_quote) = quote {
            if escaped {
                escaped = false;
                continue;
            }
            if active_quote == '"' && ch == '\\' {
                escaped = true;
                continue;
            }
            if ch == active_quote {
                quote = None;
            }
            continue;
        }

        match ch {
            '"' | '\'' => quote = Some(ch),
            '#' => return &line[..idx],
            _ => {}
        }
    }

    line
}

fn split_key_value(input: &str) -> Option<(&str, &str)> {
    let mut quote = None;
    let mut escaped = false;

    for (idx, ch) in input.char_indices() {
        if let Some(active_quote) = quote {
            if escaped {
                escaped = false;
                continue;
            }
            if active_quote == '"' && ch == '\\' {
                escaped = true;
                continue;
            }
            if ch == active_quote {
                quote = None;
            }
            continue;
        }

        match ch {
            '"' | '\'' => quote = Some(ch),
            '=' => return Some((&input[..idx], &input[idx + 1..])),
            _ => {}
        }
    }

    None
}

fn parse_inline_labels(value: &str) -> Vec<(String, String)> {
    let value = value.trim();
    let Some(value) = value
        .strip_prefix('{')
        .and_then(|value| value.strip_suffix('}'))
    else {
        return Vec::new();
    };

    split_top_level(value, ',')
        .into_iter()
        .flat_map(|entry| {
            let Some((key, value)) = split_key_value(entry) else {
                return Vec::new();
            };
            parse_label_values(normalize_key(key), value)
        })
        .collect()
}

fn parse_label_values(key: String, value: &str) -> Vec<(String, String)> {
    if let Some(value) = parse_string(value) {
        return vec![(key, value)];
    }

    parse_string_array(value)
        .unwrap_or_default()
        .into_iter()
        .map(|value| (key.clone(), value))
        .collect()
}

fn parse_string_array(value: &str) -> Option<Vec<String>> {
    let value = value.trim();
    let value = value.strip_prefix('[')?.strip_suffix(']')?;
    let values = split_top_level(value, ',')
        .into_iter()
        .filter_map(parse_string)
        .collect::<Vec<_>>();

    if values.is_empty() {
        None
    } else {
        Some(values)
    }
}

fn split_top_level(input: &str, delimiter: char) -> Vec<&str> {
    let mut parts = Vec::new();
    let mut start = 0;
    let mut quote = None;
    let mut escaped = false;
    let mut depth = 0_u32;

    for (idx, ch) in input.char_indices() {
        if let Some(active_quote) = quote {
            if escaped {
                escaped = false;
                continue;
            }
            if active_quote == '"' && ch == '\\' {
                escaped = true;
                continue;
            }
            if ch == active_quote {
                quote = None;
            }
            continue;
        }

        match ch {
            '"' | '\'' => quote = Some(ch),
            '[' | '{' | '(' => depth = depth.saturating_add(1),
            ']' | '}' | ')' => depth = depth.saturating_sub(1),
            _ if ch == delimiter && depth == 0 => {
                parts.push(input[start..idx].trim());
                start = idx + ch.len_utf8();
            }
            _ => {}
        }
    }

    parts.push(input[start..].trim());
    parts
}

fn parse_string(value: &str) -> Option<String> {
    let value = value.trim();
    if value.starts_with('"') && value.ends_with('"') && value.len() >= 2 {
        return Some(unescape_basic_string(&value[1..value.len() - 1]));
    }
    if value.starts_with('\'') && value.ends_with('\'') && value.len() >= 2 {
        return Some(value[1..value.len() - 1].to_string());
    }
    None
}

fn unescape_basic_string(value: &str) -> String {
    let mut result = String::new();
    let mut chars = value.chars();

    while let Some(ch) = chars.next() {
        if ch != '\\' {
            result.push(ch);
            continue;
        }

        match chars.next() {
            Some('n') => result.push('\n'),
            Some('r') => result.push('\r'),
            Some('t') => result.push('\t'),
            Some('"') => result.push('"'),
            Some('\\') => result.push('\\'),
            Some(other) => {
                result.push('\\');
                result.push(other);
            }
            None => result.push('\\'),
        }
    }

    result
}

fn normalize_key(key: &str) -> String {
    let key = key.trim();
    parse_string(key).unwrap_or_else(|| key.to_string())
}

fn normalize_path(path: &str) -> String {
    path.replace('\\', "/")
}

/// Builds a title path from a source file and Cargo manifest directory.
pub fn title_path(file: &str, manifest_dir: &str) -> Vec<String> {
    relative_file_path(file, manifest_dir)
        .split('/')
        .filter(|part| !part.is_empty())
        .map(ToString::to_string)
        .collect()
}

/// Returns a source file path relative to a Cargo manifest directory when possible.
pub fn relative_file_path(file: &str, manifest_dir: &str) -> String {
    let file = file.replace('\\', "/");
    let manifest_dir = manifest_dir.replace('\\', "/");
    if let Some(relative) = file
        .strip_prefix(&manifest_dir)
        .map(|path| path.trim_start_matches('/'))
    {
        return relative.to_string();
    }

    let Some(package_name) = manifest_dir.rsplit('/').next() else {
        return file;
    };
    let package_segment = format!("/{package_name}/");
    if let Some((_, relative)) = file.split_once(&package_segment) {
        return relative.to_string();
    }
    let package_prefix = format!("{package_name}/");
    if let Some(relative) = file.strip_prefix(&package_prefix) {
        return relative.to_string();
    }

    file
}

/// Applies synthetic suite labels derived from a Rust full test name.
pub fn apply_synthetic_suite_labels(allure: &AllureFacade, full_name: Option<&str>) {
    let Some(full_name) = full_name else {
        return;
    };

    let mut segments = full_name.split("::").collect::<Vec<_>>();
    if segments.len() < 2 {
        return;
    }

    segments.pop();
    match segments.as_slice() {
        [] => {}
        [suite] => allure.suite(*suite),
        [parent_suite, suite] => {
            allure.parent_suite(*parent_suite);
            allure.suite(*suite);
        }
        [parent_suite, suite, rest @ ..] => {
            allure.parent_suite(*parent_suite);
            allure.suite(*suite);
            allure.sub_suite(rest.join("::"));
        }
    }
}

#[cfg(test)]
mod tests {
    use crate::test_utils::allure_test;

    use super::{global_labels_from_env_vars, parse_config};

    #[test]
    fn enables_assertion_logging_by_default() {
        allure_test(
            module_path!(),
            "enables_assertion_logging_by_default",
            "Verifies assertion logging is enabled when no package metadata override is set.",
            || {
                let config = parse_config("");

                assert!(config.log_asserts);
            },
        );
    }

    #[test]
    fn package_metadata_can_disable_assertion_logging() {
        allure_test(
            module_path!(),
            "package_metadata_can_disable_assertion_logging",
            "Verifies package metadata can disable assertion step logging for the current manifest.",
            || {
                let config = parse_config(
                    r#"
[package.metadata.allure]
log_asserts = false
"#,
                );

                assert!(!config.log_asserts);
            },
        );
    }

    #[test]
    fn parses_package_metadata_allure_labels() {
        allure_test(
            module_path!(),
            "parses_package_metadata_allure_labels",
            "Verifies package metadata labels and module-specific labels are parsed for matching source paths.",
            || {
                let config = parse_config(
                    r#"
[package.metadata.allure]
log_asserts = true

[package.metadata.allure.labels]
module = "checkout"
layer = "e2e"
tag = ["smoke", "regression"]

[[package.metadata.allure.modules]]
path = "tests/payments.rs"
labels = { component = "payments", owner = "qa", tag = ["payments-smoke", "payments-regression"] }

[[package.metadata.allure.modules]]
module = "payments::cards"
[package.metadata.allure.modules.labels]
feature = "cards"
story = ["visa", "mastercard"]
"#,
                );

                assert_eq!(
                    config.labels,
                    vec![
                        ("module".to_string(), "checkout".to_string()),
                        ("layer".to_string(), "e2e".to_string()),
                        ("tag".to_string(), "smoke".to_string()),
                        ("tag".to_string(), "regression".to_string()),
                    ]
                );
                assert!(config.log_asserts);
                assert!(config.modules[0].matches("payments", "tests/payments.rs"));
                assert!(config.modules[1].matches("payments::cards::visa", "src/cards.rs"));
                assert_eq!(
                    config.modules[0].labels,
                    vec![
                        ("component".to_string(), "payments".to_string()),
                        ("owner".to_string(), "qa".to_string()),
                        ("tag".to_string(), "payments-smoke".to_string()),
                        ("tag".to_string(), "payments-regression".to_string()),
                    ]
                );
                assert_eq!(
                    config.modules[1].labels,
                    vec![
                        ("feature".to_string(), "cards".to_string()),
                        ("story".to_string(), "visa".to_string()),
                        ("story".to_string(), "mastercard".to_string()),
                    ]
                );
            },
        );
    }

    #[test]
    fn collects_global_labels_from_environment_variables() {
        allure_test(
            module_path!(),
            "collects_global_labels_from_environment_variables",
            "Verifies ALLURE_LABEL environment variables become runtime labels.",
            || {
                let labels = global_labels_from_env_vars([
                    ("ALLURE_LABEL_component".to_string(), "checkout".to_string()),
                    ("ALLURE_LABEL_".to_string(), "ignored".to_string()),
                    ("ALLURE_LABEL_empty".to_string(), String::new()),
                    ("allure.label.layer".to_string(), "e2e".to_string()),
                    ("OTHER".to_string(), "ignored".to_string()),
                ]);

                assert_eq!(
                    labels,
                    vec![
                        ("component".to_string(), "checkout".to_string()),
                        ("layer".to_string(), "e2e".to_string()),
                    ]
                );
            },
        );
    }
}