mockforge-cli 0.3.118

//! HTTP Fixture Validation Tool
//!
//! Standalone tool for validating HTTP fixtures in a directory.
//! Can validate individual files or entire directories.

use anyhow::{bail, Context, Result};
use mockforge_openapi::custom_fixture::CustomFixture;
use serde::Deserialize;
use serde_json::Value;
use std::collections::HashMap;
use std::path::{Path, PathBuf};
use tokio::fs;

/// Validation result for a single fixture
#[derive(Debug)]
pub struct ValidationResult {
    pub file: PathBuf,
    pub valid: bool,
    pub error: Option<String>,
    pub format: FixtureFormat,
}

/// Format of the fixture
#[derive(Debug, Clone, Copy)]
pub enum FixtureFormat {
    Flat,
    Nested,
    Invalid,
}

/// Validate a single fixture file
pub async fn validate_file(file_path: &Path) -> Result<ValidationResult> {
    let content = fs::read_to_string(file_path)
        .await
        .with_context(|| format!("Failed to read fixture file: {}", file_path.display()))?;

    // Check if it's a template file
    if should_skip_file(&content) {
        return Ok(ValidationResult {
            file: file_path.to_path_buf(),
            valid: false,
            error: Some("Template file (contains _comment, _usage, or scenario field)".to_string()),
            format: FixtureFormat::Invalid,
        });
    }

    // Try to parse as flat format
    match serde_json::from_str::<CustomFixture>(&content) {
        Ok(mut fixture) => {
            // Normalize path
            fixture.path = normalize_path(&fixture.path);

            // Validate
            match validate_fixture(&fixture, file_path) {
                Ok(_) => Ok(ValidationResult {
                    file: file_path.to_path_buf(),
                    valid: true,
                    error: None,
                    format: FixtureFormat::Flat,
                }),
                Err(e) => Ok(ValidationResult {
                    file: file_path.to_path_buf(),
                    valid: false,
                    error: Some(e.to_string()),
                    format: FixtureFormat::Flat,
                }),
            }
        }
        Err(_) => {
            // Try nested format
            match serde_json::from_str::<NestedFixture>(&content) {
                Ok(nested) => match convert_nested_to_flat(nested) {
                    Ok(fixture) => match validate_fixture(&fixture, file_path) {
                        Ok(_) => Ok(ValidationResult {
                            file: file_path.to_path_buf(),
                            valid: true,
                            error: None,
                            format: FixtureFormat::Nested,
                        }),
                        Err(e) => Ok(ValidationResult {
                            file: file_path.to_path_buf(),
                            valid: false,
                            error: Some(e.to_string()),
                            format: FixtureFormat::Nested,
                        }),
                    },
                    Err(e) => Ok(ValidationResult {
                        file: file_path.to_path_buf(),
                        valid: false,
                        error: Some(e.to_string()),
                        format: FixtureFormat::Nested,
                    }),
                },
                Err(e) => Ok(ValidationResult {
                    file: file_path.to_path_buf(),
                    valid: false,
                    error: Some(format!("Invalid JSON or fixture format: {}", e)),
                    format: FixtureFormat::Invalid,
                }),
            }
        }
    }
}

/// Validate all fixtures in a directory
pub async fn validate_directory(dir_path: &Path) -> Result<Vec<ValidationResult>> {
    let mut results = Vec::new();

    if !dir_path.exists() {
        anyhow::bail!("Directory does not exist: {}", dir_path.display());
    }

    if !dir_path.is_dir() {
        anyhow::bail!("Path is not a directory: {}", dir_path.display());
    }

    let mut entries = fs::read_dir(dir_path)
        .await
        .with_context(|| format!("Failed to read directory: {}", dir_path.display()))?;

    while let Some(entry) = entries.next_entry().await? {
        let path = entry.path();
        if path.is_file() && path.extension().and_then(|s| s.to_str()) == Some("json") {
            let result = validate_file(&path).await?;
            results.push(result);
        }
    }

    Ok(results)
}

// Helper functions (duplicated from CustomFixtureLoader for standalone use)
fn should_skip_file(content: &str) -> bool {
    // Check for template indicators
    if content.contains("\"_comment\"") || content.contains("\"_usage\"") {
        return true;
    }

    // Check if it's a scenario/config file (not a fixture)
    if content.contains("\"scenario\"") || content.contains("\"presentation_mode\"") {
        return true;
    }

    false
}

fn normalize_path(path: &str) -> String {
    let mut normalized = path.trim().to_string();

    // Strip query string if present (query strings are handled separately)
    if let Some(query_start) = normalized.find('?') {
        normalized = normalized[..query_start].to_string();
    }

    // Collapse multiple slashes into one
    while normalized.contains("//") {
        normalized = normalized.replace("//", "/");
    }

    // Remove trailing slash (except for root path)
    if normalized.len() > 1 && normalized.ends_with('/') {
        normalized.pop();
    }

    // Ensure path starts with /
    if !normalized.starts_with('/') {
        normalized = format!("/{}", normalized);
    }

    normalized
}

fn validate_fixture(fixture: &CustomFixture, _file_path: &Path) -> Result<()> {
    // Check required fields
    if fixture.method.is_empty() {
        bail!("method is required and cannot be empty");
    }

    if fixture.path.is_empty() {
        bail!("path is required and cannot be empty");
    }

    // Validate HTTP method
    let method_upper = fixture.method.to_uppercase();
    let valid_methods = [
        "GET", "POST", "PUT", "PATCH", "DELETE", "HEAD", "OPTIONS", "TRACE",
    ];
    if !valid_methods.contains(&method_upper.as_str()) {
        // Warn but don't fail
    }

    // Validate status code
    if fixture.status < 100 || fixture.status >= 600 {
        bail!("status code {} is not a valid HTTP status code (100-599)", fixture.status);
    }

    Ok(())
}

fn convert_nested_to_flat(nested: NestedFixture) -> Result<CustomFixture> {
    let request = nested
        .request
        .ok_or_else(|| anyhow::anyhow!("Nested fixture missing 'request' object"))?;

    let response = nested
        .response
        .ok_or_else(|| anyhow::anyhow!("Nested fixture missing 'response' object"))?;

    Ok(CustomFixture {
        method: request.method,
        path: normalize_path(&request.path),
        status: response.status,
        response: response.body,
        headers: response.headers,
        delay_ms: 0,
    })
}

// Nested fixture types for parsing
#[derive(Debug, Deserialize)]
struct NestedFixture {
    request: Option<NestedRequest>,
    response: Option<NestedResponse>,
}

#[derive(Debug, Deserialize)]
struct NestedRequest {
    method: String,
    path: String,
}

#[derive(Debug, Deserialize)]
struct NestedResponse {
    status: u16,
    #[serde(default)]
    headers: HashMap<String, String>,
    body: Value,
}

/// Print validation results in a formatted way
pub fn print_results(results: &[ValidationResult], verbose: bool) {
    let valid_count = results.iter().filter(|r| r.valid).count();
    let invalid_count = results.len() - valid_count;
    let flat_count = results.iter().filter(|r| matches!(r.format, FixtureFormat::Flat)).count();
    let nested_count = results.iter().filter(|r| matches!(r.format, FixtureFormat::Nested)).count();

    println!("\n📊 Validation Summary");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Total files: {}", results.len());
    println!("✅ Valid: {}", valid_count);
    println!("❌ Invalid: {}", invalid_count);
    println!("📄 Flat format: {}", flat_count);
    println!("📦 Nested format: {}", nested_count);

    if invalid_count > 0 {
        println!("\n❌ Invalid Fixtures:");
        println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
        for result in results.iter().filter(|r| !r.valid) {
            println!("\n  File: {}", result.file.display());
            if let Some(ref error) = result.error {
                println!("  Error: {}", error);
            }
        }
    }

    if verbose && valid_count > 0 {
        println!("\n✅ Valid Fixtures:");
        println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
        for result in results.iter().filter(|r| r.valid) {
            let format_str = match result.format {
                FixtureFormat::Flat => "flat",
                FixtureFormat::Nested => "nested",
                FixtureFormat::Invalid => "invalid",
            };
            println!("  {} ({})", result.file.display(), format_str);
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use tempfile::TempDir;

    // FixtureFormat tests
    #[test]
    fn test_fixture_format_debug() {
        let format = FixtureFormat::Flat;
        let debug = format!("{:?}", format);
        assert!(debug.contains("Flat"));
    }

    #[test]
    fn test_fixture_format_clone() {
        let format = FixtureFormat::Nested;
        let cloned = format;
        assert!(matches!(cloned, FixtureFormat::Nested));
    }

    // normalize_path tests
    #[test]
    fn test_normalize_path_simple() {
        assert_eq!(normalize_path("/api/users"), "/api/users");
    }

    #[test]
    fn test_normalize_path_adds_leading_slash() {
        assert_eq!(normalize_path("api/users"), "/api/users");
    }

    #[test]
    fn test_normalize_path_removes_trailing_slash() {
        assert_eq!(normalize_path("/api/users/"), "/api/users");
    }

    #[test]
    fn test_normalize_path_root() {
        assert_eq!(normalize_path("/"), "/");
    }

    #[test]
    fn test_normalize_path_collapses_double_slashes() {
        assert_eq!(normalize_path("/api//users"), "/api/users");
        assert_eq!(normalize_path("/api///users"), "/api/users");
    }

    #[test]
    fn test_normalize_path_strips_query_string() {
        assert_eq!(normalize_path("/api/users?page=1"), "/api/users");
        assert_eq!(normalize_path("/api/users?page=1&limit=10"), "/api/users");
    }

    #[test]
    fn test_normalize_path_trims_whitespace() {
        assert_eq!(normalize_path("  /api/users  "), "/api/users");
    }

    #[test]
    fn test_normalize_path_empty() {
        assert_eq!(normalize_path(""), "/");
    }

    // should_skip_file tests
    #[test]
    fn test_should_skip_file_with_comment() {
        let content = r#"{"_comment": "This is a template", "method": "GET"}"#;
        assert!(should_skip_file(content));
    }

    #[test]
    fn test_should_skip_file_with_usage() {
        let content = r#"{"_usage": "Example usage", "method": "GET"}"#;
        assert!(should_skip_file(content));
    }

    #[test]
    fn test_should_skip_file_with_scenario() {
        let content = r#"{"scenario": "test-scenario", "steps": []}"#;
        assert!(should_skip_file(content));
    }

    #[test]
    fn test_should_skip_file_with_presentation_mode() {
        let content = r#"{"presentation_mode": true, "slides": []}"#;
        assert!(should_skip_file(content));
    }

    #[test]
    fn test_should_skip_file_normal_fixture() {
        let content = r#"{"method": "GET", "path": "/api/users", "status": 200}"#;
        assert!(!should_skip_file(content));
    }

    // validate_file tests
    #[tokio::test]
    async fn test_validate_file_valid_flat_fixture() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("fixture.json");
        let fixture = r#"{
            "method": "GET",
            "path": "/api/users",
            "status": 200,
            "response": {"users": []}
        }"#;
        std::fs::write(&file_path, fixture).unwrap();

        let result = validate_file(&file_path).await.unwrap();
        assert!(result.valid);
        assert!(matches!(result.format, FixtureFormat::Flat));
    }

    #[tokio::test]
    async fn test_validate_file_valid_nested_fixture() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("fixture.json");
        let fixture = r#"{
            "request": {
                "method": "POST",
                "path": "/api/users"
            },
            "response": {
                "status": 201,
                "body": {"id": 1}
            }
        }"#;
        std::fs::write(&file_path, fixture).unwrap();

        let result = validate_file(&file_path).await.unwrap();
        assert!(result.valid);
        assert!(matches!(result.format, FixtureFormat::Nested));
    }

    #[tokio::test]
    async fn test_validate_file_invalid_json() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("fixture.json");
        std::fs::write(&file_path, "{ invalid json }").unwrap();

        let result = validate_file(&file_path).await.unwrap();
        assert!(!result.valid);
        assert!(result.error.is_some());
        assert!(matches!(result.format, FixtureFormat::Invalid));
    }

    #[tokio::test]
    async fn test_validate_file_template_file() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("template.json");
        let template = r#"{"_comment": "Template file", "method": "GET"}"#;
        std::fs::write(&file_path, template).unwrap();

        let result = validate_file(&file_path).await.unwrap();
        assert!(!result.valid);
        assert!(result.error.unwrap().contains("Template file"));
    }

    #[tokio::test]
    async fn test_validate_file_missing_method() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("fixture.json");
        let fixture = r#"{
            "path": "/api/users",
            "status": 200,
            "response": {}
        }"#;
        std::fs::write(&file_path, fixture).unwrap();

        let result = validate_file(&file_path).await.unwrap();
        // May fail during parsing or validation
        // Just ensure it handles gracefully
        assert!(result.valid || result.error.is_some());
    }

    #[tokio::test]
    async fn test_validate_file_invalid_status_code() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("fixture.json");
        let fixture = r#"{
            "method": "GET",
            "path": "/api/users",
            "status": 999,
            "response": {}
        }"#;
        std::fs::write(&file_path, fixture).unwrap();

        let result = validate_file(&file_path).await.unwrap();
        assert!(!result.valid);
        assert!(result.error.unwrap().contains("status code"));
    }

    #[tokio::test]
    async fn test_validate_file_status_code_too_low() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("fixture.json");
        let fixture = r#"{
            "method": "GET",
            "path": "/api/users",
            "status": 50,
            "response": {}
        }"#;
        std::fs::write(&file_path, fixture).unwrap();

        let result = validate_file(&file_path).await.unwrap();
        assert!(!result.valid);
    }

    // validate_directory tests
    #[tokio::test]
    async fn test_validate_directory_empty() {
        let temp_dir = TempDir::new().unwrap();
        let results = validate_directory(temp_dir.path()).await.unwrap();
        assert!(results.is_empty());
    }

    #[tokio::test]
    async fn test_validate_directory_with_fixtures() {
        let temp_dir = TempDir::new().unwrap();

        // Create valid fixture
        let valid_fixture = r#"{
            "method": "GET",
            "path": "/api/users",
            "status": 200,
            "response": []
        }"#;
        std::fs::write(temp_dir.path().join("valid.json"), valid_fixture).unwrap();

        // Create invalid fixture
        std::fs::write(temp_dir.path().join("invalid.json"), "{ bad json }").unwrap();

        let results = validate_directory(temp_dir.path()).await.unwrap();
        assert_eq!(results.len(), 2);

        let valid_count = results.iter().filter(|r| r.valid).count();
        let invalid_count = results.iter().filter(|r| !r.valid).count();
        assert_eq!(valid_count, 1);
        assert_eq!(invalid_count, 1);
    }

    #[tokio::test]
    async fn test_validate_directory_ignores_non_json() {
        let temp_dir = TempDir::new().unwrap();

        // Create JSON fixture
        let fixture = r#"{"method": "GET", "path": "/api", "status": 200, "response": {}}"#;
        std::fs::write(temp_dir.path().join("fixture.json"), fixture).unwrap();

        // Create non-JSON file
        std::fs::write(temp_dir.path().join("readme.txt"), "This is not JSON").unwrap();

        let results = validate_directory(temp_dir.path()).await.unwrap();
        assert_eq!(results.len(), 1);
    }

    #[tokio::test]
    async fn test_validate_directory_not_exists() {
        let result = validate_directory(Path::new("/nonexistent/path")).await;
        assert!(result.is_err());
    }

    #[tokio::test]
    async fn test_validate_directory_is_file() {
        let temp_dir = TempDir::new().unwrap();
        let file_path = temp_dir.path().join("file.txt");
        std::fs::write(&file_path, "content").unwrap();

        let result = validate_directory(&file_path).await;
        assert!(result.is_err());
    }

    // ValidationResult tests
    #[test]
    fn test_validation_result_debug() {
        let result = ValidationResult {
            file: PathBuf::from("test.json"),
            valid: true,
            error: None,
            format: FixtureFormat::Flat,
        };
        let debug = format!("{:?}", result);
        assert!(debug.contains("ValidationResult"));
        assert!(debug.contains("test.json"));
    }

    // print_results tests (just ensure no panic)
    #[test]
    fn test_print_results_empty() {
        let results: Vec<ValidationResult> = vec![];
        print_results(&results, false);
    }

    #[test]
    fn test_print_results_with_valid() {
        let results = vec![ValidationResult {
            file: PathBuf::from("test.json"),
            valid: true,
            error: None,
            format: FixtureFormat::Flat,
        }];
        print_results(&results, true);
    }

    #[test]
    fn test_print_results_with_invalid() {
        let results = vec![ValidationResult {
            file: PathBuf::from("test.json"),
            valid: false,
            error: Some("Test error".to_string()),
            format: FixtureFormat::Invalid,
        }];
        print_results(&results, false);
    }

    #[test]
    fn test_print_results_mixed() {
        let results = vec![
            ValidationResult {
                file: PathBuf::from("valid.json"),
                valid: true,
                error: None,
                format: FixtureFormat::Flat,
            },
            ValidationResult {
                file: PathBuf::from("nested.json"),
                valid: true,
                error: None,
                format: FixtureFormat::Nested,
            },
            ValidationResult {
                file: PathBuf::from("invalid.json"),
                valid: false,
                error: Some("Parse error".to_string()),
                format: FixtureFormat::Invalid,
            },
        ];
        print_results(&results, true);
    }
}