amethystate 0.26.0

A state manager for Rust applications
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

use amethystate::amethystate;
use amethystate::store::builder::{Backend, StoreBuilder};
use amethystate::store::instances::resolve_instance;
use amethystate_core::test_utils::TempPath;
use amethystate_test_macros::backends;
use uuid::Uuid;

#[amethystate(prefix = "registry")]
pub struct Tracked {
    #[amestate(default = 0)]
    pub port: u16,
}

fn store(backend: Backend, tag: &str) -> (TempPath, amethystate::Store) {
    let at = TempPath::new(tag);
    let store = StoreBuilder::new(&at).backend(backend).build().unwrap();
    (at, store)
}

#[backends(all)]
fn an_instance_leaves_the_registry_when_it_drops(backend: Backend) {
    let (_at, s) = store(backend, "drop");
    let id = Uuid::new_v4();

    {
        let _state = Tracked::new_with_id(&s, id).unwrap();
        assert!(resolve_instance(id).is_some(), "registered while alive");
    }

    assert!(resolve_instance(id).is_none(), "dropped from the registry");
}

#[backends(all)]
fn a_clone_keeps_the_instance_alive(backend: Backend) {
    let (_at, s) = store(backend, "clone");
    let id = Uuid::new_v4();

    let state = Tracked::new_with_id(&s, id).unwrap();
    let clone = state.clone();

    drop(state);
    assert!(
        resolve_instance(id).is_some(),
        "the surviving clone still resolves"
    );

    drop(clone);
    assert!(resolve_instance(id).is_none(), "the last clone released it");
}

#[backends(all)]
fn repeated_construction_does_not_accumulate(backend: Backend) {
    let (_at, s) = store(backend, "churn");
    let ids: Vec<Uuid> = (0..64).map(|_| Uuid::new_v4()).collect();

    for id in &ids {
        let _state = Tracked::new_with_id(&s, *id).unwrap();
    }

    let still_registered = ids.iter().filter(|id| resolve_instance(**id).is_some());
    assert_eq!(still_registered.count(), 0, "nothing left behind");
}