1234567891011121314151617181920212223#![cfg_attr(not(feature = "std"), no_std)]24#![allow(clippy::unused_unit)]2526use core::ops::Deref;2728use frame_support::{29 dispatch::DispatchResult, pallet_prelude::*, storage_alias, traits::EnsureOrigin, PalletId,30};31use frame_system::pallet_prelude::*;32use pallet_common::{33 dispatch::CollectionDispatch, erc::CrossAccountId, XcmExtensions, NATIVE_FUNGIBLE_COLLECTION_ID,34};35use sp_runtime::traits::AccountIdConversion;36use sp_std::{boxed::Box, vec, vec::Vec};37use staging_xcm::{v4::prelude::*, VersionedAssetId};38use staging_xcm_executor::{39 traits::{ConvertLocation, Error as XcmExecutorError, TransactAsset, WeightTrader},40 AssetsInHolding,41};42use up_data_structs::{43 budget::ZeroBudget, CollectionId, CollectionMode, CollectionName, CollectionTokenPrefix,44 CreateCollectionData, CreateFungibleData, CreateItemData, TokenId,45};4647pub mod weights;4849#[cfg(feature = "runtime-benchmarks")]50mod benchmarking;5152pub use module::*;53pub use weights::WeightInfo;545556#[derive(Clone, Copy, PartialEq, Eq, RuntimeDebug, Encode, Decode, TypeInfo, MaxEncodedLen)]57pub enum MigrationStatus {58 V3ToV4(MigrationStatusV3ToV4),59}606162#[derive(Clone, Copy, PartialEq, Eq, RuntimeDebug, Encode, Decode, TypeInfo, MaxEncodedLen)]63pub enum MigrationStatusV3ToV4 {64 65 Done,6667 68 69 SkippedInconsistentAssetData(staging_xcm::v3::AssetId),7071 72 73 SkippedInconsistentAssetInstanceData {74 asset_id: staging_xcm::v3::AssetId,75 asset_instance: staging_xcm::v3::AssetInstance,76 },7778 79 80 SkippedNotConvertibleAssetId(staging_xcm::v3::AssetId),8182 83 84 SkippedNotConvertibleAssetInstance {85 asset_id: staging_xcm::v3::AssetId,86 asset_instance: staging_xcm::v3::AssetInstance,87 },88}8990#[frame_support::pallet]91pub mod module {92 use pallet_common::CollectionIssuer;93 use up_data_structs::CollectionDescription;9495 use super::*;9697 #[pallet::config]98 pub trait Config:99 frame_system::Config100 + pallet_common::Config101 + pallet_fungible::Config102 + pallet_balances::Config103 {104 105 type RuntimeEvent: From<Event<Self>> + IsType<<Self as frame_system::Config>::RuntimeEvent>;106107 108 type ForceRegisterOrigin: EnsureOrigin<Self::RuntimeOrigin>;109110 111 type PalletId: Get<PalletId>;112113 114 type SelfLocation: Get<Location>;115116 117 type LocationToAccountId: ConvertLocation<Self::CrossAccountId>;118119 120 type WeightInfo: WeightInfo;121 }122123 #[pallet::error]124 pub enum Error<T> {125 126 ForeignAssetAlreadyRegistered,127128 129 BadForeignAssetId,130 }131132 #[pallet::event]133 #[pallet::generate_deposit(pub(crate) fn deposit_event)]134 pub enum Event<T: Config> {135 136 ForeignAssetRegistered {137 collection_id: CollectionId,138 asset_id: Box<VersionedAssetId>,139 },140141 142 MigrationStatus(MigrationStatus),143 }144145 146 #[pallet::storage]147 #[pallet::getter(fn foreign_asset_to_collection)]148 pub type ForeignAssetToCollection<T: Config> =149 StorageMap<_, Blake2_128Concat, staging_xcm::v4::AssetId, CollectionId, OptionQuery>;150151 152 #[pallet::storage]153 #[pallet::getter(fn collection_to_foreign_asset)]154 pub type CollectionToForeignAsset<T: Config> =155 StorageMap<_, Blake2_128Concat, CollectionId, staging_xcm::v4::AssetId, OptionQuery>;156157 158 #[pallet::storage]159 #[pallet::getter(fn foreign_reserve_asset_instance_to_token_id)]160 pub type ForeignReserveAssetInstanceToTokenId<T: Config> = StorageDoubleMap<161 Hasher1 = Blake2_128Concat,162 Key1 = CollectionId,163 Hasher2 = Blake2_128Concat,164 Key2 = staging_xcm::v4::AssetInstance,165 Value = TokenId,166 QueryKind = OptionQuery,167 >;168169 170 #[pallet::storage]171 #[pallet::getter(fn token_id_to_foreign_reserve_asset_instance)]172 pub type TokenIdToForeignReserveAssetInstance<T: Config> = StorageDoubleMap<173 Hasher1 = Blake2_128Concat,174 Key1 = CollectionId,175 Hasher2 = Blake2_128Concat,176 Key2 = TokenId,177 Value = staging_xcm::v4::AssetInstance,178 QueryKind = OptionQuery,179 >;180181 const STORAGE_VERSION: StorageVersion = StorageVersion::new(staging_xcm::v4::VERSION as u16);182183 #[pallet::pallet]184 #[pallet::storage_version(STORAGE_VERSION)]185 pub struct Pallet<T>(_);186187 #[pallet::call]188 impl<T: Config> Pallet<T> {189 #[pallet::call_index(0)]190 #[pallet::weight(<T as Config>::WeightInfo::force_register_foreign_asset())]191 pub fn force_register_foreign_asset(192 origin: OriginFor<T>,193 versioned_asset_id: Box<VersionedAssetId>,194 name: CollectionName,195 token_prefix: CollectionTokenPrefix,196 mode: ForeignCollectionMode,197 ) -> DispatchResult {198 T::ForceRegisterOrigin::ensure_origin(origin.clone())?;199200 let asset_id: AssetId = versioned_asset_id201 .as_ref()202 .clone()203 .try_into()204 .map_err(|()| Error::<T>::BadForeignAssetId)?;205206 ensure!(207 !<ForeignAssetToCollection<T>>::contains_key(&asset_id),208 <Error<T>>::ForeignAssetAlreadyRegistered,209 );210211 let foreign_collection_owner = Self::pallet_account();212213 let description: CollectionDescription = "Foreign Assets Collection"214 .encode_utf16()215 .collect::<Vec<_>>()216 .try_into()217 .expect("description length < max description length; qed");218219 let collection_id = T::CollectionDispatch::create(220 foreign_collection_owner,221 CollectionIssuer::Internals,222 CreateCollectionData {223 name,224 token_prefix,225 description,226 mode: mode.into(),227 ..Default::default()228 },229 )?;230231 <ForeignAssetToCollection<T>>::insert(&asset_id, collection_id);232 <CollectionToForeignAsset<T>>::insert(collection_id, asset_id);233234 Self::deposit_event(Event::<T>::ForeignAssetRegistered {235 collection_id,236 asset_id: versioned_asset_id,237 });238239 Ok(())240 }241 }242243 #[pallet::hooks]244 impl<T: Config> Hooks<BlockNumberFor<T>> for Pallet<T> {245 fn on_runtime_upgrade() -> Weight {246 Self::migrate_v3_to_v4()247 }248 }249}250251mod v3_storage {252 use super::*;253254 #[storage_alias]255 pub type ForeignAssetToCollection<T: Config> =256 StorageMap<Pallet<T>, Twox64Concat, staging_xcm::v3::AssetId, CollectionId, OptionQuery>;257258 #[storage_alias]259 pub type CollectionToForeignAsset<T: Config> =260 StorageMap<Pallet<T>, Twox64Concat, CollectionId, staging_xcm::v3::AssetId, OptionQuery>;261262 #[storage_alias]263 pub type ForeignReserveAssetInstanceToTokenId<T: Config> = StorageDoubleMap<264 Pallet<T>,265 Twox64Concat,266 CollectionId,267 Blake2_128Concat,268 staging_xcm::v3::AssetInstance,269 TokenId,270 OptionQuery,271 >;272273 #[storage_alias]274 pub type TokenIdToForeignReserveAssetInstance<T: Config> = StorageDoubleMap<275 Pallet<T>,276 Twox64Concat,277 CollectionId,278 Blake2_128Concat,279 TokenId,280 staging_xcm::v3::AssetInstance,281 OptionQuery,282 >;283}284285impl<T: Config> Pallet<T> {286 fn migrate_v3_to_v4() -> Weight {287 if Self::on_chain_storage_version() < staging_xcm::v4::VERSION as u16 {288 let put_version_weight = T::DbWeight::get().writes(1);289 let event_weight = T::DbWeight::get().writes(1);290 let collection_migration_weight = Self::migrate_collections();291292 StorageVersion::new(staging_xcm::v4::VERSION as u16).put::<Self>();293294 Self::deposit_event(Event::<T>::MigrationStatus(MigrationStatus::V3ToV4(295 MigrationStatusV3ToV4::Done,296 )));297298 put_version_weight299 .saturating_add(collection_migration_weight)300 .saturating_add(event_weight)301 } else {302 Weight::zero()303 }304 }305306 fn migrate_collections() -> Weight {307 use MigrationStatus::*;308 use MigrationStatusV3ToV4::*;309310 let mut weight = Weight::zero();311312 for (fwd_asset_id, collection_id) in v3_storage::ForeignAssetToCollection::<T>::drain() {313 let bwd_asset_id = v3_storage::CollectionToForeignAsset::<T>::take(collection_id);314 weight = weight.saturating_add(T::DbWeight::get().reads(2));315316 let Some(bwd_asset_id) = bwd_asset_id else {317 Self::deposit_event(Event::<T>::MigrationStatus(V3ToV4(318 SkippedInconsistentAssetData(fwd_asset_id),319 )));320321 weight = weight.saturating_add(T::DbWeight::get().writes(1));322 continue;323 };324325 if fwd_asset_id != bwd_asset_id {326 Self::deposit_event(Event::<T>::MigrationStatus(V3ToV4(327 SkippedInconsistentAssetData(fwd_asset_id),328 )));329330 weight = weight.saturating_add(T::DbWeight::get().writes(1));331 continue;332 }333334 let Ok(asset_id) = staging_xcm::v4::AssetId::try_from(fwd_asset_id) else {335 Self::deposit_event(Event::<T>::MigrationStatus(V3ToV4(336 SkippedNotConvertibleAssetId(fwd_asset_id),337 )));338339 weight = weight.saturating_add(T::DbWeight::get().writes(1));340 continue;341 };342343 <ForeignAssetToCollection<T>>::insert(&asset_id, collection_id);344 <CollectionToForeignAsset<T>>::insert(collection_id, asset_id);345 weight = weight.saturating_add(T::DbWeight::get().writes(2));346347 let migrate_tokens_weight = Self::migrate_tokens(&fwd_asset_id, collection_id);348 weight = weight.saturating_add(migrate_tokens_weight);349 }350351 weight352 }353354 fn migrate_tokens(asset_id: &staging_xcm::v3::AssetId, collection_id: CollectionId) -> Weight {355 use MigrationStatus::*;356 use MigrationStatusV3ToV4::*;357358 let mut weight = Weight::zero();359360 for (fwd_asset_instance, token_id) in361 v3_storage::ForeignReserveAssetInstanceToTokenId::<T>::drain_prefix(collection_id)362 {363 let bwd_asset_instance = v3_storage::TokenIdToForeignReserveAssetInstance::<T>::take(364 collection_id,365 token_id,366 );367 weight = weight.saturating_add(T::DbWeight::get().reads(2));368369 let Some(bwd_asset_instance) = bwd_asset_instance else {370 Self::deposit_event(Event::<T>::MigrationStatus(V3ToV4(371 SkippedInconsistentAssetInstanceData {372 asset_id: *asset_id,373 asset_instance: fwd_asset_instance,374 },375 )));376377 weight = weight.saturating_add(T::DbWeight::get().writes(1));378 continue;379 };380381 if fwd_asset_instance != bwd_asset_instance {382 Self::deposit_event(Event::<T>::MigrationStatus(V3ToV4(383 SkippedInconsistentAssetInstanceData {384 asset_id: *asset_id,385 asset_instance: fwd_asset_instance,386 },387 )));388389 weight = weight.saturating_add(T::DbWeight::get().writes(1));390 continue;391 }392393 let Ok(asset_instance) = staging_xcm::v4::AssetInstance::try_from(fwd_asset_instance)394 else {395 Self::deposit_event(Event::<T>::MigrationStatus(V3ToV4(396 SkippedNotConvertibleAssetInstance {397 asset_id: *asset_id,398 asset_instance: fwd_asset_instance,399 },400 )));401402 weight = weight.saturating_add(T::DbWeight::get().writes(1));403 continue;404 };405406 <ForeignReserveAssetInstanceToTokenId<T>>::insert(407 collection_id,408 &asset_instance,409 token_id,410 );411 <TokenIdToForeignReserveAssetInstance<T>>::insert(412 collection_id,413 token_id,414 asset_instance,415 );416 weight = weight.saturating_add(T::DbWeight::get().writes(2));417 }418419 weight420 }421422 fn pallet_account() -> T::CrossAccountId {423 let owner: T::AccountId = T::PalletId::get().into_account_truncating();424 T::CrossAccountId::from_sub(owner)425 }426427 428 429 430 431 432 433 434 435 436 437 438 439 440 fn local_asset_id_to_collection(441 AssetId(asset_location): &AssetId,442 ) -> Option<CollectionLocality> {443 let self_location = T::SelfLocation::get();444445 if *asset_location == Here.into() || *asset_location == self_location {446 return Some(CollectionLocality::Local(NATIVE_FUNGIBLE_COLLECTION_ID));447 }448449 let prefix = if asset_location.parents == 0 {450 &Here451 } else if asset_location.parents == self_location.parents {452 &self_location.interior453 } else {454 return None;455 };456457 let GeneralIndex(collection_id) = asset_location.interior.match_and_split(prefix)? else {458 return None;459 };460461 let collection_id = CollectionId((*collection_id).try_into().ok()?);462463 Self::collection_to_foreign_asset(collection_id)464 .is_none()465 .then_some(CollectionLocality::Local(collection_id))466 }467468 469 470 471 472 473 474 475 476 477 478 479 fn asset_to_collection(asset_id: &AssetId) -> Result<CollectionLocality, XcmError> {480 Self::foreign_asset_to_collection(asset_id)481 .map(CollectionLocality::Foreign)482 .or_else(|| Self::local_asset_id_to_collection(asset_id))483 .ok_or_else(|| XcmExecutorError::AssetIdConversionFailed.into())484 }485486 487 488 489 490 491 492 493 494 495 496 fn local_asset_instance_to_token_id(asset_instance: &AssetInstance) -> Option<TokenId> {497 match asset_instance {498 AssetInstance::Index(token_id) => Some(TokenId((*token_id).try_into().ok()?)),499 _ => None,500 }501 }502503 504 505 506 507 fn asset_instance_to_token_id(508 collection_locality: CollectionLocality,509 asset_instance: &AssetInstance,510 ) -> Option<TokenId> {511 match collection_locality {512 CollectionLocality::Local(_) => Self::local_asset_instance_to_token_id(asset_instance),513 CollectionLocality::Foreign(collection_id) => {514 Self::foreign_reserve_asset_instance_to_token_id(collection_id, asset_instance)515 }516 }517 }518519 520 fn create_foreign_asset_instance(521 xcm_ext: &dyn XcmExtensions<T>,522 collection_id: CollectionId,523 asset_instance: &AssetInstance,524 to: T::CrossAccountId,525 ) -> DispatchResult {526 let derivative_token_id = xcm_ext.create_item(527 &Self::pallet_account(),528 to,529 CreateItemData::NFT(Default::default()),530 &ZeroBudget,531 )?;532533 <ForeignReserveAssetInstanceToTokenId<T>>::insert(534 collection_id,535 asset_instance,536 derivative_token_id,537 );538539 <TokenIdToForeignReserveAssetInstance<T>>::insert(540 collection_id,541 derivative_token_id,542 asset_instance,543 );544545 Ok(())546 }547548 549 550 551 552 fn deposit_asset_instance(553 xcm_ext: &dyn XcmExtensions<T>,554 collection_locality: CollectionLocality,555 asset_instance: &AssetInstance,556 to: T::CrossAccountId,557 ) -> XcmResult {558 let token_id = Self::asset_instance_to_token_id(collection_locality, asset_instance);559560 let deposit_result = match (collection_locality, token_id) {561 (_, Some(token_id)) => {562 let depositor = &Self::pallet_account();563 let from = depositor;564 let amount = 1;565566 xcm_ext.transfer_item(depositor, from, &to, token_id, amount, &ZeroBudget)567 }568 (CollectionLocality::Foreign(collection_id), None) => {569 Self::create_foreign_asset_instance(xcm_ext, collection_id, asset_instance, to)570 }571 (CollectionLocality::Local(_), None) => {572 return Err(XcmExecutorError::InstanceConversionFailed.into());573 }574 };575576 deposit_result577 .map_err(|_| XcmError::FailedToTransactAsset("non-fungible item deposit failed"))578 }579580 581 582 583 fn withdraw_asset_instance(584 xcm_ext: &dyn XcmExtensions<T>,585 collection_locality: CollectionLocality,586 asset_instance: &AssetInstance,587 from: T::CrossAccountId,588 ) -> XcmResult {589 let token_id = Self::asset_instance_to_token_id(collection_locality, asset_instance)590 .ok_or(XcmExecutorError::InstanceConversionFailed)?;591592 let depositor = &from;593 let to = Self::pallet_account();594 let amount = 1;595 xcm_ext596 .transfer_item(depositor, &from, &to, token_id, amount, &ZeroBudget)597 .map_err(|_| XcmError::FailedToTransactAsset("non-fungible item withdraw failed"))?;598599 Ok(())600 }601}602603604605606607608impl<T: Config> TransactAsset for Pallet<T> {609 fn can_check_in(_origin: &Location, _what: &Asset, _context: &XcmContext) -> XcmResult {610 Err(XcmError::Unimplemented)611 }612613 fn check_in(_origin: &Location, _what: &Asset, _context: &XcmContext) {}614615 fn can_check_out(_dest: &Location, _what: &Asset, _context: &XcmContext) -> XcmResult {616 Err(XcmError::Unimplemented)617 }618619 fn check_out(_dest: &Location, _what: &Asset, _context: &XcmContext) {}620621 fn deposit_asset(what: &Asset, to: &Location, _context: Option<&XcmContext>) -> XcmResult {622 let to = T::LocationToAccountId::convert_location(to)623 .ok_or(XcmExecutorError::AccountIdConversionFailed)?;624625 let collection_locality = Self::asset_to_collection(&what.id)?;626 let dispatch = T::CollectionDispatch::dispatch(*collection_locality)627 .map_err(|_| XcmExecutorError::AssetIdConversionFailed)?;628629 let collection = dispatch.as_dyn();630 let xcm_ext = collection.xcm_extensions().ok_or(XcmError::Unimplemented)?;631632 match what.fun {633 Fungibility::Fungible(amount) => xcm_ext634 .create_item(635 &Self::pallet_account(),636 to,637 CreateItemData::Fungible(CreateFungibleData { value: amount }),638 &ZeroBudget,639 )640 .map(|_| ())641 .map_err(|_| XcmError::FailedToTransactAsset("fungible item deposit failed")),642643 Fungibility::NonFungible(asset_instance) => {644 Self::deposit_asset_instance(xcm_ext, collection_locality, &asset_instance, to)645 }646 }647 }648649 fn withdraw_asset(650 what: &Asset,651 from: &Location,652 _maybe_context: Option<&XcmContext>,653 ) -> Result<AssetsInHolding, XcmError> {654 let from = T::LocationToAccountId::convert_location(from)655 .ok_or(XcmExecutorError::AccountIdConversionFailed)?;656657 let collection_locality = Self::asset_to_collection(&what.id)?;658 let dispatch = T::CollectionDispatch::dispatch(*collection_locality)659 .map_err(|_| XcmExecutorError::AssetIdConversionFailed)?;660661 let collection = dispatch.as_dyn();662 let xcm_ext = collection.xcm_extensions().ok_or(XcmError::NoPermission)?;663664 match what.fun {665 Fungibility::Fungible(amount) => xcm_ext666 .burn_item(from, TokenId::default(), amount)667 .map_err(|_| XcmError::FailedToTransactAsset("fungible item withdraw failed"))?,668669 Fungibility::NonFungible(asset_instance) => {670 Self::withdraw_asset_instance(xcm_ext, collection_locality, &asset_instance, from)?;671 }672 }673674 Ok(what.clone().into())675 }676677 fn internal_transfer_asset(678 what: &Asset,679 from: &Location,680 to: &Location,681 _context: &XcmContext,682 ) -> Result<AssetsInHolding, XcmError> {683 let from = T::LocationToAccountId::convert_location(from)684 .ok_or(XcmExecutorError::AccountIdConversionFailed)?;685686 let to = T::LocationToAccountId::convert_location(to)687 .ok_or(XcmExecutorError::AccountIdConversionFailed)?;688689 let collection_locality = Self::asset_to_collection(&what.id)?;690691 let dispatch = T::CollectionDispatch::dispatch(*collection_locality)692 .map_err(|_| XcmExecutorError::AssetIdConversionFailed)?;693 let collection = dispatch.as_dyn();694 let xcm_ext = collection.xcm_extensions().ok_or(XcmError::NoPermission)?;695696 let depositor = &from;697698 let token_id;699 let amount;700 let map_error: fn(DispatchError) -> XcmError;701702 match what.fun {703 Fungibility::Fungible(fungible_amount) => {704 token_id = TokenId::default();705 amount = fungible_amount;706 map_error = |_| XcmError::FailedToTransactAsset("fungible item transfer failed");707 }708709 Fungibility::NonFungible(asset_instance) => {710 token_id = Self::asset_instance_to_token_id(collection_locality, &asset_instance)711 .ok_or(XcmExecutorError::InstanceConversionFailed)?;712713 amount = 1;714 map_error = |_| XcmError::FailedToTransactAsset("non-fungible item transfer failed")715 }716 }717718 xcm_ext719 .transfer_item(depositor, &from, &to, token_id, amount, &ZeroBudget)720 .map_err(map_error)?;721722 Ok(what.clone().into())723 }724}725726#[derive(Clone, Copy)]727pub enum CollectionLocality {728 Local(CollectionId),729 Foreign(CollectionId),730}731732impl Deref for CollectionLocality {733 type Target = CollectionId;734735 fn deref(&self) -> &Self::Target {736 match self {737 Self::Local(id) => id,738 Self::Foreign(id) => id,739 }740 }741}742743pub struct CurrencyIdConvert<T: Config>(PhantomData<T>);744impl<T: Config> sp_runtime::traits::Convert<CollectionId, Option<Location>>745 for CurrencyIdConvert<T>746{747 fn convert(collection_id: CollectionId) -> Option<Location> {748 if collection_id == NATIVE_FUNGIBLE_COLLECTION_ID {749 Some(T::SelfLocation::get())750 } else {751 <Pallet<T>>::collection_to_foreign_asset(collection_id)752 .map(|AssetId(location)| location)753 .or_else(|| {754 T::SelfLocation::get()755 .pushed_with_interior(GeneralIndex(collection_id.0.into()))756 .ok()757 })758 }759 }760}761762#[derive(Encode, Decode, Eq, Debug, Clone, PartialEq, TypeInfo, MaxEncodedLen)]763pub enum ForeignCollectionMode {764 NFT,765 Fungible(u8),766}767768impl From<ForeignCollectionMode> for CollectionMode {769 fn from(value: ForeignCollectionMode) -> Self {770 match value {771 ForeignCollectionMode::NFT => Self::NFT,772 ForeignCollectionMode::Fungible(decimals) => Self::Fungible(decimals),773 }774 }775}776777pub struct FreeForAll;778779impl WeightTrader for FreeForAll {780 fn new() -> Self {781 Self782 }783784 fn buy_weight(785 &mut self,786 weight: Weight,787 payment: AssetsInHolding,788 _xcm: &XcmContext,789 ) -> Result<AssetsInHolding, XcmError> {790 log::trace!(target: "fassets::weight", "buy_weight weight: {:?}, payment: {:?}", weight, payment);791 Ok(payment)792 }793}