feat(permission0): implement curator re-delegation (#128)

This change finished CHAIN-105 by implementing the same re-delegation
system for curator scopes.

Author: saiintbrisson

Cargo.toml

@@ -13,7 +13,7 @@ resolver = "2"
 
 [workspace.package]
 authors = ["Renlabs <contact@renlabs.dev>"]
-edition = "2021"
+edition = "2024"
 
 [workspace.lints.clippy]
 all = "deny"

node/src/chain_spec.rs

@@ -19,7 +19,7 @@ use polkadot_sdk::{
     sc_service::{ChainType, Properties},
     *,
 };
-use serde_json::{json, Value};
+use serde_json::{Value, json};
 use torus_runtime::WASM_BINARY;
 
 /// This is a specialization of the general Substrate ChainSpec type.
@@ -53,8 +53,8 @@ fn testnet_genesis() -> Value {
         sp_keyring::{Ed25519Keyring, Sr25519Keyring},
     };
     use torus_runtime::{
-        interface::{Balance, MinimumBalance},
         BalancesConfig, SudoConfig,
+        interface::{Balance, MinimumBalance},
     };
 
     let endowment = <MinimumBalance as Get<Balance>>::get().max(1) * 1000;

node/src/cli/eth.rs

@@ -14,7 +14,7 @@ use futures::{future, prelude::*};
 use polkadot_sdk::{
     sc_client_api::BlockchainEvents,
     sc_network_sync::SyncingService,
-    sc_service::{error::Error as ServiceError, Configuration, TaskManager},
+    sc_service::{Configuration, TaskManager, error::Error as ServiceError},
 };
 use torus_runtime::opaque::Block;
 

node/src/command.rs

@@ -15,7 +15,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use benchmarking::{inherent_benchmark_data, RemarkBuilder, TransferKeepAliveBuilder};
+use benchmarking::{RemarkBuilder, TransferKeepAliveBuilder, inherent_benchmark_data};
 use frame_benchmarking_cli::{BenchmarkCmd, ExtrinsicFactory, SUBSTRATE_REFERENCE_HARDWARE};
 use futures::TryFutureExt;
 use polkadot_sdk::{sc_cli::SubstrateCli, sc_service::PartialComponents, *};

node/src/rpc.rs

@@ -32,8 +32,8 @@ use pallet_torus0_rpc::{Torus0ApiServer, Torus0Rpc};
 use polkadot_sdk::{
     pallet_transaction_payment_rpc::{TransactionPayment, TransactionPaymentApiServer},
     sc_consensus_manual_seal::{
-        rpc::{ManualSeal, ManualSealApiServer},
         EngineCommand,
+        rpc::{ManualSeal, ManualSealApiServer},
     },
     sc_rpc::SubscriptionTaskExecutor,
     sc_transaction_pool::ChainApi,

node/src/rpc/eth.rs

@@ -93,9 +93,9 @@ where
     CIDP: CreateInherentDataProviders<Block, ()> + Send + 'static,
 {
     use fc_rpc::{
-        pending::AuraConsensusDataProvider, Debug, DebugApiServer, Eth, EthApiServer, EthDevSigner,
-        EthFilter, EthFilterApiServer, EthPubSub, EthPubSubApiServer, EthSigner, Net, NetApiServer,
-        TxPool, TxPoolApiServer, Web3, Web3ApiServer,
+        Debug, DebugApiServer, Eth, EthApiServer, EthDevSigner, EthFilter, EthFilterApiServer,
+        EthPubSub, EthPubSubApiServer, EthSigner, Net, NetApiServer, TxPool, TxPoolApiServer, Web3,
+        Web3ApiServer, pending::AuraConsensusDataProvider,
     };
 
     let EthDeps {

node/src/service.rs

@@ -24,7 +24,7 @@ use polkadot_sdk::{
     sc_client_api::{Backend, BlockBackend},
     sc_executor::WasmExecutor,
     sc_network_sync::strategy::warp::WarpSyncProvider,
-    sc_service::{error::Error as ServiceError, Configuration, TaskManager, WarpSyncConfig},
+    sc_service::{Configuration, TaskManager, WarpSyncConfig, error::Error as ServiceError},
     sc_telemetry::{Telemetry, TelemetryHandle, TelemetryWorker},
     sc_transaction_pool_api::OffchainTransactionPoolFactory,
     sp_consensus_aura::sr25519::AuthorityPair,
@@ -34,11 +34,11 @@ use polkadot_sdk::{
 use torus_runtime::{apis::RuntimeApi, configs::eth::TransactionConverter, opaque::Block};
 
 use crate::cli::{
+    Consensus,
     eth::{
-        db_config_dir, new_frontier_partial, spawn_frontier_tasks, EthConfiguration,
-        FrontierPartialComponents,
+        EthConfiguration, FrontierPartialComponents, db_config_dir, new_frontier_partial,
+        spawn_frontier_tasks,
     },
-    Consensus,
 };
 
 type HostFunctions = sp_io::SubstrateHostFunctions;
@@ -165,9 +165,8 @@ type AuraData = Pin<
 
 fn aura_data_provider(
     slot_duration: sp_consensus_aura::SlotDuration,
-    eth_config: &EthConfiguration,
+    target_gas_price: u64,
 ) -> impl Fn(sp_core::H256, ()) -> AuraData {
-    let target_gas_price = eth_config.target_gas_price;
     move |_, ()| {
         Box::pin(async move {
             let timestamp = sp_timestamp::InherentDataProvider::from_system_time();
@@ -198,7 +197,10 @@ fn build_aura_grandpa_import_queue(
             block_import: grandpa_block_import.clone(),
             justification_import: Some(Box::new(grandpa_block_import.clone())),
             client,
-            create_inherent_data_providers: aura_data_provider(slot_duration, eth_config),
+            create_inherent_data_providers: aura_data_provider(
+                slot_duration,
+                eth_config.target_gas_price,
+            ),
             spawner: &task_manager.spawn_essential_handle(),
             registry: config.prometheus_registry(),
             check_for_equivocation: Default::default(),
@@ -350,7 +352,10 @@ pub async fn new_full<Network: sc_network::NetworkBackend<Block, <Block as Block
                     proposer_factory: proposer,
                     sync_oracle: sync_service.clone(),
                     justification_sync_link: sync_service.clone(),
-                    create_inherent_data_providers: aura_data_provider(slot_duration, &eth_config),
+                    create_inherent_data_providers: aura_data_provider(
+                        slot_duration,
+                        eth_config.target_gas_price,
+                    ),
                     force_authoring: config.force_authoring,
                     backoff_authoring_blocks: Option::<()>::None,
                     keystore: keystore_container.keystore(),
@@ -550,7 +555,7 @@ pub async fn new_full<Network: sc_network::NetworkBackend<Block, <Block as Block
                 forced_parent_hashes: None,
                 pending_create_inherent_data_providers: aura_data_provider(
                     slot_duration,
-                    &eth_config,
+                    eth_config.target_gas_price,
                 ),
             };
 
@@ -578,7 +583,7 @@ pub async fn new_full<Network: sc_network::NetworkBackend<Block, <Block as Block
         tx_handler_controller,
         sync_service: sync_service.clone(),
         config,
-        telemetry: telemetry.as_mut(),
+        telemetry: Option::as_mut(&mut telemetry),
     })?;
 
     spawn_frontier_tasks(

pallets/emission0/src/distribute.rs

@@ -3,15 +3,15 @@ use pallet_permission0_api::Permission0EmissionApi;
 use pallet_torus0_api::Torus0Api;
 use polkadot_sdk::{
     frame_support::{
+        DebugNoBound,
         dispatch::DispatchResult,
         storage::with_storage_layer,
         traits::{Currency, Imbalance},
-        DebugNoBound,
     },
     polkadot_sdk_frame::prelude::BlockNumberFor,
     sp_core::Get,
     sp_runtime::{
-        traits::Saturating, ArithmeticError, DispatchError, FixedU128, Percent, Perquintill,
+        ArithmeticError, DispatchError, FixedU128, Percent, Perquintill, traits::Saturating,
     },
     sp_std::{
         borrow::Cow,

pallets/emission0/src/distribute/math.rs

@@ -3,7 +3,7 @@
 #[cfg(not(feature = "std"))]
 use num_traits::float::FloatCore;
 use polkadot_sdk::{
-    sp_runtime::{traits::Saturating, FixedPointNumber, FixedU128},
+    sp_runtime::{FixedPointNumber, FixedU128, traits::Saturating},
     sp_std::vec,
     sp_std::vec::Vec,
 };

pallets/emission0/src/lib.rs

@@ -7,7 +7,7 @@ pub(crate) use ext::*;
 pub use pallet::*;
 use pallet_emission0_api::Emission0Api;
 use polkadot_sdk::{
-    frame_support::{dispatch::DispatchResult, pallet_prelude::*, DefaultNoBound},
+    frame_support::{DefaultNoBound, dispatch::DispatchResult, pallet_prelude::*},
     frame_system,
     frame_system::pallet_prelude::OriginFor,
     polkadot_sdk_frame::{self as frame, traits::Currency},