depyler 4.1.1

//! Training Monitor Integration
//!
//! Integrates entrenar's real-time monitoring with depyler's overnight improvement loop.
//! Implements Toyota Way principles for quality assurance during transpilation training.

use entrenar::monitor::{
    AndonSystem, DriftDetector, HanseiAnalyzer, Metric, MetricsCollector,
};
use std::time::Instant;

/// Training monitor for overnight improvement runs
pub struct TrainingMonitor {
    collector: MetricsCollector,
    drift_detector: DriftDetector,
    andon: AndonSystem,
    start_time: Instant,
    last_compile_rate: f64,
}

impl TrainingMonitor {
    /// Create a new training monitor
    pub fn new() -> Self {
        Self {
            collector: MetricsCollector::new(),
            drift_detector: DriftDetector::new(10), // 10-epoch window
            andon: AndonSystem::new(),
            start_time: Instant::now(),
            last_compile_rate: 0.0,
        }
    }

    /// Record metrics for an epoch
    pub fn record_epoch(
        &mut self,
        epoch: usize,
        transpile_ok: usize,
        compile_ok: usize,
        total_files: usize,
        error_count: usize,
    ) {
        let transpile_rate = if total_files > 0 {
            transpile_ok as f64 / total_files as f64
        } else {
            0.0
        };

        let compile_rate = if total_files > 0 {
            compile_ok as f64 / total_files as f64
        } else {
            0.0
        };

        // Record metrics using entrenar's Metric::Custom
        self.collector
            .record(Metric::Custom("epoch".into()), epoch as f64);
        self.collector
            .record(Metric::Custom("transpile_rate".into()), transpile_rate);
        self.collector
            .record(Metric::Custom("compile_rate".into()), compile_rate);
        self.collector
            .record(Metric::Custom("error_count".into()), error_count as f64);
        self.collector
            .record(Metric::Custom("transpile_ok".into()), transpile_ok as f64);
        self.collector
            .record(Metric::Custom("compile_ok".into()), compile_ok as f64);

        // Check for drift (sudden drop in compile rate)
        let drift_status = self.drift_detector.check(compile_rate);
        if let entrenar::monitor::DriftStatus::Drift(z_score) = drift_status {
            self.andon.warning(format!(
                "Compile rate drift detected: {:.1}% (z={:.2})",
                compile_rate * 100.0,
                z_score
            ));
        }

        // Check for regression (compile rate dropping)
        if compile_rate < self.last_compile_rate * 0.9 && self.last_compile_rate > 0.0 {
            self.andon.warning(format!(
                "Compile rate regression: {:.1}% -> {:.1}%",
                self.last_compile_rate * 100.0,
                compile_rate * 100.0
            ));
        }

        self.last_compile_rate = compile_rate;
    }

    /// Record an error pattern
    pub fn record_error(&mut self, error_code: &str) {
        self.collector
            .record(Metric::Custom(format!("error_{}", error_code)), 1.0);
    }

    /// Check if training should stop
    pub fn should_stop(&self) -> bool {
        self.andon.should_stop()
    }

    /// Get all alerts
    pub fn get_alerts(&self) -> Vec<String> {
        self.andon
            .history()
            .iter()
            .map(|a| format!("[{}] {}", a.level.as_str(), a.message))
            .collect()
    }

    /// Generate Hansei (post-training) report
    pub fn generate_report(&self, training_id: &str) -> String {
        let duration = self.start_time.elapsed().as_secs_f64();
        let analyzer = HanseiAnalyzer::new();
        let report = analyzer.analyze(training_id, &self.collector, duration);
        analyzer.format_report(&report)
    }

    /// Get metrics summary as JSON
    pub fn summary_json(&self) -> Result<String, serde_json::Error> {
        // Convert HashMap<Metric, MetricStats> to HashMap<String, MetricStats> for JSON serialization
        let summary: std::collections::HashMap<String, _> = self
            .collector
            .summary()
            .into_iter()
            .map(|(k, v)| (k.as_str().to_string(), v))
            .collect();
        serde_json::to_string_pretty(&summary)
    }

    /// Get duration in seconds
    pub fn duration_secs(&self) -> f64 {
        self.start_time.elapsed().as_secs_f64()
    }
}

impl Default for TrainingMonitor {
    fn default() -> Self {
        Self::new()
    }
}

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

    #[test]
    fn test_training_monitor_new() {
        let monitor = TrainingMonitor::new();
        assert!(!monitor.should_stop());
    }

    #[test]
    fn test_training_monitor_default() {
        let monitor = TrainingMonitor::default();
        assert!(!monitor.should_stop());
        assert!(monitor.get_alerts().is_empty());
    }

    #[test]
    fn test_record_epoch() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 290, 280, 307, 27);

        let json = monitor.summary_json().unwrap();
        assert!(json.contains("compile_rate"));
        assert!(json.contains("transpile_rate"));
    }

    #[test]
    fn test_record_epoch_zero_total() {
        let mut monitor = TrainingMonitor::new();
        // Edge case: no files processed
        monitor.record_epoch(1, 0, 0, 0, 0);
        // Should not panic, rates should be 0.0
        let json = monitor.summary_json().unwrap();
        assert!(json.contains("compile_rate"));
    }

    #[test]
    fn test_record_epoch_all_success() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 100, 100, 100, 0);
        let json = monitor.summary_json().unwrap();
        assert!(json.contains("transpile_rate"));
    }

    #[test]
    fn test_record_epoch_all_failure() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 0, 0, 100, 100);
        let json = monitor.summary_json().unwrap();
        assert!(json.contains("error_count"));
    }

    #[test]
    fn test_record_error() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_error("E0308");
        monitor.record_error("E0277");
        let json = monitor.summary_json().unwrap();
        assert!(json.contains("error_E0308"));
        assert!(json.contains("error_E0277"));
    }

    #[test]
    fn test_record_error_multiple_same() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_error("E0001");
        monitor.record_error("E0001");
        monitor.record_error("E0001");
        let json = monitor.summary_json().unwrap();
        assert!(json.contains("error_E0001"));
    }

    #[test]
    fn test_regression_detection() {
        let mut monitor = TrainingMonitor::new();

        // First epoch: 90% compile rate
        monitor.record_epoch(1, 307, 276, 307, 31);

        // Second epoch: 50% compile rate (>10% drop triggers warning)
        monitor.record_epoch(2, 307, 153, 307, 154);

        let alerts = monitor.get_alerts();
        assert!(
            alerts.iter().any(|a| a.contains("regression")),
            "Expected regression alert, got: {:?}",
            alerts
        );
    }

    #[test]
    fn test_no_regression_stable_rate() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 100, 80, 100, 20);
        monitor.record_epoch(2, 100, 78, 100, 22);
        // Only 2.5% drop, not enough for regression
        let alerts = monitor.get_alerts();
        let regression_alerts: Vec<_> = alerts.iter().filter(|a| a.contains("regression")).collect();
        assert!(regression_alerts.is_empty(), "Unexpected regression: {:?}", regression_alerts);
    }

    #[test]
    fn test_no_regression_improving_rate() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 100, 50, 100, 50);
        monitor.record_epoch(2, 100, 75, 100, 25);
        // Rate improved, no regression
        let alerts = monitor.get_alerts();
        let regression_alerts: Vec<_> = alerts.iter().filter(|a| a.contains("regression")).collect();
        assert!(regression_alerts.is_empty());
    }

    #[test]
    fn test_generate_report() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 290, 280, 307, 27);
        monitor.record_epoch(2, 295, 285, 307, 22);

        let report = monitor.generate_report("test-run");
        assert!(report.contains("HANSEI POST-TRAINING REPORT"));
        assert!(report.contains("test-run"));
    }

    #[test]
    fn test_generate_report_empty() {
        let monitor = TrainingMonitor::new();
        let report = monitor.generate_report("empty-run");
        assert!(report.contains("HANSEI POST-TRAINING REPORT"));
        assert!(report.contains("empty-run"));
    }

    #[test]
    fn test_duration_secs() {
        let monitor = TrainingMonitor::new();
        std::thread::sleep(std::time::Duration::from_millis(10));
        let duration = monitor.duration_secs();
        assert!(duration >= 0.01);
    }

    #[test]
    fn test_summary_json_format() {
        let mut monitor = TrainingMonitor::new();
        monitor.record_epoch(1, 50, 40, 100, 10);
        let json = monitor.summary_json().unwrap();
        // Should be valid JSON
        let parsed: serde_json::Value = serde_json::from_str(&json).unwrap();
        assert!(parsed.is_object());
    }

    #[test]
    fn test_should_stop_initially_false() {
        let monitor = TrainingMonitor::new();
        assert!(!monitor.should_stop());
    }

    #[test]
    fn test_get_alerts_initially_empty() {
        let monitor = TrainingMonitor::new();
        let alerts = monitor.get_alerts();
        assert!(alerts.is_empty());
    }

    #[test]
    fn test_multiple_epochs_summary() {
        let mut monitor = TrainingMonitor::new();
        for i in 1..=10 {
            monitor.record_epoch(i, 100, 80 + i, 100, 20 - i);
        }
        let json = monitor.summary_json().unwrap();
        assert!(json.contains("epoch"));
        assert!(json.contains("compile_rate"));
    }
}