canic-core 0.111.0

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
51
52
53
54
55
56
57

//! Module: ops::caller_authority::cleanup
//!
//! Bounded source compaction under the original Component denial receipt.
//!
//! The installation-bound fence and publication ordering survive row removal.

use super::*;

const SOURCE_CLEANUP_PAGE: usize = 128;

impl CallerAuthorityOps {
    pub(super) fn cleanup_component(
        receipt: &CallerReceiptRecord,
    ) -> Result<bool, CallerPublicationError> {
        let CallerChangeRecord::DenyComponent(component) = &receipt.publication.change else {
            return Ok(true);
        };
        if receipt.phase != CallerReceiptPhase::Committed {
            return Err(CallerPublicationError::PhaseConflict);
        }
        let mut header = Self::receiver().ok_or(CallerPublicationError::AuthorityConflict)?;
        if header.pending_operation != Some(receipt.publication.operation_id)
            || header.authority != receipt.publication.authority
        {
            return Err(CallerPublicationError::ReplayConflict);
        }
        let mut page =
            CallerRowStore::source_page(header.cleanup_cursor.clone(), SOURCE_CLEANUP_PAGE + 1);
        let finished = page.len() <= SOURCE_CLEANUP_PAGE;
        page.truncate(SOURCE_CLEANUP_PAGE);
        if let Some((key, _)) = page.last() {
            header.cleanup_cursor = Some(key.clone());
        }
        let removed: Vec<_> = page
            .into_iter()
            .filter_map(|(key, source)| {
                (source.installation.component() == &component.binding
                    && source.installation.component_install_id == component.install_id)
                    .then_some(key)
            })
            .collect();
        let count = u32::try_from(removed.len()).map_err(|_| CallerPublicationError::Capacity)?;
        header.entries = header
            .entries
            .checked_sub(count)
            .ok_or(CallerPublicationError::InvalidPublication)?;
        header.reserved_bytes = header
            .reserved_bytes
            .checked_sub(count * MAX_CALLER_ROW_BYTES)
            .ok_or(CallerPublicationError::InvalidPublication)?;
        for key in removed {
            CallerRowStore::remove(&key);
        }
        CallerReceiverStore::set(header);
        Ok(finished)
    }
}