distributed 2.2.1

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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

use distributed::{
    sourced, Entity, HashMapRepository, ReadModel, ReadModelWorkspaceExt,
    ReadModelWritePlanBuilder, ReadModelWritePlanCommitExt, RowKey, RowValue,
};
use serde::{Deserialize, Serialize};

#[derive(Default)]
struct TestAggregate {
    entity: Entity,
}

#[sourced(entity)]
impl TestAggregate {
    #[event("touched")]
    fn touch(&mut self) {
        if self.entity.id().is_empty() {
            self.entity.set_id("agg-1");
        }
    }
}

#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, ReadModel)]
#[table("bridge_views")]
struct BridgeView {
    #[id]
    id: String,
    value: i32,
}

#[tokio::test]
async fn repo_first_read_models_session_commit_form_is_available() {
    let repo = HashMapRepository::new();
    let view = BridgeView {
        id: "view-1".into(),
        value: 42,
    };
    let mut session = ReadModelWritePlanBuilder::new();
    session.upsert(&view).unwrap();
    let mut aggregate = TestAggregate::default();
    aggregate.touch().unwrap();

    repo.read_models(session)
        .commit(&mut aggregate)
        .await
        .unwrap();

    let loaded = repo
        .workspace()
        .load::<BridgeView>(RowKey::new([("id", RowValue::String("view-1".into()))]))
        .one()
        .await
        .unwrap()
        .unwrap();
    assert_eq!(loaded.data, view);
}