Skip to main content

kmp_application/consolidation/
read.rs

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