mirror of
https://github.com/sigp/lighthouse.git
synced 2026-03-20 21:34:46 +00:00
- Resolves #1550 - Resolves #824 - Resolves #825 - Resolves #1131 - Resolves #1411 - Resolves #1256 - Resolve #1177 - Includes the `ShufflingId` struct initially defined in #1492. That PR is now closed and the changes are included here, with significant bug fixes. - Implement the https://github.com/ethereum/eth2.0-APIs in a new `http_api` crate using `warp`. This replaces the `rest_api` crate. - Add a new `common/eth2` crate which provides a wrapper around `reqwest`, providing the HTTP client that is used by the validator client and for testing. This replaces the `common/remote_beacon_node` crate. - Create a `http_metrics` crate which is a dedicated server for Prometheus metrics (they are no longer served on the same port as the REST API). We now have flags for `--metrics`, `--metrics-address`, etc. - Allow the `subnet_id` to be an optional parameter for `VerifiedUnaggregatedAttestation::verify`. This means it does not need to be provided unnecessarily by the validator client. - Move `fn map_attestation_committee` in `mod beacon_chain::attestation_verification` to a new `fn with_committee_cache` on the `BeaconChain` so the same cache can be used for obtaining validator duties. - Add some other helpers to `BeaconChain` to assist with common API duties (e.g., `block_root_at_slot`, `head_beacon_block_root`). - Change the `NaiveAggregationPool` so it can index attestations by `hash_tree_root(attestation.data)`. This is a requirement of the API. - Add functions to `BeaconChainHarness` to allow it to create slashings and exits. - Allow for `eth1::Eth1NetworkId` to go to/from a `String`. - Add functions to the `OperationPool` to allow getting all objects in the pool. - Add function to `BeaconState` to check if a committee cache is initialized. - Fix bug where `seconds_per_eth1_block` was not transferring over from `YamlConfig` to `ChainSpec`. - Add the `deposit_contract_address` to `YamlConfig` and `ChainSpec`. We needed to be able to return it in an API response. - Change some uses of serde `serialize_with` and `deserialize_with` to a single use of `with` (code quality). - Impl `Display` and `FromStr` for several BLS fields. - Check for clock discrepancy when VC polls BN for sync state (with +/- 1 slot tolerance). This is not intended to be comprehensive, it was just easy to do. - See #1434 for a per-endpoint overview. - Seeking clarity here: https://github.com/ethereum/eth2.0-APIs/issues/75 - [x] Add docs for prom port to close #1256 - [x] Follow up on this #1177 - [x] ~~Follow up with #1424~~ Will fix in future PR. - [x] Follow up with #1411 - [x] ~~Follow up with #1260~~ Will fix in future PR. - [x] Add quotes to all integers. - [x] Remove `rest_types` - [x] Address missing beacon block error. (#1629) - [x] ~~Add tests for lighthouse/peers endpoints~~ Wontfix - [x] ~~Follow up with validator status proposal~~ Tracked in #1434 - [x] Unify graffiti structs - [x] ~~Start server when waiting for genesis?~~ Will fix in future PR. - [x] TODO in http_api tests - [x] Move lighthouse endpoints off /eth/v1 - [x] Update docs to link to standard - ~~Blocked on #1586~~ Co-authored-by: Michael Sproul <michael@sigmaprime.io>
178 lines
5.8 KiB
Rust
178 lines
5.8 KiB
Rust
/// Contains the functions required for a `TreeHash` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_tree_hash {
|
|
($byte_size: expr) => {
|
|
fn tree_hash_type() -> tree_hash::TreeHashType {
|
|
tree_hash::TreeHashType::Vector
|
|
}
|
|
|
|
fn tree_hash_packed_encoding(&self) -> Vec<u8> {
|
|
unreachable!("Vector should never be packed.")
|
|
}
|
|
|
|
fn tree_hash_packing_factor() -> usize {
|
|
unreachable!("Vector should never be packed.")
|
|
}
|
|
|
|
fn tree_hash_root(&self) -> tree_hash::Hash256 {
|
|
// We could use the tree hash implementation for `FixedVec<u8, $byte_size>`,
|
|
// but benchmarks have show that to be at least 15% slower because of the
|
|
// unnecessary copying and allocation (one Vec per byte)
|
|
let values_per_chunk = tree_hash::BYTES_PER_CHUNK;
|
|
let minimum_chunk_count = ($byte_size + values_per_chunk - 1) / values_per_chunk;
|
|
tree_hash::merkle_root(&self.serialize(), minimum_chunk_count)
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `ssz::Encode` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_ssz_encode {
|
|
($byte_size: expr) => {
|
|
fn is_ssz_fixed_len() -> bool {
|
|
true
|
|
}
|
|
|
|
fn ssz_fixed_len() -> usize {
|
|
$byte_size
|
|
}
|
|
|
|
fn ssz_bytes_len(&self) -> usize {
|
|
$byte_size
|
|
}
|
|
|
|
fn ssz_append(&self, buf: &mut Vec<u8>) {
|
|
buf.extend_from_slice(&self.serialize())
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `ssz::Decode` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_ssz_decode {
|
|
($byte_size: expr) => {
|
|
fn is_ssz_fixed_len() -> bool {
|
|
true
|
|
}
|
|
|
|
fn ssz_fixed_len() -> usize {
|
|
$byte_size
|
|
}
|
|
|
|
fn from_ssz_bytes(bytes: &[u8]) -> Result<Self, ssz::DecodeError> {
|
|
let len = bytes.len();
|
|
let expected = <Self as ssz::Decode>::ssz_fixed_len();
|
|
|
|
if len != expected {
|
|
Err(ssz::DecodeError::InvalidByteLength { len, expected })
|
|
} else {
|
|
Self::deserialize(bytes)
|
|
.map_err(|e| ssz::DecodeError::BytesInvalid(format!("{:?}", e)))
|
|
}
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `fmt::Display` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_display {
|
|
() => {
|
|
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
|
write!(f, "{}", hex_encode(self.serialize().to_vec()))
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `fmt::Display` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_from_str {
|
|
() => {
|
|
type Err = String;
|
|
|
|
fn from_str(s: &str) -> Result<Self, Self::Err> {
|
|
if s.starts_with("0x") {
|
|
let bytes = hex::decode(&s[2..]).map_err(|e| e.to_string())?;
|
|
Self::deserialize(&bytes[..]).map_err(|e| format!("{:?}", e))
|
|
} else {
|
|
Err("must start with 0x".to_string())
|
|
}
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `serde::Serialize` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_serde_serialize {
|
|
() => {
|
|
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: Serializer,
|
|
{
|
|
serializer.serialize_str(&self.to_string())
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `serde::Deserialize` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_serde_deserialize {
|
|
() => {
|
|
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
|
|
where
|
|
D: Deserializer<'de>,
|
|
{
|
|
pub struct StringVisitor;
|
|
|
|
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)
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for a `Debug` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
macro_rules! impl_debug {
|
|
() => {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
write!(f, "{}", hex_encode(&self.serialize().to_vec()))
|
|
}
|
|
};
|
|
}
|
|
|
|
/// Contains the functions required for an `Arbitrary` implementation.
|
|
///
|
|
/// Does not include the `Impl` section since it gets very complicated when it comes to generics.
|
|
#[cfg(feature = "arbitrary")]
|
|
macro_rules! impl_arbitrary {
|
|
($byte_size: expr) => {
|
|
fn arbitrary(u: &mut arbitrary::Unstructured<'_>) -> arbitrary::Result<Self> {
|
|
let mut bytes = [0u8; $byte_size];
|
|
u.fill_buffer(&mut bytes)?;
|
|
Self::deserialize(&bytes).map_err(|_| arbitrary::Error::IncorrectFormat)
|
|
}
|
|
};
|
|
}
|