ic-testkit 0.85.1

PocketIC-oriented test utilities for IC canister tests
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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148

//! Installed bounded copy preserves heap, stable memory, timer, hook and chunks.
use candid::Principal;
use ic_host_artifacts::wasm_text::{CompileLimits, compile};
use ic_management_canister_types::{CanisterTimer, SnapshotSource};
use ic_testkit::pocket_ic::{
    CanisterSettings, PocketIc,
    snapshot::{
        CallLimits, ReadCanisterSnapshotMetadataArgs, SnapshotTransfer, TransferLimits,
        TransferStatus,
    },
};
use std::time::Duration;

fn inspect(pic: &PocketIc, id: Principal) -> [u64; 5] {
    let bytes = pic
        .query_call(id, Principal::anonymous(), "inspect", vec![])
        .unwrap();
    assert_eq!(bytes.len(), 40);
    std::array::from_fn(|i| u64::from_le_bytes(bytes[i * 8..i * 8 + 8].try_into().unwrap()))
}

#[expect(
    clippy::too_many_lines,
    reason = "ordered installed snapshot restoration proof transferred from Platform"
)]
pub fn qualify(pic: &PocketIc) {
    let sender = Principal::anonymous();
    let id = pic.create_canister().unwrap();
    pic.update_canister_settings(
        id,
        None,
        CanisterSettings {
            wasm_memory_limit: Some((20_u64 * 65536).into()),
            wasm_memory_threshold: Some((2_u64 * 65536).into()),
            ..CanisterSettings::default()
        },
    )
    .unwrap();
    let wasm = compile(
        include_str!("snapshot_timer.wat"),
        CompileLimits {
            source_bytes: 16 * 1024,
            module_bytes: 16 * 1024,
        },
    )
    .unwrap();
    pic.install_canister(id, wasm, vec![], None).unwrap();
    let chunk = pic
        .upload_chunk(id, None, b"retained snapshot chunk".to_vec())
        .unwrap();
    let captured = inspect(pic, id);
    assert_eq!(&captured[1..], &[0, 7, 42, 42]);
    pic.stop_canister(id, None).unwrap();
    let native = pic.take_canister_snapshot(id, None, None).unwrap();
    let budget = CallLimits {
        http_bytes: 4_000_000,
        candid_bytes: 2_000_000,
        decoding_quota: 20_000_000,
        skipping_quota: 20_000_000,
    };
    let metadata = pic
        .read_canister_snapshot_metadata(
            sender,
            ReadCanisterSnapshotMetadataArgs {
                canister_id: id,
                snapshot_id: native.id.clone(),
            },
            budget,
        )
        .unwrap();
    assert!(matches!(metadata.global_timer,Some(CanisterTimer::Active(t)) if t==captured[0]));
    let hook = std::mem::discriminant(metadata.on_low_wasm_memory_hook_status.as_ref().unwrap());
    let mut copy = SnapshotTransfer::new(
        id,
        sender,
        native.id.clone(),
        metadata,
        TransferLimits {
            call: budget,
            chunk_bytes: 1024 * 1024,
            total_bytes: 4 * 1024 * 1024,
        },
    )
    .unwrap();
    copy.advance(pic).unwrap();
    // The consumer takes custody before any data writes, as required by the API.
    let uploaded = copy.uploaded_snapshot().unwrap().to_vec();
    while !matches!(copy.status(), TransferStatus::Complete) {
        copy.advance(pic).unwrap();
    }
    assert!(copy.transferred_bytes() > 2 * 1024 * 1024);
    pic.delete_canister_snapshot(id, None, native.id).unwrap();
    let uploaded_metadata = pic
        .read_canister_snapshot_metadata(
            sender,
            ReadCanisterSnapshotMetadataArgs {
                canister_id: id,
                snapshot_id: uploaded.clone(),
            },
            budget,
        )
        .unwrap();
    assert!(matches!(
        uploaded_metadata.source,
        Some(SnapshotSource::MetadataUpload(_))
    ));
    pic.start_canister(id, None).unwrap();
    pic.update_call(id, sender, "rearm", vec![]).unwrap();
    assert_eq!(&inspect(pic, id)[2..], &[99, 99, 99]);
    pic.clear_chunk_store(id, None).unwrap();
    pic.stop_canister(id, None).unwrap();
    pic.load_canister_snapshot(id, None, uploaded.clone())
        .unwrap();
    let restored = pic.take_canister_snapshot(id, None, None).unwrap();
    let restored_metadata = pic
        .read_canister_snapshot_metadata(
            sender,
            ReadCanisterSnapshotMetadataArgs {
                canister_id: id,
                snapshot_id: restored.id.clone(),
            },
            budget,
        )
        .unwrap();
    assert!(
        matches!(restored_metadata.global_timer,Some(CanisterTimer::Active(t)) if t==captured[0])
    );
    assert_eq!(
        std::mem::discriminant(
            restored_metadata
                .on_low_wasm_memory_hook_status
                .as_ref()
                .unwrap()
        ),
        hook
    );
    pic.delete_canister_snapshot(id, None, restored.id).unwrap();
    pic.start_canister(id, None).unwrap();
    assert_eq!(inspect(pic, id), captured);
    assert_eq!(pic.stored_chunks(id, None).unwrap(), vec![chunk]);
    pic.advance_time(Duration::from_secs(61)).unwrap();
    pic.tick().unwrap();
    assert_eq!(inspect(pic, id)[1], 1, "restored timer must execute");
    pic.delete_canister_snapshot(id, None, uploaded).unwrap();
    println!(
        "Bounded snapshot copy: module/heap/stable/globals/chunks/timer/hook restoration passed"
    );
}