better-auth 0.10.0

//! `SpecValidator` framework for batch endpoint validation and reporting.
//!
//! Collects per-endpoint results and produces a human-readable compatibility
//! report suitable for CI output.

use super::schema::{extract_success_schema, load_openapi_spec};
use super::validation::{ShapeDiff, validate_response};

/// Validate that every endpoint's response matches the OpenAPI spec schema.
/// This is the core of the compatibility testing framework.
pub struct SpecValidator {
    pub spec: oas3::spec::Spec,
    pub results: Vec<EndpointResult>,
}

pub struct EndpointResult {
    pub endpoint: String,
    pub method: String,
    pub status: u16,
    pub passed: bool,
    /// `true` when no spec schema was found for this endpoint, so validation
    /// was not possible.  Skipped endpoints are excluded from the pass/fail
    /// counts in the report.
    pub skipped: bool,
    pub diffs: Vec<ShapeDiff>,
    pub camel_case_violations: Vec<String>,
}

impl std::fmt::Display for EndpointResult {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let icon = if self.skipped {
            "SKIP"
        } else if self.passed {
            "PASS"
        } else {
            "FAIL"
        };
        write!(
            f,
            "[{}] {} {} (status={})",
            icon,
            self.method.to_uppercase(),
            self.endpoint,
            self.status
        )?;
        for diff in &self.diffs {
            write!(f, "\n      {}", diff)?;
        }
        for v in &self.camel_case_violations {
            write!(f, "\n      CAMEL_CASE {}", v)?;
        }
        Ok(())
    }
}

impl SpecValidator {
    pub fn new() -> Self {
        Self {
            spec: load_openapi_spec(),
            results: Vec::new(),
        }
    }

    /// Validate a single endpoint response against the spec.
    pub fn validate_endpoint(
        &mut self,
        path: &str,
        method: &str,
        status: u16,
        body: &serde_json::Value,
    ) {
        let schema = extract_success_schema(&self.spec, path, method);
        let (passed, skipped, diffs) = if let Some(schema) = &schema {
            let diffs = validate_response(body, schema, "");
            (diffs.is_empty(), false, diffs)
        } else {
            // No spec schema found -- mark as skipped, not passed
            (false, true, vec![])
        };

        self.results.push(EndpointResult {
            endpoint: path.to_string(),
            method: method.to_uppercase(),
            status,
            passed,
            skipped,
            diffs,
            camel_case_violations: vec![],
        });
    }

    /// Generate a human-readable compatibility report.
    pub fn report(&self) -> String {
        let mut lines = Vec::new();
        lines.push("=== Spec-Driven Compatibility Report ===".to_string());
        lines.push(String::new());

        let total = self.results.len();
        let skipped = self.results.iter().filter(|r| r.skipped).count();
        let passed = self
            .results
            .iter()
            .filter(|r| r.passed && !r.skipped)
            .count();
        let failed = total - passed - skipped;

        lines.push(format!("Total endpoints tested: {}", total));
        lines.push(format!("Passed: {}", passed));
        lines.push(format!("Failed: {}", failed));
        lines.push(format!("Skipped (no spec schema): {}", skipped));
        lines.push(String::new());

        for result in &self.results {
            lines.push(format!("{}", result));
        }

        lines.push(String::new());
        lines.push("========================================".to_string());
        lines.join("\n")
    }

    #[allow(dead_code)]
    pub fn all_passed(&self) -> bool {
        self.results.iter().filter(|r| !r.skipped).all(|r| r.passed)
    }

    /// Return the number of endpoints that were skipped due to missing spec
    /// schemas.
    #[allow(dead_code)]
    pub fn skipped_count(&self) -> usize {
        self.results.iter().filter(|r| r.skipped).count()
    }
}