sofie-db 0.4.0

The handler model (inputs, events, replies), aggregates, read models, the query builder, the unit of work, migrations, the worker and the database seam.
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

use sofie_core::{Error, Result};

use crate::{Aggregate, Id, Query, Read, Source};

pub trait Select: Source {
    #[must_use]
    fn query() -> Query<Self> {
        Query::default()
    }
}

impl<T: Source> Select for T {}

pub trait Load: Aggregate {
    fn find(read: &Read, id: Id<Self>) -> impl Future<Output = Result<Self>> + Send {
        async move {
            Self::query()
                .where_(Self::ID.eq(id))
                .first(read)
                .await?
                .ok_or(Error::NotFound)
        }
    }
}

impl<A: Aggregate> Load for A {}