Decouple Staking and Election - Part 2.1: Unleash Multi Phase

Cargo.toml

@@ -105,7 +105,6 @@ members = [
  "frame/session/benchmarking",
  "frame/society",
  "frame/staking",
- "frame/staking/fuzzer",
  "frame/staking/reward-curve",
  "frame/sudo",
  "frame/support",

bin/node/runtime/src/lib.rs

@@ -468,14 +468,6 @@ parameter_types! {
  pub const SlashDeferDuration: pallet_staking::EraIndex = 24 * 7; // 1/4 the bonding duration.
  pub const RewardCurve: &'static PiecewiseLinear<'static> = &REWARD_CURVE;
  pub const MaxNominatorRewardedPerValidator: u32 = 256;
- pub const ElectionLookahead: BlockNumber = EPOCH_DURATION_IN_BLOCKS / 4;
- pub const MaxIterations: u32 = 10;
- // 0.05%. The higher the value, the more strict solution acceptance becomes.
- pub MinSolutionScoreBump: Perbill = Perbill::from_rational(5u32, 10_000);
- pub OffchainSolutionWeightLimit: Weight = RuntimeBlockWeights::get()
- .get(DispatchClass::Normal)
- .max_extrinsic.expect("Normal extrinsics have a weight limit configured; qed")
- .saturating_sub(BlockExecutionWeight::get());
 }
 
 impl pallet_staking::Config for Runtime {
@@ -499,14 +491,6 @@ impl pallet_staking::Config for Runtime {
  type EraPayout = pallet_staking::ConvertCurve<RewardCurve>;
  type NextNewSession = Session;
  type MaxNominatorRewardedPerValidator = MaxNominatorRewardedPerValidator;
- type ElectionLookahead = ElectionLookahead;
- type Call = Call;
- type MaxIterations = MaxIterations;
- type MinSolutionScoreBump = MinSolutionScoreBump;
- type UnsignedPriority = StakingUnsignedPriority;
- // The unsigned solution weight targeted by the OCW. We set it to the maximum possible value of
- // a single extrinsic.
- type OffchainSolutionWeightLimit = OffchainSolutionWeightLimit;
  type ElectionProvider = ElectionProviderMultiPhase;
  type WeightInfo = pallet_staking::weights::SubstrateWeight<Runtime>;
 }
@@ -536,7 +520,7 @@ impl pallet_election_provider_multi_phase::Config for Runtime {
  type Currency = Balances;
  type SignedPhase = SignedPhase;
  type UnsignedPhase = UnsignedPhase;
- type SolutionImprovementThreshold = MinSolutionScoreBump;
+ type SolutionImprovementThreshold = SolutionImprovementThreshold;
  type MinerMaxIterations = MinerMaxIterations;
  type MinerMaxWeight = MinerMaxWeight;
  type MinerTxPriority = MultiPhaseUnsignedPriority;
@@ -1095,7 +1079,7 @@ construct_runtime!(
  Balances: pallet_balances::{Module, Call, Storage, Config<T>, Event<T>},
  TransactionPayment: pallet_transaction_payment::{Module, Storage},
  ElectionProviderMultiPhase: pallet_election_provider_multi_phase::{Module, Call, Storage, Event<T>, ValidateUnsigned},
- Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>, ValidateUnsigned},
+ Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>},
  Session: pallet_session::{Module, Call, Storage, Event, Config<T>},
  Democracy: pallet_democracy::{Module, Call, Storage, Config, Event<T>},
  Council: pallet_collective::<Instance1>::{Module, Call, Storage, Origin<T>, Event<T>, Config<T>},

frame/babe/src/mock.rs

@@ -208,12 +208,6 @@ impl pallet_staking::Config for Test {
  type EraPayout = pallet_staking::ConvertCurve<RewardCurve>;
  type MaxNominatorRewardedPerValidator = MaxNominatorRewardedPerValidator;
  type NextNewSession = Session;
- type ElectionLookahead = ElectionLookahead;
- type Call = Call;
- type UnsignedPriority = StakingUnsignedPriority;
- type MaxIterations = ();
- type MinSolutionScoreBump = ();
- type OffchainSolutionWeightLimit = ();
  type ElectionProvider = onchain::OnChainSequentialPhragmen<Self>;
  type WeightInfo = ();
 }

frame/election-provider-multi-phase/src/unsigned.rs

@@ -737,7 +737,6 @@ mod tests {
  roll_to(25);
  assert!(MultiPhase::current_phase().is_unsigned());
 
- // mine seq_phragmen solution with 2 iters.
  assert_eq!(
  MultiPhase::mine_check_and_submit().unwrap_err(),
  MinerError::PreDispatchChecksFailed,
@@ -844,7 +843,7 @@ mod tests {
  }
 
  #[test]
- fn ocw_only_runs_when_signed_open_now() {
+ fn ocw_only_runs_when_unsigned_open_now() {
  let (mut ext, pool) = ExtBuilder::default().build_offchainify(0);
  ext.execute_with(|| {
  roll_to(25);

frame/election-provider-support/src/lib.rs

@@ -168,7 +168,9 @@ use frame_support::weights::Weight;
 
 /// Re-export some type as they are used in the interface.
 pub use sp_arithmetic::PerThing;
-pub use sp_npos_elections::{Assignment, ExtendedBalance, PerThing128, Supports, VoteWeight};
+pub use sp_npos_elections::{
+ Assignment, ExtendedBalance, PerThing128, Supports, Support, VoteWeight
+};
 
 /// Types that are used by the data provider trait.
 pub mod data_provider {

frame/grandpa/src/mock.rs

@@ -54,7 +54,7 @@ frame_support::construct_runtime!(
  System: frame_system::{Module, Call, Config, Storage, Event<T>},
  Timestamp: pallet_timestamp::{Module, Call, Storage, Inherent},
  Balances: pallet_balances::{Module, Call, Storage, Config<T>, Event<T>},
- Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>, ValidateUnsigned},
+ Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>},
  Session: pallet_session::{Module, Call, Storage, Event, Config<T>},
  Grandpa: pallet_grandpa::{Module, Call, Storage, Config, Event, ValidateUnsigned},
  Offences: pallet_offences::{Module, Call, Storage, Event},
@@ -214,12 +214,6 @@ impl pallet_staking::Config for Test {
  type EraPayout = pallet_staking::ConvertCurve<RewardCurve>;
  type MaxNominatorRewardedPerValidator = MaxNominatorRewardedPerValidator;
  type NextNewSession = Session;
- type ElectionLookahead = ElectionLookahead;
- type Call = Call;
- type UnsignedPriority = StakingUnsignedPriority;
- type MaxIterations = ();
- type MinSolutionScoreBump = ();
- type OffchainSolutionWeightLimit = ();
  type ElectionProvider = onchain::OnChainSequentialPhragmen<Self>;
  type WeightInfo = ();
 }

frame/offences/benchmarking/src/lib.rs

@@ -40,7 +40,7 @@ use pallet_session::historical::{Config as HistoricalConfig, IdentificationTuple
 use pallet_session::{Config as SessionConfig, SessionManager};
 use pallet_staking::{
  Module as Staking, Config as StakingConfig, RewardDestination, ValidatorPrefs,
- Exposure, IndividualExposure, ElectionStatus, MAX_NOMINATIONS, Event as StakingEvent
+ Exposure, IndividualExposure, MAX_NOMINATIONS, Event as StakingEvent
 };
 
 const SEED: u32 = 0;
@@ -386,8 +386,6 @@ benchmarks! {
  let o = 10;
  let n = 100;
 
- Staking::<T>::put_election_status(ElectionStatus::Closed);
-
  let mut deferred_offences = vec![];
  let offenders = make_offenders::<T>(o, n)?.0;
  let offence_details = offenders.into_iter()

frame/offences/benchmarking/src/mock.rs

@@ -172,13 +172,7 @@ impl pallet_staking::Config for Test {
  type SessionInterface = Self;
  type EraPayout = pallet_staking::ConvertCurve<RewardCurve>;
  type NextNewSession = Session;
- type ElectionLookahead = ();
- type Call = Call;
  type MaxNominatorRewardedPerValidator = MaxNominatorRewardedPerValidator;
- type UnsignedPriority = ();
- type MaxIterations = ();
- type MinSolutionScoreBump = ();
- type OffchainSolutionWeightLimit = ();
  type ElectionProvider = onchain::OnChainSequentialPhragmen<Self>;
  type WeightInfo = ();
 }
@@ -222,7 +216,7 @@ frame_support::construct_runtime!(
  {
  System: system::{Module, Call, Event<T>},
  Balances: pallet_balances::{Module, Call, Storage, Config<T>, Event<T>},
- Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>, ValidateUnsigned},
+ Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>},
  Session: pallet_session::{Module, Call, Storage, Event, Config<T>},
  ImOnline: pallet_im_online::{Module, Call, Storage, Event<T>, ValidateUnsigned, Config<T>},
  Offences: pallet_offences::{Module, Call, Storage, Event},

frame/session/benchmarking/src/mock.rs

@@ -39,7 +39,7 @@ frame_support::construct_runtime!(
  {
  System: frame_system::{Module, Call, Config, Storage, Event<T>},
  Balances: pallet_balances::{Module, Call, Storage, Config<T>, Event<T>},
- Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>, ValidateUnsigned},
+ Staking: pallet_staking::{Module, Call, Config<T>, Storage, Event<T>},
  Session: pallet_session::{Module, Call, Storage, Event, Config<T>},
  }
 );
@@ -177,13 +177,7 @@ impl pallet_staking::Config for Test {
  type SessionInterface = Self;
  type EraPayout = pallet_staking::ConvertCurve<RewardCurve>;
  type NextNewSession = Session;
- type ElectionLookahead = ();
- type Call = Call;
  type MaxNominatorRewardedPerValidator = MaxNominatorRewardedPerValidator;
- type UnsignedPriority = UnsignedPriority;
- type MaxIterations = ();
- type MinSolutionScoreBump = ();
- type OffchainSolutionWeightLimit = ();
  type ElectionProvider = onchain::OnChainSequentialPhragmen<Self>;
  type WeightInfo = ();
 }

frame/staking/Cargo.toml

@@ -17,7 +17,6 @@ static_assertions = "1.1.0"
 serde = { version = "1.0.101", optional = true }
 codec = { package = "parity-scale-codec", version = "2.0.0", default-features = false, features = ["derive"] }
 sp-std = { version = "3.0.0", default-features = false, path = "../../primitives/std" }
-# TWO_PHASE_NOTE:: ideally we should be able to get rid of this.
 sp-npos-elections = { version = "3.0.0", default-features = false, path = "../../primitives/npos-elections" }
 sp-io ={ version = "3.0.0", default-features = false, path = "../../primitives/io" }
 sp-runtime = { version = "3.0.0", default-features = false, path = "../../primitives/runtime" }
@@ -27,8 +26,9 @@ frame-system = { version = "3.0.0", default-features = false, path = "../system"
 pallet-session = { version = "3.0.0", default-features = false, features = ["historical"], path = "../session" }
 pallet-authorship = { version = "3.0.0", default-features = false, path = "../authorship" }
 sp-application-crypto = { version = "3.0.0", default-features = false, path = "../../primitives/application-crypto" }
-log = { version = "0.4.14", default-features = false }
 frame-election-provider-support = { version = "3.0.0", default-features = false, path = "../election-provider-support" }
+log = { version = "0.4.14", default-features = false }
+paste = "1.0"
 
 # Optional imports for benchmarking
 frame-benchmarking = { version = "3.1.0", default-features = false, path = "../benchmarking", optional = true }