camel-api 0.5.8

use crate::{CamelError, MetricsCollector};
use async_trait::async_trait;
use serde::{Deserialize, Serialize};
use std::sync::Arc;

/// Status of a Lifecycle service.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
pub enum ServiceStatus {
    Stopped,
    Started,
    Failed,
}

/// Aggregated system health status.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
pub enum HealthStatus {
    Healthy,
    Unhealthy,
}

/// Lifecycle trait for background services.
///
/// This trait follows Apache Camel's Service pattern but uses a different name
/// to avoid confusion with tower::Service which is the core of rust-camel's
/// request processing.
///
/// # Why `&mut self`?
///
/// The `start()` and `stop()` methods require `&mut self` to ensure:
/// - **Exclusive access**: Prevents concurrent start/stop operations on the same service
/// - **Safe state transitions**: Services can safely mutate their internal state
/// - **No data races**: Compile-time guarantee of single-threaded access to service state
///
/// This design choice trades flexibility for safety - services cannot be started/stopped
/// concurrently, which simplifies implementation and prevents race conditions.
#[async_trait]
pub trait Lifecycle: Send + Sync {
    /// Service name for logging
    fn name(&self) -> &str;

    /// Start service (called during CamelContext.start())
    async fn start(&mut self) -> Result<(), CamelError>;

    /// Stop service (called during CamelContext.stop())
    async fn stop(&mut self) -> Result<(), CamelError>;

    /// Optional: expose MetricsCollector for auto-registration
    fn as_metrics_collector(&self) -> Option<Arc<dyn MetricsCollector>> {
        None
    }

    /// Current status of the service.
    fn status(&self) -> ServiceStatus {
        ServiceStatus::Stopped
    }
}

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

    struct TestService;

    #[async_trait]
    impl Lifecycle for TestService {
        fn name(&self) -> &str {
            "test"
        }

        async fn start(&mut self) -> Result<(), CamelError> {
            Ok(())
        }

        async fn stop(&mut self) -> Result<(), CamelError> {
            Ok(())
        }
    }

    #[tokio::test]
    async fn test_lifecycle_trait() {
        let mut service = TestService;
        assert_eq!(service.name(), "test");
        service.start().await.unwrap();
        service.stop().await.unwrap();
    }

    #[test]
    fn test_default_status_is_stopped() {
        let service = TestService;
        assert_eq!(service.status(), ServiceStatus::Stopped);
    }
}