canic-core 0.110.10

Canic — a canister orchestration and management toolkit for the Internet Computer
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

pub use crate::ops::runtime::root_funding::{
    RootFundingRuntime, RootFundingRuntimeApi, RootFundingRuntimeConfig,
};

/// Lifecycle-facing control over the sole Root cycle-top-up owner.
pub struct RootFundingTimerApi;

impl RootFundingTimerApi {
    /// Re-read protected demand and reconcile the existing native timer claim.
    pub fn reconcile() -> Result<(), crate::dto::error::Error> {
        crate::workflow::runtime::cycles::CycleWorkflow::start().map_err(Into::into)
    }

    /// Disarm the sole timer only when no funding or refill attempt is executing.
    pub fn prepare_policy_rotation_fence() -> Result<(), crate::error::InternalError> {
        use crate::{
            ops::storage::{async_job_recovery::AsyncJobOwner, icp_refill::IcpRefillStoreOps},
            workflow::runtime::async_job::AsyncJobWorkflow,
        };

        if AsyncJobWorkflow::has_active_attempt(AsyncJobOwner::CycleTopup)
            || IcpRefillStoreOps::resumable_operation_count() != 0
        {
            return Err(crate::error::InternalError::conflict());
        }
        crate::workflow::runtime::cycles::CycleWorkflow::cancel_timer()?;
        Ok(())
    }

    /// Durably disable and disarm new Root funding before terminal deletion work.
    pub fn fence_for_deletion() -> Result<(), crate::error::InternalError> {
        use crate::{
            ops::storage::{
                async_job_recovery::AsyncJobOwner,
                icp_refill::IcpRefillStoreOps,
                state::fleet::{FleetStateCommand, FleetStateOps},
            },
            workflow::runtime::async_job::AsyncJobWorkflow,
        };

        if AsyncJobWorkflow::has_active_attempt(AsyncJobOwner::CycleTopup)
            || IcpRefillStoreOps::resumable_operation_count() != 0
        {
            return Err(crate::error::InternalError::conflict());
        }
        let _ = FleetStateOps::execute_command(FleetStateCommand::SetCyclesFundingEnabled(false));
        crate::workflow::runtime::cycles::CycleWorkflow::cancel_timer()?;
        Ok(())
    }
}