datasources 0.1.5

Async datasource interfaces, middleware, registry, and test doubles
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

use crate::repository_tree::RepositoryTree;
use crate::repository_tree_node::RepositoryTreeNode;
use crate::result::Result;
use crate::row::Row;
use crate::stored_enrichment::StoredEnrichment;
use crate::stubs::StubRepository;
use crate::write_enrichment_strategy::WriteEnrichmentStrategy;
use crate::write_mode::WriteMode;
use std::sync::{Arc, Mutex};

pub(crate) async fn after_bulk_write(
    write: Option<&Arc<dyn WriteEnrichmentStrategy>>,
    enrichments: Option<&Arc<Mutex<Vec<StoredEnrichment>>>>,
    items: &mut [Row],
    mode: WriteMode,
) -> Result<()> {
    let (Some(write), Some(enrichments)) = (write, enrichments) else {
        return Ok(());
    };
    if enrichments.lock().expect("enrichments").is_empty() {
        return Ok(());
    }
    let tree = RepositoryTree::new(RepositoryTreeNode::new(
        Arc::new(StubRepository::new("bulk")),
        "",
        Arc::clone(enrichments),
    ));
    write.persist_bulk(&tree, items, mode).await
}