hatchery_server/
lib.rs

1//! Host for hatchery subservices. See `deploy/README.md`.
2
3pub mod config;
4pub mod control;
5pub mod error;
6#[cfg(feature = "m4a")]
7pub mod m4a;
8#[cfg(feature = "memory")]
9pub mod memory;
10#[cfg(feature = "m4a")]
11pub mod hub;
12#[cfg(feature = "m4a")]
13pub mod m4a_link;
14pub mod node_controller;
15pub mod drain_consumer;
16pub mod operator_control;
17pub mod mesh_runtime;
18#[cfg(feature = "m4a")]
19pub mod node_sink;
20#[cfg(feature = "m4a")]
21#[cfg(feature = "m4a")]
22pub mod provision;
23#[cfg(feature = "m4a")]
24pub mod tasks;
25pub mod routing;
26pub mod subservice;
27pub mod supervisor;
28
29pub use config::ServerConfig;
30pub use error::ServerError;
31pub use subservice::{State, Status, Subservice};
32pub use supervisor::Supervisor;
33
34/// Build the subservices enabled by features and configuration.
35pub fn build_subservices(config: &ServerConfig) -> Vec<Box<dyn Subservice>> {
36    #[allow(unused_mut)]
37    let mut services: Vec<Box<dyn Subservice>> = Vec::new();
38    #[cfg(feature = "m4a")]
39    if config.m4a_enabled {
40        services.push(Box::new(m4a::M4aSubservice::new(
41            &config.data_dir,
42            config.m4a_master_key_var.clone(),
43        )));
44    }
45    #[cfg(feature = "m4a")]
46    if let (true, Some(master), Some(c2_addr)) =
47        (config.m4a_enabled, config.m4a_master_key_var.clone(), config.provision_c2_addr.clone())
48    {
49        services.push(Box::new(provision::ProvisionSubservice::new(provision::ProvisionConfig {
50            data_dir: config.data_dir.clone(),
51            master_key_var: master,
52            c2_addr,
53            c2_token_var: config.provision_c2_token_var.clone(),
54            interval: std::time::Duration::from_secs(config.provision_interval_secs),
55            server_ref: config.m4a_server_ref.clone(),
56            mail_domain: config.mail_domain.clone(),
57            policy_path: config.policy_path.clone(),
58        })));
59    }
60    #[cfg(feature = "memory")]
61    services.push(Box::new(memory::MemorySubservice::new(
62        config.memory_bin.clone(),
63        &config.data_dir,
64    )));
65    let _ = config;
66    services
67}
hatchery_server/lib.rs

hatchery_server/
lib.rs
