dendrite_lib 0.12.0

Event Sourcing and CQRS in Rust with AxonServer.
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

use super::AxonServerHandle;
use crate::axon_server::event::event_store_client::EventStoreClient;
use crate::axon_server::event::{Event, GetAggregateEventsRequest};
use anyhow::Result;
use tonic::transport::Channel;

/// Fetch all events for a given aggregate.
pub async fn query_events(
    axon_server_handle: &AxonServerHandle,
    aggregate_identifier: &str,
) -> Result<Vec<Event>> {
    let axon_server_handle = axon_server_handle.clone();
    let conn = axon_server_handle.conn;
    let mut client = EventStoreClient::new(conn);
    query_events_from_client(&mut client, aggregate_identifier).await
}

/// Fetch all events for a given aggregate.
pub async fn query_events_from_client(
    client: &mut EventStoreClient<Channel>,
    aggregate_identifier: &str,
) -> Result<Vec<Event>> {
    let request = GetAggregateEventsRequest {
        aggregate_id: aggregate_identifier.to_string(),
        allow_snapshots: false,
        initial_sequence: 0,
        max_sequence: i64::MAX,
        min_token: 0,
    };
    let mut result = Vec::new();
    let mut stream = client.list_aggregate_events(request).await?.into_inner();
    while let Some(event) = stream.message().await? {
        result.push(event.clone());
    }
    Ok(result)
}