-
Notifications
You must be signed in to change notification settings - Fork 799
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
a857546
commit 3480d62
Showing
91 changed files
with
1,685 additions
and
242 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,123 @@ | ||
| //! Provides tools for checking if a node is ready for the Eip7594 upgrade and following merge | ||
| //! transition. | ||
| use crate::{BeaconChain, BeaconChainTypes}; | ||
| use execution_layer::http::{ | ||
| ENGINE_FORKCHOICE_UPDATED_V3, ENGINE_GET_PAYLOAD_V3, ENGINE_NEW_PAYLOAD_V3, | ||
| }; | ||
| use serde::{Deserialize, Serialize}; | ||
| use std::fmt; | ||
| use std::time::Duration; | ||
| use types::*; | ||
|
|
||
| /// The time before the Eip7594 fork when we will start issuing warnings about preparation. | ||
| use super::bellatrix_readiness::SECONDS_IN_A_WEEK; | ||
| pub const EIP7594_READINESS_PREPARATION_SECONDS: u64 = SECONDS_IN_A_WEEK * 2; | ||
| pub const ENGINE_CAPABILITIES_REFRESH_INTERVAL: u64 = 300; | ||
|
|
||
| #[derive(Debug, Serialize, Deserialize)] | ||
| #[serde(rename_all = "snake_case")] | ||
| #[serde(tag = "type")] | ||
| pub enum Eip7594Readiness { | ||
| /// The execution engine is eip7594-enabled (as far as we can tell) | ||
| Ready, | ||
| /// We are connected to an execution engine which doesn't support the V3 engine api methods | ||
| V3MethodsNotSupported { error: String }, | ||
| /// The transition configuration with the EL failed, there might be a problem with | ||
| /// connectivity, authentication or a difference in configuration. | ||
| ExchangeCapabilitiesFailed { error: String }, | ||
| /// The user has not configured an execution endpoint | ||
| NoExecutionEndpoint, | ||
| } | ||
|
|
||
| impl fmt::Display for Eip7594Readiness { | ||
| fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { | ||
| match self { | ||
| Eip7594Readiness::Ready => { | ||
| write!(f, "This node appears ready for Eip7594.") | ||
| } | ||
| Eip7594Readiness::ExchangeCapabilitiesFailed { error } => write!( | ||
| f, | ||
| "Could not exchange capabilities with the \ | ||
| execution endpoint: {}", | ||
| error | ||
| ), | ||
| Eip7594Readiness::NoExecutionEndpoint => write!( | ||
| f, | ||
| "The --execution-endpoint flag is not specified, this is a \ | ||
| requirement post-merge" | ||
| ), | ||
| Eip7594Readiness::V3MethodsNotSupported { error } => write!( | ||
| f, | ||
| "Execution endpoint does not support Eip7594 methods: {}", | ||
| error | ||
| ), | ||
| } | ||
| } | ||
| } | ||
|
|
||
| impl<T: BeaconChainTypes> BeaconChain<T> { | ||
| /// Returns `true` if eip7594 epoch is set and Eip7594 fork has occurred or will | ||
| /// occur within `EIP7594_READINESS_PREPARATION_SECONDS` | ||
| pub fn is_time_to_prepare_for_eip7594(&self, current_slot: Slot) -> bool { | ||
| if let Some(eip7594_epoch) = self.spec.eip7594_fork_epoch { | ||
| let eip7594_slot = eip7594_epoch.start_slot(T::EthSpec::slots_per_epoch()); | ||
| let eip7594_readiness_preparation_slots = | ||
| EIP7594_READINESS_PREPARATION_SECONDS / self.spec.seconds_per_slot; | ||
| // Return `true` if Eip7594 has happened or is within the preparation time. | ||
| current_slot + eip7594_readiness_preparation_slots > eip7594_slot | ||
| } else { | ||
| // The Eip7594 fork epoch has not been defined yet, no need to prepare. | ||
| false | ||
| } | ||
| } | ||
|
|
||
| /// Attempts to connect to the EL and confirm that it is ready for eip7594. | ||
| pub async fn check_eip7594_readiness(&self) -> Eip7594Readiness { | ||
| if let Some(el) = self.execution_layer.as_ref() { | ||
| match el | ||
| .get_engine_capabilities(Some(Duration::from_secs( | ||
| ENGINE_CAPABILITIES_REFRESH_INTERVAL, | ||
| ))) | ||
| .await | ||
| { | ||
| Err(e) => { | ||
| // The EL was either unreachable or responded with an error | ||
| Eip7594Readiness::ExchangeCapabilitiesFailed { | ||
| error: format!("{:?}", e), | ||
| } | ||
| } | ||
| Ok(capabilities) => { | ||
| // TODO(eip7594): Update in the event we get V4s. | ||
| let mut missing_methods = String::from("Required Methods Unsupported:"); | ||
| let mut all_good = true; | ||
| if !capabilities.get_payload_v3 { | ||
| missing_methods.push(' '); | ||
| missing_methods.push_str(ENGINE_GET_PAYLOAD_V3); | ||
| all_good = false; | ||
| } | ||
| if !capabilities.forkchoice_updated_v3 { | ||
| missing_methods.push(' '); | ||
| missing_methods.push_str(ENGINE_FORKCHOICE_UPDATED_V3); | ||
| all_good = false; | ||
| } | ||
| if !capabilities.new_payload_v3 { | ||
| missing_methods.push(' '); | ||
| missing_methods.push_str(ENGINE_NEW_PAYLOAD_V3); | ||
| all_good = false; | ||
| } | ||
|
|
||
| if all_good { | ||
| Eip7594Readiness::Ready | ||
| } else { | ||
| Eip7594Readiness::V3MethodsNotSupported { | ||
| error: missing_methods, | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } else { | ||
| Eip7594Readiness::NoExecutionEndpoint | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.