aprender-test-lib 0.31.1

//! Build Coordinator for WASM Compilation
//!
//! Manages cargo build process for WASM targets with progress tracking.

use super::config::{OptLevel, RunnerConfig};
use serde::{Deserialize, Serialize};
use std::path::PathBuf;
use std::time::Duration;

/// Build status
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
pub enum BuildStatus {
    /// Build not started
    Pending,
    /// Build in progress
    Building,
    /// Build succeeded
    Success,
    /// Build failed
    Failed,
}

/// Build event for progress tracking
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum BuildEvent {
    /// Build started
    Started {
        /// Timestamp
        timestamp: std::time::SystemTime,
    },
    /// Compiling a crate
    Compiling {
        /// Crate name
        crate_name: String,
        /// Crate version
        version: String,
    },
    /// Build finished
    Finished {
        /// Build result
        success: bool,
        /// Duration
        duration: Duration,
    },
    /// Build error
    Error {
        /// Error message
        message: String,
    },
    /// Optimization step
    Optimizing {
        /// Step name (e.g., "wasm-opt")
        step: String,
    },
}

/// Result of a build operation
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct BuildResult {
    /// Build status
    pub status: BuildStatus,
    /// Size of output WASM in bytes
    pub size: Option<u64>,
    /// Gzipped size in bytes
    pub gzip_size: Option<u64>,
    /// Build duration
    pub duration: Option<Duration>,
    /// Error messages
    pub errors: Vec<String>,
    /// Warning messages
    pub warnings: Vec<String>,
    /// Output path
    pub output_path: Option<PathBuf>,
}

impl BuildResult {
    /// Create a success result
    #[must_use]
    pub fn success(size: u64, duration: Duration) -> Self {
        Self {
            status: BuildStatus::Success,
            size: Some(size),
            gzip_size: None,
            duration: Some(duration),
            errors: Vec::new(),
            warnings: Vec::new(),
            output_path: None,
        }
    }

    /// Create a failure result
    #[must_use]
    pub fn failure(errors: Vec<String>) -> Self {
        Self {
            status: BuildStatus::Failed,
            size: None,
            gzip_size: None,
            duration: None,
            errors,
            warnings: Vec::new(),
            output_path: None,
        }
    }

    /// Check if build succeeded
    #[must_use]
    pub fn is_success(&self) -> bool {
        self.status == BuildStatus::Success
    }

    /// Get size in bytes
    #[must_use]
    pub fn size_bytes(&self) -> Option<u64> {
        self.size
    }

    /// Get size in KB
    #[must_use]
    pub fn size_kb(&self) -> Option<f64> {
        self.size.map(|s| s as f64 / 1024.0)
    }

    /// Get errors
    #[must_use]
    pub fn errors(&self) -> Option<&[String]> {
        if self.errors.is_empty() {
            None
        } else {
            Some(&self.errors)
        }
    }

    /// Add a warning
    pub fn add_warning(&mut self, warning: impl Into<String>) {
        self.warnings.push(warning.into());
    }

    /// Set output path
    pub fn set_output_path(&mut self, path: PathBuf) {
        self.output_path = Some(path);
    }

    /// Set gzip size
    pub fn set_gzip_size(&mut self, size: u64) {
        self.gzip_size = Some(size);
    }
}

/// Build coordinator for managing WASM compilation
#[derive(Debug)]
pub struct BuildCoordinator {
    config: RunnerConfig,
    opt_level: OptLevel,
    status: BuildStatus,
    last_result: Option<BuildResult>,
}

impl BuildCoordinator {
    /// Create a new build coordinator
    #[must_use]
    pub fn new(config: RunnerConfig, opt_level: OptLevel) -> Self {
        Self {
            config,
            opt_level,
            status: BuildStatus::Pending,
            last_result: None,
        }
    }

    /// Get current status
    #[must_use]
    pub fn status(&self) -> BuildStatus {
        self.status
    }

    /// Get last build result
    #[must_use]
    pub fn last_result(&self) -> Option<&BuildResult> {
        self.last_result.as_ref()
    }

    /// Build the cargo command arguments
    #[must_use]
    pub fn build_args(&self) -> Vec<String> {
        let mut args = vec![
            "build".to_string(),
            "--target".to_string(),
            self.config.target.clone(),
        ];

        if self.opt_level.is_release() {
            args.push("--release".to_string());
        }

        if let Some(ref package) = self.config.package {
            args.push("--package".to_string());
            args.push(package.clone());
        }

        for feature in &self.config.features {
            args.push("--features".to_string());
            args.push(feature.clone());
        }

        args
    }

    /// Simulate a build (for testing without actual compilation)
    pub fn simulate_build(&mut self) -> BuildResult {
        self.status = BuildStatus::Building;

        // Simulate successful build
        let result = BuildResult::success(150_000, Duration::from_millis(500));
        self.last_result = Some(result.clone());
        self.status = BuildStatus::Success;

        result
    }

    /// Mark build as started
    pub fn mark_started(&mut self) {
        self.status = BuildStatus::Building;
    }

    /// Mark build as completed
    pub fn mark_completed(&mut self, result: BuildResult) {
        self.status = result.status;
        self.last_result = Some(result);
    }

    /// Get configuration
    #[must_use]
    pub fn config(&self) -> &RunnerConfig {
        &self.config
    }

    /// Get optimization level
    #[must_use]
    pub fn opt_level(&self) -> OptLevel {
        self.opt_level
    }
}

/// Format file size for display
#[allow(dead_code)]
#[must_use]
pub fn format_size(bytes: u64) -> String {
    if bytes < 1024 {
        format!("{} B", bytes)
    } else if bytes < 1024 * 1024 {
        format!("{:.1} KB", bytes as f64 / 1024.0)
    } else {
        format!("{:.2} MB", bytes as f64 / (1024.0 * 1024.0))
    }
}

#[cfg(test)]
#[allow(
    clippy::unwrap_used,
    clippy::expect_used,
    clippy::field_reassign_with_default
)]
mod tests {
    use super::*;

    #[test]
    fn test_build_result_success() {
        let result = BuildResult::success(1024, Duration::from_secs(1));
        assert!(result.is_success());
        assert_eq!(result.size_bytes(), Some(1024));
        assert!((result.size_kb().unwrap() - 1.0).abs() < 0.01);
    }

    #[test]
    fn test_build_result_failure() {
        let result = BuildResult::failure(vec!["error".to_string()]);
        assert!(!result.is_success());
        assert!(result.errors().is_some());
        assert_eq!(result.errors().unwrap().len(), 1);
    }

    #[test]
    fn test_build_result_add_warning() {
        let mut result = BuildResult::success(1024, Duration::from_secs(1));
        result.add_warning("test warning");
        assert_eq!(result.warnings.len(), 1);
    }

    #[test]
    fn test_coordinator_new() {
        let config = RunnerConfig::default();
        let coordinator = BuildCoordinator::new(config, OptLevel::Debug);
        assert_eq!(coordinator.status(), BuildStatus::Pending);
    }

    #[test]
    fn test_coordinator_build_args() {
        let mut config = RunnerConfig::default();
        config.package = Some("myapp".to_string());
        config.features = vec!["web".to_string()];

        let coordinator = BuildCoordinator::new(config, OptLevel::Release);
        let args = coordinator.build_args();

        assert!(args.contains(&"build".to_string()));
        assert!(args.contains(&"--target".to_string()));
        assert!(args.contains(&"--release".to_string()));
        assert!(args.contains(&"--package".to_string()));
        assert!(args.contains(&"myapp".to_string()));
        assert!(args.contains(&"--features".to_string()));
        assert!(args.contains(&"web".to_string()));
    }

    #[test]
    fn test_coordinator_simulate_build() {
        let config = RunnerConfig::default();
        let mut coordinator = BuildCoordinator::new(config, OptLevel::Debug);

        let result = coordinator.simulate_build();
        assert!(result.is_success());
        assert_eq!(coordinator.status(), BuildStatus::Success);
    }

    #[test]
    fn test_format_size() {
        assert_eq!(format_size(500), "500 B");
        assert_eq!(format_size(1024), "1.0 KB");
        assert_eq!(format_size(1536), "1.5 KB");
        assert_eq!(format_size(1024 * 1024), "1.00 MB");
        assert_eq!(format_size(1024 * 1024 + 512 * 1024), "1.50 MB");
    }

    #[test]
    fn test_build_event_variants() {
        let event = BuildEvent::Started {
            timestamp: std::time::SystemTime::now(),
        };
        assert!(matches!(event, BuildEvent::Started { .. }));

        let event = BuildEvent::Compiling {
            crate_name: "test".to_string(),
            version: "1.0.0".to_string(),
        };
        assert!(matches!(event, BuildEvent::Compiling { .. }));
    }

    #[test]
    fn test_build_event_finished_variant() {
        let event = BuildEvent::Finished {
            success: true,
            duration: Duration::from_secs(5),
        };
        assert!(matches!(
            event,
            BuildEvent::Finished {
                success: true,
                duration: _
            }
        ));

        let event_fail = BuildEvent::Finished {
            success: false,
            duration: Duration::from_millis(100),
        };
        assert!(matches!(
            event_fail,
            BuildEvent::Finished { success: false, .. }
        ));
    }

    #[test]
    fn test_build_event_error_variant() {
        let event = BuildEvent::Error {
            message: "compilation failed".to_string(),
        };
        if let BuildEvent::Error { message } = event {
            assert_eq!(message, "compilation failed");
        } else {
            panic!("Expected BuildEvent::Error");
        }
    }

    #[test]
    fn test_build_event_optimizing_variant() {
        let event = BuildEvent::Optimizing {
            step: "wasm-opt".to_string(),
        };
        if let BuildEvent::Optimizing { step } = event {
            assert_eq!(step, "wasm-opt");
        } else {
            panic!("Expected BuildEvent::Optimizing");
        }
    }

    #[test]
    fn test_build_status_variants() {
        assert_eq!(BuildStatus::Pending, BuildStatus::Pending);
        assert_eq!(BuildStatus::Building, BuildStatus::Building);
        assert_eq!(BuildStatus::Success, BuildStatus::Success);
        assert_eq!(BuildStatus::Failed, BuildStatus::Failed);

        // Test all variant distinctions
        assert_ne!(BuildStatus::Pending, BuildStatus::Building);
        assert_ne!(BuildStatus::Building, BuildStatus::Success);
        assert_ne!(BuildStatus::Success, BuildStatus::Failed);
    }

    #[test]
    fn test_build_result_errors_empty() {
        let result = BuildResult::success(1024, Duration::from_secs(1));
        assert!(result.errors().is_none());
    }

    #[test]
    fn test_build_result_set_output_path() {
        let mut result = BuildResult::success(1024, Duration::from_secs(1));
        assert!(result.output_path.is_none());

        result.set_output_path(PathBuf::from("/tmp/output.wasm"));
        assert_eq!(result.output_path, Some(PathBuf::from("/tmp/output.wasm")));
    }

    #[test]
    fn test_build_result_set_gzip_size() {
        let mut result = BuildResult::success(10240, Duration::from_secs(1));
        assert!(result.gzip_size.is_none());

        result.set_gzip_size(3200);
        assert_eq!(result.gzip_size, Some(3200));
    }

    #[test]
    fn test_build_result_failure_no_size() {
        let result = BuildResult::failure(vec!["error1".to_string(), "error2".to_string()]);
        assert!(result.size_bytes().is_none());
        assert!(result.size_kb().is_none());
        assert!(result.duration.is_none());
        assert!(result.gzip_size.is_none());
        assert!(result.output_path.is_none());
        assert_eq!(result.warnings.len(), 0);
    }

    #[test]
    fn test_coordinator_mark_started() {
        let config = RunnerConfig::default();
        let mut coordinator = BuildCoordinator::new(config, OptLevel::Debug);
        assert_eq!(coordinator.status(), BuildStatus::Pending);

        coordinator.mark_started();
        assert_eq!(coordinator.status(), BuildStatus::Building);
    }

    #[test]
    fn test_coordinator_mark_completed_success() {
        let config = RunnerConfig::default();
        let mut coordinator = BuildCoordinator::new(config, OptLevel::Release);

        coordinator.mark_started();
        let result = BuildResult::success(50000, Duration::from_secs(2));
        coordinator.mark_completed(result);

        assert_eq!(coordinator.status(), BuildStatus::Success);
        assert!(coordinator.last_result().is_some());
        assert!(coordinator.last_result().unwrap().is_success());
    }

    #[test]
    fn test_coordinator_mark_completed_failure() {
        let config = RunnerConfig::default();
        let mut coordinator = BuildCoordinator::new(config, OptLevel::Debug);

        coordinator.mark_started();
        let result = BuildResult::failure(vec!["error: cannot find crate".to_string()]);
        coordinator.mark_completed(result);

        assert_eq!(coordinator.status(), BuildStatus::Failed);
        assert!(coordinator.last_result().is_some());
        assert!(!coordinator.last_result().unwrap().is_success());
    }

    #[test]
    fn test_coordinator_config_accessor() {
        let mut config = RunnerConfig::default();
        config.package = Some("my-wasm-app".to_string());
        config.features = vec!["feature1".to_string(), "feature2".to_string()];

        let coordinator = BuildCoordinator::new(config, OptLevel::Size);

        assert_eq!(
            coordinator.config().package,
            Some("my-wasm-app".to_string())
        );
        assert_eq!(coordinator.config().features.len(), 2);
        assert_eq!(coordinator.config().target, "wasm32-unknown-unknown");
    }

    #[test]
    fn test_coordinator_opt_level_accessor() {
        let config = RunnerConfig::default();

        let coord_debug = BuildCoordinator::new(config.clone(), OptLevel::Debug);
        assert_eq!(coord_debug.opt_level(), OptLevel::Debug);

        let coord_release = BuildCoordinator::new(config.clone(), OptLevel::Release);
        assert_eq!(coord_release.opt_level(), OptLevel::Release);

        let coord_size = BuildCoordinator::new(config.clone(), OptLevel::Size);
        assert_eq!(coord_size.opt_level(), OptLevel::Size);

        let coord_minsize = BuildCoordinator::new(config, OptLevel::MinSize);
        assert_eq!(coord_minsize.opt_level(), OptLevel::MinSize);
    }

    #[test]
    fn test_coordinator_last_result_none() {
        let config = RunnerConfig::default();
        let coordinator = BuildCoordinator::new(config, OptLevel::Debug);
        assert!(coordinator.last_result().is_none());
    }

    #[test]
    fn test_coordinator_build_args_debug_no_package() {
        let config = RunnerConfig::default();
        let coordinator = BuildCoordinator::new(config, OptLevel::Debug);
        let args = coordinator.build_args();

        assert!(args.contains(&"build".to_string()));
        assert!(args.contains(&"--target".to_string()));
        assert!(args.contains(&"wasm32-unknown-unknown".to_string()));
        assert!(!args.contains(&"--release".to_string()));
        assert!(!args.contains(&"--package".to_string()));
        assert!(!args.contains(&"--features".to_string()));
    }

    #[test]
    fn test_coordinator_build_args_multiple_features() {
        let mut config = RunnerConfig::default();
        config.features = vec![
            "feature_a".to_string(),
            "feature_b".to_string(),
            "feature_c".to_string(),
        ];

        let coordinator = BuildCoordinator::new(config, OptLevel::Release);
        let args = coordinator.build_args();

        // Each feature gets its own --features flag
        let feature_count = args.iter().filter(|a| *a == "--features").count();
        assert_eq!(feature_count, 3);

        assert!(args.contains(&"feature_a".to_string()));
        assert!(args.contains(&"feature_b".to_string()));
        assert!(args.contains(&"feature_c".to_string()));
    }

    #[test]
    fn test_format_size_edge_cases() {
        // Boundary at 1024 bytes
        assert_eq!(format_size(1023), "1023 B");
        assert_eq!(format_size(1024), "1.0 KB");
        assert_eq!(format_size(1025), "1.0 KB");

        // Boundary at 1 MB
        assert_eq!(format_size(1024 * 1024 - 1), "1024.0 KB");
        assert_eq!(format_size(1024 * 1024), "1.00 MB");
        assert_eq!(format_size(1024 * 1024 + 1), "1.00 MB");

        // Zero
        assert_eq!(format_size(0), "0 B");

        // Large file (10 MB)
        assert_eq!(format_size(10 * 1024 * 1024), "10.00 MB");
    }

    #[test]
    fn test_build_result_size_kb_precision() {
        let result = BuildResult::success(2560, Duration::from_secs(1));
        let kb = result.size_kb().unwrap();
        assert!((kb - 2.5).abs() < 0.001);

        let result2 = BuildResult::success(512, Duration::from_secs(1));
        let kb2 = result2.size_kb().unwrap();
        assert!((kb2 - 0.5).abs() < 0.001);
    }

    #[test]
    fn test_build_result_multiple_warnings() {
        let mut result = BuildResult::success(1024, Duration::from_secs(1));
        result.add_warning("warning 1");
        result.add_warning("warning 2");
        result.add_warning(String::from("warning 3"));

        assert_eq!(result.warnings.len(), 3);
        assert_eq!(result.warnings[0], "warning 1");
        assert_eq!(result.warnings[1], "warning 2");
        assert_eq!(result.warnings[2], "warning 3");
    }

    #[test]
    fn test_build_status_serialization() {
        let status = BuildStatus::Building;
        let json = serde_json::to_string(&status).unwrap();
        let deserialized: BuildStatus = serde_json::from_str(&json).unwrap();
        assert_eq!(status, deserialized);
    }

    #[test]
    fn test_build_event_serialization() {
        let event = BuildEvent::Compiling {
            crate_name: "my_crate".to_string(),
            version: "0.1.0".to_string(),
        };
        let json = serde_json::to_string(&event).unwrap();
        assert!(json.contains("my_crate"));
        assert!(json.contains("0.1.0"));
    }

    #[test]
    fn test_build_result_serialization() {
        let mut result = BuildResult::success(4096, Duration::from_millis(250));
        result.set_output_path(PathBuf::from("/output/app.wasm"));
        result.set_gzip_size(1500);
        result.add_warning("unused variable");

        let json = serde_json::to_string(&result).unwrap();
        let deserialized: BuildResult = serde_json::from_str(&json).unwrap();

        assert_eq!(deserialized.status, BuildStatus::Success);
        assert_eq!(deserialized.size, Some(4096));
        assert_eq!(deserialized.gzip_size, Some(1500));
        assert_eq!(deserialized.warnings.len(), 1);
    }

    #[test]
    fn test_coordinator_simulate_build_state_transitions() {
        let config = RunnerConfig::default();
        let mut coordinator = BuildCoordinator::new(config, OptLevel::Debug);

        // Initial state
        assert_eq!(coordinator.status(), BuildStatus::Pending);
        assert!(coordinator.last_result().is_none());

        // After simulate_build
        let result = coordinator.simulate_build();
        assert_eq!(coordinator.status(), BuildStatus::Success);
        assert!(coordinator.last_result().is_some());
        assert_eq!(result.size, Some(150_000));
        assert_eq!(result.duration, Some(Duration::from_millis(500)));
    }

    #[test]
    fn test_coordinator_with_custom_target() {
        let mut config = RunnerConfig::default();
        config.target = "wasm32-wasi".to_string();

        let coordinator = BuildCoordinator::new(config, OptLevel::Release);
        let args = coordinator.build_args();

        assert!(args.contains(&"wasm32-wasi".to_string()));
    }
}