mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-23 04:55:41 +00:00
1f687256fb
* [Feature] Add deposit to fast-unstake * disable on ErasToCheckPerBlock == 0 * removed signed ext * remove obsolete import * remove some obsolete stuff * fix some comments * fixed all the comments * remove obsolete imports * fix some tests * CallNotAllowed tests * Update frame/fast-unstake/src/lib.rs Co-authored-by: Kian Paimani <5588131+kianenigma@users.noreply.github.com> * fix tests * fix deregister + tests * more fixes * make sure we go above existential deposit * fixed the last test * some nit fixes * fix node * fix bench * last bench fix * Update frame/fast-unstake/src/lib.rs * ".git/.scripts/fmt.sh" 1 Co-authored-by: Kian Paimani <5588131+kianenigma@users.noreply.github.com> Co-authored-by: command-bot <>
207 lines
6.2 KiB
Rust
207 lines
6.2 KiB
Rust
// This file is part of Substrate.
|
|
|
|
// Copyright (C) 2022 Parity Technologies (UK) Ltd.
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
//! Benchmarking for pallet-fast-unstake.
|
|
|
|
#![cfg(feature = "runtime-benchmarks")]
|
|
|
|
use crate::{types::*, Pallet as FastUnstake, *};
|
|
use frame_benchmarking::{benchmarks, whitelist_account};
|
|
use frame_support::{
|
|
assert_ok,
|
|
traits::{Currency, EnsureOrigin, Get, Hooks},
|
|
};
|
|
use frame_system::RawOrigin;
|
|
use pallet_staking::Pallet as Staking;
|
|
use sp_runtime::traits::{StaticLookup, Zero};
|
|
use sp_staking::EraIndex;
|
|
use sp_std::prelude::*;
|
|
|
|
const USER_SEED: u32 = 0;
|
|
const DEFAULT_BACKER_PER_VALIDATOR: u32 = 128;
|
|
const MAX_VALIDATORS: u32 = 128;
|
|
|
|
type CurrencyOf<T> = <T as pallet_staking::Config>::Currency;
|
|
|
|
fn l<T: Config>(
|
|
who: T::AccountId,
|
|
) -> <<T as frame_system::Config>::Lookup as StaticLookup>::Source {
|
|
T::Lookup::unlookup(who)
|
|
}
|
|
|
|
fn create_unexposed_nominator<T: Config>() -> T::AccountId {
|
|
let account = frame_benchmarking::account::<T::AccountId>("nominator_42", 0, USER_SEED);
|
|
fund_and_bond_account::<T>(&account);
|
|
account
|
|
}
|
|
|
|
fn fund_and_bond_account<T: Config>(account: &T::AccountId) {
|
|
let stake = CurrencyOf::<T>::minimum_balance() * 100u32.into();
|
|
CurrencyOf::<T>::make_free_balance_be(&account, stake * 10u32.into());
|
|
|
|
let account_lookup = l::<T>(account.clone());
|
|
// bond and nominate ourselves, this will guarantee that we are not backing anyone.
|
|
assert_ok!(Staking::<T>::bond(
|
|
RawOrigin::Signed(account.clone()).into(),
|
|
account_lookup.clone(),
|
|
stake,
|
|
pallet_staking::RewardDestination::Controller,
|
|
));
|
|
assert_ok!(Staking::<T>::nominate(
|
|
RawOrigin::Signed(account.clone()).into(),
|
|
vec![account_lookup]
|
|
));
|
|
}
|
|
|
|
pub(crate) fn fast_unstake_events<T: Config>() -> Vec<crate::Event<T>> {
|
|
frame_system::Pallet::<T>::events()
|
|
.into_iter()
|
|
.map(|r| r.event)
|
|
.filter_map(|e| <T as Config>::RuntimeEvent::from(e).try_into().ok())
|
|
.collect::<Vec<_>>()
|
|
}
|
|
|
|
fn setup_staking<T: Config>(v: u32, until: EraIndex) {
|
|
let ed = CurrencyOf::<T>::minimum_balance();
|
|
|
|
log!(debug, "registering {} validators and {} eras.", v, until);
|
|
|
|
// our validators don't actually need to registered in staking -- just generate `v` random
|
|
// accounts.
|
|
let validators = (0..v)
|
|
.map(|x| frame_benchmarking::account::<T::AccountId>("validator", x, USER_SEED))
|
|
.collect::<Vec<_>>();
|
|
|
|
for era in 0..=until {
|
|
let others = (0..DEFAULT_BACKER_PER_VALIDATOR)
|
|
.map(|s| {
|
|
let who = frame_benchmarking::account::<T::AccountId>("nominator", era, s);
|
|
let value = ed;
|
|
pallet_staking::IndividualExposure { who, value }
|
|
})
|
|
.collect::<Vec<_>>();
|
|
let exposure =
|
|
pallet_staking::Exposure { total: Default::default(), own: Default::default(), others };
|
|
validators.iter().for_each(|v| {
|
|
Staking::<T>::add_era_stakers(era, v.clone(), exposure.clone());
|
|
});
|
|
}
|
|
}
|
|
|
|
fn on_idle_full_block<T: Config>() {
|
|
let remaining_weight = <T as frame_system::Config>::BlockWeights::get().max_block;
|
|
FastUnstake::<T>::on_idle(Zero::zero(), remaining_weight);
|
|
}
|
|
|
|
benchmarks! {
|
|
// on_idle, we we don't check anyone, but fully unbond and move them to another pool.
|
|
on_idle_unstake {
|
|
ErasToCheckPerBlock::<T>::put(1);
|
|
let who = create_unexposed_nominator::<T>();
|
|
assert_ok!(FastUnstake::<T>::register_fast_unstake(
|
|
RawOrigin::Signed(who.clone()).into(),
|
|
));
|
|
|
|
// run on_idle once. This will check era 0.
|
|
assert_eq!(Head::<T>::get(), None);
|
|
on_idle_full_block::<T>();
|
|
assert_eq!(
|
|
Head::<T>::get(),
|
|
Some(UnstakeRequest { stash: who.clone(), checked: vec![0].try_into().unwrap(), deposit: T::Deposit::get() })
|
|
);
|
|
}
|
|
: {
|
|
on_idle_full_block::<T>();
|
|
}
|
|
verify {
|
|
assert!(matches!(
|
|
fast_unstake_events::<T>().last(),
|
|
Some(Event::Unstaked { .. })
|
|
));
|
|
}
|
|
|
|
// on_idle, when we check some number of eras,
|
|
on_idle_check {
|
|
// number of eras multiplied by validators in that era.
|
|
let x in (<T as pallet_staking::Config>::BondingDuration::get() * 1) .. (<T as pallet_staking::Config>::BondingDuration::get() * MAX_VALIDATORS);
|
|
|
|
let v = x / <T as pallet_staking::Config>::BondingDuration::get();
|
|
let u = <T as pallet_staking::Config>::BondingDuration::get();
|
|
|
|
ErasToCheckPerBlock::<T>::put(u);
|
|
pallet_staking::CurrentEra::<T>::put(u);
|
|
|
|
// setup staking with v validators and u eras of data (0..=u)
|
|
setup_staking::<T>(v, u);
|
|
let who = create_unexposed_nominator::<T>();
|
|
assert_ok!(FastUnstake::<T>::register_fast_unstake(
|
|
RawOrigin::Signed(who.clone()).into(),
|
|
));
|
|
|
|
// no one is queued thus far.
|
|
assert_eq!(Head::<T>::get(), None);
|
|
}
|
|
: {
|
|
on_idle_full_block::<T>();
|
|
}
|
|
verify {
|
|
let checked: frame_support::BoundedVec<_, _> = (1..=u).rev().collect::<Vec<EraIndex>>().try_into().unwrap();
|
|
assert_eq!(
|
|
Head::<T>::get(),
|
|
Some(UnstakeRequest { stash: who.clone(), checked, deposit: T::Deposit::get() })
|
|
);
|
|
assert!(matches!(
|
|
fast_unstake_events::<T>().last(),
|
|
Some(Event::Checking { .. })
|
|
));
|
|
}
|
|
|
|
register_fast_unstake {
|
|
ErasToCheckPerBlock::<T>::put(1);
|
|
let who = create_unexposed_nominator::<T>();
|
|
whitelist_account!(who);
|
|
assert_eq!(Queue::<T>::count(), 0);
|
|
|
|
}
|
|
:_(RawOrigin::Signed(who.clone()))
|
|
verify {
|
|
assert_eq!(Queue::<T>::count(), 1);
|
|
}
|
|
|
|
deregister {
|
|
ErasToCheckPerBlock::<T>::put(1);
|
|
let who = create_unexposed_nominator::<T>();
|
|
assert_ok!(FastUnstake::<T>::register_fast_unstake(
|
|
RawOrigin::Signed(who.clone()).into(),
|
|
));
|
|
assert_eq!(Queue::<T>::count(), 1);
|
|
whitelist_account!(who);
|
|
}
|
|
:_(RawOrigin::Signed(who.clone()))
|
|
verify {
|
|
assert_eq!(Queue::<T>::count(), 0);
|
|
}
|
|
|
|
control {
|
|
let origin = <T as Config>::ControlOrigin::successful_origin();
|
|
}
|
|
: _<T::RuntimeOrigin>(origin, 128)
|
|
verify {}
|
|
|
|
impl_benchmark_test_suite!(Pallet, crate::mock::ExtBuilder::default().build(), crate::mock::Runtime)
|
|
}
|