eure-schema 0.1.8

//! Union type validator
//!
//! Validates union values using parse_union() API pattern.

use eure_document::parse::union::has_explicit_variant_tag;
use eure_document::parse::{DocumentParser, ParseContext};

use crate::{SchemaNodeId, UnionSchema};

use super::SchemaValidator;
use super::context::ValidationContext;
use super::error::{ValidationError, ValidatorError, select_best_variant_match};

// =============================================================================
// UnionValidator
// =============================================================================

/// Validates union values against UnionSchema.
///
/// Uses similar pattern to `UnionParser` but for validation:
/// - `$variant` extension for explicit variant tagging
/// - Short-circuit semantics by default, unambiguous opt-in
pub struct UnionValidator<'a, 'doc, 's> {
    pub ctx: &'a ValidationContext<'doc>,
    pub schema: &'s UnionSchema,
    pub schema_node_id: SchemaNodeId,
}

#[derive(Copy, Clone)]
struct VariantValidationOptions {
    propagate_errors: bool,
    requires_explicit_tag: bool,
    has_explicit_tag: bool,
}

impl<'a, 'doc, 's> DocumentParser<'doc> for UnionValidator<'a, 'doc, 's> {
    type Output = ();
    type Error = ValidatorError;

    fn parse(&mut self, parse_ctx: &ParseContext<'doc>) -> Result<(), ValidatorError> {
        // Use parse_union() API to leverage the same variant resolution logic
        let union_parser = match parse_ctx.parse_union::<(), ValidatorError>() {
            Ok(p) => p,
            Err(e) => {
                if let Some(parse_error) = e.as_parse_error() {
                    self.ctx.record_error(ValidationError::ParseError {
                        path: self.ctx.path(),
                        node_id: parse_ctx.node_id(),
                        schema_node_id: self.schema_node_id,
                        error: parse_error.clone(),
                    });
                } else {
                    self.ctx.record_error(ValidationError::InvalidVariantTag {
                        tag: format!("{e}"),
                        path: self.ctx.path(),
                        node_id: parse_ctx.node_id(),
                        schema_node_id: self.schema_node_id,
                    });
                }
                return Ok(());
            }
        };

        // Create a validator that tries variants using UnionParser's pattern
        let mut builder = union_parser;

        // Check if this value has explicit variant tagging ($variant extension)
        // This is used to enforce deny_untagged: variants in deny_untagged must have explicit tags
        let has_explicit_tag =
            match has_explicit_variant_tag(self.ctx.document, parse_ctx.node_id()) {
                Ok(has_tag) => has_tag,
                Err(parse_error) => {
                    self.ctx.record_error(ValidationError::ParseError {
                        path: self.ctx.path(),
                        node_id: parse_ctx.node_id(),
                        schema_node_id: self.schema_node_id,
                        error: parse_error,
                    });
                    return Ok(());
                }
            };
        // Tagged mode propagates nested errors directly.
        let is_tagged = has_explicit_tag;

        let deny_untagged = &self.schema.deny_untagged;
        let unambiguous = &self.schema.unambiguous;
        // Register all variants
        // Default: short-circuit (first match wins)
        // Opt-in: unambiguous (try all, detect conflicts)
        for (name, &variant_schema_id) in &self.schema.variants {
            let ctx = self.ctx;
            let schema_node_id = variant_schema_id;
            let variant_name = name.clone();
            let options = VariantValidationOptions {
                propagate_errors: is_tagged,
                requires_explicit_tag: deny_untagged.contains(name),
                has_explicit_tag,
            };

            let validator = move |parse_ctx: &ParseContext<'_>| {
                validate_variant(ctx, parse_ctx, schema_node_id, &variant_name, options)
            };

            if unambiguous.contains(name) {
                builder = builder.variant_unambiguous(name, validator);
            } else {
                builder = builder.variant(name, validator);
            }
        }

        // Execute union parsing/validation
        match builder.parse() {
            Ok(()) => {
                // Success - clear any accumulated variant errors
                self.ctx.clear_variant_errors();
                Ok(())
            }
            Err(e) => {
                // Skip adding error if inner errors were already propagated
                if matches!(e, ValidatorError::InnerErrorsPropagated) {
                    return Ok(());
                }

                // Convert ValidatorError to ValidationError with schema context
                if let Some(parse_error) = e.as_parse_error() {
                    // Wrap ParseError with schema context
                    self.ctx.record_error(ValidationError::ParseError {
                        path: self.ctx.path(),
                        node_id: parse_ctx.node_id(),
                        schema_node_id: self.schema_node_id,
                        error: parse_error.clone(),
                    });
                } else {
                    // Untagged union failed - create NoVariantMatched with best match info
                    let variant_errors = self.ctx.take_variant_errors();
                    let best_match = select_best_variant_match(variant_errors).map(Box::new);

                    self.ctx.record_error(ValidationError::NoVariantMatched {
                        path: self.ctx.path(),
                        best_match,
                        node_id: parse_ctx.node_id(),
                        schema_node_id: self.schema_node_id,
                    });
                }
                Ok(())
            }
        }
    }
}

/// Validate a single variant.
///
/// Returns Ok(()) if validation succeeds (no errors accumulated).
/// Returns Err if validation fails (so UnionParser can try other variants).
///
/// `propagate_errors`: When true (tagged mode), propagate nested errors to parent context
/// so they are reported with correct node positions. When false (untagged mode), store
/// errors for later analysis to find the best matching variant.
///
/// `requires_explicit_tag`: When true, this variant is in deny_untagged and requires explicit tagging.
/// `has_explicit_tag`: Whether the value has an explicit variant tag (`$variant`).
fn validate_variant<'doc>(
    ctx: &ValidationContext<'doc>,
    parse_ctx: &ParseContext<'doc>,
    schema_node_id: SchemaNodeId,
    variant_name: &str,
    options: VariantValidationOptions,
) -> Result<(), ValidatorError> {
    // Fork state for trial validation
    let forked_state = ctx.fork_state();
    let trial_ctx = ValidationContext::with_state(ctx.document, ctx.schema, forked_state);

    let child_validator = SchemaValidator {
        ctx: &trial_ctx,
        schema_node_id,
    };

    let result = parse_ctx.parse_with(child_validator);

    if result.is_ok() && !trial_ctx.has_errors() {
        // Check deny_untagged constraint: variant requires explicit tag but none was provided
        if options.requires_explicit_tag && !options.has_explicit_tag {
            ctx.record_error(ValidationError::RequiresExplicitVariant {
                variant: variant_name.to_string(),
                path: ctx.path(),
                node_id: parse_ctx.node_id(),
                schema_node_id,
            });
            // Signal that inner errors were propagated - no additional error needed
            return Err(ValidatorError::InnerErrorsPropagated);
        }

        // Success - merge any warnings/holes from trial
        ctx.merge_state(trial_ctx.state.into_inner());
        Ok(())
    } else {
        // Validation failed
        let trial_state = trial_ctx.state.into_inner();

        if options.propagate_errors && !trial_state.errors.is_empty() {
            // Tagged mode: propagate errors to parent context
            ctx.merge_state(trial_state);
            // Signal that inner errors were propagated - no additional error needed
            Err(ValidatorError::InnerErrorsPropagated)
        } else {
            // Untagged mode: store errors for later analysis
            if !trial_state.errors.is_empty() {
                ctx.record_variant_errors(
                    variant_name.to_string(),
                    schema_node_id,
                    trial_state.errors,
                );
            }
            Err(ValidatorError::InvalidVariantTag {
                tag: variant_name.to_string(),
                reason: "type mismatch".to_string(),
            })
        }
    }
}