difftreelog
fix(xcm) get rid of xcm warns, fix quartz CurrencyIdConvert
in: master
19 files changed
pallets/foreing-assets/src/lib.rsdiffbeforeafterboth--- a/pallets/foreing-assets/src/lib.rs
+++ b/pallets/foreing-assets/src/lib.rs
@@ -54,7 +54,7 @@
// NOTE:v1::MultiLocation is used in storages, we would need to do migration if upgrade the
// MultiLocation in the future.
-use xcm::opaque::latest::{prelude::XcmError, MultiAsset};
+use xcm::opaque::latest::prelude::XcmError;
use xcm::{v1::MultiLocation, VersionedMultiLocation};
use xcm_executor::{traits::WeightTrader, Assets};
@@ -445,8 +445,6 @@
}
}
-use sp_runtime::SaturatedConversion;
-use sp_runtime::traits::Saturating;
pub use frame_support::{
traits::{
fungibles::{Balanced, CreditOf},
@@ -455,8 +453,6 @@
},
weights::{WeightToFeePolynomial, WeightToFee},
};
-
-use xcm::latest::{Fungibility::Fungible as XcmFungible};
pub struct FreeForAll<
WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,
runtime/common/config/xcm.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/>.1617use frame_support::{18 traits::{19 Contains, tokens::currency::Currency as CurrencyT, OnUnbalanced as OnUnbalancedT, Get,20 Everything, fungibles,21 },22 weights::{Weight, WeightToFeePolynomial, WeightToFee},23 parameter_types, match_types,24};25use frame_system::EnsureRoot;26use sp_runtime::{27 traits::{Saturating, CheckedConversion, Zero},28 SaturatedConversion,29};30use pallet_xcm::XcmPassthrough;31use polkadot_parachain::primitives::Sibling;32use xcm::v1::{BodyId, Junction::*, MultiLocation, NetworkId, Junctions::*};33use xcm::latest::{34 AssetId::{Concrete},35 Fungibility::Fungible as XcmFungible,36 MultiAsset, Error as XcmError, Instruction, Xcm,37};38use xcm_builder::{39 AccountId32Aliases, AllowTopLevelPaidExecutionFrom, CurrencyAdapter, EnsureXcmOrigin,40 FixedWeightBounds, FungiblesAdapter, LocationInverter, NativeAsset, ParentAsSuperuser,41 RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,42 SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,43 ParentIsPreset, ConvertedConcreteAssetId,44};45use xcm_executor::{Config, XcmExecutor, Assets};46use xcm_executor::traits::{47 Convert as ConvertXcm, JustTry, MatchesFungible, WeightTrader, FilterAssetLocation,48 ShouldExecute,49};50use pallet_foreing_assets::{51 AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, CurrencyId, NativeCurrency, FreeForAll,52 TryAsForeing, ForeignAssetId,53};54use sp_std::{borrow::Borrow, marker::PhantomData, vec, vec::Vec};55use crate::{56 Runtime, Call, Event, Origin, Balances, ParachainInfo, ParachainSystem, PolkadotXcm, XcmpQueue,57 xcm_config::Barrier,58};59#[cfg(feature = "foreign-assets")]60use crate::ForeingAssets;6162use up_common::{63 types::{AccountId, Balance},64 constants::*,65};6667parameter_types! {68 pub const RelayLocation: MultiLocation = MultiLocation::parent();69 pub const RelayNetwork: NetworkId = NetworkId::Polkadot;70 pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();71 pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();72}7374/// Type for specifying how a `MultiLocation` can be converted into an `AccountId`. This is used75/// when determining ownership of accounts for asset transacting and when attempting to use XCM76/// `Transact` in order to determine the dispatch Origin.77pub type LocationToAccountId = (78 // The parent (Relay-chain) origin converts to the default `AccountId`.79 ParentIsPreset<AccountId>,80 // Sibling parachain origins convert to AccountId via the `ParaId::into`.81 SiblingParachainConvertsVia<Sibling, AccountId>,82 // Straight up local `AccountId32` origins just alias directly to `AccountId`.83 AccountId32Aliases<RelayNetwork, AccountId>,84);8586pub struct OnlySelfCurrency;87impl<B: TryFrom<u128>> MatchesFungible<B> for OnlySelfCurrency {88 fn matches_fungible(a: &MultiAsset) -> Option<B> {89 let paraid = Parachain(ParachainInfo::parachain_id().into());90 match (&a.id, &a.fun) {91 (92 Concrete(MultiLocation {93 parents: 1,94 interior: X1(loc),95 }),96 XcmFungible(ref amount),97 ) if paraid == *loc => CheckedConversion::checked_from(*amount),98 (99 Concrete(MultiLocation {100 parents: 0,101 interior: Here,102 }),103 XcmFungible(ref amount),104 ) => CheckedConversion::checked_from(*amount),105 _ => None,106 }107 }108}109110/// Means for transacting assets on this chain.111pub type LocalAssetTransactor = CurrencyAdapter<112 // Use this currency:113 Balances,114 // Use this currency when it is a fungible asset matching the given location or name:115 OnlySelfCurrency,116 // Do a simple punn to convert an AccountId32 MultiLocation into a native chain account ID:117 LocationToAccountId,118 // Our chain's account ID type (we can't get away without mentioning it explicitly):119 AccountId,120 // We don't track any teleports.121 (),122>;123124/// No local origins on this chain are allowed to dispatch XCM sends/executions.125pub type LocalOriginToLocation = (SignedToAccountId32<Origin, AccountId, RelayNetwork>,);126127/// The means for routing XCM messages which are not for local execution into the right message128/// queues.129pub type XcmRouter = (130 // Two routers - use UMP to communicate with the relay chain:131 cumulus_primitives_utility::ParentAsUmp<ParachainSystem, ()>,132 // ..and XCMP to communicate with the sibling chains.133 XcmpQueue,134);135136/// This is the type we use to convert an (incoming) XCM origin into a local `Origin` instance,137/// ready for dispatching a transaction with Xcm's `Transact`. There is an `OriginKind` which can138/// biases the kind of local `Origin` it will become.139pub type XcmOriginToTransactDispatchOrigin = (140 // Sovereign account converter; this attempts to derive an `AccountId` from the origin location141 // using `LocationToAccountId` and then turn that into the usual `Signed` origin. Useful for142 // foreign chains who want to have a local sovereign account on this chain which they control.143 SovereignSignedViaLocation<LocationToAccountId, Origin>,144 // Native converter for Relay-chain (Parent) location; will converts to a `Relay` origin when145 // recognised.146 RelayChainAsNative<RelayOrigin, Origin>,147 // Native converter for sibling Parachains; will convert to a `SiblingPara` origin when148 // recognised.149 SiblingParachainAsNative<cumulus_pallet_xcm::Origin, Origin>,150 // Superuser converter for the Relay-chain (Parent) location. This will allow it to issue a151 // transaction from the Root origin.152 ParentAsSuperuser<Origin>,153 // Native signed account converter; this just converts an `AccountId32` origin into a normal154 // `Origin::Signed` origin of the same 32-byte value.155 SignedAccountId32AsNative<RelayNetwork, Origin>,156 // Xcm origins can be represented natively under the Xcm pallet's Xcm origin.157 XcmPassthrough<Origin>,158);159160parameter_types! {161 // One XCM operation is 1_000_000 weight - almost certainly a conservative estimate.162 pub UnitWeightCost: Weight = 1_000_000;163 // 1200 UNIQUEs buy 1 second of weight.164 pub const WeightPrice: (MultiLocation, u128) = (MultiLocation::parent(), 1_200 * UNIQUE);165 pub const MaxInstructions: u32 = 100;166}167168match_types! {169 pub type ParentOrParentsUnitPlurality: impl Contains<MultiLocation> = {170 MultiLocation { parents: 1, interior: Here } |171 MultiLocation { parents: 1, interior: X1(Plurality { id: BodyId::Unit, .. }) }172 };173}174175pub trait TryPass {176 fn try_pass<Call>(177 origin: &MultiLocation,178 message: &mut Xcm<Call>,179 ) -> Result<(), ()>;180}181182#[impl_trait_for_tuples::impl_for_tuples(30)]183impl TryPass for Tuple {184 fn try_pass<Call>(185 origin: &MultiLocation,186 message: &mut Xcm<Call>,187 ) -> Result<(), ()> {188 for_tuples!( #(189 Tuple::try_pass(origin, message)?;190 )* );191192 Ok(())193 }194}195196pub struct DenyTransact;197impl TryPass for DenyTransact {198 fn try_pass<Call>(199 _origin: &MultiLocation,200 message: &mut Xcm<Call>,201 ) -> Result<(), ()> {202 let transact_inst = message203 .0204 .iter()205 .find(|inst| matches![inst, Instruction::Transact { .. }]);206207 match transact_inst {208 Some(_) => {209 log::warn!(210 target: "xcm::barrier",211 "transact XCM rejected"212 );213214 Err(())215 }216 None => Ok(()),217 }218 }219}220221/// Deny executing the XCM if it matches any of the Deny filter regardless of anything else.222/// If it passes the Deny, and matches one of the Allow cases then it is let through.223pub struct DenyThenTry<Deny, Allow>(PhantomData<Deny>, PhantomData<Allow>)224where225 Deny: TryPass,226 Allow: ShouldExecute;227228impl<Deny, Allow> ShouldExecute for DenyThenTry<Deny, Allow>229where230 Deny: TryPass,231 Allow: ShouldExecute,232{233 fn should_execute<Call>(234 origin: &MultiLocation,235 message: &mut Xcm<Call>,236 max_weight: Weight,237 weight_credit: &mut Weight,238 ) -> Result<(), ()> {239 Deny::try_pass(origin, message)?;240 Allow::should_execute(origin, message, max_weight, weight_credit)241 }242}243244pub struct UsingOnlySelfCurrencyComponents<245 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,246 AssetId: Get<MultiLocation>,247 AccountId,248 Currency: CurrencyT<AccountId>,249 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,250>(251 Weight,252 Currency::Balance,253 PhantomData<(WeightToFee, AssetId, AccountId, Currency, OnUnbalanced)>,254);255impl<256 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,257 AssetId: Get<MultiLocation>,258 AccountId,259 Currency: CurrencyT<AccountId>,260 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,261 > WeightTrader262 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>263{264 fn new() -> Self {265 Self(0, Zero::zero(), PhantomData)266 }267268 fn buy_weight(&mut self, weight: Weight, payment: Assets) -> Result<Assets, XcmError> {269 Ok(payment)270 }271}272impl<273 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,274 AssetId: Get<MultiLocation>,275 AccountId,276 Currency: CurrencyT<AccountId>,277 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,278 > Drop279 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>280{281 fn drop(&mut self) {282 OnUnbalanced::on_unbalanced(Currency::issue(self.1));283 }284}285286parameter_types! {287 pub CheckingAccount: AccountId = PolkadotXcm::check_account();288}289/// Allow checking in assets that have issuance > 0.290#[cfg(feature = "foreign-assets")]291pub struct NonZeroIssuance<AccountId, ForeingAssets>(PhantomData<(AccountId, ForeingAssets)>);292293#[cfg(feature = "foreign-assets")]294impl<AccountId, ForeingAssets> Contains<<ForeingAssets as fungibles::Inspect<AccountId>>::AssetId>295 for NonZeroIssuance<AccountId, ForeingAssets>296where297 ForeingAssets: fungibles::Inspect<AccountId>,298{299 fn contains(id: &<ForeingAssets as fungibles::Inspect<AccountId>>::AssetId) -> bool {300 !ForeingAssets::total_issuance(*id).is_zero()301 }302}303304#[cfg(feature = "foreign-assets")]305pub struct AsInnerId<AssetId, ConvertAssetId>(PhantomData<(AssetId, ConvertAssetId)>);306#[cfg(feature = "foreign-assets")]307impl<AssetId: Clone + PartialEq, ConvertAssetId: ConvertXcm<AssetId, AssetId>>308 ConvertXcm<MultiLocation, AssetId> for AsInnerId<AssetId, ConvertAssetId>309where310 AssetId: Borrow<AssetId>,311 AssetId: TryAsForeing<AssetId, ForeignAssetId>,312 AssetIds: Borrow<AssetId>,313{314 fn convert_ref(id: impl Borrow<MultiLocation>) -> Result<AssetId, ()> {315 let id = id.borrow();316317 log::trace!(318 target: "xcm::AsInnerId::Convert",319 "AsInnerId {:?}",320 id321 );322323 let parent = MultiLocation::parent();324 let here = MultiLocation::here();325 let self_location = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));326327 if *id == parent {328 return ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Parent));329 }330331 if *id == here || *id == self_location {332 return ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Here));333 }334335 match XcmForeignAssetIdMapping::<Runtime>::get_currency_id(id.clone()) {336 Some(AssetIds::ForeignAssetId(foreign_asset_id)) => {337 ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(foreign_asset_id))338 }339 _ => ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(0)),340 }341 }342343 fn reverse_ref(what: impl Borrow<AssetId>) -> Result<MultiLocation, ()> {344 log::trace!(345 target: "xcm::AsInnerId::Reverse",346 "AsInnerId",347 );348349 let asset_id = what.borrow();350351 let parent_id =352 ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Parent)).unwrap();353 let here_id =354 ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Here)).unwrap();355356 if asset_id.clone() == parent_id {357 return Ok(MultiLocation::parent());358 }359360 if asset_id.clone() == here_id {361 return Ok(MultiLocation::new(362 1,363 X1(Parachain(ParachainInfo::get().into())),364 ));365 }366367 match <AssetId as TryAsForeing<AssetId, ForeignAssetId>>::try_as_foreing(asset_id.clone()) {368 Some(fid) => match XcmForeignAssetIdMapping::<Runtime>::get_multi_location(fid) {369 Some(location) => Ok(location),370 None => Err(()),371 },372 None => Err(()),373 }374 }375}376377/// Means for transacting assets besides the native currency on this chain.378#[cfg(feature = "foreign-assets")]379pub type FungiblesTransactor = FungiblesAdapter<380 // Use this fungibles implementation:381 ForeingAssets,382 // Use this currency when it is a fungible asset matching the given location or name:383 ConvertedConcreteAssetId<AssetIds, Balance, AsInnerId<AssetIds, JustTry>, JustTry>,384 // Convert an XCM MultiLocation into a local account id:385 LocationToAccountId,386 // Our chain's account ID type (we can't get away without mentioning it explicitly):387 AccountId,388 // We only want to allow teleports of known assets. We use non-zero issuance as an indication389 // that this asset is known.390 NonZeroIssuance<AccountId, ForeingAssets>,391 // The account to use for tracking teleports.392 CheckingAccount,393>;394395/// Means for transacting assets on this chain.396#[cfg(feature = "foreign-assets")]397pub type AssetTransactors = FungiblesTransactor;398399#[cfg(not(feature = "foreign-assets"))]400pub type AssetTransactors = LocalAssetTransactor;401402#[cfg(feature = "foreign-assets")]403pub struct AllAsset;404#[cfg(feature = "foreign-assets")]405impl FilterAssetLocation for AllAsset {406 fn filter_asset_location(asset: &MultiAsset, origin: &MultiLocation) -> bool {407 true408 }409}410411#[cfg(feature = "foreign-assets")]412pub type IsReserve = AllAsset;413#[cfg(not(feature = "foreign-assets"))]414pub type IsReserve = NativeAsset;415416#[cfg(feature = "foreign-assets")]417type Trader<T> = FreeForAll<418 pallet_configuration::WeightToFee<T, Balance>,419 RelayLocation,420 AccountId,421 Balances,422 (),423>;424#[cfg(not(feature = "foreign-assets"))]425type Trader<T> = UsingOnlySelfCurrencyComponents<426 pallet_configuration::WeightToFee<T, Balance>,427 RelayLocation,428 AccountId,429 Balances,430 (),431>;432433pub struct XcmConfig<T>(PhantomData<T>);434impl<T> Config for XcmConfig<T>435where436 T: pallet_configuration::Config,437{438 type Call = Call;439 type XcmSender = XcmRouter;440 // How to withdraw and deposit an asset.441 type AssetTransactor = AssetTransactors;442 type OriginConverter = XcmOriginToTransactDispatchOrigin;443 type IsReserve = IsReserve;444 type IsTeleporter = (); // Teleportation is disabled445 type LocationInverter = LocationInverter<Ancestry>;446 type Barrier = Barrier;447 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;448 type Trader = Trader<T>;449 type ResponseHandler = (); // Don't handle responses for now.450 type SubscriptionService = PolkadotXcm;451452 type AssetTrap = PolkadotXcm;453 type AssetClaims = PolkadotXcm;454}455456impl pallet_xcm::Config for Runtime {457 type Event = Event;458 type SendXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;459 type XcmRouter = XcmRouter;460 type ExecuteXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;461 type XcmExecuteFilter = Everything;462 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;463 type XcmTeleportFilter = Everything;464 type XcmReserveTransferFilter = Everything;465 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;466 type LocationInverter = LocationInverter<Ancestry>;467 type Origin = Origin;468 type Call = Call;469 const VERSION_DISCOVERY_QUEUE_SIZE: u32 = 100;470 type AdvertisedXcmVersion = pallet_xcm::CurrentXcmVersion;471}472473impl cumulus_pallet_xcm::Config for Runtime {474 type Event = Event;475 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;476}477478impl cumulus_pallet_xcmp_queue::Config for Runtime {479 type WeightInfo = ();480 type Event = Event;481 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;482 type ChannelInfo = ParachainSystem;483 type VersionWrapper = ();484 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;485 type ControllerOrigin = EnsureRoot<AccountId>;486 type ControllerOriginConverter = XcmOriginToTransactDispatchOrigin;487}488489impl cumulus_pallet_dmp_queue::Config for Runtime {490 type Event = Event;491 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;492 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;493}runtime/common/config/xcm/foreignassets.rsdiffbeforeafterboth--- /dev/null
+++ b/runtime/common/config/xcm/foreignassets.rs
@@ -0,0 +1,160 @@
+// 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/>.
+
+use frame_support::{
+ traits::{Contains, Get, fungibles},
+ parameter_types,
+};
+use sp_runtime::traits::Zero;
+use xcm::v1::{Junction::*, MultiLocation, Junctions::*};
+use xcm::latest::MultiAsset;
+use xcm_builder::{FungiblesAdapter, ConvertedConcreteAssetId};
+use xcm_executor::traits::{Convert as ConvertXcm, JustTry, FilterAssetLocation};
+use pallet_foreing_assets::{
+ AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, NativeCurrency, FreeForAll, TryAsForeing,
+ ForeignAssetId,
+};
+use sp_std::{borrow::Borrow, marker::PhantomData};
+use crate::{Runtime, Balances, ParachainInfo, PolkadotXcm, ForeingAssets};
+
+use super::{LocationToAccountId, RelayLocation};
+
+use up_common::types::{AccountId, Balance};
+
+parameter_types! {
+ pub CheckingAccount: AccountId = PolkadotXcm::check_account();
+}
+
+/// Allow checking in assets that have issuance > 0.
+pub struct NonZeroIssuance<AccountId, ForeingAssets>(PhantomData<(AccountId, ForeingAssets)>);
+
+impl<AccountId, ForeingAssets> Contains<<ForeingAssets as fungibles::Inspect<AccountId>>::AssetId>
+ for NonZeroIssuance<AccountId, ForeingAssets>
+where
+ ForeingAssets: fungibles::Inspect<AccountId>,
+{
+ fn contains(id: &<ForeingAssets as fungibles::Inspect<AccountId>>::AssetId) -> bool {
+ !ForeingAssets::total_issuance(*id).is_zero()
+ }
+}
+
+pub struct AsInnerId<AssetId, ConvertAssetId>(PhantomData<(AssetId, ConvertAssetId)>);
+impl<AssetId: Clone + PartialEq, ConvertAssetId: ConvertXcm<AssetId, AssetId>>
+ ConvertXcm<MultiLocation, AssetId> for AsInnerId<AssetId, ConvertAssetId>
+where
+ AssetId: Borrow<AssetId>,
+ AssetId: TryAsForeing<AssetId, ForeignAssetId>,
+ AssetIds: Borrow<AssetId>,
+{
+ fn convert_ref(id: impl Borrow<MultiLocation>) -> Result<AssetId, ()> {
+ let id = id.borrow();
+
+ log::trace!(
+ target: "xcm::AsInnerId::Convert",
+ "AsInnerId {:?}",
+ id
+ );
+
+ let parent = MultiLocation::parent();
+ let here = MultiLocation::here();
+ let self_location = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));
+
+ if *id == parent {
+ return ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Parent));
+ }
+
+ if *id == here || *id == self_location {
+ return ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Here));
+ }
+
+ match XcmForeignAssetIdMapping::<Runtime>::get_currency_id(id.clone()) {
+ Some(AssetIds::ForeignAssetId(foreign_asset_id)) => {
+ ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(foreign_asset_id))
+ }
+ _ => ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(0)),
+ }
+ }
+
+ fn reverse_ref(what: impl Borrow<AssetId>) -> Result<MultiLocation, ()> {
+ log::trace!(
+ target: "xcm::AsInnerId::Reverse",
+ "AsInnerId",
+ );
+
+ let asset_id = what.borrow();
+
+ let parent_id =
+ ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Parent)).unwrap();
+ let here_id =
+ ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Here)).unwrap();
+
+ if asset_id.clone() == parent_id {
+ return Ok(MultiLocation::parent());
+ }
+
+ if asset_id.clone() == here_id {
+ return Ok(MultiLocation::new(
+ 1,
+ X1(Parachain(ParachainInfo::get().into())),
+ ));
+ }
+
+ match <AssetId as TryAsForeing<AssetId, ForeignAssetId>>::try_as_foreing(asset_id.clone()) {
+ Some(fid) => match XcmForeignAssetIdMapping::<Runtime>::get_multi_location(fid) {
+ Some(location) => Ok(location),
+ None => Err(()),
+ },
+ None => Err(()),
+ }
+ }
+}
+
+/// Means for transacting assets besides the native currency on this chain.
+pub type FungiblesTransactor = FungiblesAdapter<
+ // Use this fungibles implementation:
+ ForeingAssets,
+ // Use this currency when it is a fungible asset matching the given location or name:
+ ConvertedConcreteAssetId<AssetIds, Balance, AsInnerId<AssetIds, JustTry>, JustTry>,
+ // Convert an XCM MultiLocation into a local account id:
+ LocationToAccountId,
+ // Our chain's account ID type (we can't get away without mentioning it explicitly):
+ AccountId,
+ // We only want to allow teleports of known assets. We use non-zero issuance as an indication
+ // that this asset is known.
+ NonZeroIssuance<AccountId, ForeingAssets>,
+ // The account to use for tracking teleports.
+ CheckingAccount,
+>;
+
+/// Means for transacting assets on this chain.
+pub type AssetTransactors = FungiblesTransactor;
+
+pub struct AllAsset;
+impl FilterAssetLocation for AllAsset {
+ fn filter_asset_location(_asset: &MultiAsset, _origin: &MultiLocation) -> bool {
+ true
+ }
+}
+
+pub type IsReserve = AllAsset;
+
+pub type Trader<T> = FreeForAll<
+ pallet_configuration::WeightToFee<T, Balance>,
+ RelayLocation,
+ AccountId,
+ Balances,
+ (),
+>;
runtime/common/config/xcm/mod.rsdiffbeforeafterboth--- /dev/null
+++ b/runtime/common/config/xcm/mod.rs
@@ -0,0 +1,232 @@
+// 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/>.
+
+use frame_support::{traits::Everything, weights::Weight, parameter_types};
+use frame_system::EnsureRoot;
+use pallet_xcm::XcmPassthrough;
+use polkadot_parachain::primitives::Sibling;
+use xcm::v1::{Junction::*, MultiLocation, NetworkId};
+use xcm::latest::{Instruction, Xcm};
+use xcm_builder::{
+ AccountId32Aliases, EnsureXcmOrigin, FixedWeightBounds, LocationInverter, ParentAsSuperuser,
+ RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,
+ SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, ParentIsPreset,
+};
+use xcm_executor::{Config, XcmExecutor, traits::ShouldExecute};
+use sp_std::marker::PhantomData;
+use crate::{
+ Runtime, Call, Event, Origin, ParachainInfo, ParachainSystem, PolkadotXcm, XcmpQueue,
+ xcm_config::Barrier,
+};
+
+use up_common::types::AccountId;
+
+#[cfg(feature = "foreign-assets")]
+mod foreignassets;
+
+#[cfg(not(feature = "foreign-assets"))]
+mod nativeassets;
+
+#[cfg(feature = "foreign-assets")]
+use foreignassets as xcm_assets;
+
+#[cfg(not(feature = "foreign-assets"))]
+use nativeassets as xcm_assets;
+
+use xcm_assets::{AssetTransactors, IsReserve, Trader};
+
+parameter_types! {
+ pub const RelayLocation: MultiLocation = MultiLocation::parent();
+ pub const RelayNetwork: NetworkId = NetworkId::Polkadot;
+ pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();
+ pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();
+}
+
+/// Type for specifying how a `MultiLocation` can be converted into an `AccountId`. This is used
+/// when determining ownership of accounts for asset transacting and when attempting to use XCM
+/// `Transact` in order to determine the dispatch Origin.
+pub type LocationToAccountId = (
+ // The parent (Relay-chain) origin converts to the default `AccountId`.
+ ParentIsPreset<AccountId>,
+ // Sibling parachain origins convert to AccountId via the `ParaId::into`.
+ SiblingParachainConvertsVia<Sibling, AccountId>,
+ // Straight up local `AccountId32` origins just alias directly to `AccountId`.
+ AccountId32Aliases<RelayNetwork, AccountId>,
+);
+
+/// No local origins on this chain are allowed to dispatch XCM sends/executions.
+pub type LocalOriginToLocation = (SignedToAccountId32<Origin, AccountId, RelayNetwork>,);
+
+/// The means for routing XCM messages which are not for local execution into the right message
+/// queues.
+pub type XcmRouter = (
+ // Two routers - use UMP to communicate with the relay chain:
+ cumulus_primitives_utility::ParentAsUmp<ParachainSystem, ()>,
+ // ..and XCMP to communicate with the sibling chains.
+ XcmpQueue,
+);
+
+/// This is the type we use to convert an (incoming) XCM origin into a local `Origin` instance,
+/// ready for dispatching a transaction with Xcm's `Transact`. There is an `OriginKind` which can
+/// biases the kind of local `Origin` it will become.
+pub type XcmOriginToTransactDispatchOrigin = (
+ // Sovereign account converter; this attempts to derive an `AccountId` from the origin location
+ // using `LocationToAccountId` and then turn that into the usual `Signed` origin. Useful for
+ // foreign chains who want to have a local sovereign account on this chain which they control.
+ SovereignSignedViaLocation<LocationToAccountId, Origin>,
+ // Native converter for Relay-chain (Parent) location; will converts to a `Relay` origin when
+ // recognised.
+ RelayChainAsNative<RelayOrigin, Origin>,
+ // Native converter for sibling Parachains; will convert to a `SiblingPara` origin when
+ // recognised.
+ SiblingParachainAsNative<cumulus_pallet_xcm::Origin, Origin>,
+ // Superuser converter for the Relay-chain (Parent) location. This will allow it to issue a
+ // transaction from the Root origin.
+ ParentAsSuperuser<Origin>,
+ // Native signed account converter; this just converts an `AccountId32` origin into a normal
+ // `Origin::Signed` origin of the same 32-byte value.
+ SignedAccountId32AsNative<RelayNetwork, Origin>,
+ // Xcm origins can be represented natively under the Xcm pallet's Xcm origin.
+ XcmPassthrough<Origin>,
+);
+
+parameter_types! {
+ // One XCM operation is 1_000_000 weight - almost certainly a conservative estimate.
+ pub UnitWeightCost: Weight = 1_000_000;
+ pub const MaxInstructions: u32 = 100;
+}
+
+pub trait TryPass {
+ fn try_pass<Call>(origin: &MultiLocation, message: &mut Xcm<Call>) -> Result<(), ()>;
+}
+
+#[impl_trait_for_tuples::impl_for_tuples(30)]
+impl TryPass for Tuple {
+ fn try_pass<Call>(origin: &MultiLocation, message: &mut Xcm<Call>) -> Result<(), ()> {
+ for_tuples!( #(
+ Tuple::try_pass(origin, message)?;
+ )* );
+
+ Ok(())
+ }
+}
+
+pub struct DenyTransact;
+impl TryPass for DenyTransact {
+ fn try_pass<Call>(_origin: &MultiLocation, message: &mut Xcm<Call>) -> Result<(), ()> {
+ let transact_inst = message
+ .0
+ .iter()
+ .find(|inst| matches![inst, Instruction::Transact { .. }]);
+
+ match transact_inst {
+ Some(_) => {
+ log::warn!(
+ target: "xcm::barrier",
+ "transact XCM rejected"
+ );
+
+ Err(())
+ }
+ None => Ok(()),
+ }
+ }
+}
+
+/// Deny executing the XCM if it matches any of the Deny filter regardless of anything else.
+/// If it passes the Deny, and matches one of the Allow cases then it is let through.
+pub struct DenyThenTry<Deny, Allow>(PhantomData<Deny>, PhantomData<Allow>)
+where
+ Deny: TryPass,
+ Allow: ShouldExecute;
+
+impl<Deny, Allow> ShouldExecute for DenyThenTry<Deny, Allow>
+where
+ Deny: TryPass,
+ Allow: ShouldExecute,
+{
+ fn should_execute<Call>(
+ origin: &MultiLocation,
+ message: &mut Xcm<Call>,
+ max_weight: Weight,
+ weight_credit: &mut Weight,
+ ) -> Result<(), ()> {
+ Deny::try_pass(origin, message)?;
+ Allow::should_execute(origin, message, max_weight, weight_credit)
+ }
+}
+
+pub struct XcmConfig<T>(PhantomData<T>);
+impl<T> Config for XcmConfig<T>
+where
+ T: pallet_configuration::Config,
+{
+ type Call = Call;
+ type XcmSender = XcmRouter;
+ // How to withdraw and deposit an asset.
+ type AssetTransactor = AssetTransactors;
+ type OriginConverter = XcmOriginToTransactDispatchOrigin;
+ type IsReserve = IsReserve;
+ type IsTeleporter = (); // Teleportation is disabled
+ type LocationInverter = LocationInverter<Ancestry>;
+ type Barrier = Barrier;
+ type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
+ type Trader = Trader<T>;
+ type ResponseHandler = (); // Don't handle responses for now.
+ type SubscriptionService = PolkadotXcm;
+
+ type AssetTrap = PolkadotXcm;
+ type AssetClaims = PolkadotXcm;
+}
+
+impl pallet_xcm::Config for Runtime {
+ type Event = Event;
+ type SendXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;
+ type XcmRouter = XcmRouter;
+ type ExecuteXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;
+ type XcmExecuteFilter = Everything;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+ type XcmTeleportFilter = Everything;
+ type XcmReserveTransferFilter = Everything;
+ type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
+ type LocationInverter = LocationInverter<Ancestry>;
+ type Origin = Origin;
+ type Call = Call;
+ const VERSION_DISCOVERY_QUEUE_SIZE: u32 = 100;
+ type AdvertisedXcmVersion = pallet_xcm::CurrentXcmVersion;
+}
+
+impl cumulus_pallet_xcm::Config for Runtime {
+ type Event = Event;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+}
+
+impl cumulus_pallet_xcmp_queue::Config for Runtime {
+ type WeightInfo = ();
+ type Event = Event;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+ type ChannelInfo = ParachainSystem;
+ type VersionWrapper = ();
+ type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;
+ type ControllerOrigin = EnsureRoot<AccountId>;
+ type ControllerOriginConverter = XcmOriginToTransactDispatchOrigin;
+}
+
+impl cumulus_pallet_dmp_queue::Config for Runtime {
+ type Event = Event;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+ type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;
+}
runtime/common/config/xcm/nativeassets.rsdiffbeforeafterboth--- /dev/null
+++ b/runtime/common/config/xcm/nativeassets.rs
@@ -0,0 +1,129 @@
+// 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/>.
+
+use frame_support::{
+ traits::{tokens::currency::Currency as CurrencyT, OnUnbalanced as OnUnbalancedT, Get},
+ weights::{Weight, WeightToFeePolynomial},
+};
+use sp_runtime::traits::{CheckedConversion, Zero};
+use xcm::v1::{Junction::*, MultiLocation, Junctions::*};
+use xcm::latest::{
+ AssetId::{Concrete},
+ Fungibility::Fungible as XcmFungible,
+ MultiAsset, Error as XcmError,
+};
+use xcm_builder::{CurrencyAdapter, NativeAsset};
+use xcm_executor::{
+ Assets,
+ traits::{MatchesFungible, WeightTrader},
+};
+use sp_std::marker::PhantomData;
+use crate::{Balances, ParachainInfo};
+use super::{LocationToAccountId, RelayLocation};
+
+use up_common::types::{AccountId, Balance};
+
+pub struct OnlySelfCurrency;
+impl<B: TryFrom<u128>> MatchesFungible<B> for OnlySelfCurrency {
+ fn matches_fungible(a: &MultiAsset) -> Option<B> {
+ let paraid = Parachain(ParachainInfo::parachain_id().into());
+ match (&a.id, &a.fun) {
+ (
+ Concrete(MultiLocation {
+ parents: 1,
+ interior: X1(loc),
+ }),
+ XcmFungible(ref amount),
+ ) if paraid == *loc => CheckedConversion::checked_from(*amount),
+ (
+ Concrete(MultiLocation {
+ parents: 0,
+ interior: Here,
+ }),
+ XcmFungible(ref amount),
+ ) => CheckedConversion::checked_from(*amount),
+ _ => None,
+ }
+ }
+}
+
+/// Means for transacting assets on this chain.
+pub type LocalAssetTransactor = CurrencyAdapter<
+ // Use this currency:
+ Balances,
+ // Use this currency when it is a fungible asset matching the given location or name:
+ OnlySelfCurrency,
+ // Do a simple punn to convert an AccountId32 MultiLocation into a native chain account ID:
+ LocationToAccountId,
+ // Our chain's account ID type (we can't get away without mentioning it explicitly):
+ AccountId,
+ // We don't track any teleports.
+ (),
+>;
+
+pub type AssetTransactors = LocalAssetTransactor;
+
+pub type IsReserve = NativeAsset;
+
+pub struct UsingOnlySelfCurrencyComponents<
+ WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,
+ AssetId: Get<MultiLocation>,
+ AccountId,
+ Currency: CurrencyT<AccountId>,
+ OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,
+>(
+ Weight,
+ Currency::Balance,
+ PhantomData<(WeightToFee, AssetId, AccountId, Currency, OnUnbalanced)>,
+);
+impl<
+ WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,
+ AssetId: Get<MultiLocation>,
+ AccountId,
+ Currency: CurrencyT<AccountId>,
+ OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,
+ > WeightTrader
+ for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>
+{
+ fn new() -> Self {
+ Self(0, Zero::zero(), PhantomData)
+ }
+
+ fn buy_weight(&mut self, _weight: Weight, payment: Assets) -> Result<Assets, XcmError> {
+ Ok(payment)
+ }
+}
+impl<
+ WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,
+ AssetId: Get<MultiLocation>,
+ AccountId,
+ Currency: CurrencyT<AccountId>,
+ OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,
+ > Drop
+ for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>
+{
+ fn drop(&mut self) {
+ OnUnbalanced::on_unbalanced(Currency::issue(self.1));
+ }
+}
+
+pub type Trader<T> = UsingOnlySelfCurrencyComponents<
+ pallet_configuration::WeightToFee<T, Balance>,
+ RelayLocation,
+ AccountId,
+ Balances,
+ (),
+>;
runtime/common/tests/mod.rsdiffbeforeafterboth--- a/runtime/common/tests/mod.rs
+++ b/runtime/common/tests/mod.rs
@@ -29,20 +29,18 @@
}
fn new_test_ext(para_id: u32) -> sp_io::TestExternalities {
- let cfg = GenesisConfig {
- aura: AuraConfig {
- authorities: vec![
- get_from_seed::<AuraId>("Alice"),
- get_from_seed::<AuraId>("Bob"),
- ],
- },
- parachain_info: ParachainInfoConfig {
- parachain_id: para_id.into(),
- },
- ..GenesisConfig::default()
- };
+ let cfg = GenesisConfig {
+ aura: AuraConfig {
+ authorities: vec![
+ get_from_seed::<AuraId>("Alice"),
+ get_from_seed::<AuraId>("Bob"),
+ ],
+ },
+ parachain_info: ParachainInfoConfig {
+ parachain_id: para_id.into(),
+ },
+ ..GenesisConfig::default()
+ };
- cfg.build_storage()
- .unwrap()
- .into()
+ cfg.build_storage().unwrap().into()
}
runtime/common/tests/xcm.rsdiffbeforeafterboth--- a/runtime/common/tests/xcm.rs
+++ b/runtime/common/tests/xcm.rs
@@ -20,154 +20,143 @@
use crate::Call;
use super::new_test_ext;
-fn catch_xcm_barrier_log(
- logger: &mut Logger,
- expected_msg: &str
-) -> Result<(), String> {
- for record in logger {
- if record.target() == "xcm::barrier"
- && record.args() == expected_msg {
- return Ok(());
- }
- }
+fn catch_xcm_barrier_log(logger: &mut Logger, expected_msg: &str) -> Result<(), String> {
+ for record in logger {
+ if record.target() == "xcm::barrier" && record.args() == expected_msg {
+ return Ok(());
+ }
+ }
- Err(format!("the expected XCM barrier log `{}` is not found", expected_msg))
+ Err(format!(
+ "the expected XCM barrier log `{}` is not found",
+ expected_msg
+ ))
}
/// WARNING: Uses log capturing
/// See https://docs.rs/logtest/latest/logtest/index.html#constraints
pub fn barrier_denies_transact<B: ShouldExecute>(logger: &mut Logger) {
- let location = MultiLocation {
- parents: 0,
- interior: Junctions::Here,
- };
+ let location = MultiLocation {
+ parents: 0,
+ interior: Junctions::Here,
+ };
- // We will never decode this "call",
- // so it is irrelevant what we are passing to the `transact` cmd.
- let fake_encoded_call = vec![0u8];
+ // We will never decode this "call",
+ // so it is irrelevant what we are passing to the `transact` cmd.
+ let fake_encoded_call = vec![0u8];
- let transact_inst = Transact {
- origin_type: OriginKind::Superuser,
- require_weight_at_most: 0,
- call: fake_encoded_call.into(),
- };
+ let transact_inst = Transact {
+ origin_type: OriginKind::Superuser,
+ require_weight_at_most: 0,
+ call: fake_encoded_call.into(),
+ };
- let mut xcm_program = Xcm::<Call>(vec![transact_inst]);
+ let mut xcm_program = Xcm::<Call>(vec![transact_inst]);
- let max_weight = 100_000;
- let mut weight_credit = 100_000_000;
+ let max_weight = 100_000;
+ let mut weight_credit = 100_000_000;
- let result = B::should_execute(
- &location,
- &mut xcm_program,
- max_weight,
- &mut weight_credit
- );
+ let result = B::should_execute(&location, &mut xcm_program, max_weight, &mut weight_credit);
- assert!(result.is_err(), "the barrier should disallow the XCM transact cmd");
+ assert!(
+ result.is_err(),
+ "the barrier should disallow the XCM transact cmd"
+ );
- catch_xcm_barrier_log(logger, "transact XCM rejected").unwrap();
+ catch_xcm_barrier_log(logger, "transact XCM rejected").unwrap();
}
fn xcm_execute<B: ShouldExecute>(
- self_para_id: u32,
- location: &MultiLocation,
- xcm: &mut Xcm<Call>
+ self_para_id: u32,
+ location: &MultiLocation,
+ xcm: &mut Xcm<Call>,
) -> Result<(), ()> {
- new_test_ext(self_para_id).execute_with(|| {
- let max_weight = 100_000;
- let mut weight_credit = 100_000_000;
+ new_test_ext(self_para_id).execute_with(|| {
+ let max_weight = 100_000;
+ let mut weight_credit = 100_000_000;
- B::should_execute(
- &location,
- xcm,
- max_weight,
- &mut weight_credit
- )
- })
+ B::should_execute(&location, xcm, max_weight, &mut weight_credit)
+ })
}
fn make_multiassets(location: &MultiLocation) -> MultiAssets {
- let id = AssetId::Concrete(location.clone());
- let fun = Fungibility::Fungible(42);
- let multiasset = MultiAsset {
- id,
- fun,
- };
+ let id = AssetId::Concrete(location.clone());
+ let fun = Fungibility::Fungible(42);
+ let multiasset = MultiAsset { id, fun };
- multiasset.into()
+ multiasset.into()
}
fn make_transfer_reserve_asset(location: &MultiLocation) -> Xcm<Call> {
- let assets = make_multiassets(location);
- let inst = TransferReserveAsset {
- assets,
- dest: location.clone(),
- xcm: Xcm(vec![]),
- };
+ let assets = make_multiassets(location);
+ let inst = TransferReserveAsset {
+ assets,
+ dest: location.clone(),
+ xcm: Xcm(vec![]),
+ };
- Xcm::<Call>(vec![inst])
+ Xcm::<Call>(vec![inst])
}
fn make_deposit_reserve_asset(location: &MultiLocation) -> Xcm<Call> {
- let assets = make_multiassets(location);
- let inst = DepositReserveAsset {
- assets: assets.into(),
- max_assets: 42,
- dest: location.clone(),
- xcm: Xcm(vec![]),
- };
+ let assets = make_multiassets(location);
+ let inst = DepositReserveAsset {
+ assets: assets.into(),
+ max_assets: 42,
+ dest: location.clone(),
+ xcm: Xcm(vec![]),
+ };
- Xcm::<Call>(vec![inst])
+ Xcm::<Call>(vec![inst])
}
fn expect_transfer_location_denied<B: ShouldExecute>(
- logger: &mut Logger,
- self_para_id: u32,
- location: &MultiLocation,
- xcm: &mut Xcm<Call>
+ logger: &mut Logger,
+ self_para_id: u32,
+ location: &MultiLocation,
+ xcm: &mut Xcm<Call>,
) -> Result<(), String> {
- let result = xcm_execute::<B>(self_para_id, location, xcm);
+ let result = xcm_execute::<B>(self_para_id, location, xcm);
- if result.is_ok() {
- return Err("the barrier should deny the unknown location".into());
- }
+ if result.is_ok() {
+ return Err("the barrier should deny the unknown location".into());
+ }
- catch_xcm_barrier_log(logger, "Unexpected deposit or transfer location")
+ catch_xcm_barrier_log(logger, "Unexpected deposit or transfer location")
}
/// WARNING: Uses log capturing
/// See https://docs.rs/logtest/latest/logtest/index.html#constraints
pub fn barrier_denies_transfer_from_unknown_location<B>(
- logger: &mut Logger,
- self_para_id: u32,
+ logger: &mut Logger,
+ self_para_id: u32,
) -> Result<(), String>
where
- B: ShouldExecute
+ B: ShouldExecute,
{
- const UNKNOWN_PARACHAIN_ID: u32 = 4057;
+ const UNKNOWN_PARACHAIN_ID: u32 = 4057;
- let unknown_location = MultiLocation {
- parents: 1,
- interior: X1(Parachain(UNKNOWN_PARACHAIN_ID)),
- };
+ let unknown_location = MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(UNKNOWN_PARACHAIN_ID)),
+ };
- let mut transfer_reserve_asset = make_transfer_reserve_asset(&unknown_location);
- let mut deposit_reserve_asset = make_deposit_reserve_asset(&unknown_location);
+ let mut transfer_reserve_asset = make_transfer_reserve_asset(&unknown_location);
+ let mut deposit_reserve_asset = make_deposit_reserve_asset(&unknown_location);
- expect_transfer_location_denied::<B>(
- logger,
- self_para_id,
- &unknown_location,
- &mut transfer_reserve_asset
- )?;
+ expect_transfer_location_denied::<B>(
+ logger,
+ self_para_id,
+ &unknown_location,
+ &mut transfer_reserve_asset,
+ )?;
- expect_transfer_location_denied::<B>(
- logger,
- self_para_id,
- &unknown_location,
- &mut deposit_reserve_asset
- )?;
+ expect_transfer_location_denied::<B>(
+ logger,
+ self_para_id,
+ &unknown_location,
+ &mut deposit_reserve_asset,
+ )?;
- Ok(())
+ Ok(())
}
runtime/opal/src/tests/logcapture.rsdiffbeforeafterboth--- a/runtime/opal/src/tests/logcapture.rs
+++ b/runtime/opal/src/tests/logcapture.rs
@@ -19,7 +19,7 @@
#[test]
fn opal_log_capture_tests() {
- let mut logger = Logger::start();
-
- opal_xcm_tests(&mut logger);
+ let mut logger = Logger::start();
+
+ opal_xcm_tests(&mut logger);
}
runtime/opal/src/tests/mod.rsdiffbeforeafterboth--- a/runtime/opal/src/tests/mod.rs
+++ b/runtime/opal/src/tests/mod.rs
@@ -14,5 +14,5 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
+mod logcapture;
mod xcm;
-mod logcapture;
runtime/opal/src/tests/xcm.rsdiffbeforeafterboth--- a/runtime/opal/src/tests/xcm.rs
+++ b/runtime/opal/src/tests/xcm.rs
@@ -15,18 +15,13 @@
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
use logtest::Logger;
-use crate::{
- runtime_common::tests::xcm::*,
- xcm_config::Barrier,
-};
+use crate::{runtime_common::tests::xcm::*, xcm_config::Barrier};
const OPAL_PARA_ID: u32 = 2095; // Same as Quartz
pub fn opal_xcm_tests(logger: &mut Logger) {
- barrier_denies_transact::<Barrier>(logger);
+ barrier_denies_transact::<Barrier>(logger);
- barrier_denies_transfer_from_unknown_location::<Barrier>(
- logger,
- OPAL_PARA_ID,
- ).expect_err("opal runtime allows any location");
+ barrier_denies_transfer_from_unknown_location::<Barrier>(logger, OPAL_PARA_ID)
+ .expect_err("opal runtime allows any location");
}
runtime/opal/src/xcm_config.rsdiffbeforeafterboth--- a/runtime/opal/src/xcm_config.rs
+++ b/runtime/opal/src/xcm_config.rs
@@ -14,98 +14,41 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
-use cumulus_pallet_xcm;
use frame_support::{
{match_types, parameter_types, weights::Weight},
pallet_prelude::Get,
- traits::{Contains, Everything, fungibles},
+ traits::{Contains, Everything},
};
-use frame_system::EnsureRoot;
use orml_traits::{location::AbsoluteReserveProvider, parameter_type_with_key};
-use pallet_xcm::XcmPassthrough;
-use polkadot_parachain::primitives::Sibling;
-use sp_runtime::traits::{AccountIdConversion, CheckedConversion, Convert, Zero};
-use sp_std::{borrow::Borrow, marker::PhantomData, vec, vec::Vec};
+use sp_runtime::traits::{AccountIdConversion, Convert};
+use sp_std::{vec, vec::Vec};
use xcm::{
- latest::{MultiAsset, Xcm},
- prelude::{Concrete, Fungible as XcmFungible},
+ latest::Xcm,
v1::{BodyId, Junction::*, Junctions::*, MultiLocation, NetworkId},
};
use xcm_builder::{
- AccountId32Aliases, AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom, EnsureXcmOrigin,
- FixedWeightBounds, FungiblesAdapter, LocationInverter, ParentAsSuperuser, ParentIsPreset,
- RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,
- SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,
- ConvertedConcreteAssetId,
-};
-use xcm_executor::{
- {Config, XcmExecutor},
- traits::{Convert as ConvertXcm, FilterAssetLocation, JustTry, MatchesFungible, ShouldExecute},
+ AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom, FixedWeightBounds, LocationInverter,
+ TakeWeightCredit,
};
+use xcm_executor::{XcmExecutor, traits::ShouldExecute};
-use up_common::{
- constants::{MAXIMUM_BLOCK_WEIGHT, UNIQUE},
- types::{AccountId, Balance},
-};
-
+use up_common::types::{AccountId, Balance};
use crate::{
- Balances, Call, DmpQueue, Event, ForeingAssets, Origin, ParachainInfo, ParachainSystem,
- PolkadotXcm, Runtime, XcmpQueue,
+ Call, Event, ParachainInfo, Runtime,
+ runtime_common::config::{
+ substrate::{TreasuryModuleId, MaxLocks, MaxReserves},
+ pallets::TreasuryAccountId,
+ xcm::*,
+ },
};
-use crate::runtime_common::config::substrate::{TreasuryModuleId, MaxLocks, MaxReserves};
-use crate::runtime_common::config::pallets::TreasuryAccountId;
-use crate::runtime_common::config::xcm::*;
-use crate::*;
use pallet_foreing_assets::{
- AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, CurrencyId, NativeCurrency, FreeForAll,
- TryAsForeing, ForeignAssetId,
+ AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, CurrencyId, NativeCurrency,
};
// Signed version of balance
pub type Amount = i128;
-
-parameter_types! {
- pub const RelayLocation: MultiLocation = MultiLocation::parent();
- pub const RelayNetwork: NetworkId = NetworkId::Polkadot;
- pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();
- pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();
- pub SelfLocation: MultiLocation = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));
-}
-/// This is the type we use to convert an (incoming) XCM origin into a local `Origin` instance,
-/// ready for dispatching a transaction with Xcm's `Transact`. There is an `OriginKind` which can
-/// biases the kind of local `Origin` it will become.
-pub type XcmOriginToTransactDispatchOrigin = (
- // Sovereign account converter; this attempts to derive an `AccountId` from the origin location
- // using `LocationToAccountId` and then turn that into the usual `Signed` origin. Useful for
- // foreign chains who want to have a local sovereign account on this chain which they control.
- SovereignSignedViaLocation<LocationToAccountId, Origin>,
- // Native converter for Relay-chain (Parent) location; will converts to a `Relay` origin when
- // recognised.
- RelayChainAsNative<RelayOrigin, Origin>,
- // Native converter for sibling Parachains; will convert to a `SiblingPara` origin when
- // recognised.
- SiblingParachainAsNative<cumulus_pallet_xcm::Origin, Origin>,
- // Superuser converter for the Relay-chain (Parent) location. This will allow it to issue a
- // transaction from the Root origin.
- ParentAsSuperuser<Origin>,
- // Native signed account converter; this just converts an `AccountId32` origin into a normal
- // `Origin::Signed` origin of the same 32-byte value.
- SignedAccountId32AsNative<RelayNetwork, Origin>,
- // Xcm origins can be represented natively under the Xcm pallet's Xcm origin.
- XcmPassthrough<Origin>,
-);
-
-parameter_types! {
- // One XCM operation is 1_000_000 weight - almost certainly a conservative estimate.
- pub UnitWeightCost: Weight = 1_000_000;
- // 1200 UNIQUEs buy 1 second of weight.
- pub const WeightPrice: (MultiLocation, u128) = (MultiLocation::parent(), 1_200 * UNIQUE);
- pub const MaxInstructions: u32 = 100;
- pub const MaxAuthorities: u32 = 100_000;
-}
-
match_types! {
pub type ParentOrParentsUnitPlurality: impl Contains<MultiLocation> = {
MultiLocation { parents: 1, interior: Here } |
@@ -123,8 +66,8 @@
fn should_execute<Call>(
_origin: &MultiLocation,
_message: &mut Xcm<Call>,
- max_weight: Weight,
- weight_credit: &mut Weight,
+ _max_weight: Weight,
+ _weight_credit: &mut Weight,
) -> Result<(), ()> {
Ok(())
}
@@ -138,31 +81,9 @@
AllowUnpaidExecutionFrom<ParentOrParentsUnitPlurality>,
// ^^^ Parent & its unit plurality gets free execution
AllowAllDebug,
- )
+ ),
>;
-
-pub struct AllAsset;
-impl FilterAssetLocation for AllAsset {
- fn filter_asset_location(asset: &MultiAsset, origin: &MultiLocation) -> bool {
- true
- }
-}
-pub struct CurrencyIdConvert;
-impl Convert<AssetIds, Option<MultiLocation>> for CurrencyIdConvert {
- fn convert(id: AssetIds) -> Option<MultiLocation> {
- match id {
- AssetIds::NativeAssetId(NativeCurrency::Here) => Some(MultiLocation::new(
- 1,
- X1(Parachain(ParachainInfo::get().into())),
- )),
- AssetIds::NativeAssetId(NativeCurrency::Parent) => Some(MultiLocation::parent()),
- AssetIds::ForeignAssetId(foreign_asset_id) => {
- XcmForeignAssetIdMapping::<Runtime>::get_multi_location(foreign_asset_id)
- }
- }
- }
-}
impl Convert<MultiLocation, Option<CurrencyId>> for CurrencyIdConvert {
fn convert(location: MultiLocation) -> Option<CurrencyId> {
if location == MultiLocation::here()
@@ -185,15 +106,39 @@
}
}
-pub fn get_all_module_accounts() -> Vec<AccountId> {
- vec![TreasuryModuleId::get().into_account_truncating()]
+impl orml_tokens::Config for Runtime {
+ type Event = Event;
+ type Balance = Balance;
+ type Amount = Amount;
+ type CurrencyId = CurrencyId;
+ type WeightInfo = ();
+ type ExistentialDeposits = ExistentialDeposits;
+ type OnDust = orml_tokens::TransferDust<Runtime, TreasuryAccountId>;
+ type MaxLocks = MaxLocks;
+ type MaxReserves = MaxReserves;
+ // TODO: Add all module accounts
+ type DustRemovalWhitelist = DustRemovalWhitelist;
+ /// The id type for named reserves.
+ type ReserveIdentifier = ();
+ type OnNewTokenAccount = ();
+ type OnKilledTokenAccount = ();
}
-pub struct DustRemovalWhitelist;
-impl Contains<AccountId> for DustRemovalWhitelist {
- fn contains(a: &AccountId) -> bool {
- get_all_module_accounts().contains(a)
- }
+impl orml_xtokens::Config for Runtime {
+ type Event = Event;
+ type Balance = Balance;
+ type CurrencyId = CurrencyId;
+ type CurrencyIdConvert = CurrencyIdConvert;
+ type AccountIdToMultiLocation = AccountIdToMultiLocation;
+ type SelfLocation = SelfLocation;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+ type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
+ type BaseXcmWeight = BaseXcmWeight;
+ type LocationInverter = LocationInverter<Ancestry>;
+ type MaxAssetsForTransfer = MaxAssetsForTransfer;
+ type MinXcmFee = ParachainMinFee;
+ type MultiLocationsFilter = Everything;
+ type ReserveProvider = AbsoluteReserveProvider;
}
parameter_type_with_key! {
@@ -208,27 +153,35 @@
};
}
-impl orml_tokens::Config for Runtime {
- type Event = Event;
- type Balance = Balance;
- type Amount = Amount;
- type CurrencyId = CurrencyId;
- type WeightInfo = ();
- type ExistentialDeposits = ExistentialDeposits;
- type OnDust = orml_tokens::TransferDust<Runtime, TreasuryAccountId>;
- type MaxLocks = MaxLocks;
- type MaxReserves = MaxReserves;
- // TODO: Add all module accounts
- type DustRemovalWhitelist = DustRemovalWhitelist;
- /// The id type for named reserves.
- type ReserveIdentifier = ();
- type OnNewTokenAccount = ();
- type OnKilledTokenAccount = ();
+pub struct DustRemovalWhitelist;
+impl Contains<AccountId> for DustRemovalWhitelist {
+ fn contains(a: &AccountId) -> bool {
+ get_all_module_accounts().contains(a)
+ }
+}
+
+pub struct CurrencyIdConvert;
+impl Convert<AssetIds, Option<MultiLocation>> for CurrencyIdConvert {
+ fn convert(id: AssetIds) -> Option<MultiLocation> {
+ match id {
+ AssetIds::NativeAssetId(NativeCurrency::Here) => Some(MultiLocation::new(
+ 1,
+ X1(Parachain(ParachainInfo::get().into())),
+ )),
+ AssetIds::NativeAssetId(NativeCurrency::Parent) => Some(MultiLocation::parent()),
+ AssetIds::ForeignAssetId(foreign_asset_id) => {
+ XcmForeignAssetIdMapping::<Runtime>::get_multi_location(foreign_asset_id)
+ }
+ }
+ }
}
parameter_types! {
pub const BaseXcmWeight: Weight = 100_000_000; // TODO: recheck this
pub const MaxAssetsForTransfer: usize = 2;
+
+ pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();
+ pub SelfLocation: MultiLocation = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));
}
parameter_type_with_key! {
@@ -237,6 +190,9 @@
};
}
+pub fn get_all_module_accounts() -> Vec<AccountId> {
+ vec![TreasuryModuleId::get().into_account_truncating()]
+}
pub struct AccountIdToMultiLocation;
impl Convert<AccountId, MultiLocation> for AccountIdToMultiLocation {
fn convert(account: AccountId) -> MultiLocation {
@@ -246,21 +202,4 @@
})
.into()
}
-}
-
-impl orml_xtokens::Config for Runtime {
- type Event = Event;
- type Balance = Balance;
- type CurrencyId = CurrencyId;
- type CurrencyIdConvert = CurrencyIdConvert;
- type AccountIdToMultiLocation = AccountIdToMultiLocation;
- type SelfLocation = SelfLocation;
- type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
- type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
- type BaseXcmWeight = BaseXcmWeight;
- type LocationInverter = LocationInverter<Ancestry>;
- type MaxAssetsForTransfer = MaxAssetsForTransfer;
- type MinXcmFee = ParachainMinFee;
- type MultiLocationsFilter = Everything;
- type ReserveProvider = AbsoluteReserveProvider;
}
runtime/quartz/src/tests/logcapture.rsdiffbeforeafterboth--- a/runtime/quartz/src/tests/logcapture.rs
+++ b/runtime/quartz/src/tests/logcapture.rs
@@ -19,7 +19,7 @@
#[test]
fn quartz_log_capture_tests() {
- let mut logger = Logger::start();
-
- quartz_xcm_tests(&mut logger);
+ let mut logger = Logger::start();
+
+ quartz_xcm_tests(&mut logger);
}
runtime/quartz/src/tests/mod.rsdiffbeforeafterboth--- a/runtime/quartz/src/tests/mod.rs
+++ b/runtime/quartz/src/tests/mod.rs
@@ -14,5 +14,5 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
+mod logcapture;
mod xcm;
-mod logcapture;
runtime/quartz/src/tests/xcm.rsdiffbeforeafterboth--- a/runtime/quartz/src/tests/xcm.rs
+++ b/runtime/quartz/src/tests/xcm.rs
@@ -15,18 +15,13 @@
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
use logtest::Logger;
-use crate::{
- runtime_common::tests::xcm::*,
- xcm_config::Barrier,
-};
+use crate::{runtime_common::tests::xcm::*, xcm_config::Barrier};
const QUARTZ_PARA_ID: u32 = 2095;
pub fn quartz_xcm_tests(logger: &mut Logger) {
- barrier_denies_transact::<Barrier>(logger);
+ barrier_denies_transact::<Barrier>(logger);
- barrier_denies_transfer_from_unknown_location::<Barrier>(
- logger,
- QUARTZ_PARA_ID,
- ).expect("quartz runtime denies an unknown location");
+ barrier_denies_transfer_from_unknown_location::<Barrier>(logger, QUARTZ_PARA_ID)
+ .expect("quartz runtime denies an unknown location");
}
runtime/quartz/src/xcm_config.rsdiffbeforeafterboth--- a/runtime/quartz/src/xcm_config.rs
+++ b/runtime/quartz/src/xcm_config.rs
@@ -14,53 +14,31 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
-use cumulus_pallet_xcm;
use frame_support::{
- {match_types, parameter_types, weights::Weight},
- pallet_prelude::Get,
- traits::{Contains, Everything, fungibles},
+ {match_types, parameter_types, weights::Weight},
+ pallet_prelude::Get,
+ traits::{Contains, Everything},
};
-use frame_system::EnsureRoot;
use orml_traits::{location::AbsoluteReserveProvider, parameter_type_with_key};
-use pallet_xcm::XcmPassthrough;
-use polkadot_parachain::primitives::Sibling;
-use sp_runtime::traits::{AccountIdConversion, CheckedConversion, Convert, Zero};
-use sp_std::{borrow::Borrow, marker::PhantomData, vec, vec::Vec};
+use sp_runtime::traits::{AccountIdConversion, Convert};
+use sp_std::{vec, vec::Vec};
use xcm::{
- latest::{MultiAsset, Xcm},
- prelude::{Concrete, Fungible as XcmFungible},
- v1::{BodyId, Junction::*, Junctions::*, MultiLocation, NetworkId},
+ latest::Xcm,
+ v1::{BodyId, Junction::*, Junctions::*, MultiLocation, NetworkId},
};
use xcm_builder::{
- AllowKnownQueryResponses, AllowSubscriptionsFrom,
- AccountId32Aliases, AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom,
- EnsureXcmOrigin, FixedWeightBounds, FungiblesAdapter, LocationInverter, ParentAsSuperuser,
- ParentIsPreset, RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,
- SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,
- ConvertedConcreteAssetId,
+ AllowKnownQueryResponses, AllowSubscriptionsFrom, AllowTopLevelPaidExecutionFrom,
+ AllowUnpaidExecutionFrom, FixedWeightBounds, LocationInverter, TakeWeightCredit,
};
-use xcm_executor::{
- {Config, XcmExecutor},
- traits::{Convert as ConvertXcm, FilterAssetLocation, JustTry, MatchesFungible},
-};
+use xcm_executor::XcmExecutor;
-use up_common::{
- constants::{MAXIMUM_BLOCK_WEIGHT, UNIQUE},
- types::{AccountId, Balance},
-};
-use pallet_foreing_assets::{
- AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, CurrencyId, NativeCurrency,
- FreeForAll, TryAsForeing, ForeignAssetId,
-};
-use crate::{
- Balances, Call, DmpQueue, Event, Origin, ParachainInfo,
- ParachainSystem, PolkadotXcm, Runtime, XcmpQueue,
-};
+use up_common::types::{AccountId, Balance};
+use pallet_foreing_assets::{AssetIds, CurrencyId, NativeCurrency};
+use crate::{Call, Event, ParachainInfo, PolkadotXcm, Runtime};
use crate::runtime_common::config::substrate::{TreasuryModuleId, MaxLocks, MaxReserves};
use crate::runtime_common::config::pallets::TreasuryAccountId;
use crate::runtime_common::config::xcm::*;
-use crate::*;
-use xcm::opaque::latest::prelude::{ DepositReserveAsset, DepositAsset, TransferAsset, TransferReserveAsset };
+use xcm::opaque::latest::prelude::{DepositReserveAsset, TransferReserveAsset};
// Signed version of balance
pub type Amount = i128;
@@ -76,103 +54,113 @@
};
}
+pub type Barrier = DenyThenTry<
+ (DenyTransact, DenyExchangeWithUnknownLocation),
+ (
+ TakeWeightCredit,
+ AllowTopLevelPaidExecutionFrom<Everything>,
+ // Parent and its exec plurality get free execution
+ AllowUnpaidExecutionFrom<ParentOrParentsExecutivePlurality>,
+ // Expected responses are OK.
+ AllowKnownQueryResponses<PolkadotXcm>,
+ // Subscriptions for version tracking are OK.
+ AllowSubscriptionsFrom<ParentOrSiblings>,
+ ),
+>;
+
pub fn get_allowed_locations() -> Vec<MultiLocation> {
- vec![
- // Self location
- MultiLocation { parents: 0, interior: Here },
- // Parent location
- MultiLocation { parents: 1, interior: Here },
- // Karura/Acala location
- MultiLocation { parents: 1, interior: X1(Parachain(2000)) },
- // Moonriver location
- MultiLocation { parents: 1, interior: X1(Parachain(2023)) },
- // Self parachain address
- MultiLocation { parents: 1, interior: X1(Parachain(ParachainInfo::get().into())) },
- ]
+ vec![
+ // Self location
+ MultiLocation {
+ parents: 0,
+ interior: Here,
+ },
+ // Parent location
+ MultiLocation {
+ parents: 1,
+ interior: Here,
+ },
+ // Karura/Acala location
+ MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(2000)),
+ },
+ // Moonriver location
+ MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(2023)),
+ },
+ // Self parachain address
+ MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(ParachainInfo::get().into())),
+ },
+ ]
}
// Allow xcm exchange only with locations in list
pub struct DenyExchangeWithUnknownLocation;
impl TryPass for DenyExchangeWithUnknownLocation {
- fn try_pass<Call>(
- origin: &MultiLocation,
- message: &mut Xcm<Call>,
- ) -> Result<(), ()> {
+ fn try_pass<Call>(origin: &MultiLocation, message: &mut Xcm<Call>) -> Result<(), ()> {
+ // Check if deposit or transfer belongs to allowed parachains
+ let mut allowed = get_allowed_locations().contains(origin);
- // Check if deposit or transfer belongs to allowed parachains
- let mut allowed = get_allowed_locations().contains(origin);
+ message.0.iter().for_each(|inst| match inst {
+ DepositReserveAsset { dest: dst, .. } => {
+ allowed |= get_allowed_locations().contains(dst);
+ }
+ TransferReserveAsset { dest: dst, .. } => {
+ allowed |= get_allowed_locations().contains(dst);
+ }
+ _ => {}
+ });
- message.0.iter().for_each(|inst| {
- match inst {
- DepositReserveAsset { dest: dst, .. } => { allowed |= get_allowed_locations().contains(dst); }
- TransferReserveAsset { dest: dst, .. } => { allowed |= get_allowed_locations().contains(dst); }
- _ => {}
- }
- });
+ if allowed {
+ return Ok(());
+ }
- if allowed {
- return Ok(());
- }
-
- log::warn!(
+ log::warn!(
target: "xcm::barrier",
"Unexpected deposit or transfer location"
);
- // Deny
- Err(())
- }
+ // Deny
+ Err(())
+ }
}
-pub type Barrier = DenyThenTry<
- (
- DenyTransact,
- DenyExchangeWithUnknownLocation,
- ),
- (
- TakeWeightCredit,
- AllowTopLevelPaidExecutionFrom<Everything>,
- // Parent and its exec plurality get free execution
- AllowUnpaidExecutionFrom<ParentOrParentsExecutivePlurality>,
- // Expected responses are OK.
- AllowKnownQueryResponses<PolkadotXcm>,
- // Subscriptions for version tracking are OK.
- AllowSubscriptionsFrom<ParentOrSiblings>,
- ),
->;
-
impl orml_tokens::Config for Runtime {
- type Event = Event;
- type Balance = Balance;
- type Amount = Amount;
- type CurrencyId = CurrencyId;
- type WeightInfo = ();
- type ExistentialDeposits = ExistentialDeposits;
- type OnDust = orml_tokens::TransferDust<Runtime, TreasuryAccountId>;
- type MaxLocks = MaxLocks;
- type MaxReserves = MaxReserves;
- // TODO: Add all module accounts
- type DustRemovalWhitelist = DustRemovalWhitelist;
- /// The id type for named reserves.
- type ReserveIdentifier = ();
- type OnNewTokenAccount = ();
- type OnKilledTokenAccount = ();
+ type Event = Event;
+ type Balance = Balance;
+ type Amount = Amount;
+ type CurrencyId = CurrencyId;
+ type WeightInfo = ();
+ type ExistentialDeposits = ExistentialDeposits;
+ type OnDust = orml_tokens::TransferDust<Runtime, TreasuryAccountId>;
+ type MaxLocks = MaxLocks;
+ type MaxReserves = MaxReserves;
+ // TODO: Add all module accounts
+ type DustRemovalWhitelist = DustRemovalWhitelist;
+ /// The id type for named reserves.
+ type ReserveIdentifier = ();
+ type OnNewTokenAccount = ();
+ type OnKilledTokenAccount = ();
}
impl orml_xtokens::Config for Runtime {
- type Event = Event;
- type Balance = Balance;
- type CurrencyId = CurrencyId;
- type CurrencyIdConvert = CurrencyIdConvert;
- type AccountIdToMultiLocation = AccountIdToMultiLocation;
- type SelfLocation = SelfLocation;
- type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
- type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
- type BaseXcmWeight = BaseXcmWeight;
- type LocationInverter = LocationInverter<Ancestry>;
- type MaxAssetsForTransfer = MaxAssetsForTransfer;
- type MinXcmFee = ParachainMinFee;
- type MultiLocationsFilter = Everything;
- type ReserveProvider = AbsoluteReserveProvider;
+ type Event = Event;
+ type Balance = Balance;
+ type CurrencyId = CurrencyId;
+ type CurrencyIdConvert = CurrencyIdConvert;
+ type AccountIdToMultiLocation = AccountIdToMultiLocation;
+ type SelfLocation = SelfLocation;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+ type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
+ type BaseXcmWeight = BaseXcmWeight;
+ type LocationInverter = LocationInverter<Ancestry>;
+ type MaxAssetsForTransfer = MaxAssetsForTransfer;
+ type MinXcmFee = ParachainMinFee;
+ type MultiLocationsFilter = Everything;
+ type ReserveProvider = AbsoluteReserveProvider;
}
parameter_type_with_key! {
@@ -189,34 +177,28 @@
pub struct DustRemovalWhitelist;
impl Contains<AccountId> for DustRemovalWhitelist {
- fn contains(a: &AccountId) -> bool {
- get_all_module_accounts().contains(a)
- }
+ fn contains(a: &AccountId) -> bool {
+ get_all_module_accounts().contains(a)
+ }
}
pub struct CurrencyIdConvert;
impl Convert<AssetIds, Option<MultiLocation>> for CurrencyIdConvert {
- fn convert(id: AssetIds) -> Option<MultiLocation> {
- match id {
- AssetIds::NativeAssetId(NativeCurrency::Here) => Some(MultiLocation::new(
- 1,
- X1(Parachain(ParachainInfo::get().into())),
- )),
- AssetIds::NativeAssetId(NativeCurrency::Parent) => Some(MultiLocation::parent()),
- AssetIds::ForeignAssetId(_) => None,
- }
- }
+ fn convert(id: AssetIds) -> Option<MultiLocation> {
+ match id {
+ AssetIds::NativeAssetId(NativeCurrency::Here) => Some(MultiLocation::new(
+ 1,
+ X1(Parachain(ParachainInfo::get().into())),
+ )),
+ _ => None,
+ }
+ }
}
parameter_types! {
pub const BaseXcmWeight: Weight = 100_000_000; // TODO: recheck this
pub const MaxAssetsForTransfer: usize = 2;
-}
-parameter_types! {
- pub const RelayLocation: MultiLocation = MultiLocation::parent();
- pub const RelayNetwork: NetworkId = NetworkId::Polkadot;
- pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();
pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();
pub SelfLocation: MultiLocation = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));
}
@@ -228,16 +210,16 @@
}
pub fn get_all_module_accounts() -> Vec<AccountId> {
- vec![TreasuryModuleId::get().into_account_truncating()]
+ vec![TreasuryModuleId::get().into_account_truncating()]
}
pub struct AccountIdToMultiLocation;
impl Convert<AccountId, MultiLocation> for AccountIdToMultiLocation {
- fn convert(account: AccountId) -> MultiLocation {
- X1(AccountId32 {
- network: NetworkId::Any,
- id: account.into(),
- })
- .into()
- }
+ fn convert(account: AccountId) -> MultiLocation {
+ X1(AccountId32 {
+ network: NetworkId::Any,
+ id: account.into(),
+ })
+ .into()
+ }
}
runtime/unique/src/tests/logcapture.rsdiffbeforeafterboth--- a/runtime/unique/src/tests/logcapture.rs
+++ b/runtime/unique/src/tests/logcapture.rs
@@ -19,7 +19,7 @@
#[test]
fn unique_log_capture_tests() {
- let mut logger = Logger::start();
-
- unique_xcm_tests(&mut logger);
+ let mut logger = Logger::start();
+
+ unique_xcm_tests(&mut logger);
}
runtime/unique/src/tests/mod.rsdiffbeforeafterboth--- a/runtime/unique/src/tests/mod.rs
+++ b/runtime/unique/src/tests/mod.rs
@@ -14,5 +14,5 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
+mod logcapture;
mod xcm;
-mod logcapture;
runtime/unique/src/tests/xcm.rsdiffbeforeafterboth--- a/runtime/unique/src/tests/xcm.rs
+++ b/runtime/unique/src/tests/xcm.rs
@@ -15,18 +15,13 @@
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
use logtest::Logger;
-use crate::{
- runtime_common::tests::xcm::*,
- xcm_config::Barrier,
-};
+use crate::{runtime_common::tests::xcm::*, xcm_config::Barrier};
const UNIQUE_PARA_ID: u32 = 2037;
pub fn unique_xcm_tests(logger: &mut Logger) {
- barrier_denies_transact::<Barrier>(logger);
+ barrier_denies_transact::<Barrier>(logger);
- barrier_denies_transfer_from_unknown_location::<Barrier>(
- logger,
- UNIQUE_PARA_ID,
- ).expect("unique runtime denies an unknown location");
+ barrier_denies_transfer_from_unknown_location::<Barrier>(logger, UNIQUE_PARA_ID)
+ .expect("unique runtime denies an unknown location");
}
runtime/unique/src/xcm_config.rsdiffbeforeafterboth--- a/runtime/unique/src/xcm_config.rs
+++ b/runtime/unique/src/xcm_config.rs
@@ -14,143 +14,153 @@
// You should have received a copy of the GNU General Public License
// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.
-use cumulus_pallet_xcm;
use frame_support::{
- {match_types, parameter_types, weights::Weight},
- pallet_prelude::Get,
- traits::{Contains, Everything, fungibles},
+ {match_types, parameter_types, weights::Weight},
+ pallet_prelude::Get,
+ traits::{Contains, Everything},
};
-use frame_system::EnsureRoot;
use orml_traits::{location::AbsoluteReserveProvider, parameter_type_with_key};
-use pallet_xcm::XcmPassthrough;
-use polkadot_parachain::primitives::Sibling;
-use sp_runtime::traits::{AccountIdConversion, CheckedConversion, Convert, Zero};
-use sp_std::{borrow::Borrow, marker::PhantomData, vec, vec::Vec};
+use sp_runtime::traits::{AccountIdConversion, Convert};
+use sp_std::{vec, vec::Vec};
use xcm::{
- latest::{MultiAsset, Xcm},
- prelude::{Concrete, Fungible as XcmFungible},
- v1::{BodyId, Junction::*, Junctions::*, MultiLocation, NetworkId},
+ latest::Xcm,
+ v1::{BodyId, Junction::*, Junctions::*, MultiLocation, NetworkId},
};
use xcm_builder::{
- AllowKnownQueryResponses, AllowSubscriptionsFrom,
- AccountId32Aliases, AllowTopLevelPaidExecutionFrom, AllowUnpaidExecutionFrom,
- EnsureXcmOrigin, FixedWeightBounds, FungiblesAdapter, LocationInverter, ParentAsSuperuser,
- ParentIsPreset, RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,
- SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,
- ConvertedConcreteAssetId,
+ AllowKnownQueryResponses, AllowSubscriptionsFrom, AllowTopLevelPaidExecutionFrom,
+ AllowUnpaidExecutionFrom, FixedWeightBounds, LocationInverter, TakeWeightCredit,
};
-use xcm_executor::{
- {Config, XcmExecutor},
- traits::{Convert as ConvertXcm, FilterAssetLocation, JustTry, MatchesFungible},
-};
+use xcm_executor::XcmExecutor;
-use up_common::{
- constants::{MAXIMUM_BLOCK_WEIGHT, UNIQUE},
- types::{AccountId, Balance},
-};
-use pallet_foreing_assets::{
- AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, CurrencyId, NativeCurrency,
- FreeForAll, TryAsForeing, ForeignAssetId,
-};
-use crate::{
- Balances, Call, DmpQueue, Event, Origin, ParachainInfo,
- ParachainSystem, PolkadotXcm, Runtime, XcmpQueue,
-};
+use up_common::types::{AccountId, Balance};
+use pallet_foreing_assets::{AssetIds, CurrencyId, NativeCurrency};
+use crate::{Call, Event, ParachainInfo, PolkadotXcm, Runtime};
use crate::runtime_common::config::substrate::{TreasuryModuleId, MaxLocks, MaxReserves};
use crate::runtime_common::config::pallets::TreasuryAccountId;
use crate::runtime_common::config::xcm::*;
-use crate::*;
-use xcm::opaque::latest::prelude::{ DepositReserveAsset, DepositAsset, TransferAsset, TransferReserveAsset };
+use xcm::opaque::latest::prelude::{DepositReserveAsset, TransferReserveAsset};
// Signed version of balance
pub type Amount = i128;
+match_types! {
+ pub type ParentOrParentsExecutivePlurality: impl Contains<MultiLocation> = {
+ MultiLocation { parents: 1, interior: Here } |
+ MultiLocation { parents: 1, interior: X1(Plurality { id: BodyId::Executive, .. }) }
+ };
+ pub type ParentOrSiblings: impl Contains<MultiLocation> = {
+ MultiLocation { parents: 1, interior: Here } |
+ MultiLocation { parents: 1, interior: X1(_) }
+ };
+}
pub type Barrier = DenyThenTry<
- (
- DenyTransact,
- DenyExchangeWithUnknownLocation,
- ),
- (
- TakeWeightCredit,
- AllowTopLevelPaidExecutionFrom<Everything>,
- // Parent and its exec plurality get free execution
- AllowUnpaidExecutionFrom<ParentOrParentsExecutivePlurality>,
- // Expected responses are OK.
- AllowKnownQueryResponses<PolkadotXcm>,
- // Subscriptions for version tracking are OK.
- AllowSubscriptionsFrom<ParentOrSiblings>,
- ),
+ (DenyTransact, DenyExchangeWithUnknownLocation),
+ (
+ TakeWeightCredit,
+ AllowTopLevelPaidExecutionFrom<Everything>,
+ // Parent and its exec plurality get free execution
+ AllowUnpaidExecutionFrom<ParentOrParentsExecutivePlurality>,
+ // Expected responses are OK.
+ AllowKnownQueryResponses<PolkadotXcm>,
+ // Subscriptions for version tracking are OK.
+ AllowSubscriptionsFrom<ParentOrSiblings>,
+ ),
>;
pub fn get_allowed_locations() -> Vec<MultiLocation> {
- vec![
- // Self location
- MultiLocation { parents: 0, interior: Here },
- // Parent location
- MultiLocation { parents: 1, interior: Here },
- // Karura/Acala location
- MultiLocation { parents: 1, interior: X1(Parachain(2000)) },
- // Moonbeam location
- MultiLocation { parents: 1, interior: X1(Parachain(2004)) },
- // Self parachain address
- MultiLocation { parents: 1, interior: X1(Parachain(ParachainInfo::get().into())) },
- ]
+ vec![
+ // Self location
+ MultiLocation {
+ parents: 0,
+ interior: Here,
+ },
+ // Parent location
+ MultiLocation {
+ parents: 1,
+ interior: Here,
+ },
+ // Karura/Acala location
+ MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(2000)),
+ },
+ // Moonbeam location
+ MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(2004)),
+ },
+ // Self parachain address
+ MultiLocation {
+ parents: 1,
+ interior: X1(Parachain(ParachainInfo::get().into())),
+ },
+ ]
}
// Allow xcm exchange only with locations in list
pub struct DenyExchangeWithUnknownLocation;
impl TryPass for DenyExchangeWithUnknownLocation {
- fn try_pass<Call>(
- origin: &MultiLocation,
- message: &mut Xcm<Call>,
- ) -> Result<(), ()> {
+ fn try_pass<Call>(origin: &MultiLocation, message: &mut Xcm<Call>) -> Result<(), ()> {
+ // Check if deposit or transfer belongs to allowed parachains
+ let mut allowed = get_allowed_locations().contains(origin);
- // Check if deposit or transfer belongs to allowed parachains
- let mut allowed = get_allowed_locations().contains(origin);
-
- message.0.iter().for_each(|inst| {
- match inst {
- DepositReserveAsset { dest: dst, .. } => { allowed |= get_allowed_locations().contains(dst); }
- TransferReserveAsset { dest: dst, .. } => { allowed |= get_allowed_locations().contains(dst); }
- _ => {}
- }
- });
+ message.0.iter().for_each(|inst| match inst {
+ DepositReserveAsset { dest: dst, .. } => {
+ allowed |= get_allowed_locations().contains(dst);
+ }
+ TransferReserveAsset { dest: dst, .. } => {
+ allowed |= get_allowed_locations().contains(dst);
+ }
+ _ => {}
+ });
- if allowed {
- return Ok(());
- }
+ if allowed {
+ return Ok(());
+ }
- log::warn!(
+ log::warn!(
target: "xcm::barrier",
"Unexpected deposit or transfer location"
);
- // Deny
- Err(())
- }
-}
-
-
-match_types! {
- pub type ParentOrParentsExecutivePlurality: impl Contains<MultiLocation> = {
- MultiLocation { parents: 1, interior: Here } |
- MultiLocation { parents: 1, interior: X1(Plurality { id: BodyId::Executive, .. }) }
- };
- pub type ParentOrSiblings: impl Contains<MultiLocation> = {
- MultiLocation { parents: 1, interior: Here } |
- MultiLocation { parents: 1, interior: X1(_) }
- };
+ // Deny
+ Err(())
+ }
}
-pub fn get_all_module_accounts() -> Vec<AccountId> {
- vec![TreasuryModuleId::get().into_account_truncating()]
+impl orml_tokens::Config for Runtime {
+ type Event = Event;
+ type Balance = Balance;
+ type Amount = Amount;
+ type CurrencyId = CurrencyId;
+ type WeightInfo = ();
+ type ExistentialDeposits = ExistentialDeposits;
+ type OnDust = orml_tokens::TransferDust<Runtime, TreasuryAccountId>;
+ type MaxLocks = MaxLocks;
+ type MaxReserves = MaxReserves;
+ // TODO: Add all module accounts
+ type DustRemovalWhitelist = DustRemovalWhitelist;
+ /// The id type for named reserves.
+ type ReserveIdentifier = ();
+ type OnNewTokenAccount = ();
+ type OnKilledTokenAccount = ();
}
-pub struct DustRemovalWhitelist;
-impl Contains<AccountId> for DustRemovalWhitelist {
- fn contains(a: &AccountId) -> bool {
- get_all_module_accounts().contains(a)
- }
+impl orml_xtokens::Config for Runtime {
+ type Event = Event;
+ type Balance = Balance;
+ type CurrencyId = CurrencyId;
+ type CurrencyIdConvert = CurrencyIdConvert;
+ type AccountIdToMultiLocation = AccountIdToMultiLocation;
+ type SelfLocation = SelfLocation;
+ type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
+ type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
+ type BaseXcmWeight = BaseXcmWeight;
+ type LocationInverter = LocationInverter<Ancestry>;
+ type MaxAssetsForTransfer = MaxAssetsForTransfer;
+ type MinXcmFee = ParachainMinFee;
+ type MultiLocationsFilter = Everything;
+ type ReserveProvider = AbsoluteReserveProvider;
}
parameter_type_with_key! {
@@ -165,60 +175,32 @@
};
}
-impl orml_tokens::Config for Runtime {
- type Event = Event;
- type Balance = Balance;
- type Amount = Amount;
- type CurrencyId = CurrencyId;
- type WeightInfo = ();
- type ExistentialDeposits = ExistentialDeposits;
- type OnDust = orml_tokens::TransferDust<Runtime, TreasuryAccountId>;
- type MaxLocks = MaxLocks;
- type MaxReserves = MaxReserves;
- // TODO: Add all module accounts
- type DustRemovalWhitelist = DustRemovalWhitelist;
- /// The id type for named reserves.
- type ReserveIdentifier = ();
- type OnNewTokenAccount = ();
- type OnKilledTokenAccount = ();
-}
-
-impl orml_xtokens::Config for Runtime {
- type Event = Event;
- type Balance = Balance;
- type CurrencyId = CurrencyId;
- type CurrencyIdConvert = CurrencyIdConvert;
- type AccountIdToMultiLocation = AccountIdToMultiLocation;
- type SelfLocation = SelfLocation;
- type XcmExecutor = XcmExecutor<XcmConfig<Self>>;
- type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;
- type BaseXcmWeight = BaseXcmWeight;
- type LocationInverter = LocationInverter<Ancestry>;
- type MaxAssetsForTransfer = MaxAssetsForTransfer;
- type MinXcmFee = ParachainMinFee;
- type MultiLocationsFilter = Everything;
- type ReserveProvider = AbsoluteReserveProvider;
+pub struct DustRemovalWhitelist;
+impl Contains<AccountId> for DustRemovalWhitelist {
+ fn contains(a: &AccountId) -> bool {
+ get_all_module_accounts().contains(a)
+ }
}
pub struct CurrencyIdConvert;
impl Convert<AssetIds, Option<MultiLocation>> for CurrencyIdConvert {
- fn convert(id: AssetIds) -> Option<MultiLocation> {
- match id {
- AssetIds::NativeAssetId(NativeCurrency::Here) => Some(MultiLocation::new(
- 1,
- X1(Parachain(ParachainInfo::get().into())),
- )),
- _ => None,
- }
- }
+ fn convert(id: AssetIds) -> Option<MultiLocation> {
+ match id {
+ AssetIds::NativeAssetId(NativeCurrency::Here) => Some(MultiLocation::new(
+ 1,
+ X1(Parachain(ParachainInfo::get().into())),
+ )),
+ _ => None,
+ }
+ }
}
parameter_types! {
pub const BaseXcmWeight: Weight = 100_000_000; // TODO: recheck this
pub const MaxAssetsForTransfer: usize = 2;
- pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();
- pub SelfLocation: MultiLocation = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));
+ pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();
+ pub SelfLocation: MultiLocation = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));
}
parameter_type_with_key! {
@@ -227,14 +209,17 @@
};
}
+pub fn get_all_module_accounts() -> Vec<AccountId> {
+ vec![TreasuryModuleId::get().into_account_truncating()]
+}
pub struct AccountIdToMultiLocation;
impl Convert<AccountId, MultiLocation> for AccountIdToMultiLocation {
- fn convert(account: AccountId) -> MultiLocation {
- X1(AccountId32 {
- network: NetworkId::Any,
- id: account.into(),
- })
- .into()
- }
+ fn convert(account: AccountId) -> MultiLocation {
+ X1(AccountId32 {
+ network: NetworkId::Any,
+ id: account.into(),
+ })
+ .into()
+ }
}