canic-host 0.109.3

Host-side App build, Fleet install, deployment, and release-set 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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//! Module: install_root::operations::registry
//!
//! Responsibility: read one complete live Fleet Registry evidence set during installation.
//! Does not own: expected Registry derivation, validation, mutation, or journal transitions.
//! Boundary: every workflow receives the same snapshot, manifest, and version projection.

use super::query_with_arg;
use crate::{
    fleet_install_plan::PersistedFleetInstallPlan, icp::IcpCli,
    protocol_binding::ResolvedProtocolBinding,
};
use candid::Principal;
use canic_control_plane::dto::fleet_coordinator::{
    CoordinatorStatusRequest, CoordinatorStatusResponse,
};
use canic_core::{
    dto::fleet_registry::{FleetRegistry, FleetRegistryManifest, FleetRegistryVersion},
    ids::{FleetCoordinatorBinding, FleetRegistryAuthority},
    protocol,
};

pub(in crate::install_root) fn fleet_registry_authority(
    fleet_install_plan: &PersistedFleetInstallPlan,
    coordinator: Principal,
) -> FleetRegistryAuthority {
    FleetRegistryAuthority {
        binding: FleetCoordinatorBinding {
            fleet: fleet_install_plan.plan.fleet.clone(),
            coordinator_subnet: fleet_install_plan.plan.coordinator.coordinator_subnet,
            coordinator,
        },
        epoch: 1,
    }
}

pub(in crate::install_root) struct LiveRegistryEvidence {
    pub(in crate::install_root) registry: FleetRegistry,
    pub(in crate::install_root) manifest: FleetRegistryManifest,
    pub(in crate::install_root) version: FleetRegistryVersion,
}

pub(in crate::install_root) fn query_live_registry(
    icp: &IcpCli,
    binding: &ResolvedProtocolBinding,
    coordinator: Principal,
) -> Result<LiveRegistryEvidence, Box<dyn std::error::Error>> {
    let registry = query_with_arg::<_, CoordinatorStatusResponse>(
        icp,
        binding,
        coordinator,
        protocol::CANIC_STATUS,
        &CoordinatorStatusRequest::Registry,
    )?;
    let manifest = query_with_arg::<_, CoordinatorStatusResponse>(
        icp,
        binding,
        coordinator,
        protocol::CANIC_STATUS,
        &CoordinatorStatusRequest::RegistryManifest,
    )?;
    let version = query_with_arg::<_, CoordinatorStatusResponse>(
        icp,
        binding,
        coordinator,
        protocol::CANIC_STATUS,
        &CoordinatorStatusRequest::RegistryVersion,
    )?;
    Ok(LiveRegistryEvidence {
        registry: match registry {
            CoordinatorStatusResponse::Registry(registry) => registry,
            _ => return Err("Coordinator returned an unrelated Registry response".into()),
        },
        manifest: match manifest {
            CoordinatorStatusResponse::RegistryManifest(manifest) => manifest,
            _ => return Err("Coordinator returned an unrelated Registry manifest response".into()),
        },
        version: match version {
            CoordinatorStatusResponse::RegistryVersion(version) => version,
            _ => return Err("Coordinator returned an unrelated Registry version response".into()),
        },
    })
}