modrun 1.1.0

Modular application composer for Tokio: domain modules, typed wiring, lifecycle
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

//! Swap a replaceable dependency at the composition root.
//!
//! Domain modules depend on `Repo` but do not `provide` it. Production wires a
//! real constructor; tests `supply` a fake. Providing `Repo` inside the module
//! would make `supply(fake)` fail with "already provided".
//!
//! ```bash
//! cargo run --example swap
//! ```

use modrun::logging::init;
use modrun::{Lifecycle, Modrun, Module, hook};

#[derive(Clone)]
struct Repo {
    label: &'static str,
}

#[derive(Clone)]
struct Service {
    repo: Repo,
}

fn connect_repo() -> Repo {
    Repo { label: "postgres" }
}

fn fake_repo() -> Repo {
    Repo { label: "fake" }
}

fn new_service(repo: Repo) -> Service {
    Service { repo }
}

fn boot(lc: Lifecycle, service: Service) -> modrun::Result<()> {
    let label = service.repo.label;
    lc.append(hook().name("svc").on_start(move || async move {
        println!("service using {label}");
        Ok(())
    }))
}

fn user_domain() -> Module {
    Module::builder("user").provide(new_service).invoke(boot)
}

#[tokio::main]
async fn main() -> modrun::Result<()> {
    init();

    println!("-- production --");
    Modrun::builder()
        .no_banner()
        .provide(connect_repo)
        .module(user_domain())
        .start()
        .await?
        .stop()
        .await?;

    println!("-- test --");
    Modrun::builder()
        .no_banner()
        .supply(fake_repo())
        .module(user_domain())
        .start()
        .await?
        .stop()
        .await
}