assay-core 3.38.0

use crate::on_error::ErrorPolicy;

use super::types::{
    EvalConfig, Expected, SequenceRule, Settings, TestCase, TestStatus, ThresholdingConfig,
};

/// Tolerance used by the semantic-similarity evaluator at its pass boundary.
pub const SEMANTIC_SIMILARITY_EPSILON: f64 = 1e-6;

pub(crate) fn is_default_otel(o: &crate::config::otel::OtelConfig) -> bool {
    o == &crate::config::otel::OtelConfig::default()
}

pub(crate) fn is_default_thresholds(t: &crate::thresholds::ThresholdConfig) -> bool {
    t == &crate::thresholds::ThresholdConfig::default()
}

pub(crate) fn is_default_error_policy(p: &ErrorPolicy) -> bool {
    *p == ErrorPolicy::default()
}

pub(crate) fn is_default_settings(s: &Settings) -> bool {
    s == &Settings::default()
}

/// The field or field group that leaves `expected` without an effective check.
///
/// Parsing and execution share this predicate because both must reject an
/// explicitly inert assertion. Serialization deliberately uses a narrower
/// predicate: only the synthetic omitted-key sentinel may disappear on write.
pub(crate) fn vacuous_expected_field(e: &Expected) -> Option<&'static str> {
    match e {
        Expected::MustContain { must_contain } if must_contain.iter().all(String::is_empty) => {
            Some("must_contain")
        }
        Expected::MustNotContain { must_not_contain } if must_not_contain.is_empty() => {
            Some("must_not_contain")
        }
        Expected::RegexMatch { pattern, .. } if pattern.is_empty() => Some("pattern"),
        Expected::SemanticSimilarityTo { min_score, .. }
            if *min_score <= -1.0 + SEMANTIC_SIMILARITY_EPSILON =>
        {
            Some("min_score")
        }
        Expected::ArgsValid { policy, schema }
            if schema.as_ref().is_some_and(args_policy_asserts_nothing)
                || (policy.is_none() && schema.is_none()) =>
        {
            Some("policy/schema")
        }
        Expected::SequenceValid {
            policy,
            sequence,
            rules,
        } if (sequence.is_none() && rules.is_none() && policy.is_none())
            || (sequence.is_none() && rules.as_ref().is_some_and(Vec::is_empty)) =>
        {
            Some("policy/sequence/rules")
        }
        Expected::ToolOutputValid { schemas }
            if schemas.as_ref().is_none_or(schema_map_asserts_nothing) =>
        {
            Some("schemas")
        }
        Expected::ToolBlocklist { blocked } if blocked.is_empty() => Some("blocked"),
        _ => None,
    }
}

/// Decide whether an `args_valid` policy asserts anything.
///
/// For a structured policy this mirrors the control-surface half of
/// `validate_args_policy_value` exactly — merged root and `tools` allow/deny
/// lists, `any` for the universality test, and `deny` as the only enforcement
/// mode that makes a policy effective. Two approximations of the same rule
/// drift; `args_policy_oracles_agree` pins them together.
fn args_policy_asserts_nothing(schema: &serde_json::Value) -> bool {
    let Some(root) = schema.as_object() else {
        return schema_map_asserts_nothing(schema);
    };
    // The root is itself a JSON Schema rather than a tool map.
    if root
        .keys()
        .any(|key| key != "$defs" && is_json_schema_keyword(key))
    {
        return false;
    }
    if has_structured_args_policy_shape(schema) {
        let schemas_assert = root
            .get("schemas")
            .is_some_and(|schemas| !schema_map_asserts_nothing(schemas));
        if schemas_assert || structured_controls_assert(root) {
            return false;
        }
        // Claim vacuity only for a policy this rule fully understands. Anything
        // else — an unenforced field, a malformed list, a non-mapping `schemas`
        // — has a specific downstream diagnosis that is more useful than a
        // generic "asserts nothing", so defer to it.
        return structured_policy_is_fully_understood(root);
    }
    schema_map_asserts_nothing(schema)
}

/// Mirror of `validate_args_policy_value`'s control-surface effectiveness rule.
/// Whether every part of a structured policy is something this rule models.
///
/// The vacuity verdict is only honest for a policy it fully understands. For
/// anything else the execution-time check has a specific message ("not enforced
/// by this evaluator", "must be a list", "must be a mapping") that is far more
/// useful than "asserts nothing", so those defer to it.
fn structured_policy_is_fully_understood(
    root: &serde_json::Map<String, serde_json::Value>,
) -> bool {
    const KNOWN_ROOT: [&str; 8] = [
        "version",
        "name",
        "tools",
        "schemas",
        "enforcement",
        "allow",
        "deny",
        "$defs",
    ];
    if !root.keys().all(|key| KNOWN_ROOT.contains(&key.as_str())) {
        return false;
    }
    fn well_formed_list(value: Option<&serde_json::Value>) -> bool {
        value.is_none_or(|value| {
            value
                .as_array()
                .is_some_and(|entries| entries.iter().all(serde_json::Value::is_string))
        })
    }
    if !well_formed_list(root.get("allow")) || !well_formed_list(root.get("deny")) {
        return false;
    }
    if let Some(tools) = root.get("tools") {
        let Some(tools) = tools.as_object() else {
            return false;
        };
        // Execution enforces only `allow`/`deny`; every other key gets its own
        // "not enforced by this evaluator" diagnosis.
        if !tools.keys().all(|k| matches!(k.as_str(), "allow" | "deny")) {
            return false;
        }
        if !well_formed_list(tools.get("allow")) || !well_formed_list(tools.get("deny")) {
            return false;
        }
    }
    if root.get("schemas").is_some_and(|s| !s.is_object()) {
        return false;
    }
    root.get("enforcement")
        .is_none_or(serde_json::Value::is_object)
}

fn structured_controls_assert(root: &serde_json::Map<String, serde_json::Value>) -> bool {
    fn list(value: Option<&serde_json::Value>) -> Vec<&str> {
        value
            .and_then(serde_json::Value::as_array)
            .map(|entries| {
                entries
                    .iter()
                    .filter_map(serde_json::Value::as_str)
                    .collect()
            })
            .unwrap_or_default()
    }
    let mut allow = list(root.get("allow"));
    let mut deny = list(root.get("deny"));
    if let Some(tools) = root.get("tools").and_then(serde_json::Value::as_object) {
        allow.extend(list(tools.get("allow")));
        deny.extend(list(tools.get("deny")));
    }
    if !deny.is_empty()
        || (!allow.is_empty()
            && !allow
                .iter()
                .any(|pattern| is_universal_tool_pattern(pattern)))
    {
        return true;
    }
    root.get("enforcement")
        .and_then(serde_json::Value::as_object)
        .and_then(|enforcement| enforcement.get("unconstrained_tools"))
        .and_then(serde_json::Value::as_str)
        == Some("deny")
}

fn schema_map_asserts_nothing(value: &serde_json::Value) -> bool {
    if !value.is_object() {
        return false;
    }
    // Delegate the $defs merge to the one preparation implementation instead of hand-rolling a
    // copy of it here; two approximations of the same merge drift (#1951). A map that fails to
    // prepare (a $defs collision, a non-mapping $defs) is NOT classified as vacuous: preparation
    // failure is a malformed config with its own loud diagnosis at the validation and runtime
    // layers, and claiming vacuity (or effectiveness) for it here would mask that.
    let Ok(prepared) = crate::policy_engine::prepare_schema_map(value) else {
        return false;
    };
    prepared.as_object().is_some_and(|schemas| {
        schemas
            .iter()
            .all(|(_, schema)| schema_asserts_nothing(schema))
    })
}

fn schema_asserts_nothing(schema: &serde_json::Value) -> bool {
    let dialect = SchemaDialect::from_schema(schema);
    schema_asserts_nothing_inner(schema, schema, dialect, 0)
}

#[derive(Clone, Copy)]
enum SchemaDialect {
    Draft4,
    Draft6,
    Draft7,
    Modern,
}

impl SchemaDialect {
    fn from_schema(schema: &serde_json::Value) -> Self {
        match schema
            .get("$schema")
            .and_then(serde_json::Value::as_str)
            .unwrap_or_default()
        {
            value if value.contains("draft-04") => Self::Draft4,
            value if value.contains("draft-06") => Self::Draft6,
            value if value.contains("draft-07") => Self::Draft7,
            _ => Self::Modern,
        }
    }

    fn is_legacy(self) -> bool {
        matches!(self, Self::Draft4 | Self::Draft6 | Self::Draft7)
    }
}

fn schema_asserts_nothing_inner(
    schema: &serde_json::Value,
    root: &serde_json::Value,
    dialect: SchemaDialect,
    depth: usize,
) -> bool {
    if depth > 64 {
        return false;
    }
    match schema {
        serde_json::Value::Bool(value) => *value,
        serde_json::Value::Object(schema) => {
            let direct_assertion = schema.iter().any(|(keyword, value)| {
                schema_keyword_asserts(keyword, value, schema, root, dialect, depth + 1)
            });
            let conditional_assertion = conditional_asserts(schema, root, dialect, depth + 1);
            !direct_assertion && !conditional_assertion
        }
        _ => false,
    }
}

fn schema_keyword_asserts(
    keyword: &str,
    value: &serde_json::Value,
    containing_schema: &serde_json::Map<String, serde_json::Value>,
    root: &serde_json::Value,
    dialect: SchemaDialect,
    depth: usize,
) -> bool {
    match keyword {
        "$ref" => local_ref_target(value, root)
            .is_none_or(|target| !schema_asserts_nothing_inner(target, root, dialect, depth)),
        "$dynamicRef" | "$recursiveRef" | "type" | "enum" | "multipleOf" | "maximum"
        | "minimum" | "maxLength" | "maxItems" | "maxProperties" => true,
        "const" => !matches!(dialect, SchemaDialect::Draft4),
        "exclusiveMaximum" | "exclusiveMinimum" => value.as_bool() != Some(false),
        "pattern" => value.as_str() != Some(""),
        "minLength" | "minItems" | "minProperties" => {
            value.as_u64().is_none_or(|minimum| minimum > 0)
        }
        "uniqueItems" => value.as_bool() != Some(false),
        "required" => value.as_array().is_some_and(|entries| !entries.is_empty()),
        "dependentRequired" if !dialect.is_legacy() => value.as_object().is_some_and(|entries| {
            entries
                .values()
                .any(|required| required.as_array().is_some_and(|names| !names.is_empty()))
        }),
        "properties" | "patternProperties" => value.as_object().is_some_and(|schemas| {
            schemas
                .values()
                .any(|schema| !schema_asserts_nothing_inner(schema, root, dialect, depth))
        }),
        "dependentSchemas" if !dialect.is_legacy() => value.as_object().is_some_and(|schemas| {
            schemas
                .values()
                .any(|schema| !schema_asserts_nothing_inner(schema, root, dialect, depth))
        }),
        // jsonschema compiles `dependencies` for every draft that declares the
        // applicator vocabulary (keywords/mod.rs: `(_, "dependencies")`), so it
        // asserts under the modern dialect too even though the spec dropped it.
        "dependencies" => value.as_object().is_some_and(|dependencies| {
            dependencies.values().any(|dependency| {
                dependency
                    .as_array()
                    .is_some_and(|required| !required.is_empty())
                    || ((dependency.is_object() || dependency.is_boolean())
                        && !schema_asserts_nothing_inner(dependency, root, dialect, depth))
            })
        }),
        "additionalProperties" | "items" => {
            !schema_asserts_nothing_inner(value, root, dialect, depth)
        }
        "unevaluatedProperties" | "unevaluatedItems" if !dialect.is_legacy() => {
            !schema_asserts_nothing_inner(value, root, dialect, depth)
        }
        "propertyNames" if !matches!(dialect, SchemaDialect::Draft4) => {
            !schema_asserts_nothing_inner(value, root, dialect, depth)
        }
        "additionalItems"
            if dialect.is_legacy()
                && containing_schema
                    .get("items")
                    .is_some_and(serde_json::Value::is_array) =>
        {
            !schema_asserts_nothing_inner(value, root, dialect, depth)
        }
        "prefixItems" if !dialect.is_legacy() => value.as_array().is_some_and(|schemas| {
            schemas
                .iter()
                .any(|schema| !schema_asserts_nothing_inner(schema, root, dialect, depth))
        }),
        "allOf" => value.as_array().is_some_and(|schemas| {
            schemas
                .iter()
                .any(|schema| !schema_asserts_nothing_inner(schema, root, dialect, depth))
        }),
        "anyOf" => value.as_array().is_some_and(|schemas| {
            schemas.is_empty()
                || schemas
                    .iter()
                    .all(|schema| !schema_asserts_nothing_inner(schema, root, dialect, depth))
        }),
        "oneOf" => value
            .as_array()
            .is_some_and(|schemas| match schemas.as_slice() {
                [] => true,
                [schema] => !schema_asserts_nothing_inner(schema, root, dialect, depth),
                schemas
                    if schemas
                        .iter()
                        .filter(|schema| schema.as_bool() == Some(true))
                        .count()
                        == 1
                        && schemas.iter().all(serde_json::Value::is_boolean) =>
                {
                    false
                }
                _ => true,
            }),
        "not" => value != &serde_json::Value::Bool(false),
        "contains" if matches!(dialect, SchemaDialect::Draft4) => false,
        "contains" if dialect.is_legacy() => true,
        "contains" => {
            containing_schema
                .get("minContains")
                .and_then(serde_json::Value::as_u64)
                != Some(0)
                || containing_schema.contains_key("maxContains")
        }
        "format" if dialect.is_legacy() => is_known_format(value),
        _ => false,
    }
}

fn conditional_asserts(
    schema: &serde_json::Map<String, serde_json::Value>,
    root: &serde_json::Value,
    dialect: SchemaDialect,
    depth: usize,
) -> bool {
    if matches!(dialect, SchemaDialect::Draft4 | SchemaDialect::Draft6) {
        return false;
    }
    let Some(condition) = schema.get("if") else {
        return false;
    };
    let branch_asserts = |keyword| {
        schema
            .get(keyword)
            .is_some_and(|branch| !schema_asserts_nothing_inner(branch, root, dialect, depth))
    };
    match condition.as_bool() {
        Some(true) => branch_asserts("then"),
        Some(false) => branch_asserts("else"),
        None => branch_asserts("then") || branch_asserts("else"),
    }
}

fn local_ref_target<'a>(
    reference: &serde_json::Value,
    root: &'a serde_json::Value,
) -> Option<&'a serde_json::Value> {
    let reference = reference.as_str()?;
    let fragment = if let Some(fragment) = reference.strip_prefix('#') {
        fragment
    } else {
        let root_id = root.get("$id")?.as_str()?;
        reference.strip_prefix(root_id)?.strip_prefix('#')?
    };
    if fragment.is_empty() {
        return None;
    }
    root.pointer(fragment)
}

fn is_known_format(value: &serde_json::Value) -> bool {
    matches!(
        value.as_str(),
        Some(
            "date"
                | "date-time"
                | "email"
                | "hostname"
                | "ipv4"
                | "ipv6"
                | "regex"
                | "time"
                | "uri"
                | "uri-reference"
                | "uri-template"
                | "uuid"
        )
    )
}

/// Explain an `Expected` shape that the current metric set cannot execute as written.
pub(crate) fn non_executable_expected_reason(e: &Expected) -> Option<&'static str> {
    match e {
        Expected::JudgeCriteria { .. } => Some("judge_criteria has no registered evaluator"),
        Expected::SequenceValid {
            rules: Some(rules), ..
        } => rules.iter().find_map(|rule| match rule {
            SequenceRule::Require { .. }
            | SequenceRule::Blocklist { .. }
            | SequenceRule::Before { .. } => None,
            SequenceRule::Eventually { .. } => {
                Some("sequence rule eventually is not executable by sequence_valid")
            }
            SequenceRule::MaxCalls { .. } => {
                Some("sequence rule max_calls is not executable by sequence_valid")
            }
            SequenceRule::After { .. } => {
                Some("sequence rule after is not executable by sequence_valid")
            }
            SequenceRule::NeverAfter { .. } => {
                Some("sequence rule never_after is not executable by sequence_valid")
            }
            SequenceRule::Sequence { .. } => {
                Some("sequence rule sequence is not executable by sequence_valid")
            }
        }),
        _ => None,
    }
}

pub(crate) fn ineffective_expected_reason(e: &Expected) -> Option<&'static str> {
    match e {
        Expected::MustNotContain { must_not_contain }
            if must_not_contain.iter().any(String::is_empty) =>
        {
            Some("must_not_contain contains an empty string, so no response can pass")
        }
        Expected::RegexNotMatch { pattern, .. } if pattern.is_empty() => {
            Some("an empty regex_not_match pattern matches every response, so no response can pass")
        }
        Expected::SequenceValid {
            rules: Some(rules), ..
        } if rules.iter().any(|rule| {
            matches!(
                rule,
                SequenceRule::Before { first, then } if first == then
            )
        }) =>
        {
            Some("a before rule with identical tools cannot constrain a trace")
        }
        _ => None,
    }
}

/// Reject any expected value that cannot safely reach metric dispatch.
pub(crate) fn validate_expected_for_execution(e: &Expected) -> anyhow::Result<()> {
    if matches!(e, Expected::Reference { .. }) {
        anyhow::bail!("unresolved `$ref` cannot be executed; resolve or migrate it first");
    }
    if let Some(field) = vacuous_expected_field(e) {
        anyhow::bail!("`{field}` asserts nothing");
    }
    if let Some(reason) = non_executable_expected_reason(e) {
        anyhow::bail!("expected block is not executable: {reason}");
    }
    if let Some(reason) = ineffective_expected_reason(e) {
        anyhow::bail!("{reason}");
    }
    validate_static_inputs(e)?;
    Ok(())
}

fn validate_static_inputs(e: &Expected) -> anyhow::Result<()> {
    match e {
        Expected::RegexMatch { pattern, flags } | Expected::RegexNotMatch { pattern, flags } => {
            let mut builder = regex::RegexBuilder::new(pattern);
            for flag in flags {
                match flag.as_str() {
                    "i" => {
                        builder.case_insensitive(true);
                    }
                    "m" => {
                        builder.multi_line(true);
                    }
                    "s" => {
                        builder.dot_matches_new_line(true);
                    }
                    _ => {}
                }
            }
            builder
                .build()
                .map_err(|e| anyhow::anyhow!("invalid regex pattern: {e}"))?;
        }
        Expected::JsonSchema {
            json_schema,
            schema_file,
        } => {
            let source = if let Some(path) = schema_file {
                std::fs::read_to_string(path)
                    .map_err(|e| anyhow::anyhow!("failed to read schema_file '{path}': {e}"))?
            } else {
                json_schema.clone()
            };
            let schema: serde_json::Value = serde_json::from_str(&source)
                .map_err(|e| anyhow::anyhow!("invalid JSON schema: {e}"))?;
            crate::policy_engine::compile_schema(&schema)
                .map_err(|e| anyhow::anyhow!("schema compile failed: {e}"))?;
        }
        Expected::ArgsValid {
            schema: Some(schema),
            ..
        } => validate_args_policy_value(schema)?,
        Expected::ToolOutputValid {
            schemas: Some(schema),
        } => {
            // Prepare BEFORE validating, exactly as the structured args path does above, so a
            // shared-$defs collision or a non-mapping $defs is a loud config error here rather
            // than a silently vacuous schema at evaluation time (#1951). Validation, the vacuity
            // rule, and the runtime metric all reason about the SAME prepared map.
            let prepared = crate::policy_engine::prepare_schema_map(schema)
                .map_err(|e| anyhow::anyhow!("tool_output_valid schemas: {e}"))?;
            validate_schema_map(&prepared, false, true)?
        }
        Expected::ArgsValid {
            policy: Some(path),
            schema: None,
        } => validate_args_policy(path)?,
        Expected::SequenceValid {
            policy: Some(path), ..
        } => validate_sequence_policy(path)?,
        _ => {}
    }
    Ok(())
}

/// Replace file-backed assertion inputs with an immutable execution snapshot.
///
/// The returned `Expected` value is what validation, fingerprinting, and metric
/// evaluation must all consume. This prevents incremental-cache drift and avoids
/// a second file read after provider dispatch.
pub(crate) fn bind_external_expected_inputs(e: &mut Expected) -> anyhow::Result<()> {
    match e {
        Expected::JsonSchema {
            json_schema,
            schema_file,
        } => {
            if let Some(path) = schema_file.take() {
                *json_schema = std::fs::read_to_string(&path)
                    .map_err(|err| anyhow::anyhow!("failed to read schema_file '{path}': {err}"))?;
            }
        }
        Expected::ArgsValid { policy, schema } if schema.is_none() => {
            if let Some(path) = policy.take() {
                let source = std::fs::read_to_string(&path).map_err(|err| {
                    anyhow::anyhow!("failed to read args_valid policy '{path}': {err}")
                })?;
                *schema = Some(
                    serde_yaml::from_str(&source)
                        .map_err(|err| anyhow::anyhow!("invalid args_valid policy YAML: {err}"))?,
                );
            }
        }
        Expected::SequenceValid {
            policy,
            sequence,
            rules,
        } => {
            if let Some(path) = policy.take() {
                let source = std::fs::read_to_string(&path).map_err(|err| {
                    anyhow::anyhow!("failed to read sequence_valid policy '{path}': {err}")
                })?;
                if let Ok(loaded) = serde_yaml::from_str::<Vec<String>>(&source) {
                    if sequence.is_none() {
                        *sequence = Some(loaded);
                    }
                } else if let Ok(loaded) = serde_yaml::from_str::<super::types::Policy>(&source) {
                    if rules.is_none() {
                        *rules = Some(loaded.sequences);
                    }
                } else {
                    let loaded =
                        serde_yaml::from_str::<Vec<SequenceRule>>(&source).map_err(|err| {
                            anyhow::anyhow!("invalid sequence_valid policy YAML: {err}")
                        })?;
                    if rules.is_none() {
                        *rules = Some(loaded);
                    }
                }
            }
        }
        _ => {}
    }
    Ok(())
}

fn validate_args_policy(path: &str) -> anyhow::Result<()> {
    let source = std::fs::read_to_string(path)
        .map_err(|e| anyhow::anyhow!("failed to read args_valid policy '{path}': {e}"))?;
    let policy: serde_json::Value = serde_yaml::from_str(&source)
        .map_err(|e| anyhow::anyhow!("invalid args_valid policy YAML: {e}"))?;

    validate_args_policy_value(&policy)
}

/// Validate an inline `args_valid` policy using the execution-time contract.
pub fn validate_args_policy_value(policy: &serde_json::Value) -> anyhow::Result<()> {
    if policy
        .as_object()
        .and_then(|root| root.get("version"))
        .is_some_and(|version| !version.is_string())
    {
        anyhow::bail!(
            "args_valid policy version must be a string; move a legacy tool named `version` under `version: \"2.0\"` and `schemas.version`"
        );
    }
    if policy
        .as_object()
        .is_some_and(|root| root.len() == 1 && root.contains_key("schemas"))
    {
        anyhow::bail!(
            "args_valid policy with only `schemas` is ambiguous; add `version: \"2.0\"` for a structured policy, including a tool named `schemas`"
        );
    }

    let structured = has_structured_args_policy_shape(policy);

    if structured {
        const UNENFORCED: &[&str] = &[
            "constraints",
            "limits",
            "signatures",
            "tool_pins",
            "discovery",
            "runtime_monitor",
            "kill_switch",
        ];
        let unsupported: Vec<_> = UNENFORCED
            .iter()
            .copied()
            .filter(|key| policy.get(*key).is_some())
            .collect();
        if !unsupported.is_empty() {
            anyhow::bail!(
                "args_valid policy fields are not enforced by this evaluator: {}",
                unsupported.join(", ")
            );
        }

        let mut allow = policy_string_list(policy.get("allow"), "allow")?;
        let mut deny = policy_string_list(policy.get("deny"), "deny")?;
        if let Some(tools) = policy.get("tools") {
            let tools = tools
                .as_object()
                .ok_or_else(|| anyhow::anyhow!("args_valid policy tools must be a mapping"))?;
            let mut unsupported: Vec<_> = tools
                .keys()
                .filter(|key| !matches!(key.as_str(), "allow" | "deny"))
                .map(|key| format!("tools.{key}"))
                .collect();
            unsupported.sort_unstable();
            if !unsupported.is_empty() {
                anyhow::bail!(
                    "args_valid policy fields are not enforced by this evaluator: {}",
                    unsupported.join(", ")
                );
            }
            allow.extend(policy_string_list(tools.get("allow"), "tools.allow")?);
            deny.extend(policy_string_list(tools.get("deny"), "tools.deny")?);
        }
        let mut effective = !deny.is_empty()
            || (!allow.is_empty()
                && !allow
                    .iter()
                    .any(|pattern| is_universal_tool_pattern(pattern)));

        if let Some(schemas) = policy.get("schemas") {
            let schemas = schemas
                .as_object()
                .ok_or_else(|| anyhow::anyhow!("args_valid policy schemas must be a mapping"))?;
            if !schemas.is_empty() {
                let schemas = serde_json::Value::Object(schemas.clone());
                let prepared_schemas = crate::policy_engine::prepare_schema_map(&schemas)
                    .map_err(anyhow::Error::msg)?;
                if !prepared_schemas
                    .as_object()
                    .is_some_and(serde_json::Map::is_empty)
                {
                    validate_schema_map(&prepared_schemas, false, false)?;
                }
                effective |= !schema_map_asserts_nothing(&schemas);
            }
        }

        if let Some(enforcement) = policy.get("enforcement") {
            let enforcement = enforcement.as_object().ok_or_else(|| {
                anyhow::anyhow!("args_valid policy enforcement must be a mapping")
            })?;
            if let Some(mode) = enforcement.get("unconstrained_tools") {
                let mode = mode.as_str().ok_or_else(|| {
                    anyhow::anyhow!(
                        "args_valid policy enforcement.unconstrained_tools must be a string"
                    )
                })?;
                match mode {
                    "deny" => effective = true,
                    "warn" | "allow" => {}
                    _ => anyhow::bail!(
                        "args_valid policy enforcement.unconstrained_tools must be one of: warn, deny, allow"
                    ),
                }
            }
        }

        if !effective {
            anyhow::bail!("args_valid policy asserts nothing enforced by this evaluator");
        }
        return Ok(());
    }

    validate_schema_map(policy, true, true)
}

fn policy_string_list<'a>(
    value: Option<&'a serde_json::Value>,
    field: &str,
) -> anyhow::Result<Vec<&'a str>> {
    let Some(value) = value else {
        return Ok(Vec::new());
    };
    let values = value
        .as_array()
        .ok_or_else(|| anyhow::anyhow!("args_valid policy {field} must be a list"))?;
    values
        .iter()
        .map(|value| {
            value
                .as_str()
                .ok_or_else(|| anyhow::anyhow!("args_valid policy {field} entries must be strings"))
        })
        .collect()
}

fn is_universal_tool_pattern(pattern: &str) -> bool {
    !pattern.is_empty() && pattern.bytes().all(|byte| byte == b'*')
}

/// Return whether a value carries an unambiguous structured-policy discriminator.
///
/// `schemas` alone is intentionally not a discriminator: the same JSON shape can
/// be a legacy schema map for a tool literally named `schemas`. Current policy
/// documents identify themselves with `version: "2.0"` or another policy field.
pub fn has_structured_args_policy_shape(policy: &serde_json::Value) -> bool {
    let Some(root) = policy.as_object() else {
        return false;
    };
    root.get("version")
        .is_some_and(serde_json::Value::is_string)
        || root.get("name").is_some_and(serde_json::Value::is_string)
        || root.get("allow").is_some_and(serde_json::Value::is_array)
        || root.get("deny").is_some_and(serde_json::Value::is_array)
        || root
            .get("tools")
            .and_then(serde_json::Value::as_object)
            .is_some_and(|tools| {
                [
                    "allow",
                    "deny",
                    "allow_classes",
                    "deny_classes",
                    "approval_required",
                    "approval_required_classes",
                    "restrict_scope",
                    "restrict_scope_classes",
                    "restrict_scope_contract",
                    "redact_args",
                    "redact_args_classes",
                    "redact_args_contract",
                ]
                .iter()
                .any(|key| tools.contains_key(*key))
            })
        || root
            .get("enforcement")
            .and_then(serde_json::Value::as_object)
            .is_some_and(|enforcement| enforcement.contains_key("unconstrained_tools"))
        || [
            "constraints",
            "limits",
            "signatures",
            "tool_pins",
            "discovery",
            "runtime_monitor",
            "kill_switch",
        ]
        .iter()
        .any(|key| root.contains_key(*key))
}

fn validate_sequence_policy(path: &str) -> anyhow::Result<()> {
    let source = std::fs::read_to_string(path)
        .map_err(|e| anyhow::anyhow!("failed to read sequence_valid policy '{path}': {e}"))?;
    if serde_yaml::from_str::<Vec<String>>(&source).is_ok() {
        return Ok(());
    }

    let rules = if let Ok(policy) = serde_yaml::from_str::<super::types::Policy>(&source) {
        policy.sequences
    } else {
        serde_yaml::from_str::<Vec<SequenceRule>>(&source)
            .map_err(|e| anyhow::anyhow!("invalid sequence_valid policy YAML: {e}"))?
    };
    let expected = Expected::SequenceValid {
        policy: None,
        sequence: None,
        rules: Some(rules),
    };
    if let Some(field) = vacuous_expected_field(&expected) {
        anyhow::bail!("`{field}` asserts nothing");
    }
    if let Some(reason) = non_executable_expected_reason(&expected) {
        anyhow::bail!("expected block is not executable: {reason}");
    }
    if let Some(reason) = ineffective_expected_reason(&expected) {
        anyhow::bail!("{reason}");
    }
    Ok(())
}

fn validate_schema_map(
    value: &serde_json::Value,
    reject_root_schema_keywords: bool,
    require_effective_schema: bool,
) -> anyhow::Result<()> {
    let schemas = value
        .as_object()
        .filter(|schemas| !schemas.is_empty())
        .ok_or_else(|| anyhow::anyhow!("schema must be a non-empty tool-name-to-schema map"))?;
    if reject_root_schema_keywords && schemas.keys().any(|key| is_json_schema_keyword(key)) {
        anyhow::bail!(
            "root JSON Schema keywords cannot be used as tool names; expected a tool-name-to-schema map"
        );
    }
    if require_effective_schema && schema_map_asserts_nothing(value) {
        anyhow::bail!("schema map asserts nothing");
    }
    for (tool, schema) in schemas {
        if !schema.is_object() && !schema.is_boolean() {
            anyhow::bail!(
                "schema entry '{tool}' must be a JSON Schema; expected a tool-name-to-schema map"
            );
        }
        crate::policy_engine::compile_schema(schema)
            .map_err(|e| anyhow::anyhow!("schema for tool '{tool}' failed to compile: {e}"))?;
    }
    Ok(())
}

fn is_json_schema_keyword(key: &str) -> bool {
    matches!(
        key,
        "$schema"
            | "$id"
            | "$ref"
            | "$defs"
            | "$anchor"
            | "$dynamicRef"
            | "$dynamicAnchor"
            | "$vocabulary"
            | "$comment"
            | "id"
            | "definitions"
            | "dependencies"
            | "additionalItems"
            | "$recursiveRef"
            | "$recursiveAnchor"
            | "divisibleBy"
            | "disallow"
            | "extends"
            | "type"
            | "enum"
            | "const"
            | "multipleOf"
            | "maximum"
            | "exclusiveMaximum"
            | "minimum"
            | "exclusiveMinimum"
            | "maxLength"
            | "minLength"
            | "pattern"
            | "items"
            | "prefixItems"
            | "contains"
            | "maxItems"
            | "minItems"
            | "uniqueItems"
            | "maxContains"
            | "minContains"
            | "properties"
            | "patternProperties"
            | "additionalProperties"
            | "propertyNames"
            | "maxProperties"
            | "minProperties"
            | "required"
            | "dependentRequired"
            | "dependentSchemas"
            | "unevaluatedItems"
            | "unevaluatedProperties"
            | "allOf"
            | "anyOf"
            | "oneOf"
            | "not"
            | "if"
            | "then"
            | "else"
            | "title"
            | "description"
            | "default"
            | "deprecated"
            | "readOnly"
            | "writeOnly"
            | "examples"
            | "format"
            | "contentEncoding"
            | "contentMediaType"
            | "contentSchema"
    )
}

/// Validate the execution contract while preserving omitted-`expected` compatibility.
pub(crate) fn validate_test_case_for_execution(test: &TestCase) -> anyhow::Result<()> {
    // Deserialization represents an omitted `expected:` key with this exact default.
    // A written empty block never reaches here because the parser rejects it. Keep
    // the historical warning-only behavior until the assertion contract is tightened.
    if matches!(
        &test.expected,
        Expected::MustContain { must_contain } if must_contain.is_empty()
    ) {
        return Ok(());
    }
    validate_expected_for_execution(&test.expected)
}

/// True for the legacy empty-`must_contain` sentinel.
///
/// `TestCase` does not retain whether this shape came from an omitted key or from
/// programmatic construction, so serialization cannot distinguish those origins.
pub(crate) fn is_omitted_expected_sentinel(e: &Expected) -> bool {
    matches!(e, Expected::MustContain { must_contain } if must_contain.is_empty())
}

pub(crate) fn default_one() -> u32 {
    1
}

pub(crate) fn default_min_score() -> f64 {
    0.80
}

impl EvalConfig {
    pub fn is_legacy(&self) -> bool {
        self.version == 0
    }

    pub fn has_legacy_usage(&self) -> bool {
        self.tests
            .iter()
            .any(|t: &TestCase| t.expected.get_policy_path().is_some())
    }

    pub fn validate(&self) -> anyhow::Result<()> {
        if self.version >= 1 {
            for test in &self.tests {
                if matches!(test.expected, Expected::Reference { .. }) {
                    anyhow::bail!("$ref in expected block is not allowed in configVersion >= 1. Run `assay migrate` to inline policies.");
                }
            }
        }
        Ok(())
    }

    /// Get the effective error policy for a test.
    /// Test-level on_error overrides suite-level settings.
    pub fn effective_error_policy(&self, test: &TestCase) -> ErrorPolicy {
        test.on_error.unwrap_or(self.settings.on_error)
    }
}

impl Expected {
    pub fn get_policy_path(&self) -> Option<&str> {
        match self {
            Expected::ArgsValid { policy, .. } => policy.as_deref(),
            Expected::SequenceValid { policy, .. } => policy.as_deref(),
            _ => None,
        }
    }

    /// Per-test thresholding for baseline regression (mode/max_drop) when this Expected variant matches the metric.
    pub fn thresholding_for_metric(&self, metric_name: &str) -> Option<&ThresholdingConfig> {
        match (metric_name, self) {
            ("semantic_similarity_to", Expected::SemanticSimilarityTo { thresholding, .. }) => {
                thresholding.as_ref()
            }
            ("faithfulness", Expected::Faithfulness { thresholding, .. }) => thresholding.as_ref(),
            ("relevance", Expected::Relevance { thresholding, .. }) => thresholding.as_ref(),
            _ => None,
        }
    }
}

impl TestStatus {
    pub fn parse(s: &str) -> Self {
        match s {
            "pass" => TestStatus::Pass,
            "fail" => TestStatus::Fail,
            "flaky" => TestStatus::Flaky,
            "warn" => TestStatus::Warn,
            "error" => TestStatus::Error,
            "skipped" => TestStatus::Skipped,
            "unstable" => TestStatus::Unstable,
            "allowed_on_error" => TestStatus::AllowedOnError,
            _ => TestStatus::Error,
        }
    }

    /// Returns true if this status should be treated as passing for CI purposes
    pub fn is_passing(&self) -> bool {
        matches!(
            self,
            TestStatus::Pass | TestStatus::AllowedOnError | TestStatus::Warn
        )
    }

    /// Returns true if this status should block CI
    pub fn is_blocking(&self) -> bool {
        matches!(self, TestStatus::Fail | TestStatus::Error)
    }
}