feat: re-export c-kzg types and impl rlp traits

Cargo.toml

@@ -143,6 +143,8 @@ jsonrpsee-types = { version = "0.19" }
 
 ## crypto
 secp256k1 = { version = "0.27.0", default-features = false, features = ["global-context", "rand-std", "recovery"] }
+# for eip-4844
+c-kzg = { git = "https://github.com/ethereum/c-kzg-4844" }
 
 ### misc-testing
 proptest = "1.0"

crates/primitives/Cargo.toml

@@ -22,7 +22,7 @@ crunchy = { version = "0.2.2", default-features = false, features = ["limit_256"
 ruint = { version = "1.9.0", features = ["primitive-types", "rlp"] }
 
 # Bloom
- fixed-hash = { version = "0.8", default-features = false, features = ["rustc-hex"] }
+fixed-hash = { version = "0.8", default-features = false, features = ["rustc-hex"] }
 
 # crypto
 secp256k1 = { workspace = true, default-features = false, features = [
@@ -31,6 +31,9 @@ secp256k1 = { workspace = true, default-features = false, features = [
     "recovery",
 ] }
 
+# for eip-4844
+c-kzg = { workspace = true }
+
 # used for forkid
 crc = "3"
 

crates/primitives/src/lib.rs

@@ -142,6 +142,11 @@ pub mod utils {
     pub use ethers_core::types::serde_helpers;
 }
 
+/// EIP-4844 + KZG helpers
+pub mod kzg {
+    pub use c_kzg::*;
+}
+
 /// Helpers for working with serde
 pub mod serde_helper;
 

crates/rlp/Cargo.toml

@@ -18,6 +18,9 @@ ethereum-types = { version = "0.14", features = ["codec"], optional = true }
 revm-primitives = { workspace = true, features = ["serde"] }
 reth-rlp-derive = {  path = "./rlp-derive", optional = true }
 
+# for eip-4844
+c-kzg = { workspace = true, optional = true }
+
 [dev-dependencies]
 reth-rlp = { workspace = true, features = [
     "derive",
@@ -31,9 +34,11 @@ criterion = "0.5.0"
 pprof = { version = "0.12", features = ["flamegraph", "frame-pointer", "criterion"] }
 
 [features]
+default = ["kzg"]
 alloc = []
 derive = ["reth-rlp-derive"]
 std = ["alloc"]
+kzg = ["c-kzg"]
 
 [[bench]]
 name = "bench"

crates/rlp/src/encode.rs

@@ -413,6 +413,77 @@ pub fn encode_fixed_size<E: MaxEncodedLen<LEN>, const LEN: usize>(v: &E) -> Arra
     out
 }
 
+#[cfg(feature = "kzg")]
+mod kzg_support {
+    extern crate c_kzg;
+
+    use super::BufMut;
+    use crate::{Decodable, DecodeError, Encodable};
+    use c_kzg::{Blob, Bytes48, KzgCommitment, KzgProof, BYTES_PER_BLOB, BYTES_PER_COMMITMENT};
+    use core::ops::Deref;
+
+    impl Encodable for Blob {
+        fn encode(&self, out: &mut dyn BufMut) {
+            // Deref is implemented to get the underlying bytes
+            self.deref().encode(out);
+        }
+
+        fn length(&self) -> usize {
+            self.deref().length()
+        }
+    }
+
+    impl Decodable for Blob {
+        fn decode(buf: &mut &[u8]) -> Result<Self, DecodeError> {
+            let bytes: [u8; BYTES_PER_BLOB] = Decodable::decode(buf)?;
+            Ok(Blob::from(bytes))
+        }
+    }
+
+    impl Encodable for Bytes48 {
+        fn encode(&self, out: &mut dyn BufMut) {
+            self.deref().encode(out);
+        }
+
+        fn length(&self) -> usize {
+            self.deref().length()
+        }
+    }
+
+    impl Decodable for Bytes48 {
+        fn decode(buf: &mut &[u8]) -> Result<Self, DecodeError> {
+            let bytes: [u8; BYTES_PER_COMMITMENT] = Decodable::decode(buf)?;
+            Ok(Bytes48::from(bytes))
+        }
+    }
+
+    /// Only [Encodable] is implemented for [KzgCommitment] because this is a validated type - it
+    /// should be decoded using [Decodable] into a [Bytes48] type, validated, _then_ converted
+    /// into a [KzgCommitment].
+    impl Encodable for KzgCommitment {
+        fn encode(&self, out: &mut dyn BufMut) {
+            self.deref().encode(out);
+        }
+
+        fn length(&self) -> usize {
+            self.deref().length()
+        }
+    }
+
+    /// Only [Encodable] is implemented for [KzgProof] because this is a validated type - it should
+    /// be decoded using [Decodable] into a [Bytes48] type, validated, _then_ converted into a
+    /// [KzgProof].
+    impl Encodable for KzgProof {
+        fn encode(&self, out: &mut dyn BufMut) {
+            self.deref().encode(out);
+        }
+
+        fn length(&self) -> usize {
+            self.deref().length()
+        }
+    }
+}
+
 #[cfg(test)]
 mod tests {
     extern crate alloc;

deny.toml

@@ -84,6 +84,13 @@ name = "rustls-webpki"
 expression = "LicenseRef-rustls-webpki"
 license-files = [{ path = "LICENSE", hash = 0x001c7e6c }]
 
+[[licenses.clarify]]
+name = "c-kzg"
+expression = "Apache-2.0"
+# The crate is in `bindings/rust` so we have to go up two directories for the
+# license
+license-files = [{ path = "../../LICENSE", hash = 0x13cec820 }]
+
 # This section is considered when running `cargo deny check sources`.
 # More documentation about the 'sources' section can be found here:
 # https://embarkstudios.github.io/cargo-deny/checks/sources/cfg.html