Skip to main content

kmp_application/consolidation/
capture.rs

1use kmp_domain::{
2    PortError,
3    consolidation::{ConsolidationSource, ConsolidationStore},
4};
5use std::sync::Arc;
6
7pub struct CaptureConsolidationSources {
8    store: Arc<dyn ConsolidationStore>,
9}
10impl CaptureConsolidationSources {
11    pub fn new(store: Arc<dyn ConsolidationStore>) -> Self {
12        Self { store }
13    }
14    pub async fn execute(
15        &self,
16        about: String,
17        refs: Vec<String>,
18    ) -> Result<Vec<ConsolidationSource>, PortError> {
19        self.store.consolidation_sources(about, refs).await
20    }
21}