summer 0.5.1

Rust microservice framework like spring boot in java
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//! Service is a special Component that supports dependency injection at compile time
#![doc = include_str!("../../DI.md")]
use crate::app::AppBuilder;
use crate::config::ConfigRegistry;
use crate::error::Result;
use crate::plugin::ComponentRegistry;

pub use summer_macros::Service;

/// Service is a special Component that can inject dependent Components as field members
/// ```rust
/// use summer::plugin::service::Service;
/// use summer_sqlx::ConnectPool;
///
/// #[derive(Clone, Service)]
/// struct UserService {
///     #[inject(component)]
///     db: ConnectPool
/// }
/// ```
pub trait Service: Clone + Sized + 'static {
    /// Construct the Service component
    fn build<R>(registry: &R) -> Result<Self>
    where
        R: ComponentRegistry + ConfigRegistry;
}

//////////////////////////////////////////////////
/// Install the Service component into the App
pub trait ServiceRegistrar: Send + Sync + 'static {
    /// Install the Service component into the App
    fn install_service(&self, app: &mut AppBuilder) -> Result<()>;
}

inventory::collect!(&'static dyn ServiceRegistrar);

/// auto_config
#[macro_export]
macro_rules! submit_service {
    ($ty:ident) => {
        ::summer::submit_inventory! {
            &$ty as &dyn ::summer::plugin::service::ServiceRegistrar
        }
    };
}

/// Find all ServiceRegistrar and install them into the app
pub fn auto_inject_service(app: &mut AppBuilder) -> Result<()> {
    let registrars: Vec<&'static &dyn ServiceRegistrar> =
        inventory::iter::<&dyn ServiceRegistrar>().collect();
    let total = registrars.len();
    let mut pending: Vec<&'static &dyn ServiceRegistrar> = registrars;
    let mut installed = 0;

    while !pending.is_empty() {
        let mut next_pending = Vec::new();
        let mut progress_made = false;

        for registrar in pending {
            match registrar.install_service(app) {
                Ok(()) => {
                    installed += 1;
                    progress_made = true;
                }
                Err(_) => {
                    next_pending.push(registrar);
                }
            }
        }

        if !progress_made && !next_pending.is_empty() {
            if let Some(first) = next_pending.first() {
                return first.install_service(app);
            }
        }

        pending = next_pending;
    }

    log::debug!("Installed {installed}/{total} services");
    Ok(())
}