-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat(node): impl evm and eth #10
Merged
Merged
Changes from all commits
Commits
File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
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 |
|---|---|---|
| @@ -1,6 +1,2 @@ | ||
| run-localnet: | ||
| cargo xtask local --alice | ||
| # cargo xtask local --alice --chain-spec specs/local.json | ||
|
|
||
| # run-replica: | ||
| # cargo xtask replica --alice | ||
| run-localnet profile="--alice": | ||
| cargo xtask run local {{profile}} |
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,162 @@ | ||
| use std::{ | ||
| collections::BTreeMap, | ||
| path::PathBuf, | ||
| sync::{Arc, Mutex}, | ||
| time::Duration, | ||
| }; | ||
|
|
||
| use fc_rpc::EthTask; | ||
| pub use fc_rpc_core::types::{FeeHistoryCache, FeeHistoryCacheLimit, FilterPool}; | ||
| pub use fc_storage::StorageOverride; | ||
| use futures::{future, prelude::*}; | ||
| use polkadot_sdk::{ | ||
| sc_client_api::BlockchainEvents, | ||
| sc_network_sync::SyncingService, | ||
| sc_service::{error::Error as ServiceError, Configuration, TaskManager}, | ||
| }; | ||
| use torus_runtime::interface::Block; | ||
|
|
||
| use crate::service::{FullBackend, FullClient}; | ||
|
|
||
| pub fn db_config_dir(config: &Configuration) -> PathBuf { | ||
| config.base_path.config_dir(config.chain_spec.id()) | ||
| } | ||
|
|
||
| /// Avalailable frontier backend types. | ||
| #[derive(Debug, Copy, Clone, Default, clap::ValueEnum)] | ||
| pub enum BackendType { | ||
| /// Either RocksDb or ParityDb as per inherited from the global backend settings. | ||
| #[default] | ||
| KeyValue, | ||
| /// Sql database with custom log indexing. | ||
| Sql, | ||
| } | ||
|
|
||
| /// The ethereum-compatibility configuration used to run a node. | ||
| #[derive(Clone, Debug, clap::Parser)] | ||
| pub struct EthConfiguration { | ||
| /// Maximum number of logs in a query. | ||
| #[arg(long, default_value = "10000")] | ||
| pub max_past_logs: u32, | ||
|
|
||
| /// Maximum fee history cache size. | ||
| #[arg(long, default_value = "2048")] | ||
| pub fee_history_limit: u64, | ||
|
|
||
| #[arg(long)] | ||
| pub enable_dev_signer: bool, | ||
|
|
||
| /// The dynamic-fee pallet target gas price set by block author | ||
| #[arg(long, default_value = "1")] | ||
| pub target_gas_price: u64, | ||
|
|
||
| /// Maximum allowed gas limit will be `block.gas_limit * execute_gas_limit_multiplier` | ||
| /// when using eth_call/eth_estimateGas. | ||
| #[arg(long, default_value = "10")] | ||
| pub execute_gas_limit_multiplier: u64, | ||
|
|
||
| /// Size in bytes of the LRU cache for block data. | ||
| #[arg(long, default_value = "50")] | ||
| pub eth_log_block_cache: usize, | ||
|
|
||
| /// Size in bytes of the LRU cache for transactions statuses data. | ||
| #[arg(long, default_value = "50")] | ||
| pub eth_statuses_cache: usize, | ||
|
|
||
| /// Sets the frontier backend type (KeyValue or Sql) | ||
| #[arg(long, value_enum, ignore_case = true, default_value_t = BackendType::default())] | ||
| pub frontier_backend_type: BackendType, | ||
|
|
||
| // Sets the SQL backend's pool size. | ||
| #[arg(long, default_value = "100")] | ||
| pub frontier_sql_backend_pool_size: u32, | ||
|
|
||
| /// Sets the SQL backend's query timeout in number of VM ops. | ||
| #[arg(long, default_value = "10000000")] | ||
| pub frontier_sql_backend_num_ops_timeout: u32, | ||
|
|
||
| /// Sets the SQL backend's auxiliary thread limit. | ||
| #[arg(long, default_value = "4")] | ||
| pub frontier_sql_backend_thread_count: u32, | ||
|
|
||
| /// Sets the SQL backend's query timeout in number of VM ops. | ||
| /// Default value is 200MB. | ||
| #[arg(long, default_value = "209715200")] | ||
| pub frontier_sql_backend_cache_size: u64, | ||
| } | ||
|
|
||
| pub struct FrontierPartialComponents { | ||
| pub filter_pool: Option<FilterPool>, | ||
| pub fee_history_cache: FeeHistoryCache, | ||
| pub fee_history_cache_limit: FeeHistoryCacheLimit, | ||
| } | ||
|
|
||
| pub fn new_frontier_partial( | ||
| config: &EthConfiguration, | ||
| ) -> Result<FrontierPartialComponents, ServiceError> { | ||
| Ok(FrontierPartialComponents { | ||
| filter_pool: Some(Arc::new(Mutex::new(BTreeMap::new()))), | ||
| fee_history_cache: Arc::new(Mutex::new(BTreeMap::new())), | ||
| fee_history_cache_limit: config.fee_history_limit, | ||
| }) | ||
| } | ||
|
|
||
| #[allow(clippy::too_many_arguments)] | ||
| pub async fn spawn_frontier_tasks( | ||
| task_manager: &TaskManager, | ||
| client: Arc<FullClient>, | ||
| backend: Arc<FullBackend>, | ||
| frontier_backend: Arc<fc_db::kv::Backend<Block, FullClient>>, | ||
| filter_pool: Option<FilterPool>, | ||
| storage_override: Arc<dyn StorageOverride<Block>>, | ||
| fee_history_cache: FeeHistoryCache, | ||
| fee_history_cache_limit: FeeHistoryCacheLimit, | ||
| sync: Arc<SyncingService<Block>>, | ||
| pubsub_notification_sinks: Arc< | ||
| fc_mapping_sync::EthereumBlockNotificationSinks< | ||
| fc_mapping_sync::EthereumBlockNotification<Block>, | ||
| >, | ||
| >, | ||
| ) { | ||
| task_manager.spawn_essential_handle().spawn( | ||
| "frontier-mapping-sync-worker", | ||
| Some("frontier"), | ||
| fc_mapping_sync::kv::MappingSyncWorker::new( | ||
| client.import_notification_stream(), | ||
| Duration::new(6, 0), | ||
| client.clone(), | ||
| backend, | ||
| storage_override.clone(), | ||
| frontier_backend.clone(), | ||
| 3, | ||
| 0, | ||
| fc_mapping_sync::SyncStrategy::Normal, | ||
| sync, | ||
| pubsub_notification_sinks, | ||
| ) | ||
| .for_each(|()| future::ready(())), | ||
| ); | ||
|
|
||
| // Spawn Frontier EthFilterApi maintenance task. | ||
| if let Some(filter_pool) = filter_pool { | ||
| // Each filter is allowed to stay in the pool for 100 blocks. | ||
| const FILTER_RETAIN_THRESHOLD: u64 = 100; | ||
| task_manager.spawn_essential_handle().spawn( | ||
| "frontier-filter-pool", | ||
| Some("frontier"), | ||
| EthTask::filter_pool_task(client.clone(), filter_pool, FILTER_RETAIN_THRESHOLD), | ||
| ); | ||
| } | ||
|
|
||
| // Spawn Frontier FeeHistory cache maintenance task. | ||
| task_manager.spawn_essential_handle().spawn( | ||
| "frontier-fee-history", | ||
| Some("frontier"), | ||
| EthTask::fee_history_task( | ||
| client, | ||
| storage_override, | ||
| fee_history_cache, | ||
| fee_history_cache_limit, | ||
| ), | ||
| ); | ||
| } | ||
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.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
same here