/home/noah/src/realizar/src/warmup.rs

Source
//! Model Warm-up and Pre-loading
//!
//! Reduces cold start latency by pre-loading models and running warm-up inference.
//!
//! ## Features
//!
//! - Pre-load models into memory before serving
//! - Run warm-up inference to JIT compile and optimize
//! - Validate model integrity before accepting traffic
//! - Background model loading for zero-downtime updates
//!
//! ## Example
//!
//! ```rust,ignore
//! use realizar::warmup::{WarmupConfig, ModelWarmer};
//!
//! let config = WarmupConfig::new()
//!     .with_warmup_iterations(3)
//!     .with_timeout(Duration::from_secs(30));
//!
//! let warmer = ModelWarmer::new(config);
//! warmer.warm_up(&model, &tokenizer).await?;
//! ```
//!
//! ## Toyota Way Principles
//!
//! - Heijunka: Level loading by pre-warming
//! - Jidoka: Validate model before serving
//! - Poka-Yoke: Prevent cold start errors

use std::{
    sync::{
        atomic::{AtomicBool, AtomicU64, Ordering},
        Arc,
    },
    time::{Duration, Instant},
};

use serde::{Deserialize, Serialize};

// ============================================================================
// WARM-001: Configuration
// ============================================================================

/// Configuration for model warm-up
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct WarmupConfig {
    /// Number of warm-up inference iterations
    pub warmup_iterations: usize,
    /// Timeout for warm-up process
    pub timeout: Duration,
    /// Sample prompt for warm-up inference
    pub sample_prompt: String,
    /// Maximum tokens for warm-up generation
    pub sample_max_tokens: usize,
    /// Validate model output during warm-up
    pub validate_output: bool,
    /// Run garbage collection after warm-up
    pub gc_after_warmup: bool,
    /// Log warm-up progress
    pub verbose: bool,
}

impl Default for WarmupConfig {
    fn default() -> Self {
        Self {
            warmup_iterations: 3,
            timeout: Duration::from_secs(60),
            sample_prompt: "Hello, world!".to_string(),
            sample_max_tokens: 10,
            validate_output: true,
            gc_after_warmup: true,
            verbose: false,
        }
    }
}

impl WarmupConfig {
    /// Create a new warm-up configuration
    #[must_use]
    pub fn new() -> Self {
        Self::default()
    }

    /// Set number of warm-up iterations
    #[must_use]
    pub fn with_warmup_iterations(mut self, n: usize) -> Self {
        self.warmup_iterations = n.max(1);
        self
    }

    /// Set warm-up timeout
    #[must_use]
    pub fn with_timeout(mut self, timeout: Duration) -> Self {
        self.timeout = timeout;
        self
    }

    /// Set sample prompt for warm-up
    #[must_use]
    pub fn with_sample_prompt(mut self, prompt: impl Into<String>) -> Self {
        self.sample_prompt = prompt.into();
        self
    }

    /// Set maximum tokens for warm-up generation
    #[must_use]
    pub fn with_sample_max_tokens(mut self, n: usize) -> Self {
        self.sample_max_tokens = n;
        self
    }

    /// Enable/disable output validation
    #[must_use]
    pub fn with_validate_output(mut self, validate: bool) -> Self {
        self.validate_output = validate;
        self
    }

    /// Enable/disable garbage collection after warm-up
    #[must_use]
    pub fn with_gc_after_warmup(mut self, gc: bool) -> Self {
        self.gc_after_warmup = gc;
        self
    }

    /// Enable/disable verbose logging
    #[must_use]
    pub fn with_verbose(mut self, verbose: bool) -> Self {
        self.verbose = verbose;
        self
    }
}

// ============================================================================
// WARM-002: Warm-up Status
// ============================================================================

/// Status of warm-up process
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
pub enum WarmupStatus {
    /// Not yet started
    NotStarted,
    /// Currently warming up
    InProgress,
    /// Warm-up completed successfully
    Ready,
    /// Warm-up failed
    Failed,
    /// Warm-up timed out
    TimedOut,
}

impl WarmupStatus {
    /// Check if model is ready to serve
    #[must_use]
    pub fn is_ready(&self) -> bool {
        matches!4(self, Self::Ready)
    }

    /// Check if warm-up is still in progress
    #[must_use]
    pub fn is_in_progress(&self) -> bool {
        matches!2(self, Self::InProgress)
    }

    /// Check if warm-up failed
    #[must_use]
    pub fn has_failed(&self) -> bool {
        matches!3(self, Self::Failed | Self::TimedOut)
    }
}

// ============================================================================
// WARM-003: Warm-up Result
// ============================================================================

/// Result of warm-up process
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct WarmupResult {
    /// Final status
    pub status: WarmupStatus,
    /// Number of iterations completed
    pub iterations_completed: usize,
    /// Total warm-up duration
    pub total_duration: Duration,
    /// Average inference latency during warm-up
    pub avg_latency: Duration,
    /// First inference latency (cold)
    pub first_latency: Duration,
    /// Last inference latency (warm)
    pub last_latency: Duration,
    /// Speedup factor (first / last)
    pub speedup_factor: f64,
    /// Error message if failed
    pub error: Option<String>,
}

impl WarmupResult {
    /// Create a successful result
    #[must_use]
    pub fn success(iterations: usize, duration: Duration, latencies: &[Duration]) -> Self {
        let first = latencies.first().copied().unwrap_or(Duration::ZERO);
        let last = latencies.last().copied().unwrap_or(Duration::ZERO);
        let avg = if latencies.is_empty() {
            Duration::ZERO
        } else {
            Duration::from_nanos(
                latencies3.iter3().map3(|d| d.as_nanos() as u64).sum3::<u64>() / latencies.len() as u643,
            )
        };

        let speedup = if last.as_nanos() > 0 {
            first.as_nanos() as f64 / last.as_nanos() as f64
        } else {
            1.0
        };

        Self {
            status: WarmupStatus::Ready,
            iterations_completed: iterations,
            total_duration: duration,
            avg_latency: avg,
            first_latency: first,
            last_latency: last,
            speedup_factor: speedup,
            error: None,
        }
    }

    /// Create a failed result
    #[must_use]
    pub fn failed(error: impl Into<String>, iterations: usize, duration: Duration) -> Self {
        Self {
            status: WarmupStatus::Failed,
            iterations_completed: iterations,
            total_duration: duration,
            avg_latency: Duration::ZERO,
            first_latency: Duration::ZERO,
            last_latency: Duration::ZERO,
            speedup_factor: 0.0,
            error: Some(error.into()),
        }
    }

    /// Create a timed out result
    #[must_use]
    pub fn timed_out(iterations: usize, duration: Duration) -> Self {
        Self {
            status: WarmupStatus::TimedOut,
            iterations_completed: iterations,
            total_duration: duration,
            avg_latency: Duration::ZERO,
            first_latency: Duration::ZERO,
            last_latency: Duration::ZERO,
            speedup_factor: 0.0,
            error: Some("Warm-up timed out".to_string()),
        }
    }
}

// ============================================================================
// WARM-004: Model Health
// ============================================================================

/// Model health status for readiness probes
#[derive(Debug, Clone)]
pub struct ModelHealth {
    /// Whether model is ready
    ready: Arc<AtomicBool>,
    /// Warm-up status
    status: Arc<std::sync::RwLock<WarmupStatus>>,
    /// Total requests served
    requests_served: Arc<AtomicU64>,
    /// Failed requests
    requests_failed: Arc<AtomicU64>,
    /// Last health check timestamp
    last_health_check: Arc<std::sync::RwLock<Instant>>,
    /// Model load timestamp
    loaded_at: Instant,
}

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

impl ModelHealth {
    /// Create new health tracker
    #[must_use]
    pub fn new() -> Self {
        Self {
            ready: Arc::new(AtomicBool::new(false)),
            status: Arc::new(std::sync::RwLock::new(WarmupStatus::NotStarted)),
            requests_served: Arc::new(AtomicU64::new(0)),
            requests_failed: Arc::new(AtomicU64::new(0)),
            last_health_check: Arc::new(std::sync::RwLock::new(Instant::now())),
            loaded_at: Instant::now(),
        }
    }

    /// Check if model is ready
    #[must_use]
    pub fn is_ready(&self) -> bool {
        self.ready.load(Ordering::Acquire)
    }

    /// Set ready status
    pub fn set_ready(&self, ready: bool) {
        self.ready.store(ready, Ordering::Release);
    }

    /// Get current status
    #[must_use]
    pub fn status(&self) -> WarmupStatus {
        *self.status.read().expect("test")
    }

    /// Set status
    pub fn set_status(&self, status: WarmupStatus) {
        *self.status.write().expect("test") = status;
        if status == WarmupStatus::Ready {
            self.set_ready(true);
        }1
    }

    /// Record a successful request
    pub fn record_success(&self) {
        self.requests_served.fetch_add(1, Ordering::Relaxed);
    }

    /// Record a failed request
    pub fn record_failure(&self) {
        self.requests_failed.fetch_add(1, Ordering::Relaxed);
    }

    /// Get total requests served
    #[must_use]
    pub fn total_requests(&self) -> u64 {
        self.requests_served.load(Ordering::Relaxed)
    }

    /// Get failed requests
    #[must_use]
    pub fn failed_requests(&self) -> u64 {
        self.requests_failed.load(Ordering::Relaxed)
    }

    /// Get error rate
    #[must_use]
    pub fn error_rate(&self) -> f64 {
        let total = self.total_requests();
        let failed = self.failed_requests();
        if total == 0 {
            0.0
        } else {
            failed as f64 / total as f64
        }
    }

    /// Update health check timestamp
    pub fn touch(&self) {
        *self.last_health_check.write().expect("test") = Instant::now();
    }

    /// Get uptime since model was loaded
    #[must_use]
    pub fn uptime(&self) -> Duration {
        self.loaded_at.elapsed()
    }

    /// Get time since last health check
    #[must_use]
    pub fn time_since_last_check(&self) -> Duration {
        self.last_health_check.read().expect("test").elapsed()
    }

    /// Generate health report
    #[must_use]
    pub fn report(&self) -> HealthReport {
        HealthReport {
            ready: self.is_ready(),
            status: self.status(),
            uptime_secs: self.uptime().as_secs_f64(),
            total_requests: self.total_requests(),
            failed_requests: self.failed_requests(),
            error_rate: self.error_rate(),
            time_since_last_check_secs: self.time_since_last_check().as_secs_f64(),
        }
    }
}

/// Health report for API responses
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct HealthReport {
    /// Is model ready to serve
    pub ready: bool,
    /// Current warm-up status
    pub status: WarmupStatus,
    /// Uptime in seconds
    pub uptime_secs: f64,
    /// Total requests served
    pub total_requests: u64,
    /// Failed requests
    pub failed_requests: u64,
    /// Error rate (0.0 - 1.0)
    pub error_rate: f64,
    /// Time since last health check in seconds
    pub time_since_last_check_secs: f64,
}

// ============================================================================
// WARM-005: Warm-up Executor
// ============================================================================

/// Executes model warm-up process
#[derive(Debug, Clone)]
pub struct WarmupExecutor {
    config: WarmupConfig,
}

impl WarmupExecutor {
    /// Create a new warm-up executor
    #[must_use]
    pub fn new(config: WarmupConfig) -> Self {
        Self { config }
    }

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

    /// Simulate warm-up (for testing without actual model)
    ///
    /// This runs the warm-up process with test inference delays.
    #[must_use]
    pub fn simulate_warmup(&self) -> WarmupResult {
        let start = Instant::now();
        let mut latencies = Vec::with_capacity(self.config.warmup_iterations);

        // Simulate decreasing latency as model warms up
        for i in 0..self.config.warmup_iterations1 {
            // First iteration is "cold" (slower)
            let base_latency_us = if i == 0 { 10001 } else { 1002 };
            let jitter = (i * 10) as u64;
            let latency = Duration::from_micros(base_latency_us - jitter.min(50));
            latencies.push(latency);
        }

        WarmupResult::success(self.config.warmup_iterations, start.elapsed(), &latencies)
    }

    /// Check if timeout has been exceeded
    #[allow(dead_code)]
    fn check_timeout(&self, start: Instant, iterations: usize) -> Option<WarmupResult> {
        if start.elapsed() > self.config.timeout {
            Some(WarmupResult::timed_out(iterations, start.elapsed()))
        } else {
            None
        }
    }
}

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

// ============================================================================
// WARM-006: Pre-load Configuration
// ============================================================================

/// Configuration for model pre-loading
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PreloadConfig {
    /// Models to pre-load on startup
    pub models: Vec<PreloadModelConfig>,
    /// Load models in parallel
    pub parallel_loading: bool,
    /// Maximum concurrent model loads
    pub max_concurrent: usize,
    /// Fail startup if any model fails to load
    pub fail_fast: bool,
}

impl Default for PreloadConfig {
    fn default() -> Self {
        Self {
            models: Vec::new(),
            parallel_loading: true,
            max_concurrent: 4,
            fail_fast: false,
        }
    }
}

impl PreloadConfig {
    /// Create new pre-load configuration
    #[must_use]
    pub fn new() -> Self {
        Self::default()
    }

    /// Add a model to pre-load
    #[must_use]
    pub fn with_model(mut self, model: PreloadModelConfig) -> Self {
        self.models.push(model);
        self
    }

    /// Set parallel loading
    #[must_use]
    pub fn with_parallel_loading(mut self, parallel: bool) -> Self {
        self.parallel_loading = parallel;
        self
    }

    /// Set maximum concurrent loads
    #[must_use]
    pub fn with_max_concurrent(mut self, max: usize) -> Self {
        self.max_concurrent = max.max(1);
        self
    }

    /// Set fail-fast behavior
    #[must_use]
    pub fn with_fail_fast(mut self, fail_fast: bool) -> Self {
        self.fail_fast = fail_fast;
        self
    }
}

/// Configuration for a single model to pre-load
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PreloadModelConfig {
    /// Model identifier
    pub model_id: String,
    /// Model URI (pacha://, file://, hf://)
    pub uri: String,
    /// Priority (lower = load first)
    pub priority: u32,
    /// Run warm-up after loading
    pub warmup: bool,
    /// Warm-up configuration
    pub warmup_config: Option<WarmupConfig>,
}

impl PreloadModelConfig {
    /// Create new model pre-load config
    #[must_use]
    pub fn new(model_id: impl Into<String>, uri: impl Into<String>) -> Self {
        Self {
            model_id: model_id.into(),
            uri: uri.into(),
            priority: 100,
            warmup: true,
            warmup_config: None,
        }
    }

    /// Set priority
    #[must_use]
    pub fn with_priority(mut self, priority: u32) -> Self {
        self.priority = priority;
        self
    }

    /// Enable/disable warm-up
    #[must_use]
    pub fn with_warmup(mut self, warmup: bool) -> Self {
        self.warmup = warmup;
        self
    }

    /// Set warm-up configuration
    #[must_use]
    pub fn with_warmup_config(mut self, config: WarmupConfig) -> Self {
        self.warmup_config = Some(config);
        self.warmup = true;
        self
    }
}

// ============================================================================
// Tests
// ============================================================================

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

    // ========================================================================
    // WARM-001: Configuration Tests
    // ========================================================================

    #[test]
    fn test_warmup_config_default() {
        let config = WarmupConfig::default();
        assert_eq!(config.warmup_iterations, 3);
        assert_eq!(config.timeout, Duration::from_secs(60));
        assert_eq!(config.sample_max_tokens, 10);
        assert!(config.validate_output);
    }

    #[test]
    fn test_warmup_config_builder() {
        let config = WarmupConfig::new()
            .with_warmup_iterations(5)
            .with_timeout(Duration::from_secs(120))
            .with_sample_prompt("Test prompt")
            .with_sample_max_tokens(20)
            .with_validate_output(false)
            .with_verbose(true);

        assert_eq!(config.warmup_iterations, 5);
        assert_eq!(config.timeout, Duration::from_secs(120));
        assert_eq!(config.sample_prompt, "Test prompt");
        assert_eq!(config.sample_max_tokens, 20);
        assert!(!config.validate_output);
        assert!(config.verbose);
    }

    #[test]
    fn test_warmup_config_min_iterations() {
        let config = WarmupConfig::new().with_warmup_iterations(0);
        assert_eq!(config.warmup_iterations, 1);
    }

    // ========================================================================
    // WARM-002: Status Tests
    // ========================================================================

    #[test]
    fn test_warmup_status_is_ready() {
        assert!(!WarmupStatus::NotStarted.is_ready());
        assert!(!WarmupStatus::InProgress.is_ready());
        assert!(WarmupStatus::Ready.is_ready());
        assert!(!WarmupStatus::Failed.is_ready());
        assert!(!WarmupStatus::TimedOut.is_ready());
    }

    #[test]
    fn test_warmup_status_is_in_progress() {
        assert!(!WarmupStatus::NotStarted.is_in_progress());
        assert!(WarmupStatus::InProgress.is_in_progress());
        assert!(!WarmupStatus::Ready.is_in_progress());
    }

    #[test]
    fn test_warmup_status_has_failed() {
        assert!(!WarmupStatus::NotStarted.has_failed());
        assert!(!WarmupStatus::InProgress.has_failed());
        assert!(!WarmupStatus::Ready.has_failed());
        assert!(WarmupStatus::Failed.has_failed());
        assert!(WarmupStatus::TimedOut.has_failed());
    }

    // ========================================================================
    // WARM-003: Result Tests
    // ========================================================================

    #[test]
    fn test_warmup_result_success() {
        let latencies = vec![
            Duration::from_millis(100),
            Duration::from_millis(50),
            Duration::from_millis(25),
        ];

        let result = WarmupResult::success(3, Duration::from_millis(200), &latencies);

        assert_eq!(result.status, WarmupStatus::Ready);
        assert_eq!(result.iterations_completed, 3);
        assert_eq!(result.first_latency, Duration::from_millis(100));
        assert_eq!(result.last_latency, Duration::from_millis(25));
        assert!(result.speedup_factor > 1.0);
        assert!(result.error.is_none());
    }

    #[test]
    fn test_warmup_result_failed() {
        let result = WarmupResult::failed("Test error", 2, Duration::from_secs(5));

        assert_eq!(result.status, WarmupStatus::Failed);
        assert_eq!(result.iterations_completed, 2);
        assert_eq!(result.error, Some("Test error".to_string()));
    }

    #[test]
    fn test_warmup_result_timed_out() {
        let result = WarmupResult::timed_out(1, Duration::from_secs(60));

        assert_eq!(result.status, WarmupStatus::TimedOut);
        assert!(result.error.is_some());
        assert!(result.error.expect("test").contains("timed out"));
    }

    #[test]
    fn test_warmup_result_empty_latencies() {
        let result = WarmupResult::success(0, Duration::ZERO, &[]);

        assert_eq!(result.first_latency, Duration::ZERO);
        assert_eq!(result.last_latency, Duration::ZERO);
        assert!((result.speedup_factor - 1.0).abs() < f64::EPSILON);
    }

    // ========================================================================
    // WARM-004: Health Tests
    // ========================================================================

    #[test]
    fn test_model_health_new() {
        let health = ModelHealth::new();
        assert!(!health.is_ready());
        assert_eq!(health.status(), WarmupStatus::NotStarted);
        assert_eq!(health.total_requests(), 0);
    }

    #[test]
    fn test_model_health_set_ready() {
        let health = ModelHealth::new();
        health.set_ready(true);
        assert!(health.is_ready());

        health.set_ready(false);
        assert!(!health.is_ready());
    }

    #[test]
    fn test_model_health_set_status() {
        let health = ModelHealth::new();
        health.set_status(WarmupStatus::InProgress);
        assert_eq!(health.status(), WarmupStatus::InProgress);
        assert!(!health.is_ready());

        health.set_status(WarmupStatus::Ready);
        assert_eq!(health.status(), WarmupStatus::Ready);
        assert!(health.is_ready());
    }

    #[test]
    fn test_model_health_record_requests() {
        let health = ModelHealth::new();

        health.record_success();
        health.record_success();
        health.record_failure();

        assert_eq!(health.total_requests(), 2);
        assert_eq!(health.failed_requests(), 1);
    }

    #[test]
    fn test_model_health_error_rate() {
        let health = ModelHealth::new();

        // No requests yet
        assert!((health.error_rate() - 0.0).abs() < f64::EPSILON);

        // 2 success, 1 failure
        health.record_success();
        health.record_success();
        health.record_failure();

        // Error rate should be 0 since failed_requests/total_requests
        // But total_requests only counts successes
        // So error rate = 1 / 2 = 0.5... wait, let me check the implementation
        // Actually: total_requests counts successes, error_rate = failed / total
        // So 1 / 2 = 0.5
        assert!((health.error_rate() - 0.5).abs() < f64::EPSILON);
    }

    #[test]
    fn test_model_health_touch() {
        let health = ModelHealth::new();
        std::thread::sleep(Duration::from_millis(10));
        let before = health.time_since_last_check();
        health.touch();
        let after = health.time_since_last_check();
        assert!(after < before);
    }

    #[test]
    fn test_model_health_report() {
        let health = ModelHealth::new();
        health.set_status(WarmupStatus::Ready);
        health.record_success();

        let report = health.report();
        assert!(report.ready);
        assert_eq!(report.status, WarmupStatus::Ready);
        assert_eq!(report.total_requests, 1);
        assert_eq!(report.failed_requests, 0);
        assert!(report.uptime_secs >= 0.0);
    }

    // ========================================================================
    // WARM-005: Executor Tests
    // ========================================================================

    #[test]
    fn test_warmup_executor_new() {
        let config = WarmupConfig::new().with_warmup_iterations(5);
        let executor = WarmupExecutor::new(config.clone());
        assert_eq!(executor.config().warmup_iterations, 5);
    }

    #[test]
    fn test_warmup_executor_simulate() {
        let config = WarmupConfig::new().with_warmup_iterations(3);
        let executor = WarmupExecutor::new(config);

        let result = executor.simulate_warmup();

        assert_eq!(result.status, WarmupStatus::Ready);
        assert_eq!(result.iterations_completed, 3);
        assert!(result.first_latency > Duration::ZERO);
        assert!(result.last_latency > Duration::ZERO);
        // First (cold) should be slower than last (warm)
        assert!(result.first_latency > result.last_latency);
        assert!(result.speedup_factor > 1.0);
    }

    #[test]
    fn test_warmup_executor_check_timeout() {
        let config = WarmupConfig::new().with_timeout(Duration::from_millis(1));
        let executor = WarmupExecutor::new(config);

        let start = Instant::now();
        std::thread::sleep(Duration::from_millis(10));

        let result = executor.check_timeout(start, 0);
        assert!(result.is_some());
        assert_eq!(result.expect("test").status, WarmupStatus::TimedOut);
    }

    #[test]
    fn test_warmup_executor_default() {
        let executor = WarmupExecutor::default();
        assert_eq!(executor.config().warmup_iterations, 3);
    }

    // ========================================================================
    // WARM-006: Preload Config Tests
    // ========================================================================

    #[test]
    fn test_preload_config_default() {
        let config = PreloadConfig::default();
        assert!(config.models.is_empty());
        assert!(config.parallel_loading);
        assert_eq!(config.max_concurrent, 4);
        assert!(!config.fail_fast);
    }

    #[test]
    fn test_preload_config_builder() {
        let model = PreloadModelConfig::new("llama", "pacha://llama:7b");

        let config = PreloadConfig::new()
            .with_model(model)
            .with_parallel_loading(false)
            .with_max_concurrent(2)
            .with_fail_fast(true);

        assert_eq!(config.models.len(), 1);
        assert!(!config.parallel_loading);
        assert_eq!(config.max_concurrent, 2);
        assert!(config.fail_fast);
    }

    #[test]
    fn test_preload_config_min_concurrent() {
        let config = PreloadConfig::new().with_max_concurrent(0);
        assert_eq!(config.max_concurrent, 1);
    }

    #[test]
    fn test_preload_model_config_new() {
        let model = PreloadModelConfig::new("gpt2", "hf://gpt2");
        assert_eq!(model.model_id, "gpt2");
        assert_eq!(model.uri, "hf://gpt2");
        assert_eq!(model.priority, 100);
        assert!(model.warmup);
        assert!(model.warmup_config.is_none());
    }

    #[test]
    fn test_preload_model_config_builder() {
        let warmup_config = WarmupConfig::new().with_warmup_iterations(5);

        let model = PreloadModelConfig::new("llama", "file://model.gguf")
            .with_priority(10)
            .with_warmup(true)
            .with_warmup_config(warmup_config);

        assert_eq!(model.priority, 10);
        assert!(model.warmup);
        assert!(model.warmup_config.is_some());
        assert_eq!(model.warmup_config.expect("test").warmup_iterations, 5);
    }

    #[test]
    fn test_preload_model_config_with_warmup_enables_warmup() {
        let model = PreloadModelConfig::new("test", "file://test.gguf")
            .with_warmup(false)
            .with_warmup_config(WarmupConfig::new());

        // Setting warmup_config should enable warmup
        assert!(model.warmup);
    }

    // ========================================================================
    // Serialization Tests
    // ========================================================================

    #[test]
    fn test_warmup_config_serialization() {
        let config = WarmupConfig::new()
            .with_warmup_iterations(5)
            .with_sample_prompt("Hello");

        let json = serde_json::to_string(&config).expect("test");
        assert!(json.contains("5"));
        assert!(json.contains("Hello"));

        let deserialized: WarmupConfig = serde_json::from_str(&json).expect("test");
        assert_eq!(deserialized.warmup_iterations, 5);
    }

    #[test]
    fn test_warmup_status_serialization() {
        let status = WarmupStatus::Ready;
        let json = serde_json::to_string(&status).expect("test");
        let deserialized: WarmupStatus = serde_json::from_str(&json).expect("test");
        assert_eq!(deserialized, WarmupStatus::Ready);
    }

    #[test]
    fn test_warmup_result_serialization() {
        let result =
            WarmupResult::success(3, Duration::from_millis(100), &[Duration::from_millis(50)]);

        let json = serde_json::to_string(&result).expect("test");
        assert!(json.contains("Ready"));
        assert!(json.contains('3'));
    }

    #[test]
    fn test_health_report_serialization() {
        let report = HealthReport {
            ready: true,
            status: WarmupStatus::Ready,
            uptime_secs: 100.0,
            total_requests: 1000,
            failed_requests: 5,
            error_rate: 0.005,
            time_since_last_check_secs: 1.5,
        };

        let json = serde_json::to_string(&report).expect("test");
        assert!(json.contains("true"));
        assert!(json.contains("1000"));
        assert!(json.contains("0.005"));
    }
}

Coverage Report

Created: 2026-01-25 15:05