ralph-workflow 0.7.18

// Runtime operations: sleep, timers, etc.

use std::sync::Arc;
use std::time::Duration;

/// Provider for sleep operations in retry logic.
///
/// This trait allows different sleep implementations:
/// - Production: Real `std::thread::sleep` with actual delays
/// - Testing: Immediate (no-op) sleeps for fast test execution
pub trait RetryTimerProvider: Send + Sync {
    fn sleep(&self, duration: Duration);
}

pub trait RetryTimerProviderDebug: RetryTimerProvider + std::fmt::Debug {}
impl<T: RetryTimerProvider + std::fmt::Debug> RetryTimerProviderDebug for T {}

/// Production retry timer that actually sleeps.
#[derive(Debug, Clone)]
pub struct ProductionRetryTimer;

impl RetryTimerProvider for ProductionRetryTimer {
    fn sleep(&self, duration: Duration) {
        std::thread::sleep(duration);
    }
}

/// Create a new production retry timer.
pub fn production_timer() -> Arc<dyn RetryTimerProviderDebug> {
    Arc::new(ProductionRetryTimer)
}

/// Perform a blocking sleep for use by timer implementations outside boundary modules.
pub fn do_sleep(duration: Duration) {
    std::thread::sleep(duration);
}

/// Read an environment variable for use by non-boundary callers.
pub fn get_env_var(key: &str) -> Option<String> {
    std::env::var(key).ok()
}