kmp-application 0.18.9

Application services behind KMP's ten memory moves and evidence-backed recall
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

use super::{CaptureConsolidationSources, ReadConsolidationView, WriteConsolidationView};
use kmp_domain::{
    PortError,
    consolidation::{
        ConsolidatedView, ConsolidationRead, ConsolidationSource, ConsolidationStore,
        ConsolidationWrite,
    },
};
use std::sync::Arc;

/// Thin composition facade for independently owned capture, write and read use cases.
pub struct ConsolidationApplicationService {
    capture: CaptureConsolidationSources,
    write: WriteConsolidationView,
    read: ReadConsolidationView,
}
impl ConsolidationApplicationService {
    pub fn new(store: Arc<dyn ConsolidationStore>) -> Self {
        Self {
            capture: CaptureConsolidationSources::new(store.clone()),
            write: WriteConsolidationView::new(store.clone()),
            read: ReadConsolidationView::new(store),
        }
    }
    pub async fn sources(
        &self,
        about: String,
        refs: Vec<String>,
    ) -> Result<Vec<ConsolidationSource>, PortError> {
        self.capture.execute(about, refs).await
    }
    pub async fn write(&self, command: ConsolidationWrite) -> Result<ConsolidatedView, PortError> {
        self.write.execute(command).await
    }
    pub async fn read(
        &self,
        about: String,
        view: String,
        revision: Option<u64>,
    ) -> Result<ConsolidationRead, PortError> {
        self.read.execute(about, view, revision).await
    }
}