bcode_server 0.0.1-alpha.0

Local bcode daemon runtime
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Actual repeat records with independent source coverage and bounded exhaustion.
use super::representation;

pub(super) async fn inspect(
    tx: &dyn switchy_database::DatabaseTransaction,
    run: &str,
    bound: u16,
) -> (
    Vec<bcode_workflow::WorkflowRepeatOutcomeSummary>,
    Option<bool>,
) {
    let coverage = representation::journal::public_events::repeat::coverage(tx, run).await;
    match representation::graph::repeat_outcome::page_in(tx, run, None, bound).await {
        Ok((records, next)) => {
            let complete = coverage.ok().map(|coverage| {
                coverage == bcode_workflow::WorkflowSemanticHistoryCoverage::CompleteFromAdmission
                    && next.is_none()
            });
            (records, complete)
        }
        Err(_) => (Vec::new(), None),
    }
}