Skip to main content

kmp_application/consolidation/
write.rs

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