gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-06-30 03:14:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix spelling issues

Browse Source
This commit is contained in:
Eitan Seri- Levi
2026-02-24 01:03:07 -08:00
parent ffc2b97699
commit e966428ef0
6 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
beacon_node/beacon_chain/src/execution_payload_envelope_streamer.rs
View File

@@ -21,7 +21,7 @@ pub struct PayloadEnvelopeStreamer<T: BeaconChainTypes> {
_check_caches: CheckCaches, _check_caches: CheckCaches,
} }
// TODO(gloas) eventually we'll need to expand this to support loading blinded payload envelopes from the dsb // TODO(gloas) eventually we'll need to expand this to support loading blinded payload envelopes from the db
// and fetching the execution payload from the EL. See BlockStreamer impl as an example // and fetching the execution payload from the EL. See BlockStreamer impl as an example
impl<T: BeaconChainTypes> PayloadEnvelopeStreamer<T> { impl<T: BeaconChainTypes> PayloadEnvelopeStreamer<T> {
pub fn new( pub fn new(
@@ -43,7 +43,7 @@ impl<T: BeaconChainTypes> PayloadEnvelopeStreamer<T> {
})) }))
} }
// TODO(gloas) simply a strub impl for now. Should check some exec payload envelope cache // TODO(gloas) simply a stub impl for now. Should check some exec payload envelope cache
// and return the envelope if it exists in the cache // and return the envelope if it exists in the cache
fn check_payload_envelope_cache( fn check_payload_envelope_cache(
&self, &self,

4
beacon_node/lighthouse_network/src/rpc/codec.rs
View File

@@ -77,7 +77,7 @@ impl<E: EthSpec> SSZSnappyInboundCodec<E> {
}, },
RpcSuccessResponse::BlocksByRange(res) => res.as_ssz_bytes(), RpcSuccessResponse::BlocksByRange(res) => res.as_ssz_bytes(),
RpcSuccessResponse::BlocksByRoot(res) => res.as_ssz_bytes(), RpcSuccessResponse::BlocksByRoot(res) => res.as_ssz_bytes(),
RpcSuccessResponse::PayloadEnvelopesbyRange(res) => res.as_ssz_bytes(), RpcSuccessResponse::PayloadEnvelopesByRange(res) => res.as_ssz_bytes(),
RpcSuccessResponse::PayloadEnvelopesByRoot(res) => res.as_ssz_bytes(), RpcSuccessResponse::PayloadEnvelopesByRoot(res) => res.as_ssz_bytes(),
RpcSuccessResponse::BlobsByRange(res) => res.as_ssz_bytes(), RpcSuccessResponse::BlobsByRange(res) => res.as_ssz_bytes(),
RpcSuccessResponse::BlobsByRoot(res) => res.as_ssz_bytes(), RpcSuccessResponse::BlobsByRoot(res) => res.as_ssz_bytes(),
@@ -669,7 +669,7 @@ fn handle_rpc_response<E: EthSpec>(
SignedBeaconBlock::Base(SignedBeaconBlockBase::from_ssz_bytes(decoded_buffer)?), SignedBeaconBlock::Base(SignedBeaconBlockBase::from_ssz_bytes(decoded_buffer)?),
)))), )))),
SupportedProtocol::PayloadEnvelopesByRangeV1 => { SupportedProtocol::PayloadEnvelopesByRangeV1 => {
Ok(Some(RpcSuccessResponse::PayloadEnvelopesbyRange(Arc::new( Ok(Some(RpcSuccessResponse::PayloadEnvelopesByRange(Arc::new(
SignedExecutionPayloadEnvelope::from_ssz_bytes(decoded_buffer)?, SignedExecutionPayloadEnvelope::from_ssz_bytes(decoded_buffer)?,
)))) ))))
} }

10
beacon_node/lighthouse_network/src/rpc/methods.rs
View File

@@ -516,7 +516,7 @@ impl BlocksByRootRequest {
} }
} }
/// Reqwuest a number of execution payload envelopes from a peer /// Request a number of execution payload envelopes from a peer.
#[derive(Clone, Debug, PartialEq)] #[derive(Clone, Debug, PartialEq)]
pub struct PayloadEnvelopesByRootRequest { pub struct PayloadEnvelopesByRootRequest {
/// The list of beacon block roots used to request execution payload envelopes. /// The list of beacon block roots used to request execution payload envelopes.
@@ -626,7 +626,7 @@ pub enum RpcSuccessResponse<E: EthSpec> {
/// A response to a get EXECUTION_PAYLOAD_ENVELOPES_BY_RANGE request. A None response signifies /// A response to a get EXECUTION_PAYLOAD_ENVELOPES_BY_RANGE request. A None response signifies
/// the end of the batch. /// the end of the batch.
PayloadEnvelopesbyRange(Arc<SignedExecutionPayloadEnvelope<E>>), PayloadEnvelopesByRange(Arc<SignedExecutionPayloadEnvelope<E>>),
/// A response to a get EXECUTION_PAYLOAD_ENVELOPES_BY_ROOT request. /// A response to a get EXECUTION_PAYLOAD_ENVELOPES_BY_ROOT request.
PayloadEnvelopesByRoot(Arc<SignedExecutionPayloadEnvelope<E>>), PayloadEnvelopesByRoot(Arc<SignedExecutionPayloadEnvelope<E>>),
@@ -795,7 +795,7 @@ impl<E: EthSpec> RpcSuccessResponse<E> {
RpcSuccessResponse::Status(_) => Protocol::Status, RpcSuccessResponse::Status(_) => Protocol::Status,
RpcSuccessResponse::BlocksByRange(_) => Protocol::BlocksByRange, RpcSuccessResponse::BlocksByRange(_) => Protocol::BlocksByRange,
RpcSuccessResponse::BlocksByRoot(_) => Protocol::BlocksByRoot, RpcSuccessResponse::BlocksByRoot(_) => Protocol::BlocksByRoot,
RpcSuccessResponse::PayloadEnvelopesbyRange(_) => Protocol::PayloadEnvelopesByRange, RpcSuccessResponse::PayloadEnvelopesByRange(_) => Protocol::PayloadEnvelopesByRange,
RpcSuccessResponse::PayloadEnvelopesByRoot(_) => Protocol::PayloadEnvelopesByRoot, RpcSuccessResponse::PayloadEnvelopesByRoot(_) => Protocol::PayloadEnvelopesByRoot,
RpcSuccessResponse::BlobsByRange(_) => Protocol::BlobsByRange, RpcSuccessResponse::BlobsByRange(_) => Protocol::BlobsByRange,
RpcSuccessResponse::BlobsByRoot(_) => Protocol::BlobsByRoot, RpcSuccessResponse::BlobsByRoot(_) => Protocol::BlobsByRoot,
@@ -815,7 +815,7 @@ impl<E: EthSpec> RpcSuccessResponse<E> {
pub fn slot(&self) -> Option<Slot> { pub fn slot(&self) -> Option<Slot> {
match self { match self {
Self::BlocksByRange(r) | Self::BlocksByRoot(r) => Some(r.slot()), Self::BlocksByRange(r) | Self::BlocksByRoot(r) => Some(r.slot()),
Self::PayloadEnvelopesByRoot(r) | Self::PayloadEnvelopesbyRange(r) => Some(r.slot()), Self::PayloadEnvelopesByRoot(r) | Self::PayloadEnvelopesByRange(r) => Some(r.slot()),
Self::BlobsByRange(r) | Self::BlobsByRoot(r) => Some(r.slot()), Self::BlobsByRange(r) | Self::BlobsByRoot(r) => Some(r.slot()),
Self::DataColumnsByRange(r) | Self::DataColumnsByRoot(r) => Some(r.slot()), Self::DataColumnsByRange(r) | Self::DataColumnsByRoot(r) => Some(r.slot()),
Self::LightClientBootstrap(r) => Some(r.get_slot()), Self::LightClientBootstrap(r) => Some(r.get_slot()),
@@ -866,7 +866,7 @@ impl<E: EthSpec> std::fmt::Display for RpcSuccessResponse<E> {
RpcSuccessResponse::BlocksByRoot(block) => { RpcSuccessResponse::BlocksByRoot(block) => {
write!(f, "BlocksByRoot: Block slot: {}", block.slot()) write!(f, "BlocksByRoot: Block slot: {}", block.slot())
} }
RpcSuccessResponse::PayloadEnvelopesbyRange(envelope) => { RpcSuccessResponse::PayloadEnvelopesByRange(envelope) => {
write!( write!(
f, f,
"ExecutionPayloadEnvelopesByRange: Envelope slot: {}", "ExecutionPayloadEnvelopesByRange: Envelope slot: {}",

4
beacon_node/lighthouse_network/src/service/api_types.rs
View File

@@ -163,7 +163,7 @@ pub enum Response<E: EthSpec> {
BlocksByRoot(Option<Arc<SignedBeaconBlock<E>>>), BlocksByRoot(Option<Arc<SignedBeaconBlock<E>>>),
/// A response to a get `EXECUTION_PAYLOAD_ENVELOPES_BY_ROOT` request. /// A response to a get `EXECUTION_PAYLOAD_ENVELOPES_BY_ROOT` request.
PayloadEnvelopesByRoot(Option<Arc<SignedExecutionPayloadEnvelope<E>>>), PayloadEnvelopesByRoot(Option<Arc<SignedExecutionPayloadEnvelope<E>>>),
/// A response to a get `EXECUTION_PAYLOAD_ENVELOPES_BYH_RANGE` request. /// A response to a get `EXECUTION_PAYLOAD_ENVELOPES_BY_RANGE` request.
PayloadEnvelopesByRange(Option<Arc<SignedExecutionPayloadEnvelope<E>>>), PayloadEnvelopesByRange(Option<Arc<SignedExecutionPayloadEnvelope<E>>>),
/// A response to a get BLOBS_BY_ROOT request. /// A response to a get BLOBS_BY_ROOT request.
BlobsByRoot(Option<Arc<BlobSidecar<E>>>), BlobsByRoot(Option<Arc<BlobSidecar<E>>>),
@@ -195,7 +195,7 @@ impl<E: EthSpec> std::convert::From<Response<E>> for RpcResponse<E> {
None => RpcResponse::StreamTermination(ResponseTermination::PayloadEnvelopesByRoot), None => RpcResponse::StreamTermination(ResponseTermination::PayloadEnvelopesByRoot),
}, },
Response::PayloadEnvelopesByRange(r) => match r { Response::PayloadEnvelopesByRange(r) => match r {
Some(p) => RpcResponse::Success(RpcSuccessResponse::PayloadEnvelopesbyRange(p)), Some(p) => RpcResponse::Success(RpcSuccessResponse::PayloadEnvelopesByRange(p)),
None => { None => {
RpcResponse::StreamTermination(ResponseTermination::PayloadEnvelopesByRange) RpcResponse::StreamTermination(ResponseTermination::PayloadEnvelopesByRange)
} }

2
beacon_node/lighthouse_network/src/service/mod.rs
View File

@@ -1661,7 +1661,7 @@ impl<E: EthSpec> Network<E> {
RpcSuccessResponse::BlocksByRoot(resp) => { RpcSuccessResponse::BlocksByRoot(resp) => {
self.build_response(id, peer_id, Response::BlocksByRoot(Some(resp))) self.build_response(id, peer_id, Response::BlocksByRoot(Some(resp)))
} }
RpcSuccessResponse::PayloadEnvelopesbyRange(resp) => self.build_response( RpcSuccessResponse::PayloadEnvelopesByRange(resp) => self.build_response(
id, id,
peer_id, peer_id,
Response::PayloadEnvelopesByRange(Some(resp)), Response::PayloadEnvelopesByRange(Some(resp)),

2
beacon_node/network/src/network_beacon_processor/rpc_methods.rs
View File

@@ -286,7 +286,7 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
); );
} }
/// Handle a `ExecutionPayloadEnvelopes` request from the peer. /// Handle a `ExecutionPayloadEnvelopesByRoot` request from the peer.
async fn handle_payload_envelopes_by_root_request_inner( async fn handle_payload_envelopes_by_root_request_inner(
self: Arc<Self>, self: Arc<Self>,
peer_id: PeerId, peer_id: PeerId,