geeks_event_sourcing 0.3.1

Event sourcing crate for geeks productions.
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

use async_trait::async_trait;

use crate::{Aggregate, AggregateRoot};

#[async_trait]
pub trait Snapshot<T>
where
  T: Aggregate,
{
  type Error: Send + Sync;

  async fn load(&self) -> Result<AggregateRoot<T>, Self::Error>;

  async fn save(&self, root: AggregateRoot<T>) -> Result<(), Self::Error>;
}

#[cfg(test)]
mod tests {
  use std::collections::HashMap;

  use chrono::Utc;

  use geeks_git_testing::FixtureRepository;

  use crate::testing::{Todo, TodoSnapshot, TodoStatus};
  use crate::{AggregateRoot, Snapshot};

  #[tokio::test]
  async fn should_load_snapshot_from_fs() {
    let todo = Todo {
      id: "todo1".to_string(),
      title: "Eat pizza".to_string(),
      status: TodoStatus::Done,
      created_at: Utc::now().timestamp(),
      updated_at: Utc::now().timestamp(),
    };
    let root = AggregateRoot::<Todo>::new(
      HashMap::from([("todo1".to_string(), todo)]),
      HashMap::from([("todo1".to_string(), 1)]),
    );
    let fixture = FixtureRepository::setup();
    let snapshot = TodoSnapshot::new(&fixture.path);
    snapshot.save(root).await.unwrap();
    let aggregate = snapshot.load().await.unwrap();

    assert!(aggregate.get_state("todo1").is_some());
  }
}