sofie-db 0.3.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
54
55

use std::any::Any;
use std::sync::{Arc, RwLock};

use sofie_core::{Uuid, unpoisoned};

use crate::{Db, Driver};

#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub struct ChangedRecord {
    pub module: &'static str,
    pub aggregate: &'static str,
    /// `None` when the commit changed records it cannot name, such as the default it cleared.
    pub id: Option<Uuid>,
}

/// Runs after a commit that wrote aggregates, which already stands, so it cannot fail it. It also
/// runs when the caller is dropped mid-commit, landed or not; slow work goes to a task.
pub trait CommitHook: Any + Send + Sync {
    fn committed(&self, changes: &[ChangedRecord]);
}

/// Seen by every clone of `db`, made before or after.
pub fn add_commit_hook(db: &Db, hook: Arc<dyn CommitHook>) {
    unpoisoned::write(&db.commit_hooks.0).push(hook);
}

#[must_use]
pub fn commit_hook<T: CommitHook>(db: &Db) -> Option<Arc<T>> {
    let hooks = unpoisoned::read(&db.commit_hooks.0);
    hooks.iter().find_map(|hook| {
        let hook: Arc<dyn Any + Send + Sync> = hook.clone();
        hook.downcast().ok()
    })
}

/// For a cache keeping a table of its own and notifying other instances.
#[must_use]
pub fn cache_driver(db: &Db) -> &dyn Driver {
    db.driver()
}

#[derive(Default)]
pub(crate) struct CommitHooks(RwLock<Vec<Arc<dyn CommitHook>>>);

impl CommitHooks {
    pub(crate) fn run(&self, changes: &[ChangedRecord]) {
        if changes.is_empty() {
            return;
        }
        let hooks = unpoisoned::read(&self.0);
        for hook in hooks.iter() {
            hook.committed(changes);
        }
    }
}