mithril_aggregator/event_store/database/
record.rs

1use chrono::{DateTime, Utc};
2use mithril_persistence::sqlite::{HydrationError, Projection, SqLiteEntity};
3
4use crate::event_store::Event;
5
6impl SqLiteEntity for Event {
7    fn hydrate(row: sqlite::Row) -> Result<Self, HydrationError>
8    where
9        Self: Sized,
10    {
11        let created_at = &row.read::<&str, _>("created_at");
12
13        let myself = Self {
14            event_id: row.read::<i64, _>("event_id"),
15            created_at: DateTime::parse_from_rfc3339(created_at)
16                .map_err(|e| {
17                    HydrationError::InvalidData(format!(
18                        "Could not turn string '{created_at}' to rfc3339 Datetime. Error: {e}"
19                    ))
20                })?
21                .with_timezone(&Utc),
22            source: row.read::<&str, _>("source").to_string(),
23            action: row.read::<&str, _>("action").to_string(),
24            content: row.read::<&str, _>("content").to_string(),
25        };
26
27        Ok(myself)
28    }
29
30    fn get_projection() -> Projection {
31        let mut projection = Projection::default();
32        projection.add_field("event_id", "event_id", "int");
33        projection.add_field("created_at", "created_at", "string");
34        projection.add_field("source", "source", "string");
35        projection.add_field("action", "action", "string");
36        projection.add_field("content", "content", "string");
37
38        projection
39    }
40}
41
42#[cfg(test)]
43mod tests {
44    use mithril_persistence::sqlite::SourceAlias;
45
46    use super::*;
47
48    #[test]
49    fn event_projection() {
50        let projection = Event::get_projection();
51
52        assert_eq!(
53            "event_id as event_id, created_at as created_at, source as source, action as action, content as content".to_string(),
54            projection.expand(SourceAlias::default())
55        )
56    }
57}
mithril_aggregator/event_store/database/record.rs

mithril_aggregator/event_store/database/
record.rs
