mirror of
https://gitlab.com/pulsechaincom/lighthouse-pulse.git
synced 2024-12-25 21:17:17 +00:00
Move SSZ macros into own file
This commit is contained in:
parent
40c6be294b
commit
9ccaec5b91
@ -1,5 +1,6 @@
|
|||||||
mod decode;
|
mod decode;
|
||||||
mod encode;
|
mod encode;
|
||||||
|
mod macros;
|
||||||
|
|
||||||
pub use decode::{
|
pub use decode::{
|
||||||
impls::decode_list_of_variable_length_items, Decodable, DecodeError, SszDecoderBuilder,
|
impls::decode_list_of_variable_length_items, Decodable, DecodeError, SszDecoderBuilder,
|
||||||
@ -18,90 +19,3 @@ where
|
|||||||
{
|
{
|
||||||
val.as_ssz_bytes()
|
val.as_ssz_bytes()
|
||||||
}
|
}
|
||||||
|
|
||||||
#[macro_export]
|
|
||||||
macro_rules! impl_encode_via_from {
|
|
||||||
($impl_type: ty, $from_type: ty) => {
|
|
||||||
impl Encodable for $impl_type {
|
|
||||||
fn is_ssz_fixed_len() -> bool {
|
|
||||||
<$from_type as Encodable>::is_ssz_fixed_len()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn ssz_fixed_len() -> usize {
|
|
||||||
<$from_type as Encodable>::ssz_fixed_len()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn ssz_append(&self, buf: &mut Vec<u8>) {
|
|
||||||
let conv: $from_type = self.clone().into();
|
|
||||||
|
|
||||||
conv.ssz_append(buf)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
#[macro_export]
|
|
||||||
macro_rules! impl_decode_via_from {
|
|
||||||
($impl_type: ty, $from_type: tt) => {
|
|
||||||
impl Decodable for $impl_type {
|
|
||||||
fn is_ssz_fixed_len() -> bool {
|
|
||||||
<$from_type as Decodable>::is_ssz_fixed_len()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn ssz_fixed_len() -> usize {
|
|
||||||
<$from_type as Decodable>::ssz_fixed_len()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn from_ssz_bytes(bytes: &[u8]) -> Result<Self, ssz::DecodeError> {
|
|
||||||
$from_type::from_ssz_bytes(bytes).and_then(|dec| Ok(dec.into()))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod tests {
|
|
||||||
use super::*;
|
|
||||||
use crate as ssz;
|
|
||||||
|
|
||||||
#[derive(PartialEq, Debug, Clone, Copy)]
|
|
||||||
struct Wrapper(u64);
|
|
||||||
|
|
||||||
impl From<u64> for Wrapper {
|
|
||||||
fn from(x: u64) -> Wrapper {
|
|
||||||
Wrapper(x)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<Wrapper> for u64 {
|
|
||||||
fn from(x: Wrapper) -> u64 {
|
|
||||||
x.0
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl_encode_via_from!(Wrapper, u64);
|
|
||||||
impl_decode_via_from!(Wrapper, u64);
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn impl_encode_via_from() {
|
|
||||||
let check_encode = |a: u64, b: Wrapper| assert_eq!(a.as_ssz_bytes(), b.as_ssz_bytes());
|
|
||||||
|
|
||||||
check_encode(0, Wrapper(0));
|
|
||||||
check_encode(1, Wrapper(1));
|
|
||||||
check_encode(42, Wrapper(42));
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn impl_decode_via_from() {
|
|
||||||
let check_decode = |bytes: Vec<u8>| {
|
|
||||||
let a = u64::from_ssz_bytes(&bytes).unwrap();
|
|
||||||
let b = Wrapper::from_ssz_bytes(&bytes).unwrap();
|
|
||||||
|
|
||||||
assert_eq!(a, b.into())
|
|
||||||
};
|
|
||||||
|
|
||||||
check_decode(vec![0, 0, 0, 0, 0, 0, 0, 0]);
|
|
||||||
check_decode(vec![1, 0, 0, 0, 0, 0, 0, 0]);
|
|
||||||
check_decode(vec![1, 0, 0, 0, 2, 0, 0, 0]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
86
eth2/utils/ssz/src/macros.rs
Normal file
86
eth2/utils/ssz/src/macros.rs
Normal file
@ -0,0 +1,86 @@
|
|||||||
|
#[macro_export]
|
||||||
|
macro_rules! impl_encode_via_from {
|
||||||
|
($impl_type: ty, $from_type: ty) => {
|
||||||
|
impl ssz::Encodable for $impl_type {
|
||||||
|
fn is_ssz_fixed_len() -> bool {
|
||||||
|
<$from_type as ssz::Encodable>::is_ssz_fixed_len()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn ssz_fixed_len() -> usize {
|
||||||
|
<$from_type as ssz::Encodable>::ssz_fixed_len()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn ssz_append(&self, buf: &mut Vec<u8>) {
|
||||||
|
let conv: $from_type = self.clone().into();
|
||||||
|
|
||||||
|
conv.ssz_append(buf)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
#[macro_export]
|
||||||
|
macro_rules! impl_decode_via_from {
|
||||||
|
($impl_type: ty, $from_type: tt) => {
|
||||||
|
impl ssz::Decodable for $impl_type {
|
||||||
|
fn is_ssz_fixed_len() -> bool {
|
||||||
|
<$from_type as ssz::Decodable>::is_ssz_fixed_len()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn ssz_fixed_len() -> usize {
|
||||||
|
<$from_type as ssz::Decodable>::ssz_fixed_len()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn from_ssz_bytes(bytes: &[u8]) -> Result<Self, ssz::DecodeError> {
|
||||||
|
$from_type::from_ssz_bytes(bytes).and_then(|dec| Ok(dec.into()))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(test)]
|
||||||
|
mod tests {
|
||||||
|
use crate as ssz;
|
||||||
|
use ssz::{Decodable, Encodable};
|
||||||
|
|
||||||
|
#[derive(PartialEq, Debug, Clone, Copy)]
|
||||||
|
struct Wrapper(u64);
|
||||||
|
|
||||||
|
impl From<u64> for Wrapper {
|
||||||
|
fn from(x: u64) -> Wrapper {
|
||||||
|
Wrapper(x)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<Wrapper> for u64 {
|
||||||
|
fn from(x: Wrapper) -> u64 {
|
||||||
|
x.0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl_encode_via_from!(Wrapper, u64);
|
||||||
|
impl_decode_via_from!(Wrapper, u64);
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn impl_encode_via_from() {
|
||||||
|
let check_encode = |a: u64, b: Wrapper| assert_eq!(a.as_ssz_bytes(), b.as_ssz_bytes());
|
||||||
|
|
||||||
|
check_encode(0, Wrapper(0));
|
||||||
|
check_encode(1, Wrapper(1));
|
||||||
|
check_encode(42, Wrapper(42));
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn impl_decode_via_from() {
|
||||||
|
let check_decode = |bytes: Vec<u8>| {
|
||||||
|
let a = u64::from_ssz_bytes(&bytes).unwrap();
|
||||||
|
let b = Wrapper::from_ssz_bytes(&bytes).unwrap();
|
||||||
|
|
||||||
|
assert_eq!(a, b.into())
|
||||||
|
};
|
||||||
|
|
||||||
|
check_decode(vec![0, 0, 0, 0, 0, 0, 0, 0]);
|
||||||
|
check_decode(vec![1, 0, 0, 0, 0, 0, 0, 0]);
|
||||||
|
check_decode(vec![1, 0, 0, 0, 2, 0, 0, 0]);
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user