injectable-rs 0.1.0

A compile-time dependency injection framework for Rust using extractor-based DI
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

//! Unit tests for Container methods not exercised by other tests:
//! registered_types, try_resolve, try_resolve_external, destructor_count, shutdown.

use injectable_rs::prelude::*;

// ── Minimal injectable leaf type ──────────────────────────────────────────────

#[injectable]
#[derive(Default, Clone, Debug)]
struct LeafForContainer;

// ── Type with pre_destruct to test destructor_count ───────────────────────────

#[derive(Clone, Debug)]
struct DestructibleSvc;

#[injectable]
impl DestructibleSvc {
    #[injectable(ctor)]
    fn new() -> Self {
        Self
    }

    #[injectable(pre_destruct)]
    async fn cleanup(&self) -> HookResult {
        Ok(())
    }
}

// ─── Tests ────────────────────────────────────────────────────────────────────

#[tokio::test]
async fn registered_types_contains_known_type() {
    let container = Container::builder().build().await.unwrap();
    let types = container.registered_types();
    // LeafForContainer is linked in — must appear in the inventory
    assert!(
        types.contains(&"LeafForContainer"),
        "registered_types() should contain 'LeafForContainer', got: {types:?}"
    );
}

#[tokio::test]
async fn try_resolve_returns_some_for_registered_type() {
    let container = Container::builder().build().await.unwrap();
    let result = container.try_resolve::<LeafForContainer>().await.unwrap();
    assert!(result.is_some());
}

#[tokio::test]
async fn try_resolve_external_returns_none_for_unregistered() {
    let container = Container::builder().build().await.unwrap();
    let result = container.try_resolve_external::<String>().await.unwrap();
    assert!(result.is_none());
}

#[tokio::test]
async fn try_resolve_external_returns_some_when_registered() {
    let container = Container::builder()
        .register("", DynProvider::from_value(42u32))
        .build()
        .await
        .unwrap();
    let result = container.try_resolve_external::<u32>().await.unwrap();
    assert_eq!(result, Some(42));
}

#[tokio::test]
async fn destructor_count_zero_before_resolve() {
    let container = Container::builder().build().await.unwrap();
    assert_eq!(container.destructor_count().await, 0);
}

#[tokio::test]
async fn destructor_count_increases_after_resolving_pre_destruct_type() {
    let container = Container::builder().build().await.unwrap();
    let _svc: DestructibleSvc = container.resolve().await.unwrap();
    assert!(
        container.destructor_count().await > 0,
        "resolving a type with #[injectable(pre_destruct)] should register a destructor"
    );
}

#[tokio::test]
async fn shutdown_succeeds_with_no_hooks() {
    let container = Container::builder().build().await.unwrap();
    assert!(container.shutdown().await.is_ok());
}

#[tokio::test]
async fn shutdown_runs_pre_destruct_and_empties_destructors() {
    let container = Container::builder().build().await.unwrap();
    let _svc: DestructibleSvc = container.resolve().await.unwrap();
    assert!(container.destructor_count().await > 0);
    container.shutdown().await.unwrap();
    assert_eq!(container.destructor_count().await, 0);
}