chekov 0.1.1

CQRS/ES Framework
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

//! Struct and Trait correlated to Event
use crate::error::ApplyError;
use crate::message::EventMetadatas;
use event_store::prelude::RecordedEvent;
use futures::future::BoxFuture;
use std::any::TypeId;
use std::collections::BTreeMap;

pub(crate) mod handler;

#[doc(hidden)]
pub mod resolver;

pub use handler::EventHandler;
#[doc(hidden)]
pub use handler::EventHandlerInstance;

/// Define an Event which can be produced and consumed
// pub trait Event: event_store::prelude::Event {
pub trait Event: Send {
    fn into_envelope<'de>(event: RecordedEvent) -> Result<crate::message::EventEnvelope<Self>, ()>
    where
        Self: serde::Deserialize<'de> + serde::de::Deserialize<'de>,
        Self: 'static + Clone,
    {
        let r = Self::deserialize(event.data).map_err(|_| ())?;

        Ok(crate::message::EventEnvelope {
            event: r,
            meta: EventMetadatas {
                correlation_id: event.correlation_id,
                causation_id: event.causation_id,
                stream_name: event.stream_uuid,
            },
        })
    }
}

/// Define an event applier
pub trait EventApplier<E: Event> {
    fn apply(&mut self, event: &E) -> Result<(), ApplyError>;
}

/// Receive an immutable event to handle
pub trait Handler<E: crate::event::Event> {
    fn handle(&mut self, event: &E) -> BoxFuture<Result<(), ()>>;
}