canic-host 0.110.51

Host-side App build and desired-state Fleet reconciliation library for Canic workspaces
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use super::*;
use crate::fleet_ensure::model::funding_observation::{
    FundingObservationReviewRecord, FundingQuoteStage,
};
use std::io;

/// Exercise native quote stages using the generated estate's validated complete observation pass.
pub(in crate::fleet_ensure) fn qualify_observation_quotes(
    plan: &FleetEnsurePlan,
    journal: &FleetEnsureJournalRecord,
    record: &FundingObservationReviewRecord,
) {
    let root = &record.body.root;
    let base = record.body.recovery_floor_cycles;
    assert_eq!(
        observation_minimum::<io::Error>(plan, journal, root, None, base).unwrap(),
        base
    );
    let recovery = observation_source(plan, journal, root).unwrap();
    assert_eq!(recovery.stage, FundingQuoteStage::Recovery);
    assert_eq!(
        observation_minimum::<io::Error>(plan, journal, root, Some(&recovery), base).unwrap(),
        base + 30_000_000_000_000
    );
    let mut incomplete = journal.clone();
    let review = incomplete.funding_observations.get_mut(root).unwrap();
    review.attempts.clear();
    review.final_root_cycles = None;
    review.approved = false;
    let observation = observation_source(plan, &incomplete, root).unwrap();
    assert_eq!(observation.stage, FundingQuoteStage::Observation);
    assert_ne!(recovery, observation);
    assert_eq!(
        observation_minimum::<io::Error>(plan, &incomplete, root, Some(&observation), base)
            .unwrap(),
        base + record.body.maximum_cycles
    );
    assert!(
        observation_minimum::<io::Error>(plan, &incomplete, root, Some(&recovery), base).is_err()
    );
    let mut changed = recovery;
    changed.review_sha256 = "ab".repeat(32);
    assert!(matches!(
        observation_minimum::<io::Error>(plan, journal, root, Some(&changed), base),
        Err(EnsureWorkflowError::JournalIntegrity)
    ));
}