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 std::collections::HashMap;
use crate::{
aggregates::Aggregate,
errors::AggregateError,
events::EventEnvelope,
};
use super::aggregate_context::AggregateContext;
pub trait EventStore<A, AC>
where
A: Aggregate,
AC: AggregateContext<A>, {
fn load(
&mut self,
aggregate_id: &str,
) -> Vec<EventEnvelope<A>>;
fn load_aggregate(
&mut self,
aggregate_id: &str,
) -> AC;
fn commit(
&mut self,
events: Vec<A::Event>,
context: AC,
metadata: HashMap<String, String>,
) -> Result<Vec<EventEnvelope<A>>, AggregateError>;
fn wrap_events(
&self,
aggregate_id: &str,
current_sequence: usize,
resultant_events: Vec<A::Event>,
base_metadata: HashMap<String, String>,
) -> Vec<EventEnvelope<A>> {
let mut sequence = current_sequence;
let mut wrapped_events: Vec<EventEnvelope<A>> = Vec::new();
for payload in resultant_events {
sequence += 1;
let aggregate_id: String = aggregate_id.to_string();
let sequence = sequence;
let metadata = base_metadata.clone();
wrapped_events.push(EventEnvelope::new_with_metadata(
aggregate_id,
sequence,
payload,
metadata,
));
}
wrapped_events
}
}