mirror of
https://github.com/sigp/lighthouse.git
synced 2026-03-16 03:12:41 +00:00
f3fd1f210b
There are certain crates which we re-export within `types` which creates a fragmented DevEx, where there are various ways to import the same crates.
```rust
// consensus/types/src/lib.rs
pub use bls::{
AggregatePublicKey, AggregateSignature, Error as BlsError, Keypair, PUBLIC_KEY_BYTES_LEN,
PublicKey, PublicKeyBytes, SIGNATURE_BYTES_LEN, SecretKey, Signature, SignatureBytes,
get_withdrawal_credentials,
};
pub use context_deserialize::{ContextDeserialize, context_deserialize};
pub use fixed_bytes::FixedBytesExtended;
pub use milhouse::{self, List, Vector};
pub use ssz_types::{BitList, BitVector, FixedVector, VariableList, typenum, typenum::Unsigned};
pub use superstruct::superstruct;
```
This PR removes these re-exports and makes it explicit that these types are imported from a non-`consensus/types` crate.
Co-Authored-By: Mac L <mjladson@pm.me>
58 lines
2.3 KiB
Rust
58 lines
2.3 KiB
Rust
use beacon_chain::{BeaconChain, BeaconChainTypes};
|
|
use fixed_bytes::FixedBytesExtended;
|
|
use types::{EthSpec, Hash256};
|
|
|
|
use lighthouse_network::rpc::{StatusMessage, methods::StatusMessageV2};
|
|
/// Trait to produce a `StatusMessage` representing the state of the given `beacon_chain`.
|
|
///
|
|
/// NOTE: The purpose of this is simply to obtain a `StatusMessage` from the `BeaconChain` without
|
|
/// polluting/coupling the type with RPC concepts.
|
|
pub trait ToStatusMessage {
|
|
fn status_message(&self) -> StatusMessage;
|
|
}
|
|
|
|
impl<T: BeaconChainTypes> ToStatusMessage for BeaconChain<T> {
|
|
fn status_message(&self) -> StatusMessage {
|
|
status_message(self)
|
|
}
|
|
}
|
|
|
|
/// Build a `StatusMessage` representing the state of the given `beacon_chain`.
|
|
pub(crate) fn status_message<T: BeaconChainTypes>(beacon_chain: &BeaconChain<T>) -> StatusMessage {
|
|
let fork_digest = beacon_chain.enr_fork_id().fork_digest;
|
|
let cached_head = beacon_chain.canonical_head.cached_head();
|
|
let mut finalized_checkpoint = cached_head.finalized_checkpoint();
|
|
|
|
// Alias the genesis checkpoint root to `0x00`.
|
|
let spec = &beacon_chain.spec;
|
|
let genesis_epoch = spec.genesis_slot.epoch(T::EthSpec::slots_per_epoch());
|
|
if finalized_checkpoint.epoch == genesis_epoch {
|
|
finalized_checkpoint.root = Hash256::zero();
|
|
}
|
|
|
|
// NOTE: We are making an assumption that `get_data_column_custody_info` wont fail.
|
|
let earliest_available_data_column_slot = beacon_chain
|
|
.store
|
|
.get_data_column_custody_info()
|
|
.ok()
|
|
.flatten()
|
|
.and_then(|info| info.earliest_data_column_slot);
|
|
|
|
// If data_column_custody_info.earliest_data_column_slot is `None`,
|
|
// no recent cgc changes have occurred and no cgc backfill is in progress.
|
|
let earliest_available_slot =
|
|
if let Some(earliest_available_data_column_slot) = earliest_available_data_column_slot {
|
|
earliest_available_data_column_slot
|
|
} else {
|
|
beacon_chain.store.get_anchor_info().oldest_block_slot
|
|
};
|
|
StatusMessage::V2(StatusMessageV2 {
|
|
fork_digest,
|
|
finalized_root: finalized_checkpoint.root,
|
|
finalized_epoch: finalized_checkpoint.epoch,
|
|
head_root: cached_head.head_block_root(),
|
|
head_slot: cached_head.head_slot(),
|
|
earliest_available_slot,
|
|
})
|
|
}
|