relay-knowledge 1.1.17

Graph-database-based knowledge graph project.
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

//! Control-plane status mirroring after shard publication.

use std::sync::Arc;

use crate::{
    domain::CodeRepositoryStatus,
    storage::{SqliteGraphStore, StorageError},
};

use super::catalog::mirror_repository_status;

pub(super) async fn mirror_status(
    control: &Arc<SqliteGraphStore>,
    status: CodeRepositoryStatus,
) -> Result<(), StorageError> {
    let control = Arc::clone(control);
    control
        .run(move |connection| {
            let transaction = connection.transaction()?;
            mirror_repository_status(&transaction, &status)?;
            transaction.commit()?;
            Ok(())
        })
        .await
}

#[cfg(test)]
#[path = "mod_tests.rs"]
mod tests;