difftreelog
Merge pull request #341 from UniqueNetwork/feature/simple-scheduler
in: master
Feature/simple scheduler
11 files changed
pallets/scheduler/Cargo.tomldiffbeforeafterboth--- a/pallets/scheduler/Cargo.toml
+++ b/pallets/scheduler/Cargo.toml
@@ -15,11 +15,13 @@
scale-info = { version = "2.0.1", default-features = false, features = [
"derive",
] }
+
frame-support = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.22" }
frame-system = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.22" }
sp-runtime = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.22" }
sp-std = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.22" }
sp-io = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.22" }
+sp-core = { default-features = false, git = 'https://github.com/paritytech/substrate.git', branch = 'polkadot-v0.9.22' }
frame-benchmarking = { default-features = false, optional = true, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.22" }
up-sponsorship = { version = "0.1.0", default-features = false, git = "https://github.com/uniquenetwork/pallet-sponsoring", branch = "polkadot-v0.9.22" }
@@ -40,6 +42,7 @@
"up-sponsorship/std",
"sp-io/std",
"sp-std/std",
+ "sp-core/std",
"log/std",
]
runtime-benchmarks = [
pallets/scheduler/src/lib.rsdiffbeforeafterboth--- a/pallets/scheduler/src/lib.rs
+++ b/pallets/scheduler/src/lib.rs
@@ -1,23 +1,6 @@
-// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.
-// This file is part of Unique Network.
-
-// Unique Network is free software: you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-
-// Unique Network is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-
-// You should have received a copy of the GNU General Public License
-// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
-
-// Original license
// This file is part of Substrate.
-// Copyright (C) 2017-2021 Parity Technologies (UK) Ltd.
+// Copyright (C) 2017-2022 Parity Technologies (UK) Ltd.
// SPDX-License-Identifier: Apache-2.0
// Licensed under the Apache License, Version 2.0 (the "License");
@@ -32,16 +15,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
-//! # Scheduler
-//! A module for scheduling dispatches.
-//!
-//! - [`Config`]
-//! - [`Call`]
-//! - [`Module`]
-//!
-//! ## Overview
+//! # Schedulerdo_reschedule
//!
-//! This module exposes capabilities for scheduling dispatches to occur at a
+//! This Pallet exposes capabilities for scheduling dispatches to occur at a
//! specified block number or at a specified period. These scheduled dispatches
//! may be named or anonymous and may be canceled.
//!
@@ -57,106 +33,59 @@
//!
//! ### Dispatchable Functions
//!
-//! * `schedule` - schedule a dispatch, which may be periodic, to occur at a
-//! specified block and with a specified priority.
-//! * `cancel` - cancel a scheduled dispatch, specified by block number and
-//! index.
-//! * `schedule_named` - augments the `schedule` interface with an additional
-//! `Vec<u8>` parameter that can be used for identification.
+//! * `schedule` - schedule a dispatch, which may be periodic, to occur at a specified block and
+//! with a specified priority.
+//! * `cancel` - cancel a scheduled dispatch, specified by block number and index.
+//! * `schedule_named` - augments the `schedule` interface with an additional `Vec<u8>` parameter
+//! that can be used for identification.
//! * `cancel_named` - the named complement to the cancel function.
// Ensure we're `no_std` when compiling for Wasm.
#![cfg_attr(not(feature = "std"), no_std)]
-#![allow(clippy::type_complexity, clippy::boxed_local, clippy::unused_unit)]
+#[cfg(feature = "runtime-benchmarks")]
mod benchmarking;
+
pub mod weights;
-use sp_std::{prelude::*, marker::PhantomData, borrow::Borrow};
-use codec::{Encode, Decode, Codec};
+use sp_core::H160;
+use codec::{Codec, Decode, Encode};
+use frame_system::{self as system, ensure_signed};
+pub use pallet::*;
+use scale_info::TypeInfo;
use sp_runtime::{
- RuntimeDebug,
- traits::{Zero, One, BadOrigin, Saturating},
+ traits::{BadOrigin, One, Saturating, Zero},
+ RuntimeDebug, DispatchErrorWithPostInfo,
};
+use sp_std::{borrow::Borrow, cmp::Ordering, marker::PhantomData, prelude::*};
+
use frame_support::{
- decl_module, decl_storage, decl_event, decl_error,
- dispatch::{Dispatchable, DispatchError, DispatchResult, Parameter},
+ dispatch::{DispatchError, DispatchResult, Dispatchable, Parameter},
traits::{
- Get,
- schedule::{self, DispatchTime},
- OriginTrait, EnsureOrigin, IsType,
+ schedule::{self, DispatchTime, MaybeHashed},
+ NamedReservableCurrency, EnsureOrigin, Get, IsType, OriginTrait, PrivilegeCmp,
+ StorageVersion,
},
weights::{GetDispatchInfo, Weight},
};
-use frame_system::{self as system, ensure_signed};
-pub use weights::WeightInfo;
-use up_sponsorship::SponsorshipHandler;
-use scale_info::TypeInfo;
-/// Our pallet's configuration trait. All our types and constants go in here. If the
-/// pallet is dependent on specific other pallets, then their configuration traits
-/// should be added to our implied traits list.
-///
-/// `system::Config` should always be included in our implied traits.
-/// //
-pub trait Config: system::Config {
- /// The overarching event type.
- type Event: From<Event<Self>> + Into<<Self as system::Config>::Event>;
-
- /// The aggregated origin which the dispatch will take.
- type Origin: OriginTrait<PalletsOrigin = Self::PalletsOrigin>
- + From<Self::PalletsOrigin>
- + IsType<<Self as system::Config>::Origin>;
-
- /// The caller origin, overarching type of all pallets origins.
- type PalletsOrigin: From<system::RawOrigin<Self::AccountId>> + Codec + TypeInfo + Clone + Eq;
-
- /// The aggregated call type.
- type Call: Parameter
- + Dispatchable<Origin = <Self as Config>::Origin>
- + GetDispatchInfo
- + From<system::Call<Self>>;
-
- /// The maximum weight that may be scheduled per block for any dispatchables of less priority
- /// than `schedule::HARD_DEADLINE`.
- type MaximumWeight: Get<Weight>;
-
- /// Required origin to schedule or cancel calls.
- type ScheduleOrigin: EnsureOrigin<<Self as system::Config>::Origin>;
-
- /// The maximum number of scheduled calls in the queue for a single block.
- /// Not strictly enforced, but used for weight estimation.
- type MaxScheduledPerBlock: Get<u32>;
-
- /// Sponsoring function
- type SponsorshipHandler: SponsorshipHandler<Self::AccountId, <Self as Config>::Call>;
-
- /// Weight information for extrinsics in this pallet.
- type WeightInfo: WeightInfo;
-}
+pub use weights::WeightInfo;
-// pub type SelfWeightInfo<T> = <T as system::Config>::WeightInfo;
-
/// Just a simple index for naming period tasks.
pub type PeriodicIndex = u32;
/// The location of a scheduled task that can be used to remove it.
pub type TaskAddress<BlockNumber> = (BlockNumber, u32);
+pub const MAX_TASK_ID_LENGTH_IN_BYTES: u8 = 16;
-#[cfg_attr(any(feature = "std", test), derive(PartialEq, Eq))]
-#[derive(Clone, RuntimeDebug, Encode, Decode)]
-struct ScheduledV1<Call, BlockNumber> {
- maybe_id: Option<Vec<u8>>,
- priority: schedule::Priority,
- call: Call,
- maybe_periodic: Option<schedule::Period<BlockNumber>>,
-}
+type ScheduledId = [u8; MAX_TASK_ID_LENGTH_IN_BYTES as usize];
+pub type CallOrHashOf<T> = MaybeHashed<<T as Config>::Call, <T as frame_system::Config>::Hash>;
/// Information regarding an item to be executed in the future.
#[cfg_attr(any(feature = "std", test), derive(PartialEq, Eq))]
#[derive(Clone, RuntimeDebug, Encode, Decode, TypeInfo)]
-pub struct ScheduledV2<Call, BlockNumber, PalletsOrigin, AccountId> {
+pub struct ScheduledV3<Call, BlockNumber, PalletsOrigin, AccountId> {
/// The unique identity for this task, if there is one.
- maybe_id: Option<Vec<u8>>,
+ maybe_id: Option<ScheduledId>,
/// This task's priority.
priority: schedule::Priority,
/// The call to be dispatched.
@@ -168,63 +97,213 @@
_phantom: PhantomData<AccountId>,
}
+pub type ScheduledV3Of<T> = ScheduledV3<
+ CallOrHashOf<T>,
+ <T as frame_system::Config>::BlockNumber,
+ <T as Config>::PalletsOrigin,
+ <T as frame_system::Config>::AccountId,
+>;
+
+pub type ScheduledOf<T> = ScheduledV3Of<T>;
+
/// The current version of Scheduled struct.
pub type Scheduled<Call, BlockNumber, PalletsOrigin, AccountId> =
- ScheduledV2<Call, BlockNumber, PalletsOrigin, AccountId>;
+ ScheduledV3<Call, BlockNumber, PalletsOrigin, AccountId>;
-// A value placed in storage that represents the current version of the Scheduler storage.
-// This value is used by the `on_runtime_upgrade` logic to determine whether we run
-// storage migration logic.
-#[derive(Encode, Decode, Clone, Copy, PartialEq, Eq, RuntimeDebug, TypeInfo)]
-enum Releases {
- V1,
- V2,
+#[cfg(feature = "runtime-benchmarks")]
+mod preimage_provider {
+ use frame_support::traits::PreimageRecipient;
+ pub trait PreimageProviderAndMaybeRecipient<H>: PreimageRecipient<H> {}
+ impl<H, T: PreimageRecipient<H>> PreimageProviderAndMaybeRecipient<H> for T {}
}
-impl Default for Releases {
- fn default() -> Self {
- Releases::V1
- }
+#[cfg(not(feature = "runtime-benchmarks"))]
+mod preimage_provider {
+ use frame_support::traits::PreimageProvider;
+ pub trait PreimageProviderAndMaybeRecipient<H>: PreimageProvider<H> {}
+ impl<H, T: PreimageProvider<H>> PreimageProviderAndMaybeRecipient<H> for T {}
}
-#[derive(Encode, Decode, Clone, PartialEq, Eq, RuntimeDebug, TypeInfo)]
-pub struct CallSpec {
- module: u32,
- method: u32,
+pub use preimage_provider::PreimageProviderAndMaybeRecipient;
+
+pub(crate) trait MarginalWeightInfo: WeightInfo {
+ fn item(periodic: bool, named: bool, resolved: Option<bool>) -> Weight {
+ match (periodic, named, resolved) {
+ (_, false, None) => Self::on_initialize_aborted(2) - Self::on_initialize_aborted(1),
+ (_, true, None) => {
+ Self::on_initialize_named_aborted(2) - Self::on_initialize_named_aborted(1)
+ }
+ (false, false, Some(false)) => Self::on_initialize(2) - Self::on_initialize(1),
+ (false, true, Some(false)) => {
+ Self::on_initialize_named(2) - Self::on_initialize_named(1)
+ }
+ (true, false, Some(false)) => {
+ Self::on_initialize_periodic(2) - Self::on_initialize_periodic(1)
+ }
+ (true, true, Some(false)) => {
+ Self::on_initialize_periodic_named(2) - Self::on_initialize_periodic_named(1)
+ }
+ (false, false, Some(true)) => {
+ Self::on_initialize_resolved(2) - Self::on_initialize_resolved(1)
+ }
+ (false, true, Some(true)) => {
+ Self::on_initialize_named_resolved(2) - Self::on_initialize_named_resolved(1)
+ }
+ (true, false, Some(true)) => {
+ Self::on_initialize_periodic_resolved(2) - Self::on_initialize_periodic_resolved(1)
+ }
+ (true, true, Some(true)) => {
+ Self::on_initialize_periodic_named_resolved(2)
+ - Self::on_initialize_periodic_named_resolved(1)
+ }
+ }
+ }
}
+impl<T: WeightInfo> MarginalWeightInfo for T {}
-decl_storage! {
- trait Store for Module<T: Config> as Scheduler {
- /// Items to be executed, indexed by the block number that they should be executed on.
- pub Agenda: map hasher(twox_64_concat) T::BlockNumber
- => Vec<Option<Scheduled<<T as Config>::Call, T::BlockNumber, T::PalletsOrigin, T::AccountId>>>;
+#[frame_support::pallet]
+pub mod pallet {
+ use super::*;
+ use frame_support::{
+ dispatch::PostDispatchInfo,
+ pallet_prelude::*,
+ traits::{schedule::LookupError, PreimageProvider},
+ };
+ use frame_system::pallet_prelude::*;
+
+ /// The current storage version.
+ const STORAGE_VERSION: StorageVersion = StorageVersion::new(3);
+
+ #[pallet::pallet]
+ #[pallet::generate_store(pub(super) trait Store)]
+ #[pallet::storage_version(STORAGE_VERSION)]
+ #[pallet::without_storage_info]
+ pub struct Pallet<T>(_);
+
+ /// `system::Config` should always be included in our implied traits.
+ #[pallet::config]
+ pub trait Config: frame_system::Config {
+ /// The overarching event type.
+ type Event: From<Event<Self>> + IsType<<Self as frame_system::Config>::Event>;
+
+ /// The aggregated origin which the dispatch will take.
+ type Origin: OriginTrait<PalletsOrigin = Self::PalletsOrigin>
+ + From<Self::PalletsOrigin>
+ + IsType<<Self as system::Config>::Origin>;
+
+ /// The caller origin, overarching type of all pallets origins.
+ type PalletsOrigin: From<system::RawOrigin<Self::AccountId>> + Codec + Clone + Eq + TypeInfo;
+
+ type Currency: NamedReservableCurrency<Self::AccountId, ReserveIdentifier = ScheduledId>;
+
+ /// The aggregated call type.
+ type Call: Parameter
+ + Dispatchable<Origin = <Self as Config>::Origin, PostInfo = PostDispatchInfo>
+ + GetDispatchInfo
+ + From<system::Call<Self>>;
- pub SpecAgenda: map hasher(twox_64_concat) T::BlockNumber
- => Vec<Option<CallSpec>>;
+ /// The maximum weight that may be scheduled per block for any dispatchables of less
+ /// priority than `schedule::HARD_DEADLINE`.
+ #[pallet::constant]
+ type MaximumWeight: Get<Weight>;
- /// Lookup from identity to the block number and index of the task.
- Lookup: map hasher(twox_64_concat) Vec<u8> => Option<TaskAddress<T::BlockNumber>>;
+ /// Required origin to schedule or cancel calls.
+ type ScheduleOrigin: EnsureOrigin<<Self as system::Config>::Origin>;
- /// Storage version of the pallet.
+ /// Compare the privileges of origins.
+ ///
+ /// This will be used when canceling a task, to ensure that the origin that tries
+ /// to cancel has greater or equal privileges as the origin that created the scheduled task.
///
- /// New networks start with last version.
- StorageVersion build(|_| Releases::V2): Releases;
+ /// For simplicity the [`EqualPrivilegeOnly`](frame_support::traits::EqualPrivilegeOnly) can
+ /// be used. This will only check if two given origins are equal.
+ type OriginPrivilegeCmp: PrivilegeCmp<Self::PalletsOrigin>;
+
+ /// The maximum number of scheduled calls in the queue for a single block.
+ /// Not strictly enforced, but used for weight estimation.
+ #[pallet::constant]
+ type MaxScheduledPerBlock: Get<u32>;
+
+ /// Weight information for extrinsics in this pallet.
+ type WeightInfo: WeightInfo;
+
+ /// The preimage provider with which we look up call hashes to get the call.
+ type PreimageProvider: PreimageProviderAndMaybeRecipient<Self::Hash>;
+
+ /// If `Some` then the number of blocks to postpone execution for when the item is delayed.
+ type NoPreimagePostponement: Get<Option<Self::BlockNumber>>;
+
+ /// Sponsoring function.
+ // type SponsorshipHandler: SponsorshipHandler<Self::AccountId, <Self as Config>::Call>;
+
+ /// The helper type used for custom transaction fee logic.
+ type CallExecutor: DispatchCall<Self, H160>;
}
-}
-decl_event!(
- pub enum Event<T> where <T as system::Config>::BlockNumber {
- /// Scheduled some task. \[when, index\]
- Scheduled(BlockNumber, u32),
- /// Canceled some task. \[when, index\]
- Canceled(BlockNumber, u32),
- /// Dispatched some task. \[task, id, result\]
- Dispatched(TaskAddress<BlockNumber>, Option<Vec<u8>>, DispatchResult),
+ /// A Scheduler-Runtime interface for finer payment handling.
+ pub trait DispatchCall<T: frame_system::Config + Config, SelfContainedSignedInfo> {
+ fn reserve_balance(
+ id: ScheduledId,
+ sponsor: <T as frame_system::Config>::AccountId,
+ call: <T as Config>::Call,
+ count: u32,
+ ) -> Result<(), DispatchError>;
+
+ fn pay_for_call(
+ id: ScheduledId,
+ sponsor: <T as frame_system::Config>::AccountId,
+ call: <T as Config>::Call,
+ ) -> Result<u128, DispatchError>;
+
+ /// Resolve the call dispatch, including any post-dispatch operations.
+ fn dispatch_call(
+ signer: T::AccountId,
+ function: <T as Config>::Call,
+ ) -> Result<
+ Result<PostDispatchInfo, DispatchErrorWithPostInfo<PostDispatchInfo>>,
+ TransactionValidityError,
+ >;
+
+ fn cancel_reserve(
+ id: ScheduledId,
+ sponsor: <T as frame_system::Config>::AccountId,
+ ) -> Result<u128, DispatchError>;
}
-);
-decl_error! {
- pub enum Error for Module<T: Config> {
+ /// Items to be executed, indexed by the block number that they should be executed on.
+ #[pallet::storage]
+ pub type Agenda<T: Config> =
+ StorageMap<_, Twox64Concat, T::BlockNumber, Vec<Option<ScheduledV3Of<T>>>, ValueQuery>;
+
+ /// Lookup from identity to the block number and index of the task.
+ #[pallet::storage]
+ pub(crate) type Lookup<T: Config> =
+ StorageMap<_, Twox64Concat, ScheduledId, TaskAddress<T::BlockNumber>>;
+
+ /// Events type.
+ #[pallet::event]
+ #[pallet::generate_deposit(pub(super) fn deposit_event)]
+ pub enum Event<T: Config> {
+ /// Scheduled some task.
+ Scheduled { when: T::BlockNumber, index: u32 },
+ /// Canceled some task.
+ Canceled { when: T::BlockNumber, index: u32 },
+ /// Dispatched some task.
+ Dispatched {
+ task: TaskAddress<T::BlockNumber>,
+ id: Option<ScheduledId>,
+ result: DispatchResult,
+ },
+ /// The call for the provided hash was not found so the task has been aborted.
+ CallLookupFailed {
+ task: TaskAddress<T::BlockNumber>,
+ id: Option<ScheduledId>,
+ error: LookupError,
+ },
+ }
+
+ #[pallet::error]
+ pub enum Error<T> {
/// Failed to schedule a call
FailedToSchedule,
/// Cannot find the scheduled call.
@@ -234,249 +313,268 @@
/// Reschedule failed because it does not change scheduled time.
RescheduleNoChange,
}
-}
-decl_module! {
- /// Scheduler module declaration.
- pub struct Module<T: Config> for enum Call
- where
- origin: <T as system::Config>::Origin
- {
- type Error = Error<T>;
- fn deposit_event() = default;
+ #[pallet::hooks]
+ impl<T: Config> Hooks<BlockNumberFor<T>> for Pallet<T> {
+ /// Execute the scheduled calls
+ fn on_initialize(now: T::BlockNumber) -> Weight {
+ let limit = T::MaximumWeight::get();
+ let mut queued = Agenda::<T>::take(now)
+ .into_iter()
+ .enumerate()
+ .filter_map(|(index, s)| Some((index as u32, s?)))
+ .collect::<Vec<_>>();
- /// Anonymously schedule a task.
- ///
- /// # <weight>
- /// - S = Number of already scheduled calls
- /// - Base Weight: 22.29 + .126 * S µs
- /// - DB Weight:
- /// - Read: Agenda
- /// - Write: Agenda
- /// - Will use base weight of 25 which should be good for up to 30 scheduled calls
- /// # </weight>
- #[weight = <T as Config>::WeightInfo::schedule(T::MaxScheduledPerBlock::get())]
- fn schedule(origin,
- when: T::BlockNumber,
- maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
- priority: schedule::Priority,
- call: Box<<T as Config>::Call>,
- )
- {
- let origin = <T as Config>::Origin::from(origin);
- Self::do_schedule(DispatchTime::At(when), maybe_periodic, priority, origin.caller().clone(), *call)?;
- }
+ if queued.len() as u32 > T::MaxScheduledPerBlock::get() {
+ log::warn!(
+ target: "runtime::scheduler",
+ "Warning: This block has more items queued in Scheduler than \
+ expected from the runtime configuration. An update might be needed."
+ );
+ }
- /// Cancel an anonymously scheduled task.
- ///
- /// # <weight>
- /// - S = Number of already scheduled calls
- /// - Base Weight: 22.15 + 2.869 * S µs
- /// - DB Weight:
- /// - Read: Agenda
- /// - Write: Agenda, Lookup
- /// - Will use base weight of 100 which should be good for up to 30 scheduled calls
- /// # </weight>
- #[weight = <T as Config>::WeightInfo::cancel(T::MaxScheduledPerBlock::get())]
- fn cancel(origin, when: T::BlockNumber, index: u32) {
- T::ScheduleOrigin::ensure_origin(origin.clone())?;
- let origin = <T as Config>::Origin::from(origin);
- Self::do_cancel(Some(origin.caller().clone()), (when, index))?;
+ queued.sort_by_key(|(_, s)| s.priority);
+
+ let next = now + One::one();
+
+ let mut total_weight: Weight = T::WeightInfo::on_initialize(0);
+ for (order, (index, mut s)) in queued.into_iter().enumerate() {
+ let named = if let Some(ref id) = s.maybe_id {
+ Lookup::<T>::remove(id);
+ true
+ } else {
+ false
+ };
+
+ let (call, maybe_completed) = s.call.resolved::<T::PreimageProvider>();
+ s.call = call;
+
+ let resolved = if let Some(completed) = maybe_completed {
+ T::PreimageProvider::unrequest_preimage(&completed);
+ true
+ } else {
+ false
+ };
+ let call = match s.call.as_value().cloned() {
+ Some(c) => c,
+ None => {
+ // Preimage not available - postpone until some block.
+ total_weight.saturating_accrue(T::WeightInfo::item(false, named, None));
+ if let Some(delay) = T::NoPreimagePostponement::get() {
+ let until = now.saturating_add(delay);
+ if let Some(ref id) = s.maybe_id {
+ let index = Agenda::<T>::decode_len(until).unwrap_or(0);
+ Lookup::<T>::insert(id, (until, index as u32));
+ }
+ Agenda::<T>::append(until, Some(s));
+ }
+ continue;
+ }
+ };
+
+ let periodic = s.maybe_periodic.is_some();
+ let call_weight = call.get_dispatch_info().weight;
+ let mut item_weight = T::WeightInfo::item(periodic, named, Some(resolved));
+ let origin =
+ <<T as Config>::Origin as From<T::PalletsOrigin>>::from(s.origin.clone())
+ .into();
+ if ensure_signed(origin).is_ok() {
+ // Weights of Signed dispatches expect their signing account to be whitelisted.
+ item_weight.saturating_accrue(T::DbWeight::get().reads_writes(1, 1));
+ }
+
+ // We allow a scheduled call if any is true:
+ // - It's priority is `HARD_DEADLINE`
+ // - It does not push the weight past the limit.
+ // - It is the first item in the schedule
+ let hard_deadline = s.priority <= schedule::HARD_DEADLINE;
+ let test_weight = total_weight
+ .saturating_add(call_weight)
+ .saturating_add(item_weight);
+ if !hard_deadline && order > 0 && test_weight > limit {
+ // Cannot be scheduled this block - postpone until next.
+ total_weight.saturating_accrue(T::WeightInfo::item(false, named, None));
+ if let Some(ref id) = s.maybe_id {
+ // NOTE: We could reasonably not do this (in which case there would be one
+ // block where the named and delayed item could not be referenced by name),
+ // but we will do it anyway since it should be mostly free in terms of
+ // weight and it is slightly cleaner.
+ let index = Agenda::<T>::decode_len(next).unwrap_or(0);
+ Lookup::<T>::insert(id, (next, index as u32));
+ }
+ Agenda::<T>::append(next, Some(s));
+ continue;
+ }
+
+ let sender = ensure_signed(
+ <<T as Config>::Origin as From<T::PalletsOrigin>>::from(s.origin.clone())
+ .into(),
+ )
+ .unwrap();
+
+ // // if call have id it was be reserved
+ // if s.maybe_id.is_some() {
+ // let _ = T::CallExecutor::pay_for_call(
+ // s.maybe_id.unwrap(),
+ // sender.clone(),
+ // call.clone(),
+ // );
+ // }
+
+ let r = T::CallExecutor::dispatch_call(sender, call.clone());
+
+ let mut actual_call_weight: Weight = item_weight;
+ let result: Result<_, DispatchError> = match r {
+ Ok(o) => match o {
+ Ok(di) => {
+ actual_call_weight = di.actual_weight.unwrap_or(item_weight);
+ Ok(())
+ }
+ Err(err) => Err(err.error),
+ },
+ Err(_) => {
+ log::error!(
+ target: "runtime::scheduler",
+ "Warning: Scheduler has failed to execute a post-dispatch transaction. \
+ This block might have become invalid.");
+ Err(DispatchError::CannotLookup)
+ } // todo possibly force a skip/return here, do something with the error
+ };
+
+ total_weight.saturating_accrue(item_weight);
+ total_weight.saturating_accrue(actual_call_weight);
+
+ Self::deposit_event(Event::Dispatched {
+ task: (now, index),
+ id: s.maybe_id.clone(),
+ result,
+ });
+
+ if let &Some((period, count)) = &s.maybe_periodic {
+ if count > 1 {
+ s.maybe_periodic = Some((period, count - 1));
+ } else {
+ s.maybe_periodic = None;
+ }
+ let wake = now + period;
+ // If scheduled is named, place its information in `Lookup`
+ if let Some(ref id) = s.maybe_id {
+ let wake_index = Agenda::<T>::decode_len(wake).unwrap_or(0);
+ Lookup::<T>::insert(id, (wake, wake_index as u32));
+ }
+ Agenda::<T>::append(wake, Some(s));
+ }
+ }
+ 0
+ //total_weight
}
+ }
+ #[pallet::call]
+ impl<T: Config> Pallet<T> {
/// Schedule a named task.
- ///
- /// # <weight>
- /// - S = Number of already scheduled calls
- /// - Base Weight: 29.6 + .159 * S µs
- /// - DB Weight:
- /// - Read: Agenda, Lookup
- /// - Write: Agenda, Lookup
- /// - Will use base weight of 35 which should be good for more than 30 scheduled calls
- /// # </weight>
- #[weight = <T as Config>::WeightInfo::schedule_named(T::MaxScheduledPerBlock::get())]
- fn schedule_named(origin,
- id: Vec<u8>,
+ #[pallet::weight(<T as Config>::WeightInfo::schedule_named(T::MaxScheduledPerBlock::get()))]
+ pub fn schedule_named(
+ origin: OriginFor<T>,
+ id: ScheduledId,
when: T::BlockNumber,
maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
priority: schedule::Priority,
- call: Box<<T as Config>::Call>,
- ) {
+ call: Box<CallOrHashOf<T>>,
+ ) -> DispatchResult {
T::ScheduleOrigin::ensure_origin(origin.clone())?;
let origin = <T as Config>::Origin::from(origin);
Self::do_schedule_named(
- id, DispatchTime::At(when), maybe_periodic, priority, origin.caller().clone(), *call
+ id,
+ DispatchTime::At(when),
+ maybe_periodic,
+ priority,
+ origin.caller().clone(),
+ *call,
)?;
+ Ok(())
}
/// Cancel a named scheduled task.
- ///
- /// # <weight>
- /// - S = Number of already scheduled calls
- /// - Base Weight: 24.91 + 2.907 * S µs
- /// - DB Weight:
- /// - Read: Agenda, Lookup
- /// - Write: Agenda, Lookup
- /// - Will use base weight of 100 which should be good for up to 30 scheduled calls
- /// # </weight>
- #[weight = <T as Config>::WeightInfo::cancel_named(T::MaxScheduledPerBlock::get())]
- fn cancel_named(origin, id: Vec<u8>) {
+ #[pallet::weight(<T as Config>::WeightInfo::cancel_named(T::MaxScheduledPerBlock::get()))]
+ pub fn cancel_named(origin: OriginFor<T>, id: ScheduledId) -> DispatchResult {
T::ScheduleOrigin::ensure_origin(origin.clone())?;
let origin = <T as Config>::Origin::from(origin);
Self::do_cancel_named(Some(origin.caller().clone()), id)?;
- }
-
- /// Anonymously schedule a task after a delay.
- ///
- /// # <weight>
- /// Same as [`schedule`].
- /// # </weight>
- #[weight = <T as Config>::WeightInfo::schedule(T::MaxScheduledPerBlock::get())]
- fn schedule_after(origin,
- after: T::BlockNumber,
- maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
- priority: schedule::Priority,
- call: Box<<T as Config>::Call>,
- ) {
- T::ScheduleOrigin::ensure_origin(origin.clone())?;
- let origin = <T as Config>::Origin::from(origin);
- Self::do_schedule(
- DispatchTime::After(after), maybe_periodic, priority, origin.caller().clone(), *call
- )?;
+ Ok(())
}
/// Schedule a named task after a delay.
///
/// # <weight>
- /// Same as [`schedule_named`].
+ /// Same as [`schedule_named`](Self::schedule_named).
/// # </weight>
- #[weight = <T as Config>::WeightInfo::schedule_named(T::MaxScheduledPerBlock::get())]
- fn schedule_named_after(origin,
- id: Vec<u8>,
+ #[pallet::weight(<T as Config>::WeightInfo::schedule_named(T::MaxScheduledPerBlock::get()))]
+ pub fn schedule_named_after(
+ origin: OriginFor<T>,
+ id: ScheduledId,
after: T::BlockNumber,
maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
priority: schedule::Priority,
- call: Box<<T as Config>::Call>,
- ) {
+ call: Box<CallOrHashOf<T>>,
+ ) -> DispatchResult {
T::ScheduleOrigin::ensure_origin(origin.clone())?;
let origin = <T as Config>::Origin::from(origin);
Self::do_schedule_named(
- id, DispatchTime::After(after), maybe_periodic, priority, origin.caller().clone(), *call
+ id,
+ DispatchTime::After(after),
+ maybe_periodic,
+ priority,
+ origin.caller().clone(),
+ *call,
)?;
+ Ok(())
}
-
- /// Execute the scheduled calls
- ///
- /// # <weight>
- /// - S = Number of already scheduled calls
- /// - N = Named scheduled calls
- /// - P = Periodic Calls
- /// - Base Weight: 9.243 + 23.45 * S µs
- /// - DB Weight:
- /// - Read: Agenda + Lookup * N + Agenda(Future) * P
- /// - Write: Agenda + Lookup * N + Agenda(future) * P
- /// # </weight>
- fn on_initialize(now: T::BlockNumber) -> Weight {
- let limit = T::MaximumWeight::get();
- let mut queued = Agenda::<T>::take(now).into_iter()
- .enumerate()
- .filter_map(|(index, s)| s.map(|inner| (index as u32, inner)))
- .collect::<Vec<_>>();
- if queued.len() as u32 > T::MaxScheduledPerBlock::get() {
- log::warn!(
- target: "runtime::scheduler",
- "Warning: This block has more items queued in Scheduler than \
- expected from the runtime configuration. An update might be needed."
- );
- }
- queued.sort_by_key(|(_, s)| s.priority);
- let base_weight: Weight = T::DbWeight::get().reads_writes(1, 2); // Agenda + Agenda(next)
- let mut total_weight: Weight = 0;
- queued.into_iter()
- .enumerate()
- .scan(base_weight, |cumulative_weight, (order, (index, s))| {
- *cumulative_weight = cumulative_weight
- .saturating_add(s.call.get_dispatch_info().weight);
-
- let origin = <<T as Config>::Origin as From<T::PalletsOrigin>>::from(
- s.origin.clone()
- ).into();
-
- if ensure_signed(origin).is_ok() {
- // AccountData for inner call origin accountdata.
- *cumulative_weight = cumulative_weight
- .saturating_add(T::DbWeight::get().reads_writes(1, 1));
- }
-
- if s.maybe_id.is_some() {
- // Remove/Modify Lookup
- *cumulative_weight = cumulative_weight.saturating_add(T::DbWeight::get().writes(1));
- }
- if s.maybe_periodic.is_some() {
- // Read/Write Agenda for future block
- *cumulative_weight = cumulative_weight.saturating_add(T::DbWeight::get().reads_writes(1, 1));
- }
+ }
+}
- Some((order, index, *cumulative_weight, s))
- })
- .filter_map(|(order, index, cumulative_weight, mut s)| {
- // We allow a scheduled call if any is true:
- // - It's priority is `HARD_DEADLINE`
- // - It does not push the weight past the limit.
- // - It is the first item in the schedule
- if s.priority <= schedule::HARD_DEADLINE || cumulative_weight <= limit || order == 0 {
+impl<T: Config> Pallet<T> {
+ #[cfg(feature = "try-runtime")]
+ pub fn pre_migrate_to_v3() -> Result<(), &'static str> {
+ Ok(())
+ }
- let origin = <<T as Config>::Origin as From<T::PalletsOrigin>>::from(
- s.origin.clone()
- ).into();
- let sender = match ensure_signed(origin) {
- Ok(v) => v,
- // TODO: Support for unsigned extrinsics?
- Err(_) => return Some(Some(s))
- };
- let who_will_pay = T::SponsorshipHandler::get_sponsor(&sender, &s.call).unwrap_or(sender);
- let sponsor = T::PalletsOrigin::from(system::RawOrigin::Signed(who_will_pay));
- let r = s.call.clone().dispatch(sponsor.into());
- let maybe_id = s.maybe_id.clone();
- if let Some((period, count)) = s.maybe_periodic {
- if count > 1 {
- s.maybe_periodic = Some((period, count - 1));
- } else {
- s.maybe_periodic = None;
- }
- let next = now + period;
- // If scheduled is named, place it's information in `Lookup`
- if let Some(ref id) = s.maybe_id {
- let next_index = Agenda::<T>::decode_len(now + period).unwrap_or(0);
- Lookup::<T>::insert(id, (next, next_index as u32));
- }
- Agenda::<T>::append(next, Some(s));
- } else if let Some(ref id) = s.maybe_id {
- Lookup::<T>::remove(id);
- }
- Self::deposit_event(RawEvent::Dispatched(
- (now, index),
- maybe_id,
- r.map(|_| ()).map_err(|e| e.error)
- ));
- total_weight = cumulative_weight;
- None
- } else {
- Some(Some(s))
- }
- })
- .for_each(|unused| {
- let next = now + One::one();
- Agenda::<T>::append(next, unused);
- });
+ #[cfg(feature = "try-runtime")]
+ pub fn post_migrate_to_v3() -> Result<(), &'static str> {
+ use frame_support::dispatch::GetStorageVersion;
- total_weight
+ assert!(Self::current_storage_version() == 3);
+ for k in Agenda::<T>::iter_keys() {
+ let _ = Agenda::<T>::try_get(k).map_err(|()| "Invalid item in Agenda")?;
}
+ Ok(())
+ }
+
+ /// Helper to migrate scheduler when the pallet origin type has changed.
+ pub fn migrate_origin<OldOrigin: Into<T::PalletsOrigin> + codec::Decode>() {
+ Agenda::<T>::translate::<
+ Vec<Option<Scheduled<CallOrHashOf<T>, T::BlockNumber, OldOrigin, T::AccountId>>>,
+ _,
+ >(|_, agenda| {
+ Some(
+ agenda
+ .into_iter()
+ .map(|schedule| {
+ schedule.map(|schedule| Scheduled {
+ maybe_id: schedule.maybe_id,
+ priority: schedule.priority,
+ call: schedule.call,
+ maybe_periodic: schedule.maybe_periodic,
+ origin: schedule.origin.into(),
+ _phantom: Default::default(),
+ })
+ })
+ .collect::<Vec<_>>(),
+ )
+ });
}
-}
-impl<T: Config> Module<T> {
fn resolve_time(when: DispatchTime<T::BlockNumber>) -> Result<T::BlockNumber, DispatchError> {
let now = frame_system::Pallet::<T>::block_number();
@@ -499,9 +597,10 @@
maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
priority: schedule::Priority,
origin: T::PalletsOrigin,
- call: <T as Config>::Call,
+ call: CallOrHashOf<T>,
) -> Result<TaskAddress<T::BlockNumber>, DispatchError> {
let when = Self::resolve_time(when)?;
+ call.ensure_requested::<T::PreimageProvider>();
// sanitize maybe_periodic
let maybe_periodic = maybe_periodic
@@ -518,14 +617,7 @@
});
Agenda::<T>::append(when, s);
let index = Agenda::<T>::decode_len(when).unwrap_or(1) as u32 - 1;
- if index > T::MaxScheduledPerBlock::get() {
- log::warn!(
- target: "runtime::scheduler",
- "Warning: There are more items queued in the Scheduler than \
- expected from the runtime configuration. An update might be needed.",
- );
- }
- Self::deposit_event(RawEvent::Scheduled(when, index));
+ Self::deposit_event(Event::Scheduled { when, index });
Ok((when, index))
}
@@ -539,7 +631,10 @@
Ok(None),
|s| -> Result<Option<Scheduled<_, _, _, _>>, DispatchError> {
if let (Some(ref o), Some(ref s)) = (origin, s.borrow()) {
- if *o != s.origin {
+ if matches!(
+ T::OriginPrivilegeCmp::cmp_privilege(o, &s.origin),
+ Some(Ordering::Less) | None
+ ) {
return Err(BadOrigin.into());
}
};
@@ -548,13 +643,14 @@
)
})?;
if let Some(s) = scheduled {
+ s.call.ensure_unrequested::<T::PreimageProvider>();
if let Some(id) = s.maybe_id {
Lookup::<T>::remove(id);
}
- Self::deposit_event(RawEvent::Canceled(when, index));
+ Self::deposit_event(Event::Canceled { when, index });
Ok(())
} else {
- Err(Error::<T>::NotFound.into())
+ Err(Error::<T>::NotFound)?
}
}
@@ -576,27 +672,32 @@
})?;
let new_index = Agenda::<T>::decode_len(new_time).unwrap_or(1) as u32 - 1;
- Self::deposit_event(RawEvent::Canceled(when, index));
- Self::deposit_event(RawEvent::Scheduled(new_time, new_index));
+ Self::deposit_event(Event::Canceled { when, index });
+ Self::deposit_event(Event::Scheduled {
+ when: new_time,
+ index: new_index,
+ });
Ok((new_time, new_index))
}
fn do_schedule_named(
- id: Vec<u8>,
+ id: ScheduledId,
when: DispatchTime<T::BlockNumber>,
maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
priority: schedule::Priority,
origin: T::PalletsOrigin,
- call: <T as Config>::Call,
+ call: CallOrHashOf<T>,
) -> Result<TaskAddress<T::BlockNumber>, DispatchError> {
// ensure id it is unique
if Lookup::<T>::contains_key(&id) {
- return Err(Error::<T>::FailedToSchedule.into());
+ return Err(Error::<T>::FailedToSchedule)?;
}
let when = Self::resolve_time(when)?;
+ call.ensure_requested::<T::PreimageProvider>();
+
// sanitize maybe_periodic
let maybe_periodic = maybe_periodic
.filter(|p| p.1 > 1 && !p.0.is_zero())
@@ -606,52 +707,74 @@
let s = Scheduled {
maybe_id: Some(id.clone()),
priority,
- call,
+ call: call.clone(),
maybe_periodic,
- origin,
+ origin: origin.clone(),
_phantom: Default::default(),
};
+
+ // reserve balance for periodic execution
+ // let sender =
+ // ensure_signed(<<T as Config>::Origin as From<T::PalletsOrigin>>::from(origin).into())?;
+ // let repeats = match maybe_periodic {
+ // Some(p) => p.1,
+ // None => 1,
+ // };
+ // let _ = T::CallExecutor::reserve_balance(
+ // id.clone(),
+ // sender,
+ // call.as_value().unwrap().clone(),
+ // repeats,
+ // );
+
Agenda::<T>::append(when, Some(s));
let index = Agenda::<T>::decode_len(when).unwrap_or(1) as u32 - 1;
- if index > T::MaxScheduledPerBlock::get() {
- log::warn!(
- target: "runtime::scheduler",
- "Warning: There are more items queued in the Scheduler than \
- expected from the runtime configuration. An update might be needed.",
- );
- }
let address = (when, index);
Lookup::<T>::insert(&id, &address);
- Self::deposit_event(RawEvent::Scheduled(when, index));
+ Self::deposit_event(Event::Scheduled { when, index });
Ok(address)
}
- fn do_cancel_named(origin: Option<T::PalletsOrigin>, id: Vec<u8>) -> DispatchResult {
+ fn do_cancel_named(origin: Option<T::PalletsOrigin>, id: ScheduledId) -> DispatchResult {
Lookup::<T>::try_mutate_exists(id, |lookup| -> DispatchResult {
if let Some((when, index)) = lookup.take() {
let i = index as usize;
Agenda::<T>::try_mutate(when, |agenda| -> DispatchResult {
if let Some(s) = agenda.get_mut(i) {
- if let (Some(ref o), Some(ref s)) = (origin, s.borrow()) {
- if *o != s.origin {
+ if let (Some(ref o), Some(ref s)) = (origin.clone(), s.borrow()) {
+ if matches!(
+ T::OriginPrivilegeCmp::cmp_privilege(o, &s.origin),
+ Some(Ordering::Less) | None
+ ) {
return Err(BadOrigin.into());
}
+ // release balance reserve
+ // let sender = ensure_signed(
+ // <<T as Config>::Origin as From<T::PalletsOrigin>>::from(
+ // origin.unwrap(),
+ // )
+ // .into(),
+ // )?;
+ // let _ = T::CallExecutor::cancel_reserve(id, sender);
+
+ s.call.ensure_unrequested::<T::PreimageProvider>();
}
*s = None;
}
Ok(())
})?;
- Self::deposit_event(RawEvent::Canceled(when, index));
+
+ Self::deposit_event(Event::Canceled { when, index });
Ok(())
} else {
- Err(Error::<T>::NotFound.into())
+ Err(Error::<T>::NotFound)?
}
})
}
fn do_reschedule_named(
- id: Vec<u8>,
+ id: ScheduledId,
new_time: DispatchTime<T::BlockNumber>,
) -> Result<TaskAddress<T::BlockNumber>, DispatchError> {
let new_time = Self::resolve_time(new_time)?;
@@ -674,8 +797,11 @@
})?;
let new_index = Agenda::<T>::decode_len(new_time).unwrap_or(1) as u32 - 1;
- Self::deposit_event(RawEvent::Canceled(when, index));
- Self::deposit_event(RawEvent::Scheduled(new_time, new_index));
+ Self::deposit_event(Event::Canceled { when, index });
+ Self::deposit_event(Event::Scheduled {
+ when: new_time,
+ index: new_index,
+ });
*lookup = Some((new_time, new_index));
@@ -684,161 +810,86 @@
)
}
}
-
-#[cfg(test)]
-#[allow(clippy::from_over_into)]
-mod tests {
- use super::*;
- use frame_support::{
- ord_parameter_types, parameter_types,
- traits::{Contains, ConstU32, EnsureOneOf},
- weights::constants::RocksDbWeight,
- };
- use sp_core::H256;
- use sp_runtime::{
- Perbill,
- testing::Header,
- traits::{BlakeTwo256, IdentityLookup},
- };
- use frame_system::{EnsureRoot, EnsureSignedBy};
- use crate as scheduler;
+impl<T: Config> schedule::v2::Anon<T::BlockNumber, <T as Config>::Call, T::PalletsOrigin>
+ for Pallet<T>
+{
+ type Address = TaskAddress<T::BlockNumber>;
+ type Hash = T::Hash;
- #[frame_support::pallet]
- pub mod logger {
- use super::{OriginCaller, OriginTrait};
- use frame_support::pallet_prelude::*;
- use frame_system::pallet_prelude::*;
- use std::cell::RefCell;
-
- thread_local! {
- static LOG: RefCell<Vec<(OriginCaller, u32)>> = RefCell::new(Vec::new());
- }
- pub fn log() -> Vec<(OriginCaller, u32)> {
- LOG.with(|log| log.borrow().clone())
- }
-
- #[pallet::pallet]
- #[pallet::generate_store(pub(super) trait Store)]
- pub struct Pallet<T>(PhantomData<T>);
-
- #[pallet::hooks]
- impl<T: Config> Hooks<BlockNumberFor<T>> for Pallet<T> {}
-
- #[pallet::config]
- pub trait Config: frame_system::Config {
- type Event: From<Event<Self>> + IsType<<Self as frame_system::Config>::Event>;
- }
-
- #[pallet::event]
- #[pallet::generate_deposit(pub(super) fn deposit_event)]
- pub enum Event<T: Config> {
- Logged(u32, Weight),
- }
+ fn schedule(
+ when: DispatchTime<T::BlockNumber>,
+ maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
+ priority: schedule::Priority,
+ origin: T::PalletsOrigin,
+ call: CallOrHashOf<T>,
+ ) -> Result<Self::Address, DispatchError> {
+ Self::do_schedule(when, maybe_periodic, priority, origin, call)
+ }
- #[pallet::call]
- impl<T: Config> Pallet<T>
- where
- <T as frame_system::Config>::Origin: OriginTrait<PalletsOrigin = OriginCaller>,
- {
- #[pallet::weight(*weight)]
- pub fn log(origin: OriginFor<T>, i: u32, weight: Weight) -> DispatchResult {
- Self::deposit_event(Event::Logged(i, weight));
- LOG.with(|log| {
- log.borrow_mut().push((origin.caller().clone(), i));
- });
- Ok(())
- }
+ fn cancel((when, index): Self::Address) -> Result<(), ()> {
+ Self::do_cancel(None, (when, index)).map_err(|_| ())
+ }
- #[pallet::weight(*weight)]
- pub fn log_without_filter(
- origin: OriginFor<T>,
- i: u32,
- weight: Weight,
- ) -> DispatchResult {
- Self::deposit_event(Event::Logged(i, weight));
- LOG.with(|log| {
- log.borrow_mut().push((origin.caller().clone(), i));
- });
- Ok(())
- }
- }
+ fn reschedule(
+ address: Self::Address,
+ when: DispatchTime<T::BlockNumber>,
+ ) -> Result<Self::Address, DispatchError> {
+ Self::do_reschedule(address, when)
}
- type UncheckedExtrinsic = frame_system::mocking::MockUncheckedExtrinsic<Test>;
- type Block = frame_system::mocking::MockBlock<Test>;
+ fn next_dispatch_time((when, index): Self::Address) -> Result<T::BlockNumber, ()> {
+ Agenda::<T>::get(when)
+ .get(index as usize)
+ .ok_or(())
+ .map(|_| when)
+ }
+}
- frame_support::construct_runtime!(
- pub enum Test where
- Block = Block,
- NodeBlock = Block,
- UncheckedExtrinsic = UncheckedExtrinsic,
- {
- System: frame_system::{Pallet, Call, Config, Storage, Event<T>},
- Logger: logger::{Pallet, Call, Event<T>},
- Scheduler: scheduler::{Pallet, Call, Storage, Event<T>},
- }
- );
+impl<T: Config> schedule::v2::Named<T::BlockNumber, <T as Config>::Call, T::PalletsOrigin>
+ for Pallet<T>
+{
+ type Address = TaskAddress<T::BlockNumber>;
+ type Hash = T::Hash;
- // Scheduler must dispatch with root and no filter, this tests base filter is indeed not used.
- pub struct BaseFilter;
- impl Contains<Call> for BaseFilter {
- fn contains(call: &Call) -> bool {
- !matches!(call, Call::Logger(logger::Call::log { .. }))
- }
+ fn schedule_named(
+ id: Vec<u8>,
+ when: DispatchTime<T::BlockNumber>,
+ maybe_periodic: Option<schedule::Period<T::BlockNumber>>,
+ priority: schedule::Priority,
+ origin: T::PalletsOrigin,
+ call: CallOrHashOf<T>,
+ ) -> Result<Self::Address, ()> {
+ let inner_id: ScheduledId = id
+ .try_into()
+ .unwrap_or([0; MAX_TASK_ID_LENGTH_IN_BYTES as usize]);
+ Self::do_schedule_named(inner_id, when, maybe_periodic, priority, origin, call)
+ .map_err(|_| ())
}
- parameter_types! {
- pub const BlockHashCount: u64 = 250;
- pub BlockWeights: frame_system::limits::BlockWeights =
- frame_system::limits::BlockWeights::simple_max(2_000_000_000_000);
+ fn cancel_named(id: Vec<u8>) -> Result<(), ()> {
+ let inner_id: ScheduledId = id
+ .try_into()
+ .unwrap_or([0; MAX_TASK_ID_LENGTH_IN_BYTES as usize]);
+ Self::do_cancel_named(None, inner_id).map_err(|_| ())
}
- impl system::Config for Test {
- type BaseCallFilter = BaseFilter;
- type BlockWeights = ();
- type BlockLength = ();
- type DbWeight = RocksDbWeight;
- type Origin = Origin;
- type Call = Call;
- type Index = u64;
- type BlockNumber = u64;
- type Hash = H256;
- type Hashing = BlakeTwo256;
- type AccountId = u64;
- type Lookup = IdentityLookup<Self::AccountId>;
- type Header = Header;
- type Event = Event;
- type BlockHashCount = BlockHashCount;
- type Version = ();
- type PalletInfo = PalletInfo;
- type AccountData = ();
- type OnNewAccount = ();
- type OnKilledAccount = ();
- type SystemWeightInfo = ();
- type SS58Prefix = ();
- type OnSetCode = ();
- type MaxConsumers = ConstU32<16>;
- }
- impl logger::Config for Test {
- type Event = Event;
- }
- parameter_types! {
- pub MaximumSchedulerWeight: Weight = Perbill::from_percent(80) * BlockWeights::get().max_block;
- pub const MaxScheduledPerBlock: u32 = 10;
- }
- ord_parameter_types! {
- pub const One: u64 = 1;
+
+ fn reschedule_named(
+ id: Vec<u8>,
+ when: DispatchTime<T::BlockNumber>,
+ ) -> Result<Self::Address, DispatchError> {
+ let inner_id: ScheduledId = id
+ .try_into()
+ .unwrap_or([0; MAX_TASK_ID_LENGTH_IN_BYTES as usize]);
+ Self::do_reschedule_named(inner_id, when)
}
- impl Config for Test {
- type Event = Event;
- type Origin = Origin;
- type PalletsOrigin = OriginCaller;
- type Call = Call;
- type MaximumWeight = MaximumSchedulerWeight;
- type ScheduleOrigin = EnsureOneOf<EnsureRoot<u64>, EnsureSignedBy<One, u64>>;
- type MaxScheduledPerBlock = MaxScheduledPerBlock;
- type WeightInfo = ();
- type SponsorshipHandler = ();
+ fn next_dispatch_time(id: Vec<u8>) -> Result<T::BlockNumber, ()> {
+ let inner_id: ScheduledId = id
+ .try_into()
+ .unwrap_or([0; MAX_TASK_ID_LENGTH_IN_BYTES as usize]);
+ Lookup::<T>::get(inner_id)
+ .and_then(|(when, index)| Agenda::<T>::get(when).get(index as usize).map(|_| when))
+ .ok_or(())
}
}
pallets/scheduler/src/weights.rsdiffbeforeafterboth--- a/pallets/scheduler/src/weights.rs
+++ b/pallets/scheduler/src/weights.rs
@@ -1,23 +1,6 @@
-// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.
-// This file is part of Unique Network.
-
-// Unique Network is free software: you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-
-// Unique Network is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-
-// You should have received a copy of the GNU General Public License
-// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
-
-// Original license
// This file is part of Substrate.
-// Copyright (C) 2020-2021 Parity Technologies (UK) Ltd.
+// Copyright (C) 2022 Parity Technologies (UK) Ltd.
// SPDX-License-Identifier: Apache-2.0
// Licensed under the Apache License, Version 2.0 (the "License");
@@ -32,13 +15,14 @@
// See the License for the specific language governing permissions and
// limitations under the License.
-//! Weights for pallet_scheduler
-//! THIS FILE WAS AUTO-GENERATED USING THE SUBSTRATE BENCHMARK CLI VERSION 2.0.0
-//! DATE: 2020-10-27, STEPS: `[50, ]`, REPEAT: 20, LOW RANGE: [], HIGH RANGE: []
-//! EXECUTION: Some(Wasm), WASM-EXECUTION: Compiled, CHAIN: Some("dev"), DB CACHE: 128
+//! Autogenerated weights for pallet_scheduler
+//!
+//! THIS FILE WAS AUTO-GENERATED USING THE SUBSTRATE BENCHMARK CLI VERSION 4.0.0-dev
+//! DATE: 2022-01-31, STEPS: `50`, REPEAT: 20, LOW RANGE: `[]`, HIGH RANGE: `[]`
+//! EXECUTION: Some(Wasm), WASM-EXECUTION: Compiled, CHAIN: Some("dev"), DB CACHE: 1024
// Executed Command:
-// target/release/substrate
+// ./target/production/substrate
// benchmark
// --chain=dev
// --steps=50
@@ -49,78 +33,332 @@
// --wasm-execution=compiled
// --heap-pages=4096
// --output=./frame/scheduler/src/weights.rs
-// --template=./.maintain/frame-weight-template.hbs
+// --template=.maintain/frame-weight-template.hbs
+// --header=HEADER-APACHE2
+// --raw
+#![cfg_attr(rustfmt, rustfmt_skip)]
#![allow(unused_parens)]
#![allow(unused_imports)]
-use frame_support::{
- traits::Get,
- weights::{Weight, constants::RocksDbWeight},
-};
+use frame_support::{traits::Get, weights::{Weight, constants::RocksDbWeight}};
use sp_std::marker::PhantomData;
/// Weight functions needed for pallet_scheduler.
pub trait WeightInfo {
- fn schedule(s: u32) -> Weight;
- fn cancel(s: u32) -> Weight;
- fn schedule_named(s: u32) -> Weight;
- fn cancel_named(s: u32) -> Weight;
+ fn on_initialize_periodic_named_resolved(s: u32, ) -> Weight;
+ fn on_initialize_named_resolved(s: u32, ) -> Weight;
+ fn on_initialize_periodic_resolved(s: u32, ) -> Weight;
+ fn on_initialize_resolved(s: u32, ) -> Weight;
+ fn on_initialize_named_aborted(s: u32, ) -> Weight;
+ fn on_initialize_aborted(s: u32, ) -> Weight;
+ fn on_initialize_periodic_named(s: u32, ) -> Weight;
+ fn on_initialize_periodic(s: u32, ) -> Weight;
+ fn on_initialize_named(s: u32, ) -> Weight;
+ fn on_initialize(s: u32, ) -> Weight;
+ fn schedule(s: u32, ) -> Weight;
+ fn cancel(s: u32, ) -> Weight;
+ fn schedule_named(s: u32, ) -> Weight;
+ fn cancel_named(s: u32, ) -> Weight;
}
/// Weights for pallet_scheduler using the Substrate node and recommended hardware.
pub struct SubstrateWeight<T>(PhantomData<T>);
impl<T: frame_system::Config> WeightInfo for SubstrateWeight<T> {
- fn schedule(s: u32) -> Weight {
- 35_029_000_u64
- .saturating_add(77_000_u64.saturating_mul(s as Weight))
- .saturating_add(T::DbWeight::get().reads(1_u64))
- .saturating_add(T::DbWeight::get().writes(1_u64))
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_periodic_named_resolved(s: u32, ) -> Weight {
+ (11_587_000 as Weight)
+ // Standard Error: 17_000
+ .saturating_add((17_428_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().reads((3 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((4 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_named_resolved(s: u32, ) -> Weight {
+ (8_965_000 as Weight)
+ // Standard Error: 11_000
+ .saturating_add((13_410_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().reads((2 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((3 as Weight).saturating_mul(s as Weight)))
}
- fn cancel(s: u32) -> Weight {
- 31_419_000_u64
- .saturating_add(4_015_000_u64.saturating_mul(s as Weight))
- .saturating_add(T::DbWeight::get().reads(1_u64))
- .saturating_add(T::DbWeight::get().writes(2_u64))
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ fn on_initialize_periodic_resolved(s: u32, ) -> Weight {
+ (8_654_000 as Weight)
+ // Standard Error: 17_000
+ .saturating_add((14_990_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().reads((3 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((3 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ fn on_initialize_resolved(s: u32, ) -> Weight {
+ (9_303_000 as Weight)
+ // Standard Error: 10_000
+ .saturating_add((12_244_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().reads((2 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((2 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:0)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_named_aborted(s: u32, ) -> Weight {
+ (7_506_000 as Weight)
+ // Standard Error: 3_000
+ .saturating_add((5_208_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(2 as Weight))
+ .saturating_add(T::DbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(2 as Weight))
+ .saturating_add(T::DbWeight::get().writes((1 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:0)
+ fn on_initialize_aborted(s: u32, ) -> Weight {
+ (8_046_000 as Weight)
+ // Standard Error: 3_000
+ .saturating_add((2_914_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(2 as Weight))
+ .saturating_add(T::DbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(2 as Weight))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_periodic_named(s: u32, ) -> Weight {
+ (13_704_000 as Weight)
+ // Standard Error: 4_000
+ .saturating_add((8_186_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((2 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ fn on_initialize_periodic(s: u32, ) -> Weight {
+ (12_668_000 as Weight)
+ // Standard Error: 5_000
+ .saturating_add((5_868_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((1 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_named(s: u32, ) -> Weight {
+ (13_946_000 as Weight)
+ // Standard Error: 4_000
+ .saturating_add((4_367_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes((1 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn on_initialize(s: u32, ) -> Weight {
+ (13_151_000 as Weight)
+ // Standard Error: 4_000
+ .saturating_add((3_455_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn schedule(s: u32, ) -> Weight {
+ (14_040_000 as Weight)
+ // Standard Error: 1_000
+ .saturating_add((89_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes(1 as Weight))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn cancel(s: u32, ) -> Weight {
+ (14_376_000 as Weight)
+ // Standard Error: 1_000
+ .saturating_add((576_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(1 as Weight))
+ .saturating_add(T::DbWeight::get().writes(2 as Weight))
}
- fn schedule_named(s: u32) -> Weight {
- 44_752_000_u64
- .saturating_add(123_000_u64.saturating_mul(s as Weight))
- .saturating_add(T::DbWeight::get().reads(2_u64))
- .saturating_add(T::DbWeight::get().writes(2_u64))
+ // Storage: Scheduler Lookup (r:1 w:1)
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn schedule_named(s: u32, ) -> Weight {
+ (16_806_000 as Weight)
+ // Standard Error: 1_000
+ .saturating_add((102_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(2 as Weight))
+ .saturating_add(T::DbWeight::get().writes(2 as Weight))
}
- fn cancel_named(s: u32) -> Weight {
- 35_712_000_u64
- .saturating_add(4_008_000_u64.saturating_mul(s as Weight))
- .saturating_add(T::DbWeight::get().reads(2_u64))
- .saturating_add(T::DbWeight::get().writes(2_u64))
+ // Storage: Scheduler Lookup (r:1 w:1)
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn cancel_named(s: u32, ) -> Weight {
+ (15_852_000 as Weight)
+ // Standard Error: 2_000
+ .saturating_add((590_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(T::DbWeight::get().reads(2 as Weight))
+ .saturating_add(T::DbWeight::get().writes(2 as Weight))
}
}
// For backwards compatibility and tests
impl WeightInfo for () {
- fn schedule(s: u32) -> Weight {
- 35_029_000_u64
- .saturating_add(77_000_u64.saturating_mul(s as Weight))
- .saturating_add(RocksDbWeight::get().reads(1_u64))
- .saturating_add(RocksDbWeight::get().writes(1_u64))
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_periodic_named_resolved(s: u32, ) -> Weight {
+ (11_587_000 as Weight)
+ // Standard Error: 17_000
+ .saturating_add((17_428_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((3 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((4 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_named_resolved(s: u32, ) -> Weight {
+ (8_965_000 as Weight)
+ // Standard Error: 11_000
+ .saturating_add((13_410_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((2 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((3 as Weight).saturating_mul(s as Weight)))
}
- fn cancel(s: u32) -> Weight {
- 31_419_000_u64
- .saturating_add(4_015_000_u64.saturating_mul(s as Weight))
- .saturating_add(RocksDbWeight::get().reads(1_u64))
- .saturating_add(RocksDbWeight::get().writes(2_u64))
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ fn on_initialize_periodic_resolved(s: u32, ) -> Weight {
+ (8_654_000 as Weight)
+ // Standard Error: 17_000
+ .saturating_add((14_990_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((3 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((3 as Weight).saturating_mul(s as Weight)))
}
- fn schedule_named(s: u32) -> Weight {
- 44_752_000_u64
- .saturating_add(123_000_u64.saturating_mul(s as Weight))
- .saturating_add(RocksDbWeight::get().reads(2_u64))
- .saturating_add(RocksDbWeight::get().writes(2_u64))
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Preimage PreimageFor (r:1 w:1)
+ // Storage: Preimage StatusFor (r:1 w:1)
+ fn on_initialize_resolved(s: u32, ) -> Weight {
+ (9_303_000 as Weight)
+ // Standard Error: 10_000
+ .saturating_add((12_244_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((2 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((2 as Weight).saturating_mul(s as Weight)))
}
- fn cancel_named(s: u32) -> Weight {
- 35_712_000_u64
- .saturating_add(4_008_000_u64.saturating_mul(s as Weight))
- .saturating_add(RocksDbWeight::get().reads(2_u64))
- .saturating_add(RocksDbWeight::get().writes(2_u64))
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:0)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_named_aborted(s: u32, ) -> Weight {
+ (7_506_000 as Weight)
+ // Standard Error: 3_000
+ .saturating_add((5_208_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(2 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(2 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((1 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Preimage PreimageFor (r:1 w:0)
+ fn on_initialize_aborted(s: u32, ) -> Weight {
+ (8_046_000 as Weight)
+ // Standard Error: 3_000
+ .saturating_add((2_914_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(2 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(2 as Weight))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_periodic_named(s: u32, ) -> Weight {
+ (13_704_000 as Weight)
+ // Standard Error: 4_000
+ .saturating_add((8_186_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((2 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:2 w:2)
+ fn on_initialize_periodic(s: u32, ) -> Weight {
+ (12_668_000 as Weight)
+ // Standard Error: 5_000
+ .saturating_add((5_868_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().reads((1 as Weight).saturating_mul(s as Weight)))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((1 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn on_initialize_named(s: u32, ) -> Weight {
+ (13_946_000 as Weight)
+ // Standard Error: 4_000
+ .saturating_add((4_367_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes((1 as Weight).saturating_mul(s as Weight)))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn on_initialize(s: u32, ) -> Weight {
+ (13_151_000 as Weight)
+ // Standard Error: 4_000
+ .saturating_add((3_455_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn schedule(s: u32, ) -> Weight {
+ (14_040_000 as Weight)
+ // Standard Error: 1_000
+ .saturating_add((89_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes(1 as Weight))
+ }
+ // Storage: Scheduler Agenda (r:1 w:1)
+ // Storage: Scheduler Lookup (r:0 w:1)
+ fn cancel(s: u32, ) -> Weight {
+ (14_376_000 as Weight)
+ // Standard Error: 1_000
+ .saturating_add((576_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(1 as Weight))
+ .saturating_add(RocksDbWeight::get().writes(2 as Weight))
+ }
+ // Storage: Scheduler Lookup (r:1 w:1)
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn schedule_named(s: u32, ) -> Weight {
+ (16_806_000 as Weight)
+ // Standard Error: 1_000
+ .saturating_add((102_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(2 as Weight))
+ .saturating_add(RocksDbWeight::get().writes(2 as Weight))
+ }
+ // Storage: Scheduler Lookup (r:1 w:1)
+ // Storage: Scheduler Agenda (r:1 w:1)
+ fn cancel_named(s: u32, ) -> Weight {
+ (15_852_000 as Weight)
+ // Standard Error: 2_000
+ .saturating_add((590_000 as Weight).saturating_mul(s as Weight))
+ .saturating_add(RocksDbWeight::get().reads(2 as Weight))
+ .saturating_add(RocksDbWeight::get().writes(2 as Weight))
}
}
runtime/opal/src/lib.rsdiffbeforeafterboth--- a/runtime/opal/src/lib.rs
+++ b/runtime/opal/src/lib.rs
@@ -28,6 +28,8 @@
use sp_api::impl_runtime_apis;
use sp_core::{crypto::KeyTypeId, OpaqueMetadata, H256, U256, H160};
use sp_runtime::DispatchError;
+use fp_self_contained::*;
+use sp_runtime::traits::{Member};
// #[cfg(any(feature = "std", test))]
// pub use sp_runtime::BuildStorage;
@@ -59,7 +61,7 @@
traits::{
tokens::currency::Currency as CurrencyT, OnUnbalanced as OnUnbalancedT, Everything,
Currency, ExistenceRequirement, Get, IsInVec, KeyOwnerProofSystem, LockIdentifier,
- OnUnbalanced, Randomness, FindAuthor, ConstU32, Imbalance,
+ OnUnbalanced, Randomness, FindAuthor, ConstU32, Imbalance, PrivilegeCmp,
},
weights::{
constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},
@@ -67,8 +69,13 @@
WeightToFeePolynomial, WeightToFeeCoefficient, WeightToFeeCoefficients, ConstantMultiplier,
},
};
-use up_data_structs::mapping::{EvmTokenAddressMapping, CrossTokenAddressMapping};
-use up_data_structs::*;
+use pallet_unq_scheduler::DispatchCall;
+use up_data_structs::{
+ CollectionId, TokenId, TokenData, Property, PropertyKeyPermission, CollectionLimits,
+ CollectionStats, RpcCollection,
+ mapping::{EvmTokenAddressMapping, CrossTokenAddressMapping},
+};
+
// use pallet_contracts::weights::WeightInfo;
// #[cfg(any(feature = "std", test))]
use frame_system::{
@@ -79,12 +86,17 @@
traits::{BaseArithmetic, Unsigned},
};
use smallvec::smallvec;
+// use scale_info::TypeInfo;
use codec::{Encode, Decode};
use fp_rpc::TransactionStatus;
use sp_runtime::{
- traits::{BlockNumberProvider, Dispatchable, PostDispatchInfoOf, DispatchInfoOf, Saturating},
+ traits::{
+ Applyable, BlockNumberProvider, Dispatchable, PostDispatchInfoOf, DispatchInfoOf,
+ Saturating, CheckedConversion,
+ },
+ generic::Era,
transaction_validity::TransactionValidityError,
- SaturatedConversion,
+ DispatchErrorWithPostInfo, SaturatedConversion,
};
// pub use pallet_timestamp::Call as TimestampCall;
@@ -102,7 +114,7 @@
ParentIsPreset,
};
use xcm_executor::{Config, XcmExecutor, Assets};
-use sp_std::{marker::PhantomData};
+use sp_std::{cmp::Ordering, marker::PhantomData};
use xcm::latest::{
// Xcm,
@@ -113,7 +125,6 @@
};
use xcm_executor::traits::{MatchesFungible, WeightTrader};
//use xcm_executor::traits::MatchesFungible;
-use sp_runtime::traits::CheckedConversion;
use unique_runtime_common::{
impl_common_runtime_apis,
@@ -406,12 +417,13 @@
// pub const ExistentialDeposit: u128 = 500;
pub const ExistentialDeposit: u128 = 0;
pub const MaxLocks: u32 = 50;
+ pub const MaxReserves: u32 = 50;
}
impl pallet_balances::Config for Runtime {
type MaxLocks = MaxLocks;
- type MaxReserves = ();
- type ReserveIdentifier = [u8; 8];
+ type MaxReserves = MaxReserves;
+ type ReserveIdentifier = [u8; 16];
/// The type for recording an account's balance.
type Balance = Balance;
/// The ubiquitous event type.
@@ -930,33 +942,156 @@
type BlockNumberProvider = RelayChainBlockNumberProvider<Runtime>;
}
-// parameter_types! {
-// pub MaximumSchedulerWeight: Weight = Perbill::from_percent(50) *
-// RuntimeBlockWeights::get().max_block;
-// pub const MaxScheduledPerBlock: u32 = 50;
-// }
+parameter_types! {
+ pub MaximumSchedulerWeight: Weight = Perbill::from_percent(50) *
+ RuntimeBlockWeights::get().max_block;
+ pub const MaxScheduledPerBlock: u32 = 50;
+}
+
+type ChargeTransactionPayment = pallet_charge_transaction::ChargeTransactionPayment<Runtime>;
+use frame_support::traits::NamedReservableCurrency;
+
+fn get_signed_extras(from: <Runtime as frame_system::Config>::AccountId) -> SignedExtraScheduler {
+ (
+ frame_system::CheckSpecVersion::<Runtime>::new(),
+ frame_system::CheckGenesis::<Runtime>::new(),
+ frame_system::CheckEra::<Runtime>::from(Era::Immortal),
+ frame_system::CheckNonce::<Runtime>::from(frame_system::Pallet::<Runtime>::account_nonce(
+ from,
+ )),
+ frame_system::CheckWeight::<Runtime>::new(),
+ // sponsoring transaction logic
+ // pallet_charge_transaction::ChargeTransactionPayment::<Runtime>::new(0),
+ )
+}
+
+pub struct SchedulerPaymentExecutor;
+impl<T: frame_system::Config + pallet_unq_scheduler::Config, SelfContainedSignedInfo>
+ DispatchCall<T, SelfContainedSignedInfo> for SchedulerPaymentExecutor
+where
+ <T as frame_system::Config>::Call: Member
+ + Dispatchable<Origin = Origin, Info = DispatchInfo>
+ + SelfContainedCall<SignedInfo = SelfContainedSignedInfo>
+ + GetDispatchInfo
+ + From<frame_system::Call<Runtime>>,
+ SelfContainedSignedInfo: Send + Sync + 'static,
+ Call: From<<T as frame_system::Config>::Call>
+ + From<<T as pallet_unq_scheduler::Config>::Call>
+ + SelfContainedCall<SignedInfo = SelfContainedSignedInfo>,
+ sp_runtime::AccountId32: From<<T as frame_system::Config>::AccountId>,
+{
+ fn dispatch_call(
+ signer: <T as frame_system::Config>::AccountId,
+ call: <T as pallet_unq_scheduler::Config>::Call,
+ ) -> Result<
+ Result<PostDispatchInfo, DispatchErrorWithPostInfo<PostDispatchInfo>>,
+ TransactionValidityError,
+ > {
+ let dispatch_info = call.get_dispatch_info();
+ let extrinsic = fp_self_contained::CheckedExtrinsic::<
+ AccountId,
+ Call,
+ SignedExtraScheduler,
+ SelfContainedSignedInfo,
+ > {
+ signed:
+ CheckedSignature::<AccountId, SignedExtraScheduler, SelfContainedSignedInfo>::Signed(
+ signer.clone().into(),
+ get_signed_extras(signer.into()),
+ ),
+ function: call.into(),
+ };
+
+ extrinsic.apply::<Runtime>(&dispatch_info, 0)
+ }
+
+ fn reserve_balance(
+ id: [u8; 16],
+ sponsor: <T as frame_system::Config>::AccountId,
+ call: <T as pallet_unq_scheduler::Config>::Call,
+ count: u32,
+ ) -> Result<(), DispatchError> {
+ let dispatch_info = call.get_dispatch_info();
+ let weight: Balance = ChargeTransactionPayment::traditional_fee(0, &dispatch_info, 0)
+ .saturating_mul(count.into());
+
+ <Balances as NamedReservableCurrency<AccountId>>::reserve_named(
+ &id,
+ &(sponsor.into()),
+ weight,
+ )
+ }
+
+ fn pay_for_call(
+ id: [u8; 16],
+ sponsor: <T as frame_system::Config>::AccountId,
+ call: <T as pallet_unq_scheduler::Config>::Call,
+ ) -> Result<u128, DispatchError> {
+ let dispatch_info = call.get_dispatch_info();
+ let weight: Balance = ChargeTransactionPayment::traditional_fee(0, &dispatch_info, 0);
+ Ok(
+ <Balances as NamedReservableCurrency<AccountId>>::unreserve_named(
+ &id,
+ &(sponsor.into()),
+ weight,
+ ),
+ )
+ }
+
+ fn cancel_reserve(
+ id: [u8; 16],
+ sponsor: <T as frame_system::Config>::AccountId,
+ ) -> Result<u128, DispatchError> {
+ Ok(
+ <Balances as NamedReservableCurrency<AccountId>>::unreserve_named(
+ &id,
+ &(sponsor.into()),
+ u128::MAX,
+ ),
+ )
+ }
+}
+
+parameter_types! {
+ pub const NoPreimagePostponement: Option<u32> = Some(10);
+ pub const Preimage: Option<u32> = Some(10);
+}
+
+/// Used the compare the privilege of an origin inside the scheduler.
+pub struct OriginPrivilegeCmp;
+
+impl PrivilegeCmp<OriginCaller> for OriginPrivilegeCmp {
+ fn cmp_privilege(_left: &OriginCaller, _right: &OriginCaller) -> Option<Ordering> {
+ Some(Ordering::Equal)
+ }
+}
+
+impl pallet_unq_scheduler::Config for Runtime {
+ type Event = Event;
+ type Origin = Origin;
+ type Currency = Balances;
+ type PalletsOrigin = OriginCaller;
+ type Call = Call;
+ type MaximumWeight = MaximumSchedulerWeight;
+ type ScheduleOrigin = EnsureSigned<AccountId>;
+ type MaxScheduledPerBlock = MaxScheduledPerBlock;
+ type WeightInfo = ();
+ type CallExecutor = SchedulerPaymentExecutor;
+ type OriginPrivilegeCmp = OriginPrivilegeCmp;
+ type PreimageProvider = ();
+ type NoPreimagePostponement = NoPreimagePostponement;
+}
type EvmSponsorshipHandler = (
UniqueEthSponsorshipHandler<Runtime>,
pallet_evm_contract_helpers::HelpersContractSponsoring<Runtime>,
);
+
type SponsorshipHandler = (
UniqueSponsorshipHandler<Runtime>,
//pallet_contract_helpers::ContractSponsorshipHandler<Runtime>,
pallet_evm_transaction_payment::BridgeSponsorshipHandler<Runtime>,
);
-
-// impl pallet_unq_scheduler::Config for Runtime {
-// type Event = Event;
-// type Origin = Origin;
-// type PalletsOrigin = OriginCaller;
-// type Call = Call;
-// type MaximumWeight = MaximumSchedulerWeight;
-// type ScheduleOrigin = EnsureSigned<AccountId>;
-// type MaxScheduledPerBlock = MaxScheduledPerBlock;
-// type SponsorshipHandler = SponsorshipHandler;
-// type WeightInfo = ();
-// }
impl pallet_evm_transaction_payment::Config for Runtime {
type EvmSponsorshipHandler = EvmSponsorshipHandler;
@@ -1020,7 +1155,7 @@
// Unique Pallets
Inflation: pallet_inflation::{Pallet, Call, Storage} = 60,
Unique: pallet_unique::{Pallet, Call, Storage, Event<T>} = 61,
- // Scheduler: pallet_unq_scheduler::{Pallet, Call, Storage, Event<T>} = 62,
+ Scheduler: pallet_unq_scheduler::{Pallet, Call, Storage, Event<T>} = 62,
// free = 63
Charging: pallet_charge_transaction::{Pallet, Call, Storage } = 64,
// ContractHelpers: pallet_contract_helpers::{Pallet, Call, Storage} = 65,
@@ -1087,10 +1222,17 @@
frame_system::CheckEra<Runtime>,
frame_system::CheckNonce<Runtime>,
frame_system::CheckWeight<Runtime>,
- pallet_charge_transaction::ChargeTransactionPayment<Runtime>,
+ ChargeTransactionPayment,
//pallet_contract_helpers::ContractHelpersExtension<Runtime>,
pallet_ethereum::FakeTransactionFinalizer<Runtime>,
);
+pub type SignedExtraScheduler = (
+ frame_system::CheckSpecVersion<Runtime>,
+ frame_system::CheckGenesis<Runtime>,
+ frame_system::CheckEra<Runtime>,
+ frame_system::CheckNonce<Runtime>,
+ frame_system::CheckWeight<Runtime>,
+);
/// Unchecked extrinsic type as expected by this runtime.
pub type UncheckedExtrinsic =
fp_self_contained::UncheckedExtrinsic<Address, Call, Signature, SignedExtra>;
runtime/quartz/src/lib.rsdiffbeforeafterboth--- a/runtime/quartz/src/lib.rs
+++ b/runtime/quartz/src/lib.rs
@@ -33,7 +33,7 @@
use sp_runtime::{
Permill, Perbill, Percent, create_runtime_str, generic, impl_opaque_keys,
- traits::{AccountIdLookup, BlakeTwo256, Block as BlockT, AccountIdConversion, Zero},
+ traits::{AccountIdLookup, BlakeTwo256, Block as BlockT, AccountIdConversion, Zero, Member},
transaction_validity::{TransactionSource, TransactionValidity},
ApplyExtrinsicResult, RuntimeAppPublic,
};
@@ -58,7 +58,7 @@
traits::{
tokens::currency::Currency as CurrencyT, OnUnbalanced as OnUnbalancedT, Everything,
Currency, ExistenceRequirement, Get, IsInVec, KeyOwnerProofSystem, LockIdentifier,
- OnUnbalanced, Randomness, FindAuthor, ConstU32, Imbalance,
+ OnUnbalanced, Randomness, FindAuthor, ConstU32, Imbalance, PrivilegeCmp,
},
weights::{
constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},
@@ -81,18 +81,28 @@
use pallet_evm::{Account as EVMAccount, FeeCalculator, GasWeightMapping};
use fp_rpc::TransactionStatus;
use sp_runtime::{
- traits::{BlockNumberProvider, Dispatchable, PostDispatchInfoOf, Saturating},
+ traits::{
+ Applyable, BlockNumberProvider, Dispatchable, PostDispatchInfoOf, Saturating,
+ CheckedConversion,
+ },
+ generic::Era,
transaction_validity::TransactionValidityError,
- SaturatedConversion,
+ SaturatedConversion, DispatchErrorWithPostInfo,
};
+use fp_self_contained::{SelfContainedCall, CheckedSignature};
+
// pub use pallet_timestamp::Call as TimestampCall;
pub use sp_consensus_aura::sr25519::AuthorityId as AuraId;
// Polkadot imports
use pallet_xcm::XcmPassthrough;
use polkadot_parachain::primitives::Sibling;
-use up_data_structs::mapping::{CrossTokenAddressMapping, EvmTokenAddressMapping};
+use up_data_structs::{
+ CollectionId, TokenId, TokenData, Property, PropertyKeyPermission, CollectionLimits,
+ CollectionStats, RpcCollection,
+ mapping::{EvmTokenAddressMapping, CrossTokenAddressMapping}
+};
use xcm::v1::{BodyId, Junction::*, MultiLocation, NetworkId, Junctions::*};
use xcm_builder::{
AccountId32Aliases, AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom, CurrencyAdapter,
@@ -102,7 +112,8 @@
ParentIsPreset,
};
use xcm_executor::{Config, XcmExecutor, Assets};
-use sp_std::{marker::PhantomData};
+use sp_std::{cmp::Ordering, marker::PhantomData};
+use pallet_unq_scheduler::DispatchCall;
use xcm::latest::{
// Xcm,
@@ -112,8 +123,6 @@
Error as XcmError,
};
use xcm_executor::traits::{MatchesFungible, WeightTrader};
-//use xcm_executor::traits::MatchesFungible;
-use sp_runtime::traits::CheckedConversion;
use unique_runtime_common::{
impl_common_runtime_apis,
@@ -390,7 +399,7 @@
impl pallet_balances::Config for Runtime {
type MaxLocks = MaxLocks;
type MaxReserves = ();
- type ReserveIdentifier = [u8; 8];
+ type ReserveIdentifier = [u8; 16];
/// The type for recording an account's balance.
type Balance = Balance;
/// The ubiquitous event type.
@@ -913,11 +922,11 @@
type BlockNumberProvider = RelayChainBlockNumberProvider<Runtime>;
}
-// parameter_types! {
-// pub MaximumSchedulerWeight: Weight = Perbill::from_percent(50) *
-// RuntimeBlockWeights::get().max_block;
-// pub const MaxScheduledPerBlock: u32 = 50;
-// }
+parameter_types! {
+ pub MaximumSchedulerWeight: Weight = Perbill::from_percent(50) *
+ RuntimeBlockWeights::get().max_block;
+ pub const MaxScheduledPerBlock: u32 = 50;
+}
type EvmSponsorshipHandler = (
UniqueEthSponsorshipHandler<Runtime>,
@@ -929,17 +938,34 @@
pallet_evm_transaction_payment::BridgeSponsorshipHandler<Runtime>,
);
-// impl pallet_unq_scheduler::Config for Runtime {
-// type Event = Event;
-// type Origin = Origin;
-// type PalletsOrigin = OriginCaller;
-// type Call = Call;
-// type MaximumWeight = MaximumSchedulerWeight;
-// type ScheduleOrigin = EnsureSigned<AccountId>;
-// type MaxScheduledPerBlock = MaxScheduledPerBlock;
-// type SponsorshipHandler = SponsorshipHandler;
-// type WeightInfo = ();
-// }
+parameter_types! {
+ pub const NoPreimagePostponement: Option<u32> = Some(10);
+ pub const Preimage: Option<u32> = Some(10);
+}
+
+/// Used the compare the privilege of an origin inside the scheduler.
+pub struct OriginPrivilegeCmp;
+impl PrivilegeCmp<OriginCaller> for OriginPrivilegeCmp {
+ fn cmp_privilege(_left: &OriginCaller, _right: &OriginCaller) -> Option<Ordering> {
+ Some(Ordering::Equal)
+ }
+}
+
+impl pallet_unq_scheduler::Config for Runtime {
+ type Event = Event;
+ type Origin = Origin;
+ type Currency = Balances;
+ type PalletsOrigin = OriginCaller;
+ type Call = Call;
+ type MaximumWeight = MaximumSchedulerWeight;
+ type ScheduleOrigin = EnsureSigned<AccountId>;
+ type MaxScheduledPerBlock = MaxScheduledPerBlock;
+ type WeightInfo = ();
+ type CallExecutor = SchedulerPaymentExecutor;
+ type OriginPrivilegeCmp = OriginPrivilegeCmp;
+ type PreimageProvider = ();
+ type NoPreimagePostponement = NoPreimagePostponement;
+}
impl pallet_evm_transaction_payment::Config for Runtime {
type EvmSponsorshipHandler = EvmSponsorshipHandler;
@@ -954,6 +980,110 @@
// type DefaultSponsoringRateLimit = DefaultSponsoringRateLimit;
// }
+type ChargeTransactionPayment = pallet_charge_transaction::ChargeTransactionPayment<Runtime>;
+use frame_support::traits::NamedReservableCurrency;
+
+fn get_signed_extras(from: <Runtime as frame_system::Config>::AccountId) -> SignedExtraScheduler {
+ (
+ frame_system::CheckSpecVersion::<Runtime>::new(),
+ frame_system::CheckGenesis::<Runtime>::new(),
+ frame_system::CheckEra::<Runtime>::from(Era::Immortal),
+ frame_system::CheckNonce::<Runtime>::from(frame_system::Pallet::<Runtime>::account_nonce(
+ from,
+ )),
+ frame_system::CheckWeight::<Runtime>::new(),
+ // sponsoring transaction logic
+ // pallet_charge_transaction::ChargeTransactionPayment::<Runtime>::new(0),
+ )
+}
+
+pub struct SchedulerPaymentExecutor;
+impl<T: frame_system::Config + pallet_unq_scheduler::Config, SelfContainedSignedInfo>
+ DispatchCall<T, SelfContainedSignedInfo> for SchedulerPaymentExecutor
+where
+ <T as frame_system::Config>::Call: Member
+ + Dispatchable<Origin = Origin, Info = DispatchInfo>
+ + SelfContainedCall<SignedInfo = SelfContainedSignedInfo>
+ + GetDispatchInfo
+ + From<frame_system::Call<Runtime>>,
+ SelfContainedSignedInfo: Send + Sync + 'static,
+ Call: From<<T as frame_system::Config>::Call>
+ + From<<T as pallet_unq_scheduler::Config>::Call>
+ + SelfContainedCall<SignedInfo = SelfContainedSignedInfo>,
+ sp_runtime::AccountId32: From<<T as frame_system::Config>::AccountId>,
+{
+ fn dispatch_call(
+ signer: <T as frame_system::Config>::AccountId,
+ call: <T as pallet_unq_scheduler::Config>::Call,
+ ) -> Result<
+ Result<PostDispatchInfo, DispatchErrorWithPostInfo<PostDispatchInfo>>,
+ TransactionValidityError,
+ > {
+ let dispatch_info = call.get_dispatch_info();
+ let extrinsic = fp_self_contained::CheckedExtrinsic::<
+ AccountId,
+ Call,
+ SignedExtraScheduler,
+ SelfContainedSignedInfo,
+ > {
+ signed:
+ CheckedSignature::<AccountId, SignedExtraScheduler, SelfContainedSignedInfo>::Signed(
+ signer.clone().into(),
+ get_signed_extras(signer.into()),
+ ),
+ function: call.into(),
+ };
+
+ extrinsic.apply::<Runtime>(&dispatch_info, 0)
+ }
+
+ fn reserve_balance(
+ id: [u8; 16],
+ sponsor: <T as frame_system::Config>::AccountId,
+ call: <T as pallet_unq_scheduler::Config>::Call,
+ count: u32,
+ ) -> Result<(), DispatchError> {
+ let dispatch_info = call.get_dispatch_info();
+ let weight: Balance = ChargeTransactionPayment::traditional_fee(0, &dispatch_info, 0)
+ .saturating_mul(count.into());
+
+ <Balances as NamedReservableCurrency<AccountId>>::reserve_named(
+ &id,
+ &(sponsor.into()),
+ weight.into(),
+ )
+ }
+
+ fn pay_for_call(
+ id: [u8; 16],
+ sponsor: <T as frame_system::Config>::AccountId,
+ call: <T as pallet_unq_scheduler::Config>::Call,
+ ) -> Result<u128, DispatchError> {
+ let dispatch_info = call.get_dispatch_info();
+ let weight: Balance = ChargeTransactionPayment::traditional_fee(0, &dispatch_info, 0);
+ Ok(
+ <Balances as NamedReservableCurrency<AccountId>>::unreserve_named(
+ &id,
+ &(sponsor.into()),
+ weight.into(),
+ ),
+ )
+ }
+
+ fn cancel_reserve(
+ id: [u8; 16],
+ sponsor: <T as frame_system::Config>::AccountId,
+ ) -> Result<u128, DispatchError> {
+ Ok(
+ <Balances as NamedReservableCurrency<AccountId>>::unreserve_named(
+ &id,
+ &(sponsor.into()),
+ u128::MAX,
+ ),
+ )
+ }
+}
+
parameter_types! {
// 0x842899ECF380553E8a4de75bF534cdf6fBF64049
pub const HelpersContractAddress: H160 = H160([
@@ -1003,7 +1133,7 @@
// Unique Pallets
Inflation: pallet_inflation::{Pallet, Call, Storage} = 60,
Unique: pallet_unique::{Pallet, Call, Storage, Event<T>} = 61,
- // Scheduler: pallet_unq_scheduler::{Pallet, Call, Storage, Event<T>} = 62,
+ Scheduler: pallet_unq_scheduler::{Pallet, Call, Storage, Event<T>} = 62,
// free = 63
Charging: pallet_charge_transaction::{Pallet, Call, Storage } = 64,
// ContractHelpers: pallet_contract_helpers::{Pallet, Call, Storage} = 65,
@@ -1073,6 +1203,15 @@
//pallet_contract_helpers::ContractHelpersExtension<Runtime>,
pallet_ethereum::FakeTransactionFinalizer<Runtime>,
);
+
+pub type SignedExtraScheduler = (
+ frame_system::CheckSpecVersion<Runtime>,
+ frame_system::CheckGenesis<Runtime>,
+ frame_system::CheckEra<Runtime>,
+ frame_system::CheckNonce<Runtime>,
+ frame_system::CheckWeight<Runtime>,
+ // pallet_charge_transaction::ChargeTransactionPayment<Runtime>,
+);
/// Unchecked extrinsic type as expected by this runtime.
pub type UncheckedExtrinsic =
fp_self_contained::UncheckedExtrinsic<Address, Call, Signature, SignedExtra>;
runtime/unique/src/lib.rsdiffbeforeafterboth1// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.2// This file is part of Unique Network.34// Unique Network is free software: you can redistribute it and/or modify5// it under the terms of the GNU General Public License as published by6// the Free Software Foundation, either version 3 of the License, or7// (at your option) any later version.89// Unique Network is distributed in the hope that it will be useful,10// but WITHOUT ANY WARRANTY; without even the implied warranty of11// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the12// GNU General Public License for more details.1314// You should have received a copy of the GNU General Public License15// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.1617//! The Substrate Node Template runtime. This can be compiled with `#[no_std]`, ready for Wasm.1819#![cfg_attr(not(feature = "std"), no_std)]20// `construct_runtime!` does a lot of recursion and requires us to increase the limit to 256.21#![recursion_limit = "1024"]22#![allow(clippy::from_over_into, clippy::identity_op)]23#![allow(clippy::fn_to_numeric_cast_with_truncation)]24// Make the WASM binary available.25#[cfg(feature = "std")]26include!(concat!(env!("OUT_DIR"), "/wasm_binary.rs"));2728use sp_api::impl_runtime_apis;29use sp_core::{crypto::KeyTypeId, OpaqueMetadata, H256, U256, H160};30use sp_runtime::DispatchError;31// #[cfg(any(feature = "std", test))]32// pub use sp_runtime::BuildStorage;3334use sp_runtime::{35 Permill, Perbill, Percent, create_runtime_str, generic, impl_opaque_keys,36 traits::{AccountIdLookup, BlakeTwo256, Block as BlockT, AccountIdConversion, Zero},37 transaction_validity::{TransactionSource, TransactionValidity},38 ApplyExtrinsicResult, RuntimeAppPublic,39};4041use sp_std::prelude::*;4243#[cfg(feature = "std")]44use sp_version::NativeVersion;45use sp_version::RuntimeVersion;46pub use pallet_transaction_payment::{47 Multiplier, TargetedFeeAdjustment, FeeDetails, RuntimeDispatchInfo,48};49// A few exports that help ease life for downstream crates.50pub use pallet_balances::Call as BalancesCall;51pub use pallet_evm::{52 EnsureAddressTruncated, HashedAddressMapping, Runner, account::CrossAccountId as _, OnMethodCall,53 Account as EVMAccount, FeeCalculator, GasWeightMapping,54};55pub use frame_support::{56 construct_runtime, match_types,57 dispatch::DispatchResult,58 PalletId, parameter_types, StorageValue, ConsensusEngineId,59 traits::{60 tokens::currency::Currency as CurrencyT, OnUnbalanced as OnUnbalancedT, Everything,61 Currency, ExistenceRequirement, Get, IsInVec, KeyOwnerProofSystem, LockIdentifier,62 OnUnbalanced, Randomness, FindAuthor, ConstU32, Imbalance,63 },64 weights::{65 constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},66 DispatchClass, DispatchInfo, GetDispatchInfo, IdentityFee, Pays, PostDispatchInfo, Weight,67 WeightToFeePolynomial, WeightToFeeCoefficient, WeightToFeeCoefficients, ConstantMultiplier,68 },69};70use unique_runtime_common::{71 dispatch::{CollectionDispatchT, CollectionDispatch},72 weights::CommonWeights,73 sponsoring::UniqueSponsorshipHandler,74 eth_sponsoring::UniqueEthSponsorshipHandler,75};76use up_data_structs::*;77// use pallet_contracts::weights::WeightInfo;78// #[cfg(any(feature = "std", test))]79use frame_system::{80 self as frame_system, EnsureRoot, EnsureSigned,81 limits::{BlockWeights, BlockLength},82};83use sp_arithmetic::{84 traits::{BaseArithmetic, Unsigned},85};86use smallvec::smallvec;87use codec::{Encode, Decode};88use fp_rpc::TransactionStatus;89use sp_runtime::{90 traits::{BlockNumberProvider, Dispatchable, PostDispatchInfoOf, Saturating},91 transaction_validity::TransactionValidityError,92 SaturatedConversion,93};9495// pub use pallet_timestamp::Call as TimestampCall;9697// Polkadot imports98use pallet_xcm::XcmPassthrough;99use polkadot_parachain::primitives::Sibling;100use up_data_structs::mapping::{CrossTokenAddressMapping, EvmTokenAddressMapping};101use xcm::v1::{BodyId, Junction::*, MultiLocation, NetworkId, Junctions::*};102use xcm_builder::{103 AccountId32Aliases, AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom, CurrencyAdapter,104 EnsureXcmOrigin, FixedWeightBounds, LocationInverter, NativeAsset, ParentAsSuperuser,105 RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,106 SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,107 ParentIsPreset,108};109use xcm_executor::{Config, XcmExecutor, Assets};110use sp_std::{marker::PhantomData};111112use xcm::latest::{113 // Xcm,114 AssetId::{Concrete},115 Fungibility::Fungible as XcmFungible,116 MultiAsset,117 Error as XcmError,118};119use xcm_executor::traits::{MatchesFungible, WeightTrader};120//use xcm_executor::traits::MatchesFungible;121use sp_runtime::traits::CheckedConversion;122123use unique_runtime_common::{124 impl_common_runtime_apis,125 types::*,126 constants::*,127 dispatch::{CollectionDispatchT, CollectionDispatch},128 sponsoring::UniqueSponsorshipHandler,129 eth_sponsoring::UniqueEthSponsorshipHandler,130 weights::CommonWeights,131};132133pub const RUNTIME_NAME: &str = "unique";134pub const TOKEN_SYMBOL: &str = "UNQ";135136type CrossAccountId = pallet_evm::account::BasicCrossAccountId<Runtime>;137138impl RuntimeInstance for Runtime {139 type CrossAccountId = self::CrossAccountId;140141 type TransactionConverter = self::TransactionConverter;142143 fn get_transaction_converter() -> TransactionConverter {144 TransactionConverter145 }146}147148/// Opaque types. These are used by the CLI to instantiate machinery that don't need to know149/// the specifics of the runtime. They can then be made to be agnostic over specific formats150/// of data like extrinsics, allowing for them to continue syncing the network through upgrades151/// to even the core data structures.152pub mod opaque {153 use sp_std::prelude::*;154 use sp_runtime::impl_opaque_keys;155 use super::Aura;156157 pub use unique_runtime_common::types::*;158159 impl_opaque_keys! {160 pub struct SessionKeys {161 pub aura: Aura,162 }163 }164}165166/// This runtime version.167pub const VERSION: RuntimeVersion = RuntimeVersion {168 spec_name: create_runtime_str!(RUNTIME_NAME),169 impl_name: create_runtime_str!(RUNTIME_NAME),170 authoring_version: 1,171 spec_version: 922000,172 impl_version: 0,173 apis: RUNTIME_API_VERSIONS,174 transaction_version: 1,175 state_version: 0,176};177178#[derive(codec::Encode, codec::Decode)]179pub enum XCMPMessage<XAccountId, XBalance> {180 /// Transfer tokens to the given account from the Parachain account.181 TransferToken(XAccountId, XBalance),182}183184/// The version information used to identify this runtime when compiled natively.185#[cfg(feature = "std")]186pub fn native_version() -> NativeVersion {187 NativeVersion {188 runtime_version: VERSION,189 can_author_with: Default::default(),190 }191}192193type NegativeImbalance = <Balances as Currency<AccountId>>::NegativeImbalance;194195pub struct DealWithFees;196impl OnUnbalanced<NegativeImbalance> for DealWithFees {197 fn on_unbalanceds<B>(mut fees_then_tips: impl Iterator<Item = NegativeImbalance>) {198 if let Some(fees) = fees_then_tips.next() {199 // for fees, 100% to treasury200 let mut split = fees.ration(100, 0);201 if let Some(tips) = fees_then_tips.next() {202 // for tips, if any, 100% to treasury203 tips.ration_merge_into(100, 0, &mut split);204 }205 Treasury::on_unbalanced(split.0);206 // Author::on_unbalanced(split.1);207 }208 }209}210211parameter_types! {212 pub const BlockHashCount: BlockNumber = 2400;213 pub RuntimeBlockLength: BlockLength =214 BlockLength::max_with_normal_ratio(5 * 1024 * 1024, NORMAL_DISPATCH_RATIO);215 pub const AvailableBlockRatio: Perbill = Perbill::from_percent(75);216 pub const MaximumBlockLength: u32 = 5 * 1024 * 1024;217 pub RuntimeBlockWeights: BlockWeights = BlockWeights::builder()218 .base_block(BlockExecutionWeight::get())219 .for_class(DispatchClass::all(), |weights| {220 weights.base_extrinsic = ExtrinsicBaseWeight::get();221 })222 .for_class(DispatchClass::Normal, |weights| {223 weights.max_total = Some(NORMAL_DISPATCH_RATIO * MAXIMUM_BLOCK_WEIGHT);224 })225 .for_class(DispatchClass::Operational, |weights| {226 weights.max_total = Some(MAXIMUM_BLOCK_WEIGHT);227 // Operational transactions have some extra reserved space, so that they228 // are included even if block reached `MAXIMUM_BLOCK_WEIGHT`.229 weights.reserved = Some(230 MAXIMUM_BLOCK_WEIGHT - NORMAL_DISPATCH_RATIO * MAXIMUM_BLOCK_WEIGHT231 );232 })233 .avg_block_initialization(AVERAGE_ON_INITIALIZE_RATIO)234 .build_or_panic();235 pub const Version: RuntimeVersion = VERSION;236 pub const SS58Prefix: u16 = 7391;237}238239parameter_types! {240 pub const ChainId: u64 = 8880;241}242243pub struct FixedFee;244impl FeeCalculator for FixedFee {245 fn min_gas_price() -> U256 {246 MIN_GAS_PRICE.into()247 }248}249250// Assuming slowest ethereum opcode is SSTORE, with gas price of 20000 as our worst case251// (contract, which only writes a lot of data),252// approximating on top of our real store write weight253parameter_types! {254 pub const WritesPerSecond: u64 = WEIGHT_PER_SECOND / <Runtime as frame_system::Config>::DbWeight::get().write;255 pub const GasPerSecond: u64 = WritesPerSecond::get() * 20000;256 pub const WeightPerGas: u64 = WEIGHT_PER_SECOND / GasPerSecond::get();257}258259/// Limiting EVM execution to 50% of block for substrate users and management tasks260/// EVM transaction consumes more weight than substrate's, so we can't rely on them being261/// scheduled fairly262const EVM_DISPATCH_RATIO: Perbill = Perbill::from_percent(50);263parameter_types! {264 pub BlockGasLimit: U256 = U256::from(NORMAL_DISPATCH_RATIO * EVM_DISPATCH_RATIO * MAXIMUM_BLOCK_WEIGHT / WeightPerGas::get());265}266267pub enum FixedGasWeightMapping {}268impl GasWeightMapping for FixedGasWeightMapping {269 fn gas_to_weight(gas: u64) -> Weight {270 gas.saturating_mul(WeightPerGas::get())271 }272 fn weight_to_gas(weight: Weight) -> u64 {273 weight / WeightPerGas::get()274 }275}276277impl pallet_evm::Config for Runtime {278 type BlockGasLimit = BlockGasLimit;279 type FeeCalculator = FixedFee;280 type GasWeightMapping = FixedGasWeightMapping;281 type BlockHashMapping = pallet_ethereum::EthereumBlockHashMapping<Self>;282 type CallOrigin = EnsureAddressTruncated<Self>;283 type WithdrawOrigin = EnsureAddressTruncated<Self>;284 type AddressMapping = HashedAddressMapping<Self::Hashing>;285 type PrecompilesType = ();286 type PrecompilesValue = ();287 type Currency = Balances;288 type Event = Event;289 type OnMethodCall = (290 pallet_evm_migration::OnMethodCall<Self>,291 pallet_evm_contract_helpers::HelpersOnMethodCall<Self>,292 CollectionDispatchT<Self>,293 pallet_unique::eth::CollectionHelpersOnMethodCall<Self>,294 );295 type OnCreate = pallet_evm_contract_helpers::HelpersOnCreate<Self>;296 type ChainId = ChainId;297 type Runner = pallet_evm::runner::stack::Runner<Self>;298 type OnChargeTransaction = pallet_evm::EVMCurrencyAdapter<Balances, DealWithFees>;299 type TransactionValidityHack = pallet_evm_transaction_payment::TransactionValidityHack<Self>;300 type FindAuthor = EthereumFindAuthor<Aura>;301}302303impl pallet_evm_migration::Config for Runtime {304 type WeightInfo = pallet_evm_migration::weights::SubstrateWeight<Self>;305}306307pub struct EthereumFindAuthor<F>(core::marker::PhantomData<F>);308impl<F: FindAuthor<u32>> FindAuthor<H160> for EthereumFindAuthor<F> {309 fn find_author<'a, I>(digests: I) -> Option<H160>310 where311 I: 'a + IntoIterator<Item = (ConsensusEngineId, &'a [u8])>,312 {313 if let Some(author_index) = F::find_author(digests) {314 let authority_id = Aura::authorities()[author_index as usize].clone();315 return Some(H160::from_slice(&authority_id.to_raw_vec()[4..24]));316 }317 None318 }319}320321impl pallet_ethereum::Config for Runtime {322 type Event = Event;323 type StateRoot = pallet_ethereum::IntermediateStateRoot<Self>;324}325326impl pallet_randomness_collective_flip::Config for Runtime {}327328impl frame_system::Config for Runtime {329 /// The data to be stored in an account.330 type AccountData = pallet_balances::AccountData<Balance>;331 /// The identifier used to distinguish between accounts.332 type AccountId = AccountId;333 /// The basic call filter to use in dispatchable.334 type BaseCallFilter = Everything;335 /// Maximum number of block number to block hash mappings to keep (oldest pruned first).336 type BlockHashCount = BlockHashCount;337 /// The maximum length of a block (in bytes).338 type BlockLength = RuntimeBlockLength;339 /// The index type for blocks.340 type BlockNumber = BlockNumber;341 /// The weight of the overhead invoked on the block import process, independent of the extrinsics included in that block.342 type BlockWeights = RuntimeBlockWeights;343 /// The aggregated dispatch type that is available for extrinsics.344 type Call = Call;345 /// The weight of database operations that the runtime can invoke.346 type DbWeight = RocksDbWeight;347 /// The ubiquitous event type.348 type Event = Event;349 /// The type for hashing blocks and tries.350 type Hash = Hash;351 /// The hashing algorithm used.352 type Hashing = BlakeTwo256;353 /// The header type.354 type Header = generic::Header<BlockNumber, BlakeTwo256>;355 /// The index type for storing how many extrinsics an account has signed.356 type Index = Index;357 /// The lookup mechanism to get account ID from whatever is passed in dispatchers.358 type Lookup = AccountIdLookup<AccountId, ()>;359 /// What to do if an account is fully reaped from the system.360 type OnKilledAccount = ();361 /// What to do if a new account is created.362 type OnNewAccount = ();363 type OnSetCode = cumulus_pallet_parachain_system::ParachainSetCode<Self>;364 /// The ubiquitous origin type.365 type Origin = Origin;366 /// This type is being generated by `construct_runtime!`.367 type PalletInfo = PalletInfo;368 /// This is used as an identifier of the chain. 42 is the generic substrate prefix.369 type SS58Prefix = SS58Prefix;370 /// Weight information for the extrinsics of this pallet.371 type SystemWeightInfo = frame_system::weights::SubstrateWeight<Self>;372 /// Version of the runtime.373 type Version = Version;374 type MaxConsumers = ConstU32<16>;375}376377parameter_types! {378 pub const MinimumPeriod: u64 = SLOT_DURATION / 2;379}380381impl pallet_timestamp::Config for Runtime {382 /// A timestamp: milliseconds since the unix epoch.383 type Moment = u64;384 type OnTimestampSet = ();385 type MinimumPeriod = MinimumPeriod;386 type WeightInfo = ();387}388389parameter_types! {390 // pub const ExistentialDeposit: u128 = 500;391 pub const ExistentialDeposit: u128 = 0;392 pub const MaxLocks: u32 = 50;393}394395impl pallet_balances::Config for Runtime {396 type MaxLocks = MaxLocks;397 type MaxReserves = ();398 type ReserveIdentifier = [u8; 8];399 /// The type for recording an account's balance.400 type Balance = Balance;401 /// The ubiquitous event type.402 type Event = Event;403 type DustRemoval = Treasury;404 type ExistentialDeposit = ExistentialDeposit;405 type AccountStore = System;406 type WeightInfo = pallet_balances::weights::SubstrateWeight<Self>;407}408409pub const fn deposit(items: u32, bytes: u32) -> Balance {410 items as Balance * 15 * CENTIUNIQUE + (bytes as Balance) * 6 * CENTIUNIQUE411}412413/*414parameter_types! {415 pub TombstoneDeposit: Balance = deposit(416 1,417 sp_std::mem::size_of::<pallet_contracts::Pallet<Runtime>> as u32,418 );419 pub DepositPerContract: Balance = TombstoneDeposit::get();420 pub const DepositPerStorageByte: Balance = deposit(0, 1);421 pub const DepositPerStorageItem: Balance = deposit(1, 0);422 pub RentFraction: Perbill = Perbill::from_rational(1u32, 30 * DAYS);423 pub const SurchargeReward: Balance = 150 * MILLIUNIQUE;424 pub const SignedClaimHandicap: u32 = 2;425 pub const MaxDepth: u32 = 32;426 pub const MaxValueSize: u32 = 16 * 1024;427 pub const MaxCodeSize: u32 = 1024 * 1024 * 25; // 25 Mb428 // The lazy deletion runs inside on_initialize.429 pub DeletionWeightLimit: Weight = AVERAGE_ON_INITIALIZE_RATIO *430 RuntimeBlockWeights::get().max_block;431 // The weight needed for decoding the queue should be less or equal than a fifth432 // of the overall weight dedicated to the lazy deletion.433 pub DeletionQueueDepth: u32 = ((DeletionWeightLimit::get() / (434 <Runtime as pallet_contracts::Config>::WeightInfo::on_initialize_per_queue_item(1) -435 <Runtime as pallet_contracts::Config>::WeightInfo::on_initialize_per_queue_item(0)436 )) / 5) as u32;437 pub Schedule: pallet_contracts::Schedule<Runtime> = Default::default();438}439440impl pallet_contracts::Config for Runtime {441 type Time = Timestamp;442 type Randomness = RandomnessCollectiveFlip;443 type Currency = Balances;444 type Event = Event;445 type RentPayment = ();446 type SignedClaimHandicap = SignedClaimHandicap;447 type TombstoneDeposit = TombstoneDeposit;448 type DepositPerContract = DepositPerContract;449 type DepositPerStorageByte = DepositPerStorageByte;450 type DepositPerStorageItem = DepositPerStorageItem;451 type RentFraction = RentFraction;452 type SurchargeReward = SurchargeReward;453 type WeightPrice = pallet_transaction_payment::Pallet<Self>;454 type WeightInfo = pallet_contracts::weights::SubstrateWeight<Self>;455 type ChainExtension = NFTExtension;456 type DeletionQueueDepth = DeletionQueueDepth;457 type DeletionWeightLimit = DeletionWeightLimit;458 type Schedule = Schedule;459 type CallStack = [pallet_contracts::Frame<Self>; 31];460}461*/462463parameter_types! {464 /// This value increases the priority of `Operational` transactions by adding465 /// a "virtual tip" that's equal to the `OperationalFeeMultiplier * final_fee`.466 pub const OperationalFeeMultiplier: u8 = 5;467}468469/// Linear implementor of `WeightToFeePolynomial`470pub struct LinearFee<T>(sp_std::marker::PhantomData<T>);471472impl<T> WeightToFeePolynomial for LinearFee<T>473where474 T: BaseArithmetic + From<u32> + Copy + Unsigned,475{476 type Balance = T;477478 fn polynomial() -> WeightToFeeCoefficients<Self::Balance> {479 smallvec!(WeightToFeeCoefficient {480 // Targeting 0.1 Unique per NFT transfer481 coeff_integer: WEIGHT_TO_FEE_COEFF.into(),482 coeff_frac: Perbill::zero(),483 negative: false,484 degree: 1,485 })486 }487}488489impl pallet_transaction_payment::Config for Runtime {490 type OnChargeTransaction = pallet_transaction_payment::CurrencyAdapter<Balances, DealWithFees>;491 type LengthToFee = ConstantMultiplier<Balance, TransactionByteFee>;492 type OperationalFeeMultiplier = OperationalFeeMultiplier;493 type WeightToFee = LinearFee<Balance>;494 type FeeMultiplierUpdate = ();495}496497parameter_types! {498 pub const ProposalBond: Permill = Permill::from_percent(5);499 pub const ProposalBondMinimum: Balance = 1 * UNIQUE;500 pub const ProposalBondMaximum: Balance = 1000 * UNIQUE;501 pub const SpendPeriod: BlockNumber = 5 * MINUTES;502 pub const Burn: Permill = Permill::from_percent(0);503 pub const TipCountdown: BlockNumber = 1 * DAYS;504 pub const TipFindersFee: Percent = Percent::from_percent(20);505 pub const TipReportDepositBase: Balance = 1 * UNIQUE;506 pub const DataDepositPerByte: Balance = 1 * CENTIUNIQUE;507 pub const BountyDepositBase: Balance = 1 * UNIQUE;508 pub const BountyDepositPayoutDelay: BlockNumber = 1 * DAYS;509 pub const TreasuryModuleId: PalletId = PalletId(*b"py/trsry");510 pub const BountyUpdatePeriod: BlockNumber = 14 * DAYS;511 pub const MaximumReasonLength: u32 = 16384;512 pub const BountyCuratorDeposit: Permill = Permill::from_percent(50);513 pub const BountyValueMinimum: Balance = 5 * UNIQUE;514 pub const MaxApprovals: u32 = 100;515}516517impl pallet_treasury::Config for Runtime {518 type PalletId = TreasuryModuleId;519 type Currency = Balances;520 type ApproveOrigin = EnsureRoot<AccountId>;521 type RejectOrigin = EnsureRoot<AccountId>;522 type Event = Event;523 type OnSlash = ();524 type ProposalBond = ProposalBond;525 type ProposalBondMinimum = ProposalBondMinimum;526 type ProposalBondMaximum = ProposalBondMaximum;527 type SpendPeriod = SpendPeriod;528 type Burn = Burn;529 type BurnDestination = ();530 type SpendFunds = ();531 type WeightInfo = pallet_treasury::weights::SubstrateWeight<Self>;532 type MaxApprovals = MaxApprovals;533}534535impl pallet_sudo::Config for Runtime {536 type Event = Event;537 type Call = Call;538}539540pub struct RelayChainBlockNumberProvider<T>(sp_std::marker::PhantomData<T>);541542impl<T: cumulus_pallet_parachain_system::Config> BlockNumberProvider543 for RelayChainBlockNumberProvider<T>544{545 type BlockNumber = BlockNumber;546547 fn current_block_number() -> Self::BlockNumber {548 cumulus_pallet_parachain_system::Pallet::<T>::validation_data()549 .map(|d| d.relay_parent_number)550 .unwrap_or_default()551 }552}553554parameter_types! {555 pub const MinVestedTransfer: Balance = 10 * UNIQUE;556 pub const MaxVestingSchedules: u32 = 28;557}558559impl orml_vesting::Config for Runtime {560 type Event = Event;561 type Currency = pallet_balances::Pallet<Runtime>;562 type MinVestedTransfer = MinVestedTransfer;563 type VestedTransferOrigin = EnsureSigned<AccountId>;564 type WeightInfo = ();565 type MaxVestingSchedules = MaxVestingSchedules;566 type BlockNumberProvider = RelayChainBlockNumberProvider<Runtime>;567}568569parameter_types! {570 pub const ReservedDmpWeight: Weight = MAXIMUM_BLOCK_WEIGHT / 4;571 pub const ReservedXcmpWeight: Weight = MAXIMUM_BLOCK_WEIGHT / 4;572}573574impl cumulus_pallet_parachain_system::Config for Runtime {575 type Event = Event;576 type SelfParaId = parachain_info::Pallet<Self>;577 type OnSystemEvent = ();578 // type DownwardMessageHandlers = cumulus_primitives_utility::UnqueuedDmpAsParent<579 // MaxDownwardMessageWeight,580 // XcmExecutor<XcmConfig>,581 // Call,582 // >;583 type OutboundXcmpMessageSource = XcmpQueue;584 type DmpMessageHandler = DmpQueue;585 type ReservedDmpWeight = ReservedDmpWeight;586 type ReservedXcmpWeight = ReservedXcmpWeight;587 type XcmpMessageHandler = XcmpQueue;588}589590impl parachain_info::Config for Runtime {}591592impl cumulus_pallet_aura_ext::Config for Runtime {}593594parameter_types! {595 pub const RelayLocation: MultiLocation = MultiLocation::parent();596 pub const RelayNetwork: NetworkId = NetworkId::Polkadot;597 pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();598 pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();599}600601/// Type for specifying how a `MultiLocation` can be converted into an `AccountId`. This is used602/// when determining ownership of accounts for asset transacting and when attempting to use XCM603/// `Transact` in order to determine the dispatch Origin.604pub type LocationToAccountId = (605 // The parent (Relay-chain) origin converts to the default `AccountId`.606 ParentIsPreset<AccountId>,607 // Sibling parachain origins convert to AccountId via the `ParaId::into`.608 SiblingParachainConvertsVia<Sibling, AccountId>,609 // Straight up local `AccountId32` origins just alias directly to `AccountId`.610 AccountId32Aliases<RelayNetwork, AccountId>,611);612613pub struct OnlySelfCurrency;614impl<B: TryFrom<u128>> MatchesFungible<B> for OnlySelfCurrency {615 fn matches_fungible(a: &MultiAsset) -> Option<B> {616 match (&a.id, &a.fun) {617 (Concrete(_), XcmFungible(ref amount)) => CheckedConversion::checked_from(*amount),618 _ => None,619 }620 }621}622623/// Means for transacting assets on this chain.624pub type LocalAssetTransactor = CurrencyAdapter<625 // Use this currency:626 Balances,627 // Use this currency when it is a fungible asset matching the given location or name:628 OnlySelfCurrency,629 // Do a simple punn to convert an AccountId32 MultiLocation into a native chain account ID:630 LocationToAccountId,631 // Our chain's account ID type (we can't get away without mentioning it explicitly):632 AccountId,633 // We don't track any teleports.634 (),635>;636637/// This is the type we use to convert an (incoming) XCM origin into a local `Origin` instance,638/// ready for dispatching a transaction with Xcm's `Transact`. There is an `OriginKind` which can639/// biases the kind of local `Origin` it will become.640pub type XcmOriginToTransactDispatchOrigin = (641 // Sovereign account converter; this attempts to derive an `AccountId` from the origin location642 // using `LocationToAccountId` and then turn that into the usual `Signed` origin. Useful for643 // foreign chains who want to have a local sovereign account on this chain which they control.644 SovereignSignedViaLocation<LocationToAccountId, Origin>,645 // Native converter for Relay-chain (Parent) location; will converts to a `Relay` origin when646 // recognised.647 RelayChainAsNative<RelayOrigin, Origin>,648 // Native converter for sibling Parachains; will convert to a `SiblingPara` origin when649 // recognised.650 SiblingParachainAsNative<cumulus_pallet_xcm::Origin, Origin>,651 // Superuser converter for the Relay-chain (Parent) location. This will allow it to issue a652 // transaction from the Root origin.653 ParentAsSuperuser<Origin>,654 // Native signed account converter; this just converts an `AccountId32` origin into a normal655 // `Origin::Signed` origin of the same 32-byte value.656 SignedAccountId32AsNative<RelayNetwork, Origin>,657 // Xcm origins can be represented natively under the Xcm pallet's Xcm origin.658 XcmPassthrough<Origin>,659);660661parameter_types! {662 // One XCM operation is 1_000_000 weight - almost certainly a conservative estimate.663 pub UnitWeightCost: Weight = 1_000_000;664 // 1200 UNIQUEs buy 1 second of weight.665 pub const WeightPrice: (MultiLocation, u128) = (MultiLocation::parent(), 1_200 * UNIQUE);666 pub const MaxInstructions: u32 = 100;667 pub const MaxAuthorities: u32 = 100_000;668}669670match_types! {671 pub type ParentOrParentsUnitPlurality: impl Contains<MultiLocation> = {672 MultiLocation { parents: 1, interior: Here } |673 MultiLocation { parents: 1, interior: X1(Plurality { id: BodyId::Unit, .. }) }674 };675}676677pub type Barrier = (678 TakeWeightCredit,679 AllowTopLevelPaidExecutionFrom<Everything>,680 AllowUnpaidExecutionFrom<ParentOrParentsUnitPlurality>,681 // ^^^ Parent & its unit plurality gets free execution682);683684pub struct UsingOnlySelfCurrencyComponents<685 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,686 AssetId: Get<MultiLocation>,687 AccountId,688 Currency: CurrencyT<AccountId>,689 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,690>(691 Weight,692 Currency::Balance,693 PhantomData<(WeightToFee, AssetId, AccountId, Currency, OnUnbalanced)>,694);695impl<696 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,697 AssetId: Get<MultiLocation>,698 AccountId,699 Currency: CurrencyT<AccountId>,700 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,701 > WeightTrader702 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>703{704 fn new() -> Self {705 Self(0, Zero::zero(), PhantomData)706 }707708 fn buy_weight(&mut self, weight: Weight, payment: Assets) -> Result<Assets, XcmError> {709 let amount = WeightToFee::calc(&weight);710 let u128_amount: u128 = amount.try_into().map_err(|_| XcmError::Overflow)?;711712 // location to this parachain through relay chain713 let option1: xcm::v1::AssetId = Concrete(MultiLocation {714 parents: 1,715 interior: X1(Parachain(ParachainInfo::parachain_id().into())),716 });717 // direct location718 let option2: xcm::v1::AssetId = Concrete(MultiLocation {719 parents: 0,720 interior: Here,721 });722723 let required = if payment.fungible.contains_key(&option1) {724 (option1, u128_amount).into()725 } else if payment.fungible.contains_key(&option2) {726 (option2, u128_amount).into()727 } else {728 (Concrete(MultiLocation::default()), u128_amount).into()729 };730731 let unused = payment732 .checked_sub(required)733 .map_err(|_| XcmError::TooExpensive)?;734 self.0 = self.0.saturating_add(weight);735 self.1 = self.1.saturating_add(amount);736 Ok(unused)737 }738739 fn refund_weight(&mut self, weight: Weight) -> Option<MultiAsset> {740 let weight = weight.min(self.0);741 let amount = WeightToFee::calc(&weight);742 self.0 -= weight;743 self.1 = self.1.saturating_sub(amount);744 let amount: u128 = amount.saturated_into();745 if amount > 0 {746 Some((AssetId::get(), amount).into())747 } else {748 None749 }750 }751}752impl<753 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,754 AssetId: Get<MultiLocation>,755 AccountId,756 Currency: CurrencyT<AccountId>,757 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,758 > Drop759 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>760{761 fn drop(&mut self) {762 OnUnbalanced::on_unbalanced(Currency::issue(self.1));763 }764}765766pub struct XcmConfig;767impl Config for XcmConfig {768 type Call = Call;769 type XcmSender = XcmRouter;770 // How to withdraw and deposit an asset.771 type AssetTransactor = LocalAssetTransactor;772 type OriginConverter = XcmOriginToTransactDispatchOrigin;773 type IsReserve = NativeAsset;774 type IsTeleporter = (); // Teleportation is disabled775 type LocationInverter = LocationInverter<Ancestry>;776 type Barrier = Barrier;777 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;778 type Trader = UsingOnlySelfCurrencyComponents<779 IdentityFee<Balance>,780 RelayLocation,781 AccountId,782 Balances,783 (),784 >;785 type ResponseHandler = (); // Don't handle responses for now.786 type SubscriptionService = PolkadotXcm;787788 type AssetTrap = PolkadotXcm;789 type AssetClaims = PolkadotXcm;790}791792// parameter_types! {793// pub const MaxDownwardMessageWeight: Weight = MAXIMUM_BLOCK_WEIGHT / 10;794// }795796/// No local origins on this chain are allowed to dispatch XCM sends/executions.797pub type LocalOriginToLocation = (SignedToAccountId32<Origin, AccountId, RelayNetwork>,);798799/// The means for routing XCM messages which are not for local execution into the right message800/// queues.801pub type XcmRouter = (802 // Two routers - use UMP to communicate with the relay chain:803 cumulus_primitives_utility::ParentAsUmp<ParachainSystem, ()>,804 // ..and XCMP to communicate with the sibling chains.805 XcmpQueue,806);807808impl pallet_evm_coder_substrate::Config for Runtime {}809810impl pallet_xcm::Config for Runtime {811 type Event = Event;812 type SendXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;813 type XcmRouter = XcmRouter;814 type ExecuteXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;815 type XcmExecuteFilter = Everything;816 type XcmExecutor = XcmExecutor<XcmConfig>;817 type XcmTeleportFilter = Everything;818 type XcmReserveTransferFilter = Everything;819 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;820 type LocationInverter = LocationInverter<Ancestry>;821 type Origin = Origin;822 type Call = Call;823 const VERSION_DISCOVERY_QUEUE_SIZE: u32 = 100;824 type AdvertisedXcmVersion = pallet_xcm::CurrentXcmVersion;825}826827impl cumulus_pallet_xcm::Config for Runtime {828 type Event = Event;829 type XcmExecutor = XcmExecutor<XcmConfig>;830}831832impl cumulus_pallet_xcmp_queue::Config for Runtime {833 type WeightInfo = ();834 type Event = Event;835 type XcmExecutor = XcmExecutor<XcmConfig>;836 type ChannelInfo = ParachainSystem;837 type VersionWrapper = ();838 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;839 type ControllerOrigin = EnsureRoot<AccountId>;840 type ControllerOriginConverter = XcmOriginToTransactDispatchOrigin;841}842843impl cumulus_pallet_dmp_queue::Config for Runtime {844 type Event = Event;845 type XcmExecutor = XcmExecutor<XcmConfig>;846 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;847}848849impl pallet_aura::Config for Runtime {850 type AuthorityId = AuraId;851 type DisabledValidators = ();852 type MaxAuthorities = MaxAuthorities;853}854855parameter_types! {856 pub TreasuryAccountId: AccountId = TreasuryModuleId::get().into_account();857 pub const CollectionCreationPrice: Balance = 2 * UNIQUE;858}859860impl pallet_common::Config for Runtime {861 type WeightInfo = pallet_common::weights::SubstrateWeight<Self>;862 type Event = Event;863 type Currency = Balances;864 type CollectionCreationPrice = CollectionCreationPrice;865 type TreasuryAccountId = TreasuryAccountId;866 type CollectionDispatch = CollectionDispatchT<Self>;867868 type EvmTokenAddressMapping = EvmTokenAddressMapping;869 type CrossTokenAddressMapping = CrossTokenAddressMapping<Self::AccountId>;870 type ContractAddress = EvmCollectionHelpersAddress;871}872873impl pallet_structure::Config for Runtime {874 type Event = Event;875 type Call = Call;876 type WeightInfo = pallet_structure::weights::SubstrateWeight<Self>;877}878879impl pallet_evm::account::Config for Runtime {880 type CrossAccountId = pallet_evm::account::BasicCrossAccountId<Self>;881 type EvmAddressMapping = HashedAddressMapping<Self::Hashing>;882 type EvmBackwardsAddressMapping = fp_evm_mapping::MapBackwardsAddressTruncated;883}884885impl pallet_fungible::Config for Runtime {886 type WeightInfo = pallet_fungible::weights::SubstrateWeight<Self>;887}888impl pallet_refungible::Config for Runtime {889 type WeightInfo = pallet_refungible::weights::SubstrateWeight<Self>;890}891impl pallet_nonfungible::Config for Runtime {892 type WeightInfo = pallet_nonfungible::weights::SubstrateWeight<Self>;893}894/* TODO free RMRK!895impl pallet_proxy_rmrk_core::Config for Runtime {896 type Event = Event;897}898899impl pallet_proxy_rmrk_equip::Config for Runtime {900 type Event = Event;901}*/902903impl pallet_unique::Config for Runtime {904 type Event = Event;905 type WeightInfo = pallet_unique::weights::SubstrateWeight<Self>;906 type CommonWeightInfo = CommonWeights<Self>;907}908909parameter_types! {910 pub const InflationBlockInterval: BlockNumber = 100; // every time per how many blocks inflation is applied911}912913/// Used for the pallet inflation914impl pallet_inflation::Config for Runtime {915 type Currency = Balances;916 type TreasuryAccountId = TreasuryAccountId;917 type InflationBlockInterval = InflationBlockInterval;918 type BlockNumberProvider = RelayChainBlockNumberProvider<Runtime>;919}920921// parameter_types! {922// pub MaximumSchedulerWeight: Weight = Perbill::from_percent(50) *923// RuntimeBlockWeights::get().max_block;924// pub const MaxScheduledPerBlock: u32 = 50;925// }926927type EvmSponsorshipHandler = (928 UniqueEthSponsorshipHandler<Runtime>,929 pallet_evm_contract_helpers::HelpersContractSponsoring<Runtime>,930);931type SponsorshipHandler = (932 UniqueSponsorshipHandler<Runtime>,933 //pallet_contract_helpers::ContractSponsorshipHandler<Runtime>,934 pallet_evm_transaction_payment::BridgeSponsorshipHandler<Runtime>,935);936937// impl pallet_unq_scheduler::Config for Runtime {938// type Event = Event;939// type Origin = Origin;940// type PalletsOrigin = OriginCaller;941// type Call = Call;942// type MaximumWeight = MaximumSchedulerWeight;943// type ScheduleOrigin = EnsureSigned<AccountId>;944// type MaxScheduledPerBlock = MaxScheduledPerBlock;945// type SponsorshipHandler = SponsorshipHandler;946// type WeightInfo = ();947// }948949impl pallet_evm_transaction_payment::Config for Runtime {950 type EvmSponsorshipHandler = EvmSponsorshipHandler;951 type Currency = Balances;952}953954impl pallet_charge_transaction::Config for Runtime {955 type SponsorshipHandler = SponsorshipHandler;956}957958// impl pallet_contract_helpers::Config for Runtime {959// type DefaultSponsoringRateLimit = DefaultSponsoringRateLimit;960// }961962parameter_types! {963 // 0x842899ECF380553E8a4de75bF534cdf6fBF64049964 pub const HelpersContractAddress: H160 = H160([965 0x84, 0x28, 0x99, 0xec, 0xf3, 0x80, 0x55, 0x3e, 0x8a, 0x4d, 0xe7, 0x5b, 0xf5, 0x34, 0xcd, 0xf6, 0xfb, 0xf6, 0x40, 0x49,966 ]);967 968 // 0x6c4e9fe1ae37a41e93cee429e8e1881abdcbb54f969 pub const EvmCollectionHelpersAddress: H160 = H160([970 0x6c, 0x4e, 0x9f, 0xe1, 0xae, 0x37, 0xa4, 0x1e, 0x93, 0xce, 0xe4, 0x29, 0xe8, 0xe1, 0x88, 0x1a, 0xbd, 0xcb, 0xb5, 0x4f,971 ]);972}973974impl pallet_evm_contract_helpers::Config for Runtime {975 type ContractAddress = HelpersContractAddress;976 type DefaultSponsoringRateLimit = DefaultSponsoringRateLimit;977}978979construct_runtime!(980 pub enum Runtime where981 Block = Block,982 NodeBlock = opaque::Block,983 UncheckedExtrinsic = UncheckedExtrinsic984 {985 ParachainSystem: cumulus_pallet_parachain_system::{Pallet, Call, Config, Storage, Inherent, Event<T>, ValidateUnsigned} = 20,986 ParachainInfo: parachain_info::{Pallet, Storage, Config} = 21,987988 Aura: pallet_aura::{Pallet, Config<T>} = 22,989 AuraExt: cumulus_pallet_aura_ext::{Pallet, Config} = 23,990991 Balances: pallet_balances::{Pallet, Call, Storage, Config<T>, Event<T>} = 30,992 RandomnessCollectiveFlip: pallet_randomness_collective_flip::{Pallet, Storage} = 31,993 Timestamp: pallet_timestamp::{Pallet, Call, Storage, Inherent} = 32,994 TransactionPayment: pallet_transaction_payment::{Pallet, Storage} = 33,995 Treasury: pallet_treasury::{Pallet, Call, Storage, Config, Event<T>} = 34,996 Sudo: pallet_sudo::{Pallet, Call, Storage, Config<T>, Event<T>} = 35,997 System: frame_system::{Pallet, Call, Storage, Config, Event<T>} = 36,998 Vesting: orml_vesting::{Pallet, Storage, Call, Event<T>, Config<T>} = 37,999 // Vesting: pallet_vesting::{Pallet, Call, Config<T>, Storage, Event<T>} = 37,1000 // Contracts: pallet_contracts::{Pallet, Call, Storage, Event<T>} = 38,10011002 // XCM helpers.1003 XcmpQueue: cumulus_pallet_xcmp_queue::{Pallet, Call, Storage, Event<T>} = 50,1004 PolkadotXcm: pallet_xcm::{Pallet, Call, Event<T>, Origin} = 51,1005 CumulusXcm: cumulus_pallet_xcm::{Pallet, Call, Event<T>, Origin} = 52,1006 DmpQueue: cumulus_pallet_dmp_queue::{Pallet, Call, Storage, Event<T>} = 53,10071008 // Unique Pallets1009 Inflation: pallet_inflation::{Pallet, Call, Storage} = 60,1010 Unique: pallet_unique::{Pallet, Call, Storage, Event<T>} = 61,1011 // Scheduler: pallet_unq_scheduler::{Pallet, Call, Storage, Event<T>} = 62,1012 // free = 631013 Charging: pallet_charge_transaction::{Pallet, Call, Storage } = 64,1014 // ContractHelpers: pallet_contract_helpers::{Pallet, Call, Storage} = 65,1015 Common: pallet_common::{Pallet, Storage, Event<T>} = 66,1016 Fungible: pallet_fungible::{Pallet, Storage} = 67,1017 Refungible: pallet_refungible::{Pallet, Storage} = 68,1018 Nonfungible: pallet_nonfungible::{Pallet, Storage} = 69,1019 Structure: pallet_structure::{Pallet, Call, Storage, Event<T>} = 70,1020 /* TODO free RMRK!1021 RmrkCore: pallet_proxy_rmrk_core::{Pallet, Call, Storage, Event<T>} = 71,1022 RmrkEquip: pallet_proxy_rmrk_equip::{Pallet, Call, Storage, Event<T>} = 72,*/10231024 // Frontier1025 EVM: pallet_evm::{Pallet, Config, Call, Storage, Event<T>} = 100,1026 Ethereum: pallet_ethereum::{Pallet, Config, Call, Storage, Event, Origin} = 101,10271028 EvmCoderSubstrate: pallet_evm_coder_substrate::{Pallet, Storage} = 150,1029 EvmContractHelpers: pallet_evm_contract_helpers::{Pallet, Storage} = 151,1030 EvmTransactionPayment: pallet_evm_transaction_payment::{Pallet} = 152,1031 EvmMigration: pallet_evm_migration::{Pallet, Call, Storage} = 153,1032 }1033);10341035pub struct TransactionConverter;10361037impl fp_rpc::ConvertTransaction<UncheckedExtrinsic> for TransactionConverter {1038 fn convert_transaction(&self, transaction: pallet_ethereum::Transaction) -> UncheckedExtrinsic {1039 UncheckedExtrinsic::new_unsigned(1040 pallet_ethereum::Call::<Runtime>::transact { transaction }.into(),1041 )1042 }1043}10441045impl fp_rpc::ConvertTransaction<opaque::UncheckedExtrinsic> for TransactionConverter {1046 fn convert_transaction(1047 &self,1048 transaction: pallet_ethereum::Transaction,1049 ) -> opaque::UncheckedExtrinsic {1050 let extrinsic = UncheckedExtrinsic::new_unsigned(1051 pallet_ethereum::Call::<Runtime>::transact { transaction }.into(),1052 );1053 let encoded = extrinsic.encode();1054 opaque::UncheckedExtrinsic::decode(&mut &encoded[..])1055 .expect("Encoded extrinsic is always valid")1056 }1057}10581059/// The address format for describing accounts.1060pub type Address = sp_runtime::MultiAddress<AccountId, ()>;1061/// Block header type as expected by this runtime.1062pub type Header = generic::Header<BlockNumber, BlakeTwo256>;1063/// Block type as expected by this runtime.1064pub type Block = generic::Block<Header, UncheckedExtrinsic>;1065/// A Block signed with a Justification1066pub type SignedBlock = generic::SignedBlock<Block>;1067/// BlockId type as expected by this runtime.1068pub type BlockId = generic::BlockId<Block>;1069/// The SignedExtension to the basic transaction logic.1070pub type SignedExtra = (1071 frame_system::CheckSpecVersion<Runtime>,1072 // system::CheckTxVersion<Runtime>,1073 frame_system::CheckGenesis<Runtime>,1074 frame_system::CheckEra<Runtime>,1075 frame_system::CheckNonce<Runtime>,1076 frame_system::CheckWeight<Runtime>,1077 pallet_charge_transaction::ChargeTransactionPayment<Runtime>,1078 //pallet_contract_helpers::ContractHelpersExtension<Runtime>,1079 pallet_ethereum::FakeTransactionFinalizer<Runtime>,1080);1081/// Unchecked extrinsic type as expected by this runtime.1082pub type UncheckedExtrinsic =1083 fp_self_contained::UncheckedExtrinsic<Address, Call, Signature, SignedExtra>;1084/// Extrinsic type that has already been checked.1085pub type CheckedExtrinsic = fp_self_contained::CheckedExtrinsic<AccountId, Call, SignedExtra, H160>;1086/// Executive: handles dispatch to the various modules.1087pub type Executive = frame_executive::Executive<1088 Runtime,1089 Block,1090 frame_system::ChainContext<Runtime>,1091 Runtime,1092 AllPalletsReversedWithSystemFirst,1093>;10941095impl_opaque_keys! {1096 pub struct SessionKeys {1097 pub aura: Aura,1098 }1099}11001101impl fp_self_contained::SelfContainedCall for Call {1102 type SignedInfo = H160;11031104 fn is_self_contained(&self) -> bool {1105 match self {1106 Call::Ethereum(call) => call.is_self_contained(),1107 _ => false,1108 }1109 }11101111 fn check_self_contained(&self) -> Option<Result<Self::SignedInfo, TransactionValidityError>> {1112 match self {1113 Call::Ethereum(call) => call.check_self_contained(),1114 _ => None,1115 }1116 }11171118 fn validate_self_contained(&self, info: &Self::SignedInfo) -> Option<TransactionValidity> {1119 match self {1120 Call::Ethereum(call) => call.validate_self_contained(info),1121 _ => None,1122 }1123 }11241125 fn pre_dispatch_self_contained(1126 &self,1127 info: &Self::SignedInfo,1128 ) -> Option<Result<(), TransactionValidityError>> {1129 match self {1130 Call::Ethereum(call) => call.pre_dispatch_self_contained(info),1131 _ => None,1132 }1133 }11341135 fn apply_self_contained(1136 self,1137 info: Self::SignedInfo,1138 ) -> Option<sp_runtime::DispatchResultWithInfo<PostDispatchInfoOf<Self>>> {1139 match self {1140 call @ Call::Ethereum(pallet_ethereum::Call::transact { .. }) => Some(call.dispatch(1141 Origin::from(pallet_ethereum::RawOrigin::EthereumTransaction(info)),1142 )),1143 _ => None,1144 }1145 }1146}11471148macro_rules! dispatch_unique_runtime {1149 ($collection:ident.$method:ident($($name:ident),*)) => {{1150 let collection = <Runtime as pallet_common::Config>::CollectionDispatch::dispatch(<pallet_common::CollectionHandle<Runtime>>::try_get($collection)?);1151 let dispatch = collection.as_dyn();11521153 Ok::<_, DispatchError>(dispatch.$method($($name),*))1154 }};1155}11561157impl_common_runtime_apis!();11581159struct CheckInherents;11601161impl cumulus_pallet_parachain_system::CheckInherents<Block> for CheckInherents {1162 fn check_inherents(1163 block: &Block,1164 relay_state_proof: &cumulus_pallet_parachain_system::RelayChainStateProof,1165 ) -> sp_inherents::CheckInherentsResult {1166 let relay_chain_slot = relay_state_proof1167 .read_slot()1168 .expect("Could not read the relay chain slot from the proof");11691170 let inherent_data =1171 cumulus_primitives_timestamp::InherentDataProvider::from_relay_chain_slot_and_duration(1172 relay_chain_slot,1173 sp_std::time::Duration::from_secs(6),1174 )1175 .create_inherent_data()1176 .expect("Could not create the timestamp inherent data");11771178 inherent_data.check_extrinsics(block)1179 }1180}11811182cumulus_pallet_parachain_system::register_validate_block!(1183 Runtime = Runtime,1184 BlockExecutor = cumulus_pallet_aura_ext::BlockExecutor::<Runtime, Executive>,1185 CheckInherents = CheckInherents,1186);1// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.2// This file is part of Unique Network.34// Unique Network is free software: you can redistribute it and/or modify5// it under the terms of the GNU General Public License as published by6// the Free Software Foundation, either version 3 of the License, or7// (at your option) any later version.89// Unique Network is distributed in the hope that it will be useful,10// but WITHOUT ANY WARRANTY; without even the implied warranty of11// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the12// GNU General Public License for more details.1314// You should have received a copy of the GNU General Public License15// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.1617//! The Substrate Node Template runtime. This can be compiled with `#[no_std]`, ready for Wasm.1819#![cfg_attr(not(feature = "std"), no_std)]20// `construct_runtime!` does a lot of recursion and requires us to increase the limit to 256.21#![recursion_limit = "1024"]22#![allow(clippy::from_over_into, clippy::identity_op)]23#![allow(clippy::fn_to_numeric_cast_with_truncation)]24// Make the WASM binary available.25#[cfg(feature = "std")]26include!(concat!(env!("OUT_DIR"), "/wasm_binary.rs"));2728use sp_api::impl_runtime_apis;29use sp_core::{crypto::KeyTypeId, OpaqueMetadata, H256, U256, H160};30use sp_runtime::DispatchError;31// #[cfg(any(feature = "std", test))]32// pub use sp_runtime::BuildStorage;3334use sp_runtime::{35 Permill, Perbill, Percent, create_runtime_str, generic, impl_opaque_keys,36 generic::Era,37 traits::{38 Applyable, BlockNumberProvider, Dispatchable, PostDispatchInfoOf, Saturating,39 CheckedConversion, AccountIdLookup, BlakeTwo256, Block as BlockT, AccountIdConversion,40 Zero, Member,41 },42 transaction_validity::{TransactionSource, TransactionValidity, TransactionValidityError},43 ApplyExtrinsicResult, RuntimeAppPublic, SaturatedConversion, DispatchErrorWithPostInfo,44};4546use fp_self_contained::{SelfContainedCall, CheckedSignature};47use sp_std::{cmp::Ordering, marker::PhantomData};48use pallet_unq_scheduler::DispatchCall;4950use sp_std::prelude::*;5152#[cfg(feature = "std")]53use sp_version::NativeVersion;54use sp_version::RuntimeVersion;55pub use pallet_transaction_payment::{56 Multiplier, TargetedFeeAdjustment, FeeDetails, RuntimeDispatchInfo,57};58// A few exports that help ease life for downstream crates.59pub use pallet_balances::Call as BalancesCall;60pub use pallet_evm::{61 EnsureAddressTruncated, HashedAddressMapping, Runner, account::CrossAccountId as _, OnMethodCall,62 Account as EVMAccount, FeeCalculator, GasWeightMapping,63};64pub use frame_support::{65 construct_runtime, match_types,66 dispatch::DispatchResult,67 PalletId, parameter_types, StorageValue, ConsensusEngineId,68 traits::{69 tokens::currency::Currency as CurrencyT, OnUnbalanced as OnUnbalancedT, Everything,70 Currency, ExistenceRequirement, Get, IsInVec, KeyOwnerProofSystem, LockIdentifier,71 OnUnbalanced, Randomness, FindAuthor, ConstU32, Imbalance, PrivilegeCmp,72 },73 weights::{74 constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},75 DispatchClass, DispatchInfo, GetDispatchInfo, IdentityFee, Pays, PostDispatchInfo, Weight,76 WeightToFeePolynomial, WeightToFeeCoefficient, WeightToFeeCoefficients, ConstantMultiplier,77 },78};79use unique_runtime_common::{80 dispatch::{CollectionDispatchT, CollectionDispatch},81 weights::CommonWeights,82 sponsoring::UniqueSponsorshipHandler,83 eth_sponsoring::UniqueEthSponsorshipHandler,84};85use up_data_structs::*;86// use pallet_contracts::weights::WeightInfo;87// #[cfg(any(feature = "std", test))]88use frame_system::{89 self as frame_system, EnsureRoot, EnsureSigned,90 limits::{BlockWeights, BlockLength},91};92use sp_arithmetic::{93 traits::{BaseArithmetic, Unsigned},94};95use smallvec::smallvec;96use codec::{Encode, Decode};97use fp_rpc::TransactionStatus;9899// pub use pallet_timestamp::Call as TimestampCall;100101// Polkadot imports102use pallet_xcm::XcmPassthrough;103use polkadot_parachain::primitives::Sibling;104use up_data_structs::{105 CollectionId, TokenId, TokenData, Property, PropertyKeyPermission, CollectionLimits, 106 CollectionStats, RpcCollection, 107 mapping::{EvmTokenAddressMapping, CrossTokenAddressMapping}108};109use xcm::v1::{BodyId, Junction::*, MultiLocation, NetworkId, Junctions::*};110use xcm_builder::{111 AccountId32Aliases, AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom, CurrencyAdapter,112 EnsureXcmOrigin, FixedWeightBounds, LocationInverter, NativeAsset, ParentAsSuperuser,113 RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,114 SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,115 ParentIsPreset,116};117use xcm_executor::{Config, XcmExecutor, Assets};118119use xcm::latest::{120 // Xcm,121 AssetId::{Concrete},122 Fungibility::Fungible as XcmFungible,123 MultiAsset,124 Error as XcmError,125};126use xcm_executor::traits::{MatchesFungible, WeightTrader};127use sp_runtime::traits::CheckedConversion;128129use unique_runtime_common::{130 impl_common_runtime_apis,131 types::*,132 constants::*,133 dispatch::{CollectionDispatchT, CollectionDispatch},134 sponsoring::UniqueSponsorshipHandler,135 eth_sponsoring::UniqueEthSponsorshipHandler,136 weights::CommonWeights,137};138139pub const RUNTIME_NAME: &str = "unique";140pub const TOKEN_SYMBOL: &str = "UNQ";141142type CrossAccountId = pallet_evm::account::BasicCrossAccountId<Runtime>;143144impl RuntimeInstance for Runtime {145 type CrossAccountId = self::CrossAccountId;146147 type TransactionConverter = self::TransactionConverter;148149 fn get_transaction_converter() -> TransactionConverter {150 TransactionConverter151 }152}153154/// Opaque types. These are used by the CLI to instantiate machinery that don't need to know155/// the specifics of the runtime. They can then be made to be agnostic over specific formats156/// of data like extrinsics, allowing for them to continue syncing the network through upgrades157/// to even the core data structures.158pub mod opaque {159 use sp_std::prelude::*;160 use sp_runtime::impl_opaque_keys;161 use super::Aura;162163 pub use unique_runtime_common::types::*;164165 impl_opaque_keys! {166 pub struct SessionKeys {167 pub aura: Aura,168 }169 }170}171172/// This runtime version.173pub const VERSION: RuntimeVersion = RuntimeVersion {174 spec_name: create_runtime_str!(RUNTIME_NAME),175 impl_name: create_runtime_str!(RUNTIME_NAME),176 authoring_version: 1,177 spec_version: 922000,178 impl_version: 0,179 apis: RUNTIME_API_VERSIONS,180 transaction_version: 1,181 state_version: 0,182};183184#[derive(codec::Encode, codec::Decode)]185pub enum XCMPMessage<XAccountId, XBalance> {186 /// Transfer tokens to the given account from the Parachain account.187 TransferToken(XAccountId, XBalance),188}189190/// The version information used to identify this runtime when compiled natively.191#[cfg(feature = "std")]192pub fn native_version() -> NativeVersion {193 NativeVersion {194 runtime_version: VERSION,195 can_author_with: Default::default(),196 }197}198199type NegativeImbalance = <Balances as Currency<AccountId>>::NegativeImbalance;200201pub struct DealWithFees;202impl OnUnbalanced<NegativeImbalance> for DealWithFees {203 fn on_unbalanceds<B>(mut fees_then_tips: impl Iterator<Item = NegativeImbalance>) {204 if let Some(fees) = fees_then_tips.next() {205 // for fees, 100% to treasury206 let mut split = fees.ration(100, 0);207 if let Some(tips) = fees_then_tips.next() {208 // for tips, if any, 100% to treasury209 tips.ration_merge_into(100, 0, &mut split);210 }211 Treasury::on_unbalanced(split.0);212 // Author::on_unbalanced(split.1);213 }214 }215}216217parameter_types! {218 pub const BlockHashCount: BlockNumber = 2400;219 pub RuntimeBlockLength: BlockLength =220 BlockLength::max_with_normal_ratio(5 * 1024 * 1024, NORMAL_DISPATCH_RATIO);221 pub const AvailableBlockRatio: Perbill = Perbill::from_percent(75);222 pub const MaximumBlockLength: u32 = 5 * 1024 * 1024;223 pub RuntimeBlockWeights: BlockWeights = BlockWeights::builder()224 .base_block(BlockExecutionWeight::get())225 .for_class(DispatchClass::all(), |weights| {226 weights.base_extrinsic = ExtrinsicBaseWeight::get();227 })228 .for_class(DispatchClass::Normal, |weights| {229 weights.max_total = Some(NORMAL_DISPATCH_RATIO * MAXIMUM_BLOCK_WEIGHT);230 })231 .for_class(DispatchClass::Operational, |weights| {232 weights.max_total = Some(MAXIMUM_BLOCK_WEIGHT);233 // Operational transactions have some extra reserved space, so that they234 // are included even if block reached `MAXIMUM_BLOCK_WEIGHT`.235 weights.reserved = Some(236 MAXIMUM_BLOCK_WEIGHT - NORMAL_DISPATCH_RATIO * MAXIMUM_BLOCK_WEIGHT237 );238 })239 .avg_block_initialization(AVERAGE_ON_INITIALIZE_RATIO)240 .build_or_panic();241 pub const Version: RuntimeVersion = VERSION;242 pub const SS58Prefix: u16 = 7391;243}244245parameter_types! {246 pub const ChainId: u64 = 8880;247}248249pub struct FixedFee;250impl FeeCalculator for FixedFee {251 fn min_gas_price() -> U256 {252 MIN_GAS_PRICE.into()253 }254}255256// Assuming slowest ethereum opcode is SSTORE, with gas price of 20000 as our worst case257// (contract, which only writes a lot of data),258// approximating on top of our real store write weight259parameter_types! {260 pub const WritesPerSecond: u64 = WEIGHT_PER_SECOND / <Runtime as frame_system::Config>::DbWeight::get().write;261 pub const GasPerSecond: u64 = WritesPerSecond::get() * 20000;262 pub const WeightPerGas: u64 = WEIGHT_PER_SECOND / GasPerSecond::get();263}264265/// Limiting EVM execution to 50% of block for substrate users and management tasks266/// EVM transaction consumes more weight than substrate's, so we can't rely on them being267/// scheduled fairly268const EVM_DISPATCH_RATIO: Perbill = Perbill::from_percent(50);269parameter_types! {270 pub BlockGasLimit: U256 = U256::from(NORMAL_DISPATCH_RATIO * EVM_DISPATCH_RATIO * MAXIMUM_BLOCK_WEIGHT / WeightPerGas::get());271}272273pub enum FixedGasWeightMapping {}274impl GasWeightMapping for FixedGasWeightMapping {275 fn gas_to_weight(gas: u64) -> Weight {276 gas.saturating_mul(WeightPerGas::get())277 }278 fn weight_to_gas(weight: Weight) -> u64 {279 weight / WeightPerGas::get()280 }281}282283impl pallet_evm::Config for Runtime {284 type BlockGasLimit = BlockGasLimit;285 type FeeCalculator = FixedFee;286 type GasWeightMapping = FixedGasWeightMapping;287 type BlockHashMapping = pallet_ethereum::EthereumBlockHashMapping<Self>;288 type CallOrigin = EnsureAddressTruncated<Self>;289 type WithdrawOrigin = EnsureAddressTruncated<Self>;290 type AddressMapping = HashedAddressMapping<Self::Hashing>;291 type PrecompilesType = ();292 type PrecompilesValue = ();293 type Currency = Balances;294 type Event = Event;295 type OnMethodCall = (296 pallet_evm_migration::OnMethodCall<Self>,297 pallet_evm_contract_helpers::HelpersOnMethodCall<Self>,298 CollectionDispatchT<Self>,299 pallet_unique::eth::CollectionHelpersOnMethodCall<Self>,300 );301 type OnCreate = pallet_evm_contract_helpers::HelpersOnCreate<Self>;302 type ChainId = ChainId;303 type Runner = pallet_evm::runner::stack::Runner<Self>;304 type OnChargeTransaction = pallet_evm::EVMCurrencyAdapter<Balances, DealWithFees>;305 type TransactionValidityHack = pallet_evm_transaction_payment::TransactionValidityHack<Self>;306 type FindAuthor = EthereumFindAuthor<Aura>;307}308309impl pallet_evm_migration::Config for Runtime {310 type WeightInfo = pallet_evm_migration::weights::SubstrateWeight<Self>;311}312313pub struct EthereumFindAuthor<F>(core::marker::PhantomData<F>);314impl<F: FindAuthor<u32>> FindAuthor<H160> for EthereumFindAuthor<F> {315 fn find_author<'a, I>(digests: I) -> Option<H160>316 where317 I: 'a + IntoIterator<Item = (ConsensusEngineId, &'a [u8])>,318 {319 if let Some(author_index) = F::find_author(digests) {320 let authority_id = Aura::authorities()[author_index as usize].clone();321 return Some(H160::from_slice(&authority_id.to_raw_vec()[4..24]));322 }323 None324 }325}326327impl pallet_ethereum::Config for Runtime {328 type Event = Event;329 type StateRoot = pallet_ethereum::IntermediateStateRoot<Self>;330}331332impl pallet_randomness_collective_flip::Config for Runtime {}333334impl frame_system::Config for Runtime {335 /// The data to be stored in an account.336 type AccountData = pallet_balances::AccountData<Balance>;337 /// The identifier used to distinguish between accounts.338 type AccountId = AccountId;339 /// The basic call filter to use in dispatchable.340 type BaseCallFilter = Everything;341 /// Maximum number of block number to block hash mappings to keep (oldest pruned first).342 type BlockHashCount = BlockHashCount;343 /// The maximum length of a block (in bytes).344 type BlockLength = RuntimeBlockLength;345 /// The index type for blocks.346 type BlockNumber = BlockNumber;347 /// The weight of the overhead invoked on the block import process, independent of the extrinsics included in that block.348 type BlockWeights = RuntimeBlockWeights;349 /// The aggregated dispatch type that is available for extrinsics.350 type Call = Call;351 /// The weight of database operations that the runtime can invoke.352 type DbWeight = RocksDbWeight;353 /// The ubiquitous event type.354 type Event = Event;355 /// The type for hashing blocks and tries.356 type Hash = Hash;357 /// The hashing algorithm used.358 type Hashing = BlakeTwo256;359 /// The header type.360 type Header = generic::Header<BlockNumber, BlakeTwo256>;361 /// The index type for storing how many extrinsics an account has signed.362 type Index = Index;363 /// The lookup mechanism to get account ID from whatever is passed in dispatchers.364 type Lookup = AccountIdLookup<AccountId, ()>;365 /// What to do if an account is fully reaped from the system.366 type OnKilledAccount = ();367 /// What to do if a new account is created.368 type OnNewAccount = ();369 type OnSetCode = cumulus_pallet_parachain_system::ParachainSetCode<Self>;370 /// The ubiquitous origin type.371 type Origin = Origin;372 /// This type is being generated by `construct_runtime!`.373 type PalletInfo = PalletInfo;374 /// This is used as an identifier of the chain. 42 is the generic substrate prefix.375 type SS58Prefix = SS58Prefix;376 /// Weight information for the extrinsics of this pallet.377 type SystemWeightInfo = frame_system::weights::SubstrateWeight<Self>;378 /// Version of the runtime.379 type Version = Version;380 type MaxConsumers = ConstU32<16>;381}382383parameter_types! {384 pub const MinimumPeriod: u64 = SLOT_DURATION / 2;385}386387impl pallet_timestamp::Config for Runtime {388 /// A timestamp: milliseconds since the unix epoch.389 type Moment = u64;390 type OnTimestampSet = ();391 type MinimumPeriod = MinimumPeriod;392 type WeightInfo = ();393}394395parameter_types! {396 // pub const ExistentialDeposit: u128 = 500;397 pub const ExistentialDeposit: u128 = 0;398 pub const MaxLocks: u32 = 50;399}400401impl pallet_balances::Config for Runtime {402 type MaxLocks = MaxLocks;403 type MaxReserves = ();404 type ReserveIdentifier = [u8; 16];405 /// The type for recording an account's balance.406 type Balance = Balance;407 /// The ubiquitous event type.408 type Event = Event;409 type DustRemoval = Treasury;410 type ExistentialDeposit = ExistentialDeposit;411 type AccountStore = System;412 type WeightInfo = pallet_balances::weights::SubstrateWeight<Self>;413}414415pub const fn deposit(items: u32, bytes: u32) -> Balance {416 items as Balance * 15 * CENTIUNIQUE + (bytes as Balance) * 6 * CENTIUNIQUE417}418419/*420parameter_types! {421 pub TombstoneDeposit: Balance = deposit(422 1,423 sp_std::mem::size_of::<pallet_contracts::Pallet<Runtime>> as u32,424 );425 pub DepositPerContract: Balance = TombstoneDeposit::get();426 pub const DepositPerStorageByte: Balance = deposit(0, 1);427 pub const DepositPerStorageItem: Balance = deposit(1, 0);428 pub RentFraction: Perbill = Perbill::from_rational(1u32, 30 * DAYS);429 pub const SurchargeReward: Balance = 150 * MILLIUNIQUE;430 pub const SignedClaimHandicap: u32 = 2;431 pub const MaxDepth: u32 = 32;432 pub const MaxValueSize: u32 = 16 * 1024;433 pub const MaxCodeSize: u32 = 1024 * 1024 * 25; // 25 Mb434 // The lazy deletion runs inside on_initialize.435 pub DeletionWeightLimit: Weight = AVERAGE_ON_INITIALIZE_RATIO *436 RuntimeBlockWeights::get().max_block;437 // The weight needed for decoding the queue should be less or equal than a fifth438 // of the overall weight dedicated to the lazy deletion.439 pub DeletionQueueDepth: u32 = ((DeletionWeightLimit::get() / (440 <Runtime as pallet_contracts::Config>::WeightInfo::on_initialize_per_queue_item(1) -441 <Runtime as pallet_contracts::Config>::WeightInfo::on_initialize_per_queue_item(0)442 )) / 5) as u32;443 pub Schedule: pallet_contracts::Schedule<Runtime> = Default::default();444}445446impl pallet_contracts::Config for Runtime {447 type Time = Timestamp;448 type Randomness = RandomnessCollectiveFlip;449 type Currency = Balances;450 type Event = Event;451 type RentPayment = ();452 type SignedClaimHandicap = SignedClaimHandicap;453 type TombstoneDeposit = TombstoneDeposit;454 type DepositPerContract = DepositPerContract;455 type DepositPerStorageByte = DepositPerStorageByte;456 type DepositPerStorageItem = DepositPerStorageItem;457 type RentFraction = RentFraction;458 type SurchargeReward = SurchargeReward;459 type WeightPrice = pallet_transaction_payment::Pallet<Self>;460 type WeightInfo = pallet_contracts::weights::SubstrateWeight<Self>;461 type ChainExtension = NFTExtension;462 type DeletionQueueDepth = DeletionQueueDepth;463 type DeletionWeightLimit = DeletionWeightLimit;464 type Schedule = Schedule;465 type CallStack = [pallet_contracts::Frame<Self>; 31];466}467*/468469parameter_types! {470 /// This value increases the priority of `Operational` transactions by adding471 /// a "virtual tip" that's equal to the `OperationalFeeMultiplier * final_fee`.472 pub const OperationalFeeMultiplier: u8 = 5;473}474475/// Linear implementor of `WeightToFeePolynomial`476pub struct LinearFee<T>(sp_std::marker::PhantomData<T>);477478impl<T> WeightToFeePolynomial for LinearFee<T>479where480 T: BaseArithmetic + From<u32> + Copy + Unsigned,481{482 type Balance = T;483484 fn polynomial() -> WeightToFeeCoefficients<Self::Balance> {485 smallvec!(WeightToFeeCoefficient {486 // Targeting 0.1 Unique per NFT transfer487 coeff_integer: WEIGHT_TO_FEE_COEFF.into(),488 coeff_frac: Perbill::zero(),489 negative: false,490 degree: 1,491 })492 }493}494495impl pallet_transaction_payment::Config for Runtime {496 type OnChargeTransaction = pallet_transaction_payment::CurrencyAdapter<Balances, DealWithFees>;497 type LengthToFee = ConstantMultiplier<Balance, TransactionByteFee>;498 type OperationalFeeMultiplier = OperationalFeeMultiplier;499 type WeightToFee = LinearFee<Balance>;500 type FeeMultiplierUpdate = ();501}502503parameter_types! {504 pub const ProposalBond: Permill = Permill::from_percent(5);505 pub const ProposalBondMinimum: Balance = 1 * UNIQUE;506 pub const ProposalBondMaximum: Balance = 1000 * UNIQUE;507 pub const SpendPeriod: BlockNumber = 5 * MINUTES;508 pub const Burn: Permill = Permill::from_percent(0);509 pub const TipCountdown: BlockNumber = 1 * DAYS;510 pub const TipFindersFee: Percent = Percent::from_percent(20);511 pub const TipReportDepositBase: Balance = 1 * UNIQUE;512 pub const DataDepositPerByte: Balance = 1 * CENTIUNIQUE;513 pub const BountyDepositBase: Balance = 1 * UNIQUE;514 pub const BountyDepositPayoutDelay: BlockNumber = 1 * DAYS;515 pub const TreasuryModuleId: PalletId = PalletId(*b"py/trsry");516 pub const BountyUpdatePeriod: BlockNumber = 14 * DAYS;517 pub const MaximumReasonLength: u32 = 16384;518 pub const BountyCuratorDeposit: Permill = Permill::from_percent(50);519 pub const BountyValueMinimum: Balance = 5 * UNIQUE;520 pub const MaxApprovals: u32 = 100;521}522523impl pallet_treasury::Config for Runtime {524 type PalletId = TreasuryModuleId;525 type Currency = Balances;526 type ApproveOrigin = EnsureRoot<AccountId>;527 type RejectOrigin = EnsureRoot<AccountId>;528 type Event = Event;529 type OnSlash = ();530 type ProposalBond = ProposalBond;531 type ProposalBondMinimum = ProposalBondMinimum;532 type ProposalBondMaximum = ProposalBondMaximum;533 type SpendPeriod = SpendPeriod;534 type Burn = Burn;535 type BurnDestination = ();536 type SpendFunds = ();537 type WeightInfo = pallet_treasury::weights::SubstrateWeight<Self>;538 type MaxApprovals = MaxApprovals;539}540541impl pallet_sudo::Config for Runtime {542 type Event = Event;543 type Call = Call;544}545546pub struct RelayChainBlockNumberProvider<T>(sp_std::marker::PhantomData<T>);547548impl<T: cumulus_pallet_parachain_system::Config> BlockNumberProvider549 for RelayChainBlockNumberProvider<T>550{551 type BlockNumber = BlockNumber;552553 fn current_block_number() -> Self::BlockNumber {554 cumulus_pallet_parachain_system::Pallet::<T>::validation_data()555 .map(|d| d.relay_parent_number)556 .unwrap_or_default()557 }558}559560parameter_types! {561 pub const MinVestedTransfer: Balance = 10 * UNIQUE;562 pub const MaxVestingSchedules: u32 = 28;563}564565impl orml_vesting::Config for Runtime {566 type Event = Event;567 type Currency = pallet_balances::Pallet<Runtime>;568 type MinVestedTransfer = MinVestedTransfer;569 type VestedTransferOrigin = EnsureSigned<AccountId>;570 type WeightInfo = ();571 type MaxVestingSchedules = MaxVestingSchedules;572 type BlockNumberProvider = RelayChainBlockNumberProvider<Runtime>;573}574575parameter_types! {576 pub const ReservedDmpWeight: Weight = MAXIMUM_BLOCK_WEIGHT / 4;577 pub const ReservedXcmpWeight: Weight = MAXIMUM_BLOCK_WEIGHT / 4;578}579580impl cumulus_pallet_parachain_system::Config for Runtime {581 type Event = Event;582 type SelfParaId = parachain_info::Pallet<Self>;583 type OnSystemEvent = ();584 // type DownwardMessageHandlers = cumulus_primitives_utility::UnqueuedDmpAsParent<585 // MaxDownwardMessageWeight,586 // XcmExecutor<XcmConfig>,587 // Call,588 // >;589 type OutboundXcmpMessageSource = XcmpQueue;590 type DmpMessageHandler = DmpQueue;591 type ReservedDmpWeight = ReservedDmpWeight;592 type ReservedXcmpWeight = ReservedXcmpWeight;593 type XcmpMessageHandler = XcmpQueue;594}595596impl parachain_info::Config for Runtime {}597598impl cumulus_pallet_aura_ext::Config for Runtime {}599600parameter_types! {601 pub const RelayLocation: MultiLocation = MultiLocation::parent();602 pub const RelayNetwork: NetworkId = NetworkId::Polkadot;603 pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();604 pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();605}606607/// Type for specifying how a `MultiLocation` can be converted into an `AccountId`. This is used608/// when determining ownership of accounts for asset transacting and when attempting to use XCM609/// `Transact` in order to determine the dispatch Origin.610pub type LocationToAccountId = (611 // The parent (Relay-chain) origin converts to the default `AccountId`.612 ParentIsPreset<AccountId>,613 // Sibling parachain origins convert to AccountId via the `ParaId::into`.614 SiblingParachainConvertsVia<Sibling, AccountId>,615 // Straight up local `AccountId32` origins just alias directly to `AccountId`.616 AccountId32Aliases<RelayNetwork, AccountId>,617);618619pub struct OnlySelfCurrency;620impl<B: TryFrom<u128>> MatchesFungible<B> for OnlySelfCurrency {621 fn matches_fungible(a: &MultiAsset) -> Option<B> {622 match (&a.id, &a.fun) {623 (Concrete(_), XcmFungible(ref amount)) => CheckedConversion::checked_from(*amount),624 _ => None,625 }626 }627}628629/// Means for transacting assets on this chain.630pub type LocalAssetTransactor = CurrencyAdapter<631 // Use this currency:632 Balances,633 // Use this currency when it is a fungible asset matching the given location or name:634 OnlySelfCurrency,635 // Do a simple punn to convert an AccountId32 MultiLocation into a native chain account ID:636 LocationToAccountId,637 // Our chain's account ID type (we can't get away without mentioning it explicitly):638 AccountId,639 // We don't track any teleports.640 (),641>;642643/// This is the type we use to convert an (incoming) XCM origin into a local `Origin` instance,644/// ready for dispatching a transaction with Xcm's `Transact`. There is an `OriginKind` which can645/// biases the kind of local `Origin` it will become.646pub type XcmOriginToTransactDispatchOrigin = (647 // Sovereign account converter; this attempts to derive an `AccountId` from the origin location648 // using `LocationToAccountId` and then turn that into the usual `Signed` origin. Useful for649 // foreign chains who want to have a local sovereign account on this chain which they control.650 SovereignSignedViaLocation<LocationToAccountId, Origin>,651 // Native converter for Relay-chain (Parent) location; will converts to a `Relay` origin when652 // recognised.653 RelayChainAsNative<RelayOrigin, Origin>,654 // Native converter for sibling Parachains; will convert to a `SiblingPara` origin when655 // recognised.656 SiblingParachainAsNative<cumulus_pallet_xcm::Origin, Origin>,657 // Superuser converter for the Relay-chain (Parent) location. This will allow it to issue a658 // transaction from the Root origin.659 ParentAsSuperuser<Origin>,660 // Native signed account converter; this just converts an `AccountId32` origin into a normal661 // `Origin::Signed` origin of the same 32-byte value.662 SignedAccountId32AsNative<RelayNetwork, Origin>,663 // Xcm origins can be represented natively under the Xcm pallet's Xcm origin.664 XcmPassthrough<Origin>,665);666667parameter_types! {668 // One XCM operation is 1_000_000 weight - almost certainly a conservative estimate.669 pub UnitWeightCost: Weight = 1_000_000;670 // 1200 UNIQUEs buy 1 second of weight.671 pub const WeightPrice: (MultiLocation, u128) = (MultiLocation::parent(), 1_200 * UNIQUE);672 pub const MaxInstructions: u32 = 100;673 pub const MaxAuthorities: u32 = 100_000;674}675676match_types! {677 pub type ParentOrParentsUnitPlurality: impl Contains<MultiLocation> = {678 MultiLocation { parents: 1, interior: Here } |679 MultiLocation { parents: 1, interior: X1(Plurality { id: BodyId::Unit, .. }) }680 };681}682683pub type Barrier = (684 TakeWeightCredit,685 AllowTopLevelPaidExecutionFrom<Everything>,686 AllowUnpaidExecutionFrom<ParentOrParentsUnitPlurality>,687 // ^^^ Parent & its unit plurality gets free execution688);689690pub struct UsingOnlySelfCurrencyComponents<691 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,692 AssetId: Get<MultiLocation>,693 AccountId,694 Currency: CurrencyT<AccountId>,695 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,696>(697 Weight,698 Currency::Balance,699 PhantomData<(WeightToFee, AssetId, AccountId, Currency, OnUnbalanced)>,700);701impl<702 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,703 AssetId: Get<MultiLocation>,704 AccountId,705 Currency: CurrencyT<AccountId>,706 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,707 > WeightTrader708 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>709{710 fn new() -> Self {711 Self(0, Zero::zero(), PhantomData)712 }713714 fn buy_weight(&mut self, weight: Weight, payment: Assets) -> Result<Assets, XcmError> {715 let amount = WeightToFee::calc(&weight);716 let u128_amount: u128 = amount.try_into().map_err(|_| XcmError::Overflow)?;717718 // location to this parachain through relay chain719 let option1: xcm::v1::AssetId = Concrete(MultiLocation {720 parents: 1,721 interior: X1(Parachain(ParachainInfo::parachain_id().into())),722 });723 // direct location724 let option2: xcm::v1::AssetId = Concrete(MultiLocation {725 parents: 0,726 interior: Here,727 });728729 let required = if payment.fungible.contains_key(&option1) {730 (option1, u128_amount).into()731 } else if payment.fungible.contains_key(&option2) {732 (option2, u128_amount).into()733 } else {734 (Concrete(MultiLocation::default()), u128_amount).into()735 };736737 let unused = payment738 .checked_sub(required)739 .map_err(|_| XcmError::TooExpensive)?;740 self.0 = self.0.saturating_add(weight);741 self.1 = self.1.saturating_add(amount);742 Ok(unused)743 }744745 fn refund_weight(&mut self, weight: Weight) -> Option<MultiAsset> {746 let weight = weight.min(self.0);747 let amount = WeightToFee::calc(&weight);748 self.0 -= weight;749 self.1 = self.1.saturating_sub(amount);750 let amount: u128 = amount.saturated_into();751 if amount > 0 {752 Some((AssetId::get(), amount).into())753 } else {754 None755 }756 }757}758impl<759 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,760 AssetId: Get<MultiLocation>,761 AccountId,762 Currency: CurrencyT<AccountId>,763 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,764 > Drop765 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>766{767 fn drop(&mut self) {768 OnUnbalanced::on_unbalanced(Currency::issue(self.1));769 }770}771772pub struct XcmConfig;773impl Config for XcmConfig {774 type Call = Call;775 type XcmSender = XcmRouter;776 // How to withdraw and deposit an asset.777 type AssetTransactor = LocalAssetTransactor;778 type OriginConverter = XcmOriginToTransactDispatchOrigin;779 type IsReserve = NativeAsset;780 type IsTeleporter = (); // Teleportation is disabled781 type LocationInverter = LocationInverter<Ancestry>;782 type Barrier = Barrier;783 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;784 type Trader = UsingOnlySelfCurrencyComponents<785 IdentityFee<Balance>,786 RelayLocation,787 AccountId,788 Balances,789 (),790 >;791 type ResponseHandler = (); // Don't handle responses for now.792 type SubscriptionService = PolkadotXcm;793794 type AssetTrap = PolkadotXcm;795 type AssetClaims = PolkadotXcm;796}797798// parameter_types! {799// pub const MaxDownwardMessageWeight: Weight = MAXIMUM_BLOCK_WEIGHT / 10;800// }801802/// No local origins on this chain are allowed to dispatch XCM sends/executions.803pub type LocalOriginToLocation = (SignedToAccountId32<Origin, AccountId, RelayNetwork>,);804805/// The means for routing XCM messages which are not for local execution into the right message806/// queues.807pub type XcmRouter = (808 // Two routers - use UMP to communicate with the relay chain:809 cumulus_primitives_utility::ParentAsUmp<ParachainSystem, ()>,810 // ..and XCMP to communicate with the sibling chains.811 XcmpQueue,812);813814impl pallet_evm_coder_substrate::Config for Runtime {}815816impl pallet_xcm::Config for Runtime {817 type Event = Event;818 type SendXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;819 type XcmRouter = XcmRouter;820 type ExecuteXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;821 type XcmExecuteFilter = Everything;822 type XcmExecutor = XcmExecutor<XcmConfig>;823 type XcmTeleportFilter = Everything;824 type XcmReserveTransferFilter = Everything;825 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;826 type LocationInverter = LocationInverter<Ancestry>;827 type Origin = Origin;828 type Call = Call;829 const VERSION_DISCOVERY_QUEUE_SIZE: u32 = 100;830 type AdvertisedXcmVersion = pallet_xcm::CurrentXcmVersion;831}832833impl cumulus_pallet_xcm::Config for Runtime {834 type Event = Event;835 type XcmExecutor = XcmExecutor<XcmConfig>;836}837838impl cumulus_pallet_xcmp_queue::Config for Runtime {839 type WeightInfo = ();840 type Event = Event;841 type XcmExecutor = XcmExecutor<XcmConfig>;842 type ChannelInfo = ParachainSystem;843 type VersionWrapper = ();844 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;845 type ControllerOrigin = EnsureRoot<AccountId>;846 type ControllerOriginConverter = XcmOriginToTransactDispatchOrigin;847}848849impl cumulus_pallet_dmp_queue::Config for Runtime {850 type Event = Event;851 type XcmExecutor = XcmExecutor<XcmConfig>;852 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;853}854855impl pallet_aura::Config for Runtime {856 type AuthorityId = AuraId;857 type DisabledValidators = ();858 type MaxAuthorities = MaxAuthorities;859}860861parameter_types! {862 pub TreasuryAccountId: AccountId = TreasuryModuleId::get().into_account();863 pub const CollectionCreationPrice: Balance = 2 * UNIQUE;864}865866impl pallet_common::Config for Runtime {867 type WeightInfo = pallet_common::weights::SubstrateWeight<Self>;868 type Event = Event;869 type Currency = Balances;870 type CollectionCreationPrice = CollectionCreationPrice;871 type TreasuryAccountId = TreasuryAccountId;872 type CollectionDispatch = CollectionDispatchT<Self>;873874 type EvmTokenAddressMapping = EvmTokenAddressMapping;875 type CrossTokenAddressMapping = CrossTokenAddressMapping<Self::AccountId>;876 type ContractAddress = EvmCollectionHelpersAddress;877}878879impl pallet_structure::Config for Runtime {880 type Event = Event;881 type Call = Call;882 type WeightInfo = pallet_structure::weights::SubstrateWeight<Self>;883}884885impl pallet_evm::account::Config for Runtime {886 type CrossAccountId = pallet_evm::account::BasicCrossAccountId<Self>;887 type EvmAddressMapping = HashedAddressMapping<Self::Hashing>;888 type EvmBackwardsAddressMapping = fp_evm_mapping::MapBackwardsAddressTruncated;889}890891impl pallet_fungible::Config for Runtime {892 type WeightInfo = pallet_fungible::weights::SubstrateWeight<Self>;893}894impl pallet_refungible::Config for Runtime {895 type WeightInfo = pallet_refungible::weights::SubstrateWeight<Self>;896}897impl pallet_nonfungible::Config for Runtime {898 type WeightInfo = pallet_nonfungible::weights::SubstrateWeight<Self>;899}900/* TODO free RMRK!901impl pallet_proxy_rmrk_core::Config for Runtime {902 type Event = Event;903}904905impl pallet_proxy_rmrk_equip::Config for Runtime {906 type Event = Event;907}*/908909impl pallet_unique::Config for Runtime {910 type Event = Event;911 type WeightInfo = pallet_unique::weights::SubstrateWeight<Self>;912 type CommonWeightInfo = CommonWeights<Self>;913}914915parameter_types! {916 pub const InflationBlockInterval: BlockNumber = 100; // every time per how many blocks inflation is applied917}918919/// Used for the pallet inflation920impl pallet_inflation::Config for Runtime {921 type Currency = Balances;922 type TreasuryAccountId = TreasuryAccountId;923 type InflationBlockInterval = InflationBlockInterval;924 type BlockNumberProvider = RelayChainBlockNumberProvider<Runtime>;925}926927parameter_types! {928 pub MaximumSchedulerWeight: Weight = Perbill::from_percent(50) *929 RuntimeBlockWeights::get().max_block;930 pub const MaxScheduledPerBlock: u32 = 50;931}932933parameter_types! {934 pub const NoPreimagePostponement: Option<u32> = Some(10);935 pub const Preimage: Option<u32> = Some(10);936}937938/// Used the compare the privilege of an origin inside the scheduler.939pub struct OriginPrivilegeCmp;940impl PrivilegeCmp<OriginCaller> for OriginPrivilegeCmp {941 fn cmp_privilege(_left: &OriginCaller, _right: &OriginCaller) -> Option<Ordering> {942 Some(Ordering::Equal)943 }944}945946impl pallet_unq_scheduler::Config for Runtime {947 type Event = Event;948 type Origin = Origin;949 type Currency = Balances;950 type PalletsOrigin = OriginCaller;951 type Call = Call;952 type MaximumWeight = MaximumSchedulerWeight;953 type ScheduleOrigin = EnsureSigned<AccountId>;954 type MaxScheduledPerBlock = MaxScheduledPerBlock;955 type WeightInfo = ();956 type CallExecutor = SchedulerPaymentExecutor;957 type OriginPrivilegeCmp = OriginPrivilegeCmp;958 type PreimageProvider = ();959 type NoPreimagePostponement = NoPreimagePostponement;960}961962type ChargeTransactionPayment = pallet_charge_transaction::ChargeTransactionPayment<Runtime>;963use frame_support::traits::NamedReservableCurrency;964965fn get_signed_extras(from: <Runtime as frame_system::Config>::AccountId) -> SignedExtraScheduler {966 (967 frame_system::CheckSpecVersion::<Runtime>::new(),968 frame_system::CheckGenesis::<Runtime>::new(),969 frame_system::CheckEra::<Runtime>::from(Era::Immortal),970 frame_system::CheckNonce::<Runtime>::from(frame_system::Pallet::<Runtime>::account_nonce(971 from,972 )),973 frame_system::CheckWeight::<Runtime>::new(),974 // sponsoring transaction logic975 // pallet_charge_transaction::ChargeTransactionPayment::<Runtime>::new(0),976 )977}978979pub struct SchedulerPaymentExecutor;980impl<T: frame_system::Config + pallet_unq_scheduler::Config, SelfContainedSignedInfo>981 DispatchCall<T, SelfContainedSignedInfo> for SchedulerPaymentExecutor982where983 <T as frame_system::Config>::Call: Member984 + Dispatchable<Origin = Origin, Info = DispatchInfo>985 + SelfContainedCall<SignedInfo = SelfContainedSignedInfo>986 + GetDispatchInfo987 + From<frame_system::Call<Runtime>>,988 SelfContainedSignedInfo: Send + Sync + 'static,989 Call: From<<T as frame_system::Config>::Call>990 + From<<T as pallet_unq_scheduler::Config>::Call>991 + SelfContainedCall<SignedInfo = SelfContainedSignedInfo>,992 sp_runtime::AccountId32: From<<T as frame_system::Config>::AccountId>,993{994 fn dispatch_call(995 signer: <T as frame_system::Config>::AccountId,996 call: <T as pallet_unq_scheduler::Config>::Call,997 ) -> Result<998 Result<PostDispatchInfo, DispatchErrorWithPostInfo<PostDispatchInfo>>,999 TransactionValidityError,1000 > {1001 let dispatch_info = call.get_dispatch_info();1002 let extrinsic = fp_self_contained::CheckedExtrinsic::<1003 AccountId,1004 Call,1005 SignedExtraScheduler,1006 SelfContainedSignedInfo,1007 > {1008 signed:1009 CheckedSignature::<AccountId, SignedExtraScheduler, SelfContainedSignedInfo>::Signed(1010 signer.clone().into(),1011 get_signed_extras(signer.into()),1012 ),1013 function: call.into(),1014 };10151016 extrinsic.apply::<Runtime>(&dispatch_info, 0)1017 }10181019 fn reserve_balance(1020 id: [u8; 16],1021 sponsor: <T as frame_system::Config>::AccountId,1022 call: <T as pallet_unq_scheduler::Config>::Call,1023 count: u32,1024 ) -> Result<(), DispatchError> {1025 let dispatch_info = call.get_dispatch_info();1026 let weight: Balance = ChargeTransactionPayment::traditional_fee(0, &dispatch_info, 0)1027 .saturating_mul(count.into());10281029 <Balances as NamedReservableCurrency<AccountId>>::reserve_named(1030 &id,1031 &(sponsor.into()),1032 weight.into(),1033 )1034 }10351036 fn pay_for_call(1037 id: [u8; 16],1038 sponsor: <T as frame_system::Config>::AccountId,1039 call: <T as pallet_unq_scheduler::Config>::Call,1040 ) -> Result<u128, DispatchError> {1041 let dispatch_info = call.get_dispatch_info();1042 let weight: Balance = ChargeTransactionPayment::traditional_fee(0, &dispatch_info, 0);1043 Ok(1044 <Balances as NamedReservableCurrency<AccountId>>::unreserve_named(1045 &id,1046 &(sponsor.into()),1047 weight.into(),1048 ),1049 )1050 }10511052 fn cancel_reserve(1053 id: [u8; 16],1054 sponsor: <T as frame_system::Config>::AccountId,1055 ) -> Result<u128, DispatchError> {1056 Ok(1057 <Balances as NamedReservableCurrency<AccountId>>::unreserve_named(1058 &id,1059 &(sponsor.into()),1060 u128::MAX,1061 ),1062 )1063 }1064}10651066type EvmSponsorshipHandler = (1067 UniqueEthSponsorshipHandler<Runtime>,1068 pallet_evm_contract_helpers::HelpersContractSponsoring<Runtime>,1069);1070type SponsorshipHandler = (1071 UniqueSponsorshipHandler<Runtime>,1072 //pallet_contract_helpers::ContractSponsorshipHandler<Runtime>,1073 pallet_evm_transaction_payment::BridgeSponsorshipHandler<Runtime>,1074);10751076impl pallet_evm_transaction_payment::Config for Runtime {1077 type EvmSponsorshipHandler = EvmSponsorshipHandler;1078 type Currency = Balances;1079}10801081impl pallet_charge_transaction::Config for Runtime {1082 type SponsorshipHandler = SponsorshipHandler;1083}10841085// impl pallet_contract_helpers::Config for Runtime {1086// type DefaultSponsoringRateLimit = DefaultSponsoringRateLimit;1087// }10881089parameter_types! {1090 // 0x842899ECF380553E8a4de75bF534cdf6fBF640491091 pub const HelpersContractAddress: H160 = H160([1092 0x84, 0x28, 0x99, 0xec, 0xf3, 0x80, 0x55, 0x3e, 0x8a, 0x4d, 0xe7, 0x5b, 0xf5, 0x34, 0xcd, 0xf6, 0xfb, 0xf6, 0x40, 0x49,1093 ]);1094 1095 // 0x6c4e9fe1ae37a41e93cee429e8e1881abdcbb54f1096 pub const EvmCollectionHelpersAddress: H160 = H160([1097 0x6c, 0x4e, 0x9f, 0xe1, 0xae, 0x37, 0xa4, 0x1e, 0x93, 0xce, 0xe4, 0x29, 0xe8, 0xe1, 0x88, 0x1a, 0xbd, 0xcb, 0xb5, 0x4f,1098 ]);1099}11001101impl pallet_evm_contract_helpers::Config for Runtime {1102 type ContractAddress = HelpersContractAddress;1103 type DefaultSponsoringRateLimit = DefaultSponsoringRateLimit;1104}11051106construct_runtime!(1107 pub enum Runtime where1108 Block = Block,1109 NodeBlock = opaque::Block,1110 UncheckedExtrinsic = UncheckedExtrinsic1111 {1112 ParachainSystem: cumulus_pallet_parachain_system::{Pallet, Call, Config, Storage, Inherent, Event<T>, ValidateUnsigned} = 20,1113 ParachainInfo: parachain_info::{Pallet, Storage, Config} = 21,11141115 Aura: pallet_aura::{Pallet, Config<T>} = 22,1116 AuraExt: cumulus_pallet_aura_ext::{Pallet, Config} = 23,11171118 Balances: pallet_balances::{Pallet, Call, Storage, Config<T>, Event<T>} = 30,1119 RandomnessCollectiveFlip: pallet_randomness_collective_flip::{Pallet, Storage} = 31,1120 Timestamp: pallet_timestamp::{Pallet, Call, Storage, Inherent} = 32,1121 TransactionPayment: pallet_transaction_payment::{Pallet, Storage} = 33,1122 Treasury: pallet_treasury::{Pallet, Call, Storage, Config, Event<T>} = 34,1123 Sudo: pallet_sudo::{Pallet, Call, Storage, Config<T>, Event<T>} = 35,1124 System: frame_system::{Pallet, Call, Storage, Config, Event<T>} = 36,1125 Vesting: orml_vesting::{Pallet, Storage, Call, Event<T>, Config<T>} = 37,1126 // Vesting: pallet_vesting::{Pallet, Call, Config<T>, Storage, Event<T>} = 37,1127 // Contracts: pallet_contracts::{Pallet, Call, Storage, Event<T>} = 38,11281129 // XCM helpers.1130 XcmpQueue: cumulus_pallet_xcmp_queue::{Pallet, Call, Storage, Event<T>} = 50,1131 PolkadotXcm: pallet_xcm::{Pallet, Call, Event<T>, Origin} = 51,1132 CumulusXcm: cumulus_pallet_xcm::{Pallet, Call, Event<T>, Origin} = 52,1133 DmpQueue: cumulus_pallet_dmp_queue::{Pallet, Call, Storage, Event<T>} = 53,11341135 // Unique Pallets1136 Inflation: pallet_inflation::{Pallet, Call, Storage} = 60,1137 Unique: pallet_unique::{Pallet, Call, Storage, Event<T>} = 61,1138 Scheduler: pallet_unq_scheduler::{Pallet, Call, Storage, Event<T>} = 62,1139 // free = 631140 Charging: pallet_charge_transaction::{Pallet, Call, Storage } = 64,1141 // ContractHelpers: pallet_contract_helpers::{Pallet, Call, Storage} = 65,1142 Common: pallet_common::{Pallet, Storage, Event<T>} = 66,1143 Fungible: pallet_fungible::{Pallet, Storage} = 67,1144 Refungible: pallet_refungible::{Pallet, Storage} = 68,1145 Nonfungible: pallet_nonfungible::{Pallet, Storage} = 69,1146 Structure: pallet_structure::{Pallet, Call, Storage, Event<T>} = 70,1147 /* TODO free RMRK!1148 RmrkCore: pallet_proxy_rmrk_core::{Pallet, Call, Storage, Event<T>} = 71,1149 RmrkEquip: pallet_proxy_rmrk_equip::{Pallet, Call, Storage, Event<T>} = 72,*/11501151 // Frontier1152 EVM: pallet_evm::{Pallet, Config, Call, Storage, Event<T>} = 100,1153 Ethereum: pallet_ethereum::{Pallet, Config, Call, Storage, Event, Origin} = 101,11541155 EvmCoderSubstrate: pallet_evm_coder_substrate::{Pallet, Storage} = 150,1156 EvmContractHelpers: pallet_evm_contract_helpers::{Pallet, Storage} = 151,1157 EvmTransactionPayment: pallet_evm_transaction_payment::{Pallet} = 152,1158 EvmMigration: pallet_evm_migration::{Pallet, Call, Storage} = 153,1159 }1160);11611162pub struct TransactionConverter;11631164impl fp_rpc::ConvertTransaction<UncheckedExtrinsic> for TransactionConverter {1165 fn convert_transaction(&self, transaction: pallet_ethereum::Transaction) -> UncheckedExtrinsic {1166 UncheckedExtrinsic::new_unsigned(1167 pallet_ethereum::Call::<Runtime>::transact { transaction }.into(),1168 )1169 }1170}11711172impl fp_rpc::ConvertTransaction<opaque::UncheckedExtrinsic> for TransactionConverter {1173 fn convert_transaction(1174 &self,1175 transaction: pallet_ethereum::Transaction,1176 ) -> opaque::UncheckedExtrinsic {1177 let extrinsic = UncheckedExtrinsic::new_unsigned(1178 pallet_ethereum::Call::<Runtime>::transact { transaction }.into(),1179 );1180 let encoded = extrinsic.encode();1181 opaque::UncheckedExtrinsic::decode(&mut &encoded[..])1182 .expect("Encoded extrinsic is always valid")1183 }1184}11851186/// The address format for describing accounts.1187pub type Address = sp_runtime::MultiAddress<AccountId, ()>;1188/// Block header type as expected by this runtime.1189pub type Header = generic::Header<BlockNumber, BlakeTwo256>;1190/// Block type as expected by this runtime.1191pub type Block = generic::Block<Header, UncheckedExtrinsic>;1192/// A Block signed with a Justification1193pub type SignedBlock = generic::SignedBlock<Block>;1194/// BlockId type as expected by this runtime.1195pub type BlockId = generic::BlockId<Block>;1196/// The SignedExtension to the basic transaction logic.1197pub type SignedExtra = (1198 frame_system::CheckSpecVersion<Runtime>,1199 // system::CheckTxVersion<Runtime>,1200 frame_system::CheckGenesis<Runtime>,1201 frame_system::CheckEra<Runtime>,1202 frame_system::CheckNonce<Runtime>,1203 frame_system::CheckWeight<Runtime>,1204 pallet_charge_transaction::ChargeTransactionPayment<Runtime>,1205 //pallet_contract_helpers::ContractHelpersExtension<Runtime>,1206 pallet_ethereum::FakeTransactionFinalizer<Runtime>,1207);1208pub type SignedExtraScheduler = (1209 frame_system::CheckSpecVersion<Runtime>,1210 frame_system::CheckGenesis<Runtime>,1211 frame_system::CheckEra<Runtime>,1212 frame_system::CheckNonce<Runtime>,1213 frame_system::CheckWeight<Runtime>,1214 // pallet_charge_transaction::ChargeTransactionPayment<Runtime>,1215);1216/// Unchecked extrinsic type as expected by this runtime.1217pub type UncheckedExtrinsic =1218 fp_self_contained::UncheckedExtrinsic<Address, Call, Signature, SignedExtra>;1219/// Extrinsic type that has already been checked.1220pub type CheckedExtrinsic = fp_self_contained::CheckedExtrinsic<AccountId, Call, SignedExtra, H160>;1221/// Executive: handles dispatch to the various modules.1222pub type Executive = frame_executive::Executive<1223 Runtime,1224 Block,1225 frame_system::ChainContext<Runtime>,1226 Runtime,1227 AllPalletsReversedWithSystemFirst,1228>;12291230impl_opaque_keys! {1231 pub struct SessionKeys {1232 pub aura: Aura,1233 }1234}12351236impl fp_self_contained::SelfContainedCall for Call {1237 type SignedInfo = H160;12381239 fn is_self_contained(&self) -> bool {1240 match self {1241 Call::Ethereum(call) => call.is_self_contained(),1242 _ => false,1243 }1244 }12451246 fn check_self_contained(&self) -> Option<Result<Self::SignedInfo, TransactionValidityError>> {1247 match self {1248 Call::Ethereum(call) => call.check_self_contained(),1249 _ => None,1250 }1251 }12521253 fn validate_self_contained(&self, info: &Self::SignedInfo) -> Option<TransactionValidity> {1254 match self {1255 Call::Ethereum(call) => call.validate_self_contained(info),1256 _ => None,1257 }1258 }12591260 fn pre_dispatch_self_contained(1261 &self,1262 info: &Self::SignedInfo,1263 ) -> Option<Result<(), TransactionValidityError>> {1264 match self {1265 Call::Ethereum(call) => call.pre_dispatch_self_contained(info),1266 _ => None,1267 }1268 }12691270 fn apply_self_contained(1271 self,1272 info: Self::SignedInfo,1273 ) -> Option<sp_runtime::DispatchResultWithInfo<PostDispatchInfoOf<Self>>> {1274 match self {1275 call @ Call::Ethereum(pallet_ethereum::Call::transact { .. }) => Some(call.dispatch(1276 Origin::from(pallet_ethereum::RawOrigin::EthereumTransaction(info)),1277 )),1278 _ => None,1279 }1280 }1281}12821283macro_rules! dispatch_unique_runtime {1284 ($collection:ident.$method:ident($($name:ident),*)) => {{1285 let collection = <Runtime as pallet_common::Config>::CollectionDispatch::dispatch(<pallet_common::CollectionHandle<Runtime>>::try_get($collection)?);1286 let dispatch = collection.as_dyn();12871288 Ok::<_, DispatchError>(dispatch.$method($($name),*))1289 }};1290}12911292impl_common_runtime_apis!();12931294struct CheckInherents;12951296impl cumulus_pallet_parachain_system::CheckInherents<Block> for CheckInherents {1297 fn check_inherents(1298 block: &Block,1299 relay_state_proof: &cumulus_pallet_parachain_system::RelayChainStateProof,1300 ) -> sp_inherents::CheckInherentsResult {1301 let relay_chain_slot = relay_state_proof1302 .read_slot()1303 .expect("Could not read the relay chain slot from the proof");13041305 let inherent_data =1306 cumulus_primitives_timestamp::InherentDataProvider::from_relay_chain_slot_and_duration(1307 relay_chain_slot,1308 sp_std::time::Duration::from_secs(6),1309 )1310 .create_inherent_data()1311 .expect("Could not create the timestamp inherent data");13121313 inherent_data.check_extrinsics(block)1314 }1315}13161317cumulus_pallet_parachain_system::register_validate_block!(1318 Runtime = Runtime,1319 BlockExecutor = cumulus_pallet_aura_ext::BlockExecutor::<Runtime, Executive>,1320 CheckInherents = CheckInherents,1321);tests/package.jsondiffbeforeafterboth--- a/tests/package.json
+++ b/tests/package.json
@@ -68,6 +68,8 @@
"testOverflow": "mocha --timeout 9999999 -r ts-node/register ./**/overflow.test.ts",
"testSetVariableMetadataSponsoringRateLimit": "mocha --timeout 9999999 -r ts-node/register ./**/setVariableMetadataSponsoringRateLimit.test.ts",
"testInflation": "mocha --timeout 9999999 -r ts-node/register ./**/inflation.test.ts",
+ "testScheduler": "mocha --timeout 9999999 -r ts-node/register ./**/scheduler.test.ts",
+ "testSchedulingEVM": "mocha --timeout 9999999 -r ts-node/register ./**/eth/scheduling.test.ts",
"testXcmTransfer": "mocha --timeout 9999999 -r ts-node/register ./**/xcmTransfer.test.ts",
"testPalletPresence": "mocha --timeout 9999999 -r ts-node/register ./**/pallet-presence.test.ts",
"testBlockProduction": "mocha --timeout 9999999 -r ts-node/register ./**/block-production.test.ts",
tests/src/eth/scheduling.test.tsdiffbeforeafterboth--- /dev/null
+++ b/tests/src/eth/scheduling.test.ts
@@ -0,0 +1,55 @@
+// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.
+// This file is part of Unique Network.
+
+// Unique Network is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+
+// Unique Network is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+
+// You should have received a copy of the GNU General Public License
+// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
+
+import {expect} from 'chai';
+import {createEthAccountWithBalance, deployFlipper, GAS_ARGS, itWeb3, subToEth, transferBalanceToEth} from './util/helpers';
+import {scheduleExpectSuccess, waitNewBlocks} from '../util/helpers';
+import privateKey from '../substrate/privateKey';
+
+describe('Scheduing EVM smart contracts', () => {
+ itWeb3('Successfully schedules and periodically executes an EVM contract', async ({api, web3}) => {
+ const deployer = await createEthAccountWithBalance(api, web3);
+ const flipper = await deployFlipper(web3, deployer);
+ const initialValue = await flipper.methods.getValue().call();
+ const alice = privateKey('//Alice');
+ await transferBalanceToEth(api, alice, subToEth(alice.address));
+
+ {
+ const tx = api.tx.evm.call(
+ subToEth(alice.address),
+ flipper.options.address,
+ flipper.methods.flip().encodeABI(),
+ '0',
+ GAS_ARGS.gas,
+ await web3.eth.getGasPrice(),
+ null,
+ null,
+ [],
+ );
+ const waitForBlocks = 4;
+ const periodBlocks = 2;
+
+ await scheduleExpectSuccess(tx, alice, waitForBlocks, '0x' + '0'.repeat(32), periodBlocks, 2);
+ expect(await flipper.methods.getValue().call()).to.be.equal(initialValue);
+
+ await waitNewBlocks(waitForBlocks - 1);
+ expect(await flipper.methods.getValue().call()).to.be.not.equal(initialValue);
+
+ await waitNewBlocks(periodBlocks);
+ expect(await flipper.methods.getValue().call()).to.be.equal(initialValue);
+ }
+ });
+});
\ No newline at end of file
tests/src/pallet-presence.test.tsdiffbeforeafterboth--- a/tests/src/pallet-presence.test.ts
+++ b/tests/src/pallet-presence.test.ts
@@ -50,7 +50,7 @@
'unique',
'nonfungible',
'refungible',
- //'scheduler',
+ 'scheduler',
'charging',
];
tests/src/scheduler.test.tsdiffbeforeafterboth--- a/tests/src/scheduler.test.ts
+++ b/tests/src/scheduler.test.ts
@@ -14,32 +14,197 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
-import chai from 'chai';
+import chai, {expect} from 'chai';
import chaiAsPromised from 'chai-as-promised';
import privateKey from './substrate/privateKey';
-import usingApi from './substrate/substrate-api';
import {
+ default as usingApi,
+ submitTransactionAsync,
+} from './substrate/substrate-api';
+import {
createItemExpectSuccess,
createCollectionExpectSuccess,
scheduleTransferExpectSuccess,
+ scheduleTransferAndWaitExpectSuccess,
setCollectionSponsorExpectSuccess,
confirmSponsorshipExpectSuccess,
+ findUnusedAddress,
+ UNIQUE,
+ enablePublicMintingExpectSuccess,
+ addToAllowListExpectSuccess,
+ waitNewBlocks,
+ normalizeAccountId,
+ getTokenOwner,
+ getGenericResult,
+ scheduleTransferFundsPeriodicExpectSuccess,
+ getFreeBalance,
+ confirmSponsorshipByKeyExpectSuccess,
+ scheduleExpectFailure,
} from './util/helpers';
+import {IKeyringPair} from '@polkadot/types/types';
chai.use(chaiAsPromised);
-describe.skip('Integration Test scheduler base transaction', () => {
- it('User can transfer owned token with delay (scheduler)', async () => {
+describe.skip('Scheduling token and balance transfers', () => {
+ let alice: IKeyringPair;
+ let bob: IKeyringPair;
+ let scheduledIdBase: string;
+ let scheduledIdSlider: number;
+
+ before(async() => {
await usingApi(async () => {
- const alice = privateKey('//Alice');
- const bob = privateKey('//Bob');
- // nft
+ alice = privateKey('//Alice');
+ bob = privateKey('//Bob');
+ });
+
+ scheduledIdBase = '0x' + '0'.repeat(31);
+ scheduledIdSlider = 0;
+ });
+
+ // Loop scheduledId around 10. Unless there are concurrent tasks with long periods/repetitions, tests' tasks' ids shouldn't ovelap.
+ function makeScheduledId(): string {
+ return scheduledIdBase + ((scheduledIdSlider++) % 10);
+ }
+
+ it('Can schedule a transfer of an owned token with delay', async () => {
+ await usingApi(async () => {
const nftCollectionId = await createCollectionExpectSuccess();
const newNftTokenId = await createItemExpectSuccess(alice, nftCollectionId, 'NFT');
await setCollectionSponsorExpectSuccess(nftCollectionId, alice.address);
await confirmSponsorshipExpectSuccess(nftCollectionId);
- await scheduleTransferExpectSuccess(nftCollectionId, newNftTokenId, alice, bob, 1, 4);
+ await scheduleTransferAndWaitExpectSuccess(nftCollectionId, newNftTokenId, alice, bob, 1, 4, makeScheduledId());
+ });
+ });
+
+ it('Can transfer funds periodically', async () => {
+ await usingApi(async () => {
+ const waitForBlocks = 4;
+ const period = 2;
+ await scheduleTransferFundsPeriodicExpectSuccess(1n * UNIQUE, alice, bob, waitForBlocks, makeScheduledId(), period, 2);
+ const bobsBalanceBefore = await getFreeBalance(bob);
+
+ // discounting already waited-for operations
+ await waitNewBlocks(waitForBlocks - 2);
+ const bobsBalanceAfterFirst = await getFreeBalance(bob);
+ expect(bobsBalanceAfterFirst > bobsBalanceBefore).to.be.true;
+
+ await waitNewBlocks(period);
+ const bobsBalanceAfterSecond = await getFreeBalance(bob);
+ expect(bobsBalanceAfterSecond > bobsBalanceAfterFirst).to.be.true;
+ });
+ });
+
+ it('Can sponsor scheduling a transaction', async () => {
+ const collectionId = await createCollectionExpectSuccess();
+ await setCollectionSponsorExpectSuccess(collectionId, bob.address);
+ await confirmSponsorshipExpectSuccess(collectionId, '//Bob');
+
+ await usingApi(async () => {
+ const tokenId = await createItemExpectSuccess(alice, collectionId, 'NFT', alice.address);
+
+ const bobBalanceBefore = await getFreeBalance(bob);
+ const waitForBlocks = 4;
+ // no need to wait to check, fees must be deducted on scheduling, immediately
+ await scheduleTransferExpectSuccess(collectionId, tokenId, alice, bob, 0, waitForBlocks, makeScheduledId());
+ const bobBalanceAfter = await getFreeBalance(bob);
+ // expect(aliceBalanceAfter == aliceBalanceBefore).to.be.true;
+ expect(bobBalanceAfter < bobBalanceBefore).to.be.true;
+ // wait for sequentiality matters
+ await waitNewBlocks(waitForBlocks - 1);
+ });
+ });
+
+ it('Schedules and dispatches a transaction even if the caller has no funds at the time of the dispatch', async () => {
+ await usingApi(async (api) => {
+ // Find an empty, unused account
+ const zeroBalance = await findUnusedAddress(api);
+
+ const collectionId = await createCollectionExpectSuccess();
+
+ // Add zeroBalance address to allow list
+ await enablePublicMintingExpectSuccess(alice, collectionId);
+ await addToAllowListExpectSuccess(alice, collectionId, zeroBalance.address);
+
+ // Grace zeroBalance with money, enough to cover future transactions
+ const balanceTx = api.tx.balances.transfer(zeroBalance.address, 1n * UNIQUE);
+ await submitTransactionAsync(alice, balanceTx);
+
+ // Mint a fresh NFT
+ const tokenId = await createItemExpectSuccess(zeroBalance, collectionId, 'NFT');
+
+ // Schedule transfer of the NFT a few blocks ahead
+ const waitForBlocks = 5;
+ await scheduleTransferExpectSuccess(collectionId, tokenId, zeroBalance, alice, 1, waitForBlocks, makeScheduledId());
+
+ // Get rid of the account's funds before the scheduled transaction takes place
+ const balanceTx2 = api.tx.balances.transfer(alice.address, UNIQUE * 68n / 100n);
+ const events = await submitTransactionAsync(zeroBalance, balanceTx2);
+ expect(getGenericResult(events).success).to.be.true;
+ /*const emptyBalanceTx = api.tx.balances.setBalance(zeroBalance.address, 0, 0); // do not null reserved?
+ const sudoTx = api.tx.sudo.sudo(emptyBalanceTx as any);
+ const events = await submitTransactionAsync(alice, sudoTx);
+ expect(getGenericResult(events).success).to.be.true;*/
+
+ // Wait for a certain number of blocks, discarding the ones that already happened while accepting the late transactions
+ await waitNewBlocks(waitForBlocks - 3);
+
+ expect(await getTokenOwner(api, collectionId, tokenId)).to.be.deep.equal(normalizeAccountId(alice.address));
+ });
+ });
+
+ it('Sponsor going bankrupt does not impact a scheduled transaction', async () => {
+ const collectionId = await createCollectionExpectSuccess();
+
+ await usingApi(async (api) => {
+ const zeroBalance = await findUnusedAddress(api);
+ const balanceTx = api.tx.balances.transfer(zeroBalance.address, 1n * UNIQUE);
+ await submitTransactionAsync(alice, balanceTx);
+
+ await setCollectionSponsorExpectSuccess(collectionId, zeroBalance.address);
+ await confirmSponsorshipByKeyExpectSuccess(collectionId, zeroBalance);
+
+ const tokenId = await createItemExpectSuccess(alice, collectionId, 'NFT', alice.address);
+
+ const waitForBlocks = 5;
+ await scheduleTransferExpectSuccess(collectionId, tokenId, alice, zeroBalance, 1, waitForBlocks, makeScheduledId());
+
+ const emptyBalanceSponsorTx = api.tx.balances.setBalance(zeroBalance.address, 0, 0);
+ const sudoTx = api.tx.sudo.sudo(emptyBalanceSponsorTx as any);
+ const events = await submitTransactionAsync(alice, sudoTx);
+ expect(getGenericResult(events).success).to.be.true;
+
+ // Wait for a certain number of blocks, save for the ones that already happened while accepting the late transactions
+ await waitNewBlocks(waitForBlocks - 3);
+
+ expect(await getTokenOwner(api, collectionId, tokenId)).to.be.deep.equal(normalizeAccountId(zeroBalance.address));
+ });
+ });
+
+ it.skip('Exceeding sponsor rate limit without having enough funds prevents scheduling a periodic transaction', async () => {
+ const collectionId = await createCollectionExpectSuccess();
+ await setCollectionSponsorExpectSuccess(collectionId, bob.address);
+ await confirmSponsorshipExpectSuccess(collectionId, '//Bob');
+
+ await usingApi(async (api) => {
+ const zeroBalance = await findUnusedAddress(api);
+
+ await enablePublicMintingExpectSuccess(alice, collectionId);
+ await addToAllowListExpectSuccess(alice, collectionId, zeroBalance.address);
+
+ const bobBalanceBefore = await getFreeBalance(bob);
+
+ const createData = {nft: {const_data: [], variable_data: []}};
+ const creationTx = api.tx.unique.createItem(collectionId, normalizeAccountId(zeroBalance), createData as any);
+
+ /*const badTransaction = async function () {
+ await submitTransactionExpectFailAsync(zeroBalance, zeroToAlice);
+ };
+ await expect(badTransaction()).to.be.rejectedWith('Inability to pay some fees');*/
+
+ await scheduleExpectFailure(creationTx, zeroBalance, 3, makeScheduledId(), 1, 3);
+
+ expect(await getFreeBalance(bob)).to.be.equal(bobBalanceBefore);
});
});
});
tests/src/util/helpers.tsdiffbeforeafterboth--- a/tests/src/util/helpers.ts
+++ b/tests/src/util/helpers.ts
@@ -630,10 +630,16 @@
}
export async function confirmSponsorshipExpectSuccess(collectionId: number, senderSeed = '//Alice') {
+ await usingApi(async () => {
+ const sender = privateKey(senderSeed);
+ await confirmSponsorshipByKeyExpectSuccess(collectionId, sender);
+ });
+}
+
+export async function confirmSponsorshipByKeyExpectSuccess(collectionId: number, sender: IKeyringPair) {
await usingApi(async (api) => {
// Run the transaction
- const sender = privateKey(senderSeed);
const tx = api.tx.unique.confirmSponsorship(collectionId);
const events = await submitTransactionAsync(sender, tx);
const result = getGenericResult(events);
@@ -899,7 +905,7 @@
}
/* eslint no-async-promise-executor: "off" */
-async function getBlockNumber(api: ApiPromise): Promise<number> {
+export async function getBlockNumber(api: ApiPromise): Promise<number> {
return new Promise<number>(async (resolve) => {
const unsubscribe = await api.rpc.chain.subscribeNewHeads((head) => {
unsubscribe();
@@ -935,29 +941,76 @@
}
export async function
-scheduleTransferExpectSuccess(
- collectionId: number,
- tokenId: number,
+scheduleExpectSuccess(
+ operationTx: any,
sender: IKeyringPair,
- recipient: IKeyringPair,
- value: number | bigint = 1,
blockSchedule: number,
+ scheduledId: string,
+ period = 1,
+ repetitions = 1,
) {
await usingApi(async (api: ApiPromise) => {
const blockNumber: number | undefined = await getBlockNumber(api);
const expectedBlockNumber = blockNumber + blockSchedule;
expect(blockNumber).to.be.greaterThan(0);
- const transferTx = api.tx.unique.transfer(normalizeAccountId(recipient.address), collectionId, tokenId, value);
- const scheduleTx = api.tx.scheduler.schedule(expectedBlockNumber, null, 0, transferTx as any);
+ const scheduleTx = api.tx.scheduler.scheduleNamed( // schedule
+ scheduledId,
+ expectedBlockNumber,
+ repetitions > 1 ? [period, repetitions] : null,
+ 0,
+ {value: operationTx as any},
+ );
+
+ const events = await submitTransactionAsync(sender, scheduleTx);
+ expect(getGenericResult(events).success).to.be.true;
+ });
+}
+
+export async function
+scheduleExpectFailure(
+ operationTx: any,
+ sender: IKeyringPair,
+ blockSchedule: number,
+ scheduledId: string,
+ period = 1,
+ repetitions = 1,
+) {
+ await usingApi(async (api: ApiPromise) => {
+ const blockNumber: number | undefined = await getBlockNumber(api);
+ const expectedBlockNumber = blockNumber + blockSchedule;
+
+ expect(blockNumber).to.be.greaterThan(0);
+ const scheduleTx = api.tx.scheduler.scheduleNamed( // schedule
+ scheduledId,
+ expectedBlockNumber,
+ repetitions <= 1 ? null : [period, repetitions],
+ 0,
+ {value: operationTx as any},
+ );
+
+ //const events =
+ await expect(submitTransactionExpectFailAsync(sender, scheduleTx)).to.be.rejected;
+ //expect(getGenericResult(events).success).to.be.false;
+ });
+}
- await submitTransactionAsync(sender, scheduleTx);
+export async function
+scheduleTransferAndWaitExpectSuccess(
+ collectionId: number,
+ tokenId: number,
+ sender: IKeyringPair,
+ recipient: IKeyringPair,
+ value: number | bigint = 1,
+ blockSchedule: number,
+ scheduledId: string,
+) {
+ await usingApi(async (api: ApiPromise) => {
+ await scheduleTransferExpectSuccess(collectionId, tokenId, sender, recipient, value, blockSchedule, scheduledId);
const recipientBalanceBefore = (await api.query.system.account(recipient.address)).data.free.toBigInt();
- expect(await getTokenOwner(api, collectionId, tokenId)).to.be.deep.equal(normalizeAccountId(sender.address));
-
- // sleep for 4 blocks
+ // sleep for n + 1 blocks
await waitNewBlocks(blockSchedule + 1);
const recipientBalanceAfter = (await api.query.system.account(recipient.address)).data.free.toBigInt();
@@ -967,6 +1020,45 @@
});
}
+export async function
+scheduleTransferExpectSuccess(
+ collectionId: number,
+ tokenId: number,
+ sender: IKeyringPair,
+ recipient: IKeyringPair,
+ value: number | bigint = 1,
+ blockSchedule: number,
+ scheduledId: string,
+) {
+ await usingApi(async (api: ApiPromise) => {
+ const transferTx = api.tx.unique.transfer(normalizeAccountId(recipient.address), collectionId, tokenId, value);
+
+ await scheduleExpectSuccess(transferTx, sender, blockSchedule, scheduledId);
+
+ expect(await getTokenOwner(api, collectionId, tokenId)).to.be.deep.equal(normalizeAccountId(sender.address));
+ });
+}
+
+export async function
+scheduleTransferFundsPeriodicExpectSuccess(
+ amount: bigint,
+ sender: IKeyringPair,
+ recipient: IKeyringPair,
+ blockSchedule: number,
+ scheduledId: string,
+ period: number,
+ repetitions: number,
+) {
+ await usingApi(async (api: ApiPromise) => {
+ const transferTx = api.tx.balances.transfer(recipient.address, amount);
+
+ const balanceBefore = await getFreeBalance(recipient);
+
+ await scheduleExpectSuccess(transferTx, sender, blockSchedule, scheduledId, period, repetitions);
+
+ expect(await getFreeBalance(recipient)).to.be.equal(balanceBefore);
+ });
+}
export async function
transferExpectSuccess(