#![forbid(unused_crate_dependencies)]
#![forbid(unused_extern_crates)]
use polkadot_primitives::{
vstaging::{
CandidateDescriptorV2, CandidateReceiptV2, CommittedCandidateReceiptV2, MutateDescriptorV2,
},
CandidateCommitments, CandidateDescriptor, CandidateReceipt, CollatorId, CollatorSignature,
CommittedCandidateReceipt, CoreIndex, Hash, HeadData, Id as ParaId, PersistedValidationData,
SessionIndex, ValidationCode, ValidationCodeHash, ValidatorId,
};
pub use rand;
use sp_application_crypto::{sr25519, ByteArray};
use sp_keyring::Sr25519Keyring;
use sp_runtime::generic::Digest;
const MAX_POV_SIZE: u32 = 1_000_000;
pub fn dummy_candidate_receipt<H: AsRef<[u8]>>(relay_parent: H) -> CandidateReceipt<H> {
CandidateReceipt::<H> {
commitments_hash: dummy_candidate_commitments(dummy_head_data()).hash(),
descriptor: dummy_candidate_descriptor(relay_parent),
}
}
pub fn dummy_candidate_receipt_v2<H: AsRef<[u8]> + Copy>(relay_parent: H) -> CandidateReceiptV2<H> {
CandidateReceiptV2::<H> {
commitments_hash: dummy_candidate_commitments(dummy_head_data()).hash(),
descriptor: dummy_candidate_descriptor_v2(relay_parent),
}
}
pub fn dummy_committed_candidate_receipt<H: AsRef<[u8]>>(
relay_parent: H,
) -> CommittedCandidateReceipt<H> {
CommittedCandidateReceipt::<H> {
descriptor: dummy_candidate_descriptor::<H>(relay_parent),
commitments: dummy_candidate_commitments(dummy_head_data()),
}
}
pub fn dummy_committed_candidate_receipt_v2<H: AsRef<[u8]> + Copy>(
relay_parent: H,
) -> CommittedCandidateReceiptV2<H> {
CommittedCandidateReceiptV2 {
descriptor: dummy_candidate_descriptor_v2::<H>(relay_parent),
commitments: dummy_candidate_commitments(dummy_head_data()),
}
}
pub fn dummy_candidate_receipt_bad_sig(
relay_parent: Hash,
commitments: impl Into<Option<Hash>>,
) -> CandidateReceipt<Hash> {
let commitments_hash = if let Some(commitments) = commitments.into() {
commitments
} else {
dummy_candidate_commitments(dummy_head_data()).hash()
};
CandidateReceipt::<Hash> {
commitments_hash,
descriptor: dummy_candidate_descriptor_bad_sig(relay_parent),
}
}
pub fn dummy_candidate_receipt_v2_bad_sig(
relay_parent: Hash,
commitments: impl Into<Option<Hash>>,
) -> CandidateReceiptV2<Hash> {
let commitments_hash = if let Some(commitments) = commitments.into() {
commitments
} else {
dummy_candidate_commitments(dummy_head_data()).hash()
};
CandidateReceiptV2::<Hash> {
commitments_hash,
descriptor: dummy_candidate_descriptor_bad_sig(relay_parent).into(),
}
}
pub fn dummy_candidate_commitments(head_data: impl Into<Option<HeadData>>) -> CandidateCommitments {
CandidateCommitments {
head_data: head_data.into().unwrap_or(dummy_head_data()),
upward_messages: vec![].try_into().expect("empty vec fits within bounds"),
new_validation_code: None,
horizontal_messages: vec![].try_into().expect("empty vec fits within bounds"),
processed_downward_messages: 0,
hrmp_watermark: 0_u32,
}
}
pub fn dummy_hash() -> Hash {
Hash::zero()
}
pub fn dummy_digest() -> Digest {
Digest::default()
}
pub fn dummy_candidate_descriptor_bad_sig(relay_parent: Hash) -> CandidateDescriptor<Hash> {
let zeros = Hash::zero();
CandidateDescriptor::<Hash> {
para_id: 0.into(),
relay_parent,
collator: dummy_collator(),
persisted_validation_data_hash: zeros,
pov_hash: zeros,
erasure_root: zeros,
signature: dummy_collator_signature(),
para_head: zeros,
validation_code_hash: dummy_validation_code().hash(),
}
}
pub fn dummy_candidate_descriptor<H: AsRef<[u8]>>(relay_parent: H) -> CandidateDescriptor<H> {
let collator = sp_keyring::Sr25519Keyring::Ferdie;
let invalid = Hash::zero();
let descriptor = make_valid_candidate_descriptor(
1.into(),
relay_parent,
invalid,
invalid,
invalid,
invalid,
invalid,
collator,
);
descriptor
}
pub fn dummy_candidate_descriptor_v2<H: AsRef<[u8]> + Copy>(
relay_parent: H,
) -> CandidateDescriptorV2<H> {
let invalid = Hash::zero();
let descriptor = make_valid_candidate_descriptor_v2(
1.into(),
relay_parent,
CoreIndex(1),
1,
invalid,
invalid,
invalid,
invalid,
invalid,
);
descriptor
}
pub fn dummy_validation_code() -> ValidationCode {
ValidationCode(vec![1, 2, 3, 4, 5, 6, 7, 8, 9])
}
pub fn dummy_head_data() -> HeadData {
HeadData(vec![])
}
pub fn dummy_validator() -> ValidatorId {
ValidatorId::from(sr25519::Public::default())
}
pub fn dummy_collator() -> CollatorId {
CollatorId::from(sr25519::Public::default())
}
pub fn dummy_collator_signature() -> CollatorSignature {
CollatorSignature::from_slice(&mut (0..64).into_iter().collect::<Vec<_>>().as_slice())
.expect("64 bytes; qed")
}
pub fn zero_collator_signature() -> CollatorSignature {
CollatorSignature::from(sr25519::Signature::default())
}
pub fn dummy_pvd(parent_head: HeadData, relay_parent_number: u32) -> PersistedValidationData {
PersistedValidationData {
parent_head,
relay_parent_number,
max_pov_size: MAX_POV_SIZE,
relay_parent_storage_root: dummy_hash(),
}
}
pub fn dummy_signature() -> polkadot_primitives::ValidatorSignature {
sp_core::crypto::UncheckedFrom::unchecked_from([1u8; 64])
}
pub fn make_candidate(
relay_parent_hash: Hash,
relay_parent_number: u32,
para_id: ParaId,
parent_head: HeadData,
head_data: HeadData,
validation_code_hash: ValidationCodeHash,
) -> (CommittedCandidateReceiptV2, PersistedValidationData) {
let pvd = dummy_pvd(parent_head, relay_parent_number);
let commitments = CandidateCommitments {
head_data,
horizontal_messages: Default::default(),
upward_messages: Default::default(),
new_validation_code: None,
processed_downward_messages: 0,
hrmp_watermark: relay_parent_number,
};
let mut candidate =
dummy_candidate_receipt_bad_sig(relay_parent_hash, Some(Default::default()));
candidate.commitments_hash = commitments.hash();
candidate.descriptor.para_id = para_id;
candidate.descriptor.persisted_validation_data_hash = pvd.hash();
candidate.descriptor.validation_code_hash = validation_code_hash;
let candidate =
CommittedCandidateReceiptV2 { descriptor: candidate.descriptor.into(), commitments };
(candidate, pvd)
}
pub fn make_candidate_v2(
relay_parent_hash: Hash,
relay_parent_number: u32,
para_id: ParaId,
parent_head: HeadData,
head_data: HeadData,
validation_code_hash: ValidationCodeHash,
) -> (CommittedCandidateReceiptV2, PersistedValidationData) {
let pvd = dummy_pvd(parent_head, relay_parent_number);
let commitments = CandidateCommitments {
head_data,
horizontal_messages: Default::default(),
upward_messages: Default::default(),
new_validation_code: None,
processed_downward_messages: 0,
hrmp_watermark: relay_parent_number,
};
let mut descriptor = dummy_candidate_descriptor_v2(relay_parent_hash);
descriptor.set_para_id(para_id);
descriptor.set_persisted_validation_data_hash(pvd.hash());
descriptor.set_validation_code_hash(validation_code_hash);
let candidate = CommittedCandidateReceiptV2 { descriptor, commitments };
(candidate, pvd)
}
pub fn make_valid_candidate_descriptor<H: AsRef<[u8]>>(
para_id: ParaId,
relay_parent: H,
persisted_validation_data_hash: Hash,
pov_hash: Hash,
validation_code_hash: impl Into<ValidationCodeHash>,
para_head: Hash,
erasure_root: Hash,
collator: Sr25519Keyring,
) -> CandidateDescriptor<H> {
let validation_code_hash = validation_code_hash.into();
let payload = polkadot_primitives::collator_signature_payload::<H>(
&relay_parent,
¶_id,
&persisted_validation_data_hash,
&pov_hash,
&validation_code_hash,
);
let signature = collator.sign(&payload).into();
let descriptor = CandidateDescriptor {
para_id,
relay_parent,
collator: collator.public().into(),
persisted_validation_data_hash,
pov_hash,
erasure_root,
signature,
para_head,
validation_code_hash,
};
assert!(descriptor.check_collator_signature().is_ok());
descriptor
}
pub fn make_valid_candidate_descriptor_v2<H: AsRef<[u8]> + Copy>(
para_id: ParaId,
relay_parent: H,
core_index: CoreIndex,
session_index: SessionIndex,
persisted_validation_data_hash: Hash,
pov_hash: Hash,
validation_code_hash: impl Into<ValidationCodeHash>,
para_head: Hash,
erasure_root: Hash,
) -> CandidateDescriptorV2<H> {
let validation_code_hash = validation_code_hash.into();
let descriptor = CandidateDescriptorV2::new(
para_id,
relay_parent,
core_index,
session_index,
persisted_validation_data_hash,
pov_hash,
erasure_root,
para_head,
validation_code_hash,
);
descriptor
}
pub fn resign_candidate_descriptor_with_collator<H: AsRef<[u8]>>(
descriptor: &mut CandidateDescriptor<H>,
collator: Sr25519Keyring,
) {
descriptor.collator = collator.public().into();
let payload = polkadot_primitives::collator_signature_payload::<H>(
&descriptor.relay_parent,
&descriptor.para_id,
&descriptor.persisted_validation_data_hash,
&descriptor.pov_hash,
&descriptor.validation_code_hash,
);
let signature = collator.sign(&payload).into();
descriptor.signature = signature;
}
pub fn validator_pubkeys(val_ids: &[Sr25519Keyring]) -> Vec<ValidatorId> {
val_ids.iter().map(|v| v.public().into()).collect()
}
pub struct TestCandidateBuilder {
pub para_id: ParaId,
pub pov_hash: Hash,
pub relay_parent: Hash,
pub commitments_hash: Hash,
}
impl std::default::Default for TestCandidateBuilder {
fn default() -> Self {
let zeros = Hash::zero();
Self { para_id: 0.into(), pov_hash: zeros, relay_parent: zeros, commitments_hash: zeros }
}
}
impl TestCandidateBuilder {
pub fn build(self) -> CandidateReceiptV2 {
let mut descriptor = dummy_candidate_descriptor(self.relay_parent);
descriptor.para_id = self.para_id;
descriptor.pov_hash = self.pov_hash;
CandidateReceipt { descriptor, commitments_hash: self.commitments_hash }.into()
}
}
pub struct AlwaysZeroRng;
impl Default for AlwaysZeroRng {
fn default() -> Self {
Self {}
}
}
impl rand::RngCore for AlwaysZeroRng {
fn next_u32(&mut self) -> u32 {
0_u32
}
fn next_u64(&mut self) -> u64 {
0_u64
}
fn fill_bytes(&mut self, dest: &mut [u8]) {
for element in dest.iter_mut() {
*element = 0_u8;
}
}
fn try_fill_bytes(&mut self, dest: &mut [u8]) -> Result<(), rand::Error> {
self.fill_bytes(dest);
Ok(())
}
}