architecturekit 0.11.0

Building blocks for DDD-based applications with CQRS and event sourcing, on top of the EventSourcingDB by the native web.
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

// ArchitectureKit for Go tests its state cache only through Load and Execute,
// which the tests of the store mirror. These tests check what those can not
// show reliably: which of two states of the same subject the cache keeps, and
// which subject it evicts.

use super::StateCache;

#[derive(Clone, Debug, PartialEq)]
struct Count(u32);

#[derive(Clone, Debug, PartialEq)]
struct Sum(u32);

#[test]
fn holds_nothing_for_a_subject_it_was_not_given() {
    let cache = StateCache::new(10);

    assert_eq!(cache.get::<Count>("/books/42"), None);
}

#[test]
fn hands_out_a_state_with_the_id_of_the_last_event_it_was_built_from() {
    let cache = StateCache::new(10);

    cache.put("/books/42", Count(2), "7".to_owned());

    assert_eq!(
        cache.get::<Count>("/books/42"),
        Some((Count(2), "7".to_owned()))
    );
}

#[test]
fn keeps_states_of_different_types_on_the_same_subject_apart() {
    let cache = StateCache::new(10);

    cache.put("/books/42", Count(2), "7".to_owned());
    cache.put("/books/42", Sum(9), "7".to_owned());

    assert_eq!(
        cache.get::<Count>("/books/42"),
        Some((Count(2), "7".to_owned()))
    );
    assert_eq!(
        cache.get::<Sum>("/books/42"),
        Some((Sum(9), "7".to_owned()))
    );
}

#[test]
fn keeps_the_state_built_from_the_later_event() {
    let cache = StateCache::new(10);

    // Two commands on the same subject may finish in any order, and the one
    // that read less must not replace the one that read more. The IDs are
    // compared as numbers, so 10 is later than 9.
    cache.put("/books/42", Count(10), "10".to_owned());
    cache.put("/books/42", Count(9), "9".to_owned());
    assert_eq!(
        cache.get::<Count>("/books/42"),
        Some((Count(10), "10".to_owned()))
    );

    cache.put("/books/42", Count(11), "10".to_owned());
    assert_eq!(
        cache.get::<Count>("/books/42"),
        Some((Count(11), "10".to_owned())),
        "a state built from the same event replaces the cached one"
    );

    cache.put("/books/42", Count(12), "12".to_owned());
    assert_eq!(
        cache.get::<Count>("/books/42"),
        Some((Count(12), "12".to_owned()))
    );
}

#[test]
fn evicts_the_subject_used_least_recently() {
    let cache = StateCache::new(2);

    cache.put("/books/1", Count(1), "1".to_owned());
    cache.put("/books/2", Count(2), "2".to_owned());
    let _ = cache.get::<Count>("/books/1");
    cache.put("/books/3", Count(3), "3".to_owned());

    assert!(cache.get::<Count>("/books/1").is_some(), "it was used last");
    assert_eq!(
        cache.get::<Count>("/books/2"),
        None,
        "it was used least recently"
    );
    assert!(cache.get::<Count>("/books/3").is_some());
}

#[test]
fn counts_a_subject_that_is_given_again_once() {
    let cache = StateCache::new(2);

    cache.put("/books/1", Count(1), "1".to_owned());
    cache.put("/books/2", Count(2), "2".to_owned());
    cache.put("/books/1", Count(3), "3".to_owned());
    cache.put("/books/2", Count(4), "4".to_owned());

    assert_eq!(
        cache.get::<Count>("/books/1"),
        Some((Count(3), "3".to_owned()))
    );
    assert_eq!(
        cache.get::<Count>("/books/2"),
        Some((Count(4), "4".to_owned()))
    );
}

#[test]
fn counts_a_state_of_another_type_as_another_subject() {
    let cache = StateCache::new(1);

    cache.put("/books/42", Count(2), "7".to_owned());
    cache.put("/books/42", Sum(9), "7".to_owned());

    assert_eq!(cache.get::<Count>("/books/42"), None);
    assert_eq!(
        cache.get::<Sum>("/books/42"),
        Some((Sum(9), "7".to_owned()))
    );
}