use candid::encode_args;
use canic::{
dto::{
abi::v1::CanisterInitPayload,
env::EnvBootstrapArgs,
topology::{AppDirectoryArgs, SubnetDirectoryArgs},
},
ids::{CanisterRole, SubnetRole},
};
use std::{
path::{Path, PathBuf},
sync::Mutex,
};
use crate::{
Fake,
artifacts::{
WasmBuildProfile, build_wasm_canisters, read_wasm, test_target_dir, wasm_artifacts_ready,
workspace_root_for,
},
};
use super::{Pic, PicSerialGuard, acquire_pic_serial_guard, pic};
const STANDALONE_INSTALL_CYCLES: u128 = 1_000_000_000_000;
const STANDALONE_READY_TICK_LIMIT: usize = 60;
static STANDALONE_BUILD_SERIAL: Mutex<()> = Mutex::new(());
pub struct StandaloneCanisterFixture {
pub pic: Pic,
pub canister_id: canic::cdk::types::Principal,
_serial_guard: PicSerialGuard,
}
#[must_use]
pub fn install_standalone_canister(
crate_name: &str,
role: CanisterRole,
profile: WasmBuildProfile,
) -> StandaloneCanisterFixture {
assert!(
!role.is_root(),
"standalone helper is for non-root canisters"
);
let workspace_root = workspace_root();
let target_name = format!("standalone-{crate_name}");
let target_dir = test_target_dir(&workspace_root, &target_name);
ensure_canister_wasm_ready(&workspace_root, &target_dir, crate_name, profile);
let wasm = read_wasm(&target_dir, crate_name, profile);
let serial_guard = acquire_pic_serial_guard();
let pic = pic();
let canister_id = pic.create_canister();
pic.add_cycles(canister_id, STANDALONE_INSTALL_CYCLES);
pic.install_canister(canister_id, wasm, standalone_init_args(role), None);
pic.wait_for_ready(
canister_id,
STANDALONE_READY_TICK_LIMIT,
"standalone canister bootstrap",
);
StandaloneCanisterFixture {
pic,
canister_id,
_serial_guard: serial_guard,
}
}
fn ensure_canister_wasm_ready(
workspace_root: &Path,
target_dir: &Path,
crate_name: &str,
profile: WasmBuildProfile,
) {
let _build_guard = STANDALONE_BUILD_SERIAL
.lock()
.unwrap_or_else(std::sync::PoisonError::into_inner);
if wasm_artifacts_ready(target_dir, &[crate_name], profile) {
return;
}
build_wasm_canisters(workspace_root, target_dir, &[crate_name], profile, &[]);
}
fn standalone_init_args(role: CanisterRole) -> Vec<u8> {
let root_pid = Fake::principal(1);
let payload = CanisterInitPayload {
env: EnvBootstrapArgs {
prime_root_pid: Some(root_pid),
subnet_role: Some(SubnetRole::PRIME),
subnet_pid: Some(Fake::principal(2)),
root_pid: Some(root_pid),
canister_role: Some(role),
parent_pid: Some(root_pid),
},
app_directory: AppDirectoryArgs(Vec::new()),
subnet_directory: SubnetDirectoryArgs(Vec::new()),
};
encode_args::<(CanisterInitPayload, Option<Vec<u8>>)>((payload, None))
.expect("encode standalone init args")
}
fn workspace_root() -> PathBuf {
workspace_root_for(env!("CARGO_MANIFEST_DIR"))
}