canic-host 0.92.0

Host-side build, install, deployment, and fleet-template 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
83
84
85
86
87
88
89
90
91
92
93

use super::{
    AttachedFleetRoleSource,
    support::{
        admit_canister_role_name, toml_string_literal, validate_attach_kind, validate_subnet_name,
    },
};
use crate::release_set::config::{
    FleetConfigDeclaration, FleetConfigError, FleetConfigMutationConflict, FleetConfigOperation,
    model::AttachedFleetRole,
};
use canic_core::{bootstrap::parse_config_model, ids::CanisterRole};

pub(in crate::release_set) fn attach_fleet_role_source(
    config_source: &str,
    expected_fleet: &str,
    role: &str,
    subnet: &str,
    kind: &str,
) -> Result<AttachedFleetRoleSource, FleetConfigError> {
    let role = role.trim();
    let subnet = subnet.trim();
    let kind = kind.trim();
    admit_canister_role_name(role)?;
    validate_subnet_name(subnet)?;
    validate_attach_kind(kind)?;
    if role == "root" {
        return Err(FleetConfigError::MutationConflict {
            conflict: FleetConfigMutationConflict::RootRoleAttach,
        });
    }

    let config =
        parse_config_model(config_source).map_err(|source| FleetConfigError::CoreConfig {
            operation: FleetConfigOperation::AttachRole,
            source,
        })?;
    let actual_fleet = config
        .fleet_name()
        .ok_or(FleetConfigError::DeclarationMissing {
            declaration: FleetConfigDeclaration::FleetName,
        })?;
    if actual_fleet != expected_fleet {
        return Err(FleetConfigError::FleetMismatch {
            actual: actual_fleet.to_string(),
            expected: expected_fleet.to_string(),
        });
    }

    let role_id = CanisterRole::owned(role.to_string());
    config
        .roles
        .get(&role_id)
        .ok_or_else(|| FleetConfigError::DeclarationMissing {
            declaration: FleetConfigDeclaration::Role {
                fleet: expected_fleet.to_string(),
                role: role.to_string(),
            },
        })?;
    if config.attached_roles().contains(&role_id) {
        return Err(FleetConfigError::MutationConflict {
            conflict: FleetConfigMutationConflict::RoleAlreadyAttached {
                fleet: expected_fleet.to_string(),
                role: role.to_string(),
            },
        });
    }

    let mut source = config_source.trim_end().to_string();
    source.push_str("\n\n[subnets.");
    source.push_str(&toml_string_literal(subnet));
    source.push_str(".canisters.");
    source.push_str(&toml_string_literal(role));
    source.push_str("]\nkind = ");
    source.push_str(&toml_string_literal(kind));
    source.push('\n');

    parse_config_model(&source).map_err(|source| FleetConfigError::CoreConfig {
        operation: FleetConfigOperation::AttachRole,
        source,
    })?;

    Ok(AttachedFleetRoleSource {
        source,
        role: AttachedFleetRole {
            fleet: expected_fleet.to_string(),
            role: role.to_string(),
            display: format!("{expected_fleet}.{role}"),
            subnet: subnet.to_string(),
            kind: kind.to_string(),
            topology: format!("{subnet}/{role}"),
        },
    })
}