-
Notifications
You must be signed in to change notification settings - Fork 1
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
6e17c7c
commit b819f79
Showing
17 changed files
with
2,183 additions
and
503 deletions.
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.