Simplifications for ./crypto (#4677)

This commit is contained in:
Michael Sproul 2023-09-06 07:22:43 +10:00 committed by GitHub
parent 2550170337
commit 13606533b5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
7 changed files with 30 additions and 67 deletions

View File

@ -723,7 +723,7 @@ mod tests {
SignedBeaconBlock::from_block(full_block, Signature::empty()) SignedBeaconBlock::from_block(full_block, Signature::empty())
} }
fn default_blob_sidecar() -> Arc<BlobSidecar<Spec>> { fn empty_blob_sidecar() -> Arc<BlobSidecar<Spec>> {
Arc::new(BlobSidecar::empty()) Arc::new(BlobSidecar::empty())
} }
@ -1048,21 +1048,21 @@ mod tests {
assert_eq!( assert_eq!(
encode_then_decode_response( encode_then_decode_response(
SupportedProtocol::BlobsByRangeV1, SupportedProtocol::BlobsByRangeV1,
RPCCodedResponse::Success(RPCResponse::BlobsByRange(default_blob_sidecar())), RPCCodedResponse::Success(RPCResponse::BlobsByRange(empty_blob_sidecar())),
ForkName::Deneb, ForkName::Deneb,
&chain_spec &chain_spec
), ),
Ok(Some(RPCResponse::BlobsByRange(default_blob_sidecar()))), Ok(Some(RPCResponse::BlobsByRange(empty_blob_sidecar()))),
); );
assert_eq!( assert_eq!(
encode_then_decode_response( encode_then_decode_response(
SupportedProtocol::BlobsByRootV1, SupportedProtocol::BlobsByRootV1,
RPCCodedResponse::Success(RPCResponse::BlobsByRoot(default_blob_sidecar())), RPCCodedResponse::Success(RPCResponse::BlobsByRoot(empty_blob_sidecar())),
ForkName::Deneb, ForkName::Deneb,
&chain_spec &chain_spec
), ),
Ok(Some(RPCResponse::BlobsByRoot(default_blob_sidecar()))), Ok(Some(RPCResponse::BlobsByRoot(empty_blob_sidecar()))),
); );
} }

View File

@ -292,7 +292,7 @@ fn test_blobs_by_range_chunked_rpc() {
}); });
// BlocksByRange Response // BlocksByRange Response
let blob = BlobSidecar::<E>::default(); let blob = BlobSidecar::<E>::empty();
let rpc_response = Response::BlobsByRange(Some(Arc::new(blob))); let rpc_response = Response::BlobsByRange(Some(Arc::new(blob)));

View File

@ -11,7 +11,7 @@ harness = false
[dependencies] [dependencies]
merkle_proof = { path = "../../consensus/merkle_proof" } merkle_proof = { path = "../../consensus/merkle_proof" }
bls = { path = "../../crypto/bls", features = ["arbitrary"] } bls = { path = "../../crypto/bls", features = ["arbitrary"] }
kzg = { path = "../../crypto/kzg", features = ["arbitrary"] } kzg = { path = "../../crypto/kzg" }
compare_fields = { path = "../../common/compare_fields" } compare_fields = { path = "../../common/compare_fields" }
compare_fields_derive = { path = "../../common/compare_fields_derive" } compare_fields_derive = { path = "../../common/compare_fields_derive" }
eth2_interop_keypairs = { path = "../../common/eth2_interop_keypairs" } eth2_interop_keypairs = { path = "../../common/eth2_interop_keypairs" }

View File

@ -45,7 +45,6 @@ impl Ord for BlobIdentifier {
Encode, Encode,
Decode, Decode,
TreeHash, TreeHash,
Default,
TestRandom, TestRandom,
Derivative, Derivative,
arbitrary::Arbitrary, arbitrary::Arbitrary,
@ -120,7 +119,16 @@ impl<T: EthSpec> BlobSidecar<T> {
} }
pub fn empty() -> Self { pub fn empty() -> Self {
Self::default() Self {
block_root: Hash256::zero(),
index: 0,
slot: Slot::new(0),
block_parent_root: Hash256::zero(),
proposer_index: 0,
blob: Blob::<T>::default(),
kzg_commitment: KzgCommitment::empty_for_testing(),
kzg_proof: KzgProof::empty(),
}
} }
pub fn random_valid<R: Rng>(rng: &mut R, kzg: &Kzg<T::Kzg>) -> Result<Self, String> { pub fn random_valid<R: Rng>(rng: &mut R, kzg: &Kzg<T::Kzg>) -> Result<Self, String> {
@ -154,7 +162,7 @@ impl<T: EthSpec> BlobSidecar<T> {
blob, blob,
kzg_commitment: commitment, kzg_commitment: commitment,
kzg_proof: proof, kzg_proof: proof,
..Default::default() ..Self::empty()
}) })
} }
@ -198,7 +206,6 @@ impl<T: EthSpec> BlobSidecar<T> {
Encode, Encode,
Decode, Decode,
TreeHash, TreeHash,
Default,
TestRandom, TestRandom,
Derivative, Derivative,
arbitrary::Arbitrary, arbitrary::Arbitrary,

View File

@ -18,9 +18,9 @@ hex = "0.4.2"
ethereum_hashing = "1.0.0-beta.2" ethereum_hashing = "1.0.0-beta.2"
c-kzg = { git = "https://github.com/ethereum/c-kzg-4844", rev = "fa3c62989527073fdce8b2138bb27a52bb2407c5" , features = ["mainnet-spec"]} c-kzg = { git = "https://github.com/ethereum/c-kzg-4844", rev = "fa3c62989527073fdce8b2138bb27a52bb2407c5" , features = ["mainnet-spec"]}
c_kzg_min = { package = "c-kzg", git = "https://github.com/ethereum//c-kzg-4844", rev = "fa3c62989527073fdce8b2138bb27a52bb2407c5", features = ["minimal-spec"], optional = true } c_kzg_min = { package = "c-kzg", git = "https://github.com/ethereum//c-kzg-4844", rev = "fa3c62989527073fdce8b2138bb27a52bb2407c5", features = ["minimal-spec"], optional = true }
arbitrary = { version = "1.0", features = ["derive"], optional = true } arbitrary = { version = "1.0", features = ["derive"] }
[features] [features]
# TODO(deneb): enabled by default for convenience, would need more cfg magic to disable # TODO(deneb): enabled by default for convenience, would need more cfg magic to disable
default = ["c_kzg_min"] default = ["c_kzg_min"]
minimal-spec = ["c_kzg_min"] minimal-spec = ["c_kzg_min"]

View File

@ -9,7 +9,7 @@ use std::fmt::{Debug, Display, Formatter};
use std::str::FromStr; use std::str::FromStr;
use tree_hash::{Hash256, PackedEncoding, TreeHash}; use tree_hash::{Hash256, PackedEncoding, TreeHash};
pub const BLOB_COMMITMENT_VERSION_KZG: u8 = 0x01; pub const VERSIONED_HASH_VERSION_KZG: u8 = 0x01;
#[derive(Derivative, Clone, Copy, Encode, Decode)] #[derive(Derivative, Clone, Copy, Encode, Decode)]
#[derivative(PartialEq, Eq, Hash)] #[derivative(PartialEq, Eq, Hash)]
@ -19,9 +19,13 @@ pub struct KzgCommitment(pub [u8; c_kzg::BYTES_PER_COMMITMENT]);
impl KzgCommitment { impl KzgCommitment {
pub fn calculate_versioned_hash(&self) -> Hash256 { pub fn calculate_versioned_hash(&self) -> Hash256 {
let mut versioned_hash = hash_fixed(&self.0); let mut versioned_hash = hash_fixed(&self.0);
versioned_hash[0] = BLOB_COMMITMENT_VERSION_KZG; versioned_hash[0] = VERSIONED_HASH_VERSION_KZG;
Hash256::from_slice(versioned_hash.as_slice()) Hash256::from_slice(versioned_hash.as_slice())
} }
pub fn empty_for_testing() -> Self {
KzgCommitment([0; c_kzg::BYTES_PER_COMMITMENT])
}
} }
impl From<KzgCommitment> for c_kzg::Bytes48 { impl From<KzgCommitment> for c_kzg::Bytes48 {
@ -42,12 +46,6 @@ impl Display for KzgCommitment {
} }
} }
impl Default for KzgCommitment {
fn default() -> Self {
KzgCommitment([0; BYTES_PER_COMMITMENT])
}
}
impl TreeHash for KzgCommitment { impl TreeHash for KzgCommitment {
fn tree_hash_type() -> tree_hash::TreeHashType { fn tree_hash_type() -> tree_hash::TreeHashType {
<[u8; BYTES_PER_COMMITMENT] as TreeHash>::tree_hash_type() <[u8; BYTES_PER_COMMITMENT] as TreeHash>::tree_hash_type()
@ -80,25 +78,8 @@ impl<'de> Deserialize<'de> for KzgCommitment {
where where
D: Deserializer<'de>, D: Deserializer<'de>,
{ {
pub struct StringVisitor; let string = String::deserialize(deserializer)?;
Self::from_str(&string).map_err(serde::de::Error::custom)
impl<'de> serde::de::Visitor<'de> for StringVisitor {
type Value = String;
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
formatter.write_str("a hex string with 0x prefix")
}
fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
where
E: serde::de::Error,
{
Ok(value.to_string())
}
}
let string = deserializer.deserialize_str(StringVisitor)?;
<Self as std::str::FromStr>::from_str(&string).map_err(serde::de::Error::custom)
} }
} }
@ -131,7 +112,6 @@ impl Debug for KzgCommitment {
} }
} }
#[cfg(feature = "arbitrary")]
impl arbitrary::Arbitrary<'_> for KzgCommitment { impl arbitrary::Arbitrary<'_> for KzgCommitment {
fn arbitrary(u: &mut arbitrary::Unstructured<'_>) -> arbitrary::Result<Self> { fn arbitrary(u: &mut arbitrary::Unstructured<'_>) -> arbitrary::Result<Self> {
let mut bytes = [0u8; BYTES_PER_COMMITMENT]; let mut bytes = [0u8; BYTES_PER_COMMITMENT];

View File

@ -37,12 +37,6 @@ impl fmt::Display for KzgProof {
} }
} }
impl Default for KzgProof {
fn default() -> Self {
KzgProof([0; BYTES_PER_PROOF])
}
}
impl From<[u8; BYTES_PER_PROOF]> for KzgProof { impl From<[u8; BYTES_PER_PROOF]> for KzgProof {
fn from(bytes: [u8; BYTES_PER_PROOF]) -> Self { fn from(bytes: [u8; BYTES_PER_PROOF]) -> Self {
Self(bytes) Self(bytes)
@ -87,25 +81,8 @@ impl<'de> Deserialize<'de> for KzgProof {
where where
D: Deserializer<'de>, D: Deserializer<'de>,
{ {
pub struct StringVisitor; let string = String::deserialize(deserializer)?;
Self::from_str(&string).map_err(serde::de::Error::custom)
impl<'de> serde::de::Visitor<'de> for StringVisitor {
type Value = String;
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
formatter.write_str("a hex string with 0x prefix")
}
fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
where
E: serde::de::Error,
{
Ok(value.to_string())
}
}
let string = deserializer.deserialize_str(StringVisitor)?;
<Self as std::str::FromStr>::from_str(&string).map_err(serde::de::Error::custom)
} }
} }
@ -138,7 +115,6 @@ impl Debug for KzgProof {
} }
} }
#[cfg(feature = "arbitrary")]
impl arbitrary::Arbitrary<'_> for KzgProof { impl arbitrary::Arbitrary<'_> for KzgProof {
fn arbitrary(u: &mut arbitrary::Unstructured<'_>) -> arbitrary::Result<Self> { fn arbitrary(u: &mut arbitrary::Unstructured<'_>) -> arbitrary::Result<Self> {
let mut bytes = [0u8; BYTES_PER_PROOF]; let mut bytes = [0u8; BYTES_PER_PROOF];