Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Commit

Permalink
primitives/beefy: rename Payload::new to Payload::from_single_entry f…
Browse files Browse the repository at this point in the history
…or clarity
  • Loading branch information
acatangiu committed Oct 6, 2022
1 parent b908ce2 commit 09638e4
Show file tree
Hide file tree
Showing 8 changed files with 32 additions and 18 deletions.
3 changes: 2 additions & 1 deletion client/beefy/rpc/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -266,7 +266,8 @@ mod tests {
}

fn create_finality_proof() -> BeefyVersionedFinalityProof<Block> {
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
BeefyVersionedFinalityProof::<Block>::V1(SignedCommitment {
commitment: beefy_primitives::Commitment {
payload,
Expand Down
5 changes: 4 additions & 1 deletion client/beefy/src/communication/gossip.rs
Original file line number Diff line number Diff line change
Expand Up @@ -347,7 +347,10 @@ mod tests {
}

fn dummy_vote(block_number: u64) -> VoteMessage<u64, Public, Signature> {
let payload = Payload::new(known_payloads::MMR_ROOT_ID, MmrRootHash::default().encode());
let payload = Payload::from_single_entry(
known_payloads::MMR_ROOT_ID,
MmrRootHash::default().encode(),
);
let commitment = Commitment { payload, block_number, validator_set_id: 0 };
let signature = sign_commitment(&Keyring::Alice, &commitment);

Expand Down
2 changes: 1 addition & 1 deletion client/beefy/src/justification.rs
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ pub(crate) mod tests {
keys: &[Keyring],
) -> BeefyVersionedFinalityProof<Block> {
let commitment = Commitment {
payload: Payload::new(known_payloads::MMR_ROOT_ID, vec![]),
payload: Payload::from_single_entry(known_payloads::MMR_ROOT_ID, vec![]),
block_number: block_num,
validator_set_id: validator_set.id(),
};
Expand Down
8 changes: 4 additions & 4 deletions client/beefy/src/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1327,7 +1327,7 @@ pub(crate) mod tests {

let create_finality_proof = |block_num: NumberFor<Block>| {
let commitment = Commitment {
payload: Payload::new(known_payloads::MMR_ROOT_ID, vec![]),
payload: Payload::from_single_entry(known_payloads::MMR_ROOT_ID, vec![]),
block_number: block_num,
validator_set_id: validator_set.id(),
};
Expand Down Expand Up @@ -1446,7 +1446,7 @@ pub(crate) mod tests {
block_number: NumberFor<Block>,
) -> VoteMessage<NumberFor<Block>, AuthorityId, Signature> {
let commitment = Commitment {
payload: Payload::new(*b"BF", vec![]),
payload: Payload::from_single_entry(*b"BF", vec![]),
block_number,
validator_set_id: 0,
};
Expand Down Expand Up @@ -1538,7 +1538,7 @@ pub(crate) mod tests {

// import/append BEEFY justification for session boundary block 10
let commitment = Commitment {
payload: Payload::new(known_payloads::MMR_ROOT_ID, vec![]),
payload: Payload::from_single_entry(known_payloads::MMR_ROOT_ID, vec![]),
block_number: 10,
validator_set_id: validator_set.id(),
};
Expand Down Expand Up @@ -1572,7 +1572,7 @@ pub(crate) mod tests {

// import/append BEEFY justification for block 12
let commitment = Commitment {
payload: Payload::new(known_payloads::MMR_ROOT_ID, vec![]),
payload: Payload::from_single_entry(known_payloads::MMR_ROOT_ID, vec![]),
block_number: 12,
validator_set_id: validator_set.id(),
};
Expand Down
18 changes: 12 additions & 6 deletions primitives/beefy/src/commitment.rs
Original file line number Diff line number Diff line change
Expand Up @@ -285,7 +285,8 @@ mod tests {
#[test]
fn commitment_encode_decode() {
// given
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let commitment: TestCommitment =
Commitment { payload, block_number: 5, validator_set_id: 0 };

Expand All @@ -306,7 +307,8 @@ mod tests {
#[test]
fn signed_commitment_encode_decode() {
// given
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let commitment: TestCommitment =
Commitment { payload, block_number: 5, validator_set_id: 0 };

Expand Down Expand Up @@ -340,7 +342,8 @@ mod tests {
#[test]
fn signed_commitment_count_signatures() {
// given
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let commitment: TestCommitment =
Commitment { payload, block_number: 5, validator_set_id: 0 };

Expand All @@ -365,7 +368,8 @@ mod tests {
block_number: u128,
validator_set_id: crate::ValidatorSetId,
) -> TestCommitment {
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
Commitment { payload, block_number, validator_set_id }
}

Expand All @@ -385,7 +389,8 @@ mod tests {

#[test]
fn versioned_commitment_encode_decode() {
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let commitment: TestCommitment =
Commitment { payload, block_number: 5, validator_set_id: 0 };

Expand All @@ -411,7 +416,8 @@ mod tests {
#[test]
fn large_signed_commitment_encode_decode() {
// given
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let payload =
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, "Hello World!".encode());
let commitment: TestCommitment =
Commitment { payload, block_number: 5, validator_set_id: 0 };

Expand Down
5 changes: 3 additions & 2 deletions primitives/beefy/src/mmr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -185,8 +185,9 @@ mod mmr_root_provider {
R::Api: MmrApi<B, MmrRootHash>,
{
fn payload(&self, header: &B::Header) -> Option<Payload> {
self.mmr_root_from_digest_or_runtime(header)
.map(|mmr_root| Payload::new(known_payloads::MMR_ROOT_ID, mmr_root.encode()))
self.mmr_root_from_digest_or_runtime(header).map(|mmr_root| {
Payload::from_single_entry(known_payloads::MMR_ROOT_ID, mmr_root.encode())
})
}
}
}
Expand Down
4 changes: 2 additions & 2 deletions primitives/beefy/src/payload.rs
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ pub struct Payload(Vec<(BeefyPayloadId, Vec<u8>)>);

impl Payload {
/// Construct a new payload given an initial vallue
pub fn new(id: BeefyPayloadId, value: Vec<u8>) -> Self {
pub fn from_single_entry(id: BeefyPayloadId, value: Vec<u8>) -> Self {
Self(vec![(id, value)])
}

Expand Down Expand Up @@ -93,7 +93,7 @@ mod tests {
let id3: BeefyPayloadId = *b"cs";
let msg3: String = "3. Cello Cord!".to_string();

let payload = Payload::new(id1, msg1.encode())
let payload = Payload::from_single_entry(id1, msg1.encode())
.push_raw(id2, msg2.encode())
.push_raw(id3, msg3.encode());

Expand Down
5 changes: 4 additions & 1 deletion primitives/beefy/src/witness.rs
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,10 @@ mod tests {
}

fn signed_commitment() -> TestSignedCommitment {
let payload = Payload::new(known_payloads::MMR_ROOT_ID, "Hello World!".as_bytes().to_vec());
let payload = Payload::from_single_entry(
known_payloads::MMR_ROOT_ID,
"Hello World!".as_bytes().to_vec(),
);
let commitment: TestCommitment =
Commitment { payload, block_number: 5, validator_set_id: 0 };

Expand Down

0 comments on commit 09638e4

Please sign in to comment.