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
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

//! Where a split app serves the apps it left, shared by its server and their clients.

use sofie_auth::Acting;

pub const PRINCIPAL_HEADER: &str = "sofie-principal";
pub const CONTRACTS_PATH: &str = "/_sofie/contracts/";
pub const LOOKUPS_PATH: &str = "/_sofie/lookups/";
pub const FEED_PATH: &str = "/_sofie/feed";

/// Both apps compile the DTO from its contract crate, so both name it alike.
#[must_use]
pub fn lookup_name<D>() -> &'static str {
    std::any::type_name::<D>()
}

#[cfg_attr(not(feature = "live"), expect(unused_variables))]
pub fn read_through(app: &str) {
    #[cfg(feature = "live")]
    crate::live::read_remote(app);
}

tokio::task_local! {
    static ACTING: Option<Acting>;
}

pub async fn acting_as<F: Future>(acting: Option<Acting>, work: F) -> F::Output {
    ACTING.scope(acting, work).await
}

#[must_use]
pub fn acting() -> Option<Acting> {
    ACTING.try_with(Clone::clone).ok().flatten()
}

#[cfg(test)]
mod tests {
    use sofie_core::Uuid;

    use super::*;

    #[tokio::test]
    async fn work_acts_for_the_principal_of_its_scope_only() {
        let customer = Acting {
            area: "customer".to_owned(),
            principal: Uuid::now_v7().unwrap(),
        };

        let inside = acting_as(Some(customer.clone()), async { acting() }).await;

        assert_eq!(inside, Some(customer));
        assert_eq!(acting(), None);
    }
}