1234567891011121314151617use 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,37 Instruction, Xcm,38};39use xcm_builder::{40 AccountId32Aliases, AllowTopLevelPaidExecutionFrom, CurrencyAdapter, EnsureXcmOrigin,41 FixedWeightBounds, FungiblesAdapter, LocationInverter, NativeAsset, ParentAsSuperuser,42 RelayChainAsNative, SiblingParachainAsNative, SiblingParachainConvertsVia,43 SignedAccountId32AsNative, SignedToAccountId32, SovereignSignedViaLocation, TakeWeightCredit,44 ParentIsPreset, ConvertedConcreteAssetId,45};46use xcm_executor::{Config, XcmExecutor, Assets};47use xcm_executor::traits::{48 Convert as ConvertXcm, JustTry, MatchesFungible, WeightTrader, FilterAssetLocation,49 ShouldExecute,50};51use pallet_foreing_assets::{52 AssetIds, AssetIdMapping, XcmForeignAssetIdMapping, CurrencyId, NativeCurrency, FreeForAll,53 TryAsForeing, ForeignAssetId,54};55use sp_std::{borrow::Borrow, marker::PhantomData, vec, vec::Vec};56use crate::{57 Runtime, Call, Event, Origin, Balances, ParachainInfo, ParachainSystem, PolkadotXcm, XcmpQueue,58 xcm_config::Barrier,59};60#[cfg(feature = "foreign-assets")]61use crate::ForeingAssets;6263use up_common::{64 types::{AccountId, Balance},65 constants::*,66};6768parameter_types! {69 pub const RelayLocation: MultiLocation = MultiLocation::parent();70 pub const RelayNetwork: NetworkId = NetworkId::Polkadot;71 pub RelayOrigin: Origin = cumulus_pallet_xcm::Origin::Relay.into();72 pub Ancestry: MultiLocation = Parachain(ParachainInfo::parachain_id().into()).into();73}7475767778pub type LocationToAccountId = (79 80 ParentIsPreset<AccountId>,81 82 SiblingParachainConvertsVia<Sibling, AccountId>,83 84 AccountId32Aliases<RelayNetwork, AccountId>,85);8687pub struct OnlySelfCurrency;88impl<B: TryFrom<u128>> MatchesFungible<B> for OnlySelfCurrency {89 fn matches_fungible(a: &MultiAsset) -> Option<B> {90 let paraid = Parachain(ParachainInfo::parachain_id().into());91 match (&a.id, &a.fun) {92 (93 Concrete(MultiLocation {94 parents: 1,95 interior: X1(loc),96 }),97 XcmFungible(ref amount),98 ) if paraid == *loc => CheckedConversion::checked_from(*amount),99 (100 Concrete(MultiLocation {101 parents: 0,102 interior: Here,103 }),104 XcmFungible(ref amount),105 ) => CheckedConversion::checked_from(*amount),106 _ => None,107 }108 }109}110111112pub type LocalAssetTransactor = CurrencyAdapter<113 114 Balances,115 116 OnlySelfCurrency,117 118 LocationToAccountId,119 120 AccountId,121 122 (),123>;124125126pub type LocalOriginToLocation = (SignedToAccountId32<Origin, AccountId, RelayNetwork>,);127128129130pub type XcmRouter = (131 132 cumulus_primitives_utility::ParentAsUmp<ParachainSystem, ()>,133 134 XcmpQueue,135);136137138139140pub type XcmOriginToTransactDispatchOrigin = (141 142 143 144 SovereignSignedViaLocation<LocationToAccountId, Origin>,145 146 147 RelayChainAsNative<RelayOrigin, Origin>,148 149 150 SiblingParachainAsNative<cumulus_pallet_xcm::Origin, Origin>,151 152 153 ParentAsSuperuser<Origin>,154 155 156 SignedAccountId32AsNative<RelayNetwork, Origin>,157 158 XcmPassthrough<Origin>,159);160161parameter_types! {162 163 pub UnitWeightCost: Weight = 1_000_000;164 165 pub const WeightPrice: (MultiLocation, u128) = (MultiLocation::parent(), 1_200 * UNIQUE);166 pub const MaxInstructions: u32 = 100;167}168169match_types! {170 pub type ParentOrParentsUnitPlurality: impl Contains<MultiLocation> = {171 MultiLocation { parents: 1, interior: Here } |172 MultiLocation { parents: 1, interior: X1(Plurality { id: BodyId::Unit, .. }) }173 };174}175176pub struct DenyTransact;177impl ShouldExecute for DenyTransact {178 fn should_execute<Call>(179 _origin: &MultiLocation,180 message: &mut Xcm<Call>,181 _max_weight: Weight,182 _weight_credit: &mut Weight,183 ) -> Result<(), ()> {184 let transact_inst = message.0.iter()185 .find(|inst| matches![inst, Instruction::Transact { .. }]);186187 match transact_inst {188 Some(_) => {189 log::warn!(190 target: "xcm::barrier",191 "transact XCM rejected"192 );193194 Err(())195 },196 None => Ok(())197 }198 }199}200201202203pub struct DenyThenTry<Deny, Allow>(PhantomData<Deny>, PhantomData<Allow>)204 where205 Deny: ShouldExecute,206 Allow: ShouldExecute;207208impl<Deny, Allow> ShouldExecute for DenyThenTry<Deny, Allow>209 where210 Deny: ShouldExecute,211 Allow: ShouldExecute,212{213 fn should_execute<Call>(214 origin: &MultiLocation,215 message: &mut Xcm<Call>,216 max_weight: Weight,217 weight_credit: &mut Weight,218 ) -> Result<(), ()> {219 Deny::should_execute(origin, message, max_weight, weight_credit)?;220 Allow::should_execute(origin, message, max_weight, weight_credit)221 }222}223224pub struct UsingOnlySelfCurrencyComponents<225 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,226 AssetId: Get<MultiLocation>,227 AccountId,228 Currency: CurrencyT<AccountId>,229 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,230>(231 Weight,232 Currency::Balance,233 PhantomData<(WeightToFee, AssetId, AccountId, Currency, OnUnbalanced)>,234);235impl<236 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,237 AssetId: Get<MultiLocation>,238 AccountId,239 Currency: CurrencyT<AccountId>,240 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,241 > WeightTrader242 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>243{244 fn new() -> Self {245 Self(0, Zero::zero(), PhantomData)246 }247248 fn buy_weight(&mut self, weight: Weight, payment: Assets) -> Result<Assets, XcmError> {249 Ok(payment)250 }251}252impl<253 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,254 AssetId: Get<MultiLocation>,255 AccountId,256 Currency: CurrencyT<AccountId>,257 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,258 > Drop259 for UsingOnlySelfCurrencyComponents<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>260{261 fn drop(&mut self) {262 OnUnbalanced::on_unbalanced(Currency::issue(self.1));263 }264}265266parameter_types! {267 pub CheckingAccount: AccountId = PolkadotXcm::check_account();268}269270#[cfg(feature = "foreign-assets")]271pub struct NonZeroIssuance<AccountId, ForeingAssets>(PhantomData<(AccountId, ForeingAssets)>);272273#[cfg(feature = "foreign-assets")]274impl<AccountId, ForeingAssets> Contains<<ForeingAssets as fungibles::Inspect<AccountId>>::AssetId>275 for NonZeroIssuance<AccountId, ForeingAssets>276where277 ForeingAssets: fungibles::Inspect<AccountId>,278{279 fn contains(id: &<ForeingAssets as fungibles::Inspect<AccountId>>::AssetId) -> bool {280 !ForeingAssets::total_issuance(*id).is_zero()281 }282}283284#[cfg(feature = "foreign-assets")]285pub struct AsInnerId<AssetId, ConvertAssetId>(PhantomData<(AssetId, ConvertAssetId)>);286#[cfg(feature = "foreign-assets")]287impl<AssetId: Clone + PartialEq, ConvertAssetId: ConvertXcm<AssetId, AssetId>>288 ConvertXcm<MultiLocation, AssetId> for AsInnerId<AssetId, ConvertAssetId>289where290 AssetId: Borrow<AssetId>,291 AssetId: TryAsForeing<AssetId, ForeignAssetId>,292 AssetIds: Borrow<AssetId>,293{294 fn convert_ref(id: impl Borrow<MultiLocation>) -> Result<AssetId, ()> {295 let id = id.borrow();296297 log::trace!(298 target: "xcm::AsInnerId::Convert",299 "AsInnerId {:?}",300 id301 );302303 let parent = MultiLocation::parent();304 let here = MultiLocation::here();305 let self_location = MultiLocation::new(1, X1(Parachain(ParachainInfo::get().into())));306307 if *id == parent {308 return ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Parent));309 }310311 if *id == here || *id == self_location {312 return ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Here));313 }314315 match XcmForeignAssetIdMapping::<Runtime>::get_currency_id(id.clone()) {316 Some(AssetIds::ForeignAssetId(foreign_asset_id)) => {317 ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(foreign_asset_id))318 }319 _ => ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(0)),320 }321 }322323 fn reverse_ref(what: impl Borrow<AssetId>) -> Result<MultiLocation, ()> {324 log::trace!(325 target: "xcm::AsInnerId::Reverse",326 "AsInnerId",327 );328329 let asset_id = what.borrow();330331 let parent_id =332 ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Parent)).unwrap();333 let here_id =334 ConvertAssetId::convert_ref(AssetIds::NativeAssetId(NativeCurrency::Here)).unwrap();335336 if asset_id.clone() == parent_id {337 return Ok(MultiLocation::parent());338 }339340 if asset_id.clone() == here_id {341 return Ok(MultiLocation::new(342 1,343 X1(Parachain(ParachainInfo::get().into())),344 ));345 }346347 match <AssetId as TryAsForeing<AssetId, ForeignAssetId>>::try_as_foreing(asset_id.clone()) {348 Some(fid) => match XcmForeignAssetIdMapping::<Runtime>::get_multi_location(fid) {349 Some(location) => Ok(location),350 None => Err(()),351 },352 None => Err(()),353 }354 }355}356357358#[cfg(feature = "foreign-assets")]359pub type FungiblesTransactor = FungiblesAdapter<360 361 ForeingAssets,362 363 ConvertedConcreteAssetId<AssetIds, Balance, AsInnerId<AssetIds, JustTry>, JustTry>,364 365 LocationToAccountId,366 367 AccountId,368 369 370 NonZeroIssuance<AccountId, ForeingAssets>,371 372 CheckingAccount,373>;374375376#[cfg(feature = "foreign-assets")]377pub type AssetTransactors = FungiblesTransactor;378379#[cfg(not(feature = "foreign-assets"))]380pub type AssetTransactors = LocalAssetTransactor;381382#[cfg(feature = "foreign-assets")]383pub struct AllAsset;384#[cfg(feature = "foreign-assets")]385impl FilterAssetLocation for AllAsset {386 fn filter_asset_location(asset: &MultiAsset, origin: &MultiLocation) -> bool {387 true388 }389}390391#[cfg(feature = "foreign-assets")]392pub type IsReserve = AllAsset;393#[cfg(not(feature = "foreign-assets"))]394pub type IsReserve = NativeAsset;395396#[cfg(feature = "foreign-assets")]397type Trader<T> = FreeForAll<398 pallet_configuration::WeightToFee<T, Balance>,399 RelayLocation,400 AccountId,401 Balances,402 (),403>;404#[cfg(not(feature = "foreign-assets"))]405type Trader<T> = UsingOnlySelfCurrencyComponents<406 pallet_configuration::WeightToFee<T, Balance>,407 RelayLocation,408 AccountId,409 Balances,410 (),411>;412413pub struct XcmConfig<T>(PhantomData<T>);414impl<T> Config for XcmConfig<T>415where416 T: pallet_configuration::Config,417{418 type Call = Call;419 type XcmSender = XcmRouter;420 421 type AssetTransactor = AssetTransactors;422 type OriginConverter = XcmOriginToTransactDispatchOrigin;423 type IsReserve = IsReserve;424 type IsTeleporter = (); 425 type LocationInverter = LocationInverter<Ancestry>;426 type Barrier = Barrier;427 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;428 type Trader = Trader<T>;429 type ResponseHandler = (); 430 type SubscriptionService = PolkadotXcm;431432 type AssetTrap = PolkadotXcm;433 type AssetClaims = PolkadotXcm;434}435436impl pallet_xcm::Config for Runtime {437 type Event = Event;438 type SendXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;439 type XcmRouter = XcmRouter;440 type ExecuteXcmOrigin = EnsureXcmOrigin<Origin, LocalOriginToLocation>;441 type XcmExecuteFilter = Everything;442 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;443 type XcmTeleportFilter = Everything;444 type XcmReserveTransferFilter = Everything;445 type Weigher = FixedWeightBounds<UnitWeightCost, Call, MaxInstructions>;446 type LocationInverter = LocationInverter<Ancestry>;447 type Origin = Origin;448 type Call = Call;449 const VERSION_DISCOVERY_QUEUE_SIZE: u32 = 100;450 type AdvertisedXcmVersion = pallet_xcm::CurrentXcmVersion;451}452453impl cumulus_pallet_xcm::Config for Runtime {454 type Event = Event;455 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;456}457458impl cumulus_pallet_xcmp_queue::Config for Runtime {459 type WeightInfo = ();460 type Event = Event;461 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;462 type ChannelInfo = ParachainSystem;463 type VersionWrapper = ();464 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;465 type ControllerOrigin = EnsureRoot<AccountId>;466 type ControllerOriginConverter = XcmOriginToTransactDispatchOrigin;467}468469impl cumulus_pallet_dmp_queue::Config for Runtime {470 type Event = Event;471 type XcmExecutor = XcmExecutor<XcmConfig<Self>>;472 type ExecuteOverweightOrigin = frame_system::EnsureRoot<AccountId>;473}