12345678910111213141516171819202122232425262728293031323334#![cfg_attr(not(feature = "std"), no_std)]35#![allow(clippy::unused_unit)]3637use frame_support::{38 dispatch::DispatchResult,39 ensure,40 pallet_prelude::*,41 traits::{fungible, fungibles, Currency, EnsureOrigin},42 transactional, RuntimeDebug,43};44use frame_system::pallet_prelude::*;45use up_data_structs::{CollectionMode};46use pallet_fungible::{Pallet as PalletFungible};47use scale_info::{TypeInfo};48use sp_runtime::{49 traits::{One, Zero},50 ArithmeticError,51};52use sp_std::{boxed::Box, vec::Vec};53use up_data_structs::{CollectionId, TokenId, CreateCollectionData};54555657use xcm::opaque::latest::{prelude::XcmError, MultiAsset};58use xcm::{v1::MultiLocation, VersionedMultiLocation};59use xcm_executor::{traits::WeightTrader, Assets};6061use pallet_common::erc::CrossAccountId;6263#[cfg(feature = "std")]64use serde::{Deserialize, Serialize};656667686970#[derive(71 Clone,72 Copy,73 Eq,74 PartialEq,75 PartialOrd,76 Ord,77 MaxEncodedLen,78 RuntimeDebug,79 Encode,80 Decode,81 TypeInfo,82)]83#[cfg_attr(feature = "std", derive(Serialize, Deserialize))]84pub enum NativeCurrency {85 Here = 0,86 Parent = 1,87}8889#[derive(90 Clone,91 Copy,92 Eq,93 PartialEq,94 PartialOrd,95 Ord,96 MaxEncodedLen,97 RuntimeDebug,98 Encode,99 Decode,100 TypeInfo,101)]102#[cfg_attr(feature = "std", derive(Serialize, Deserialize))]103pub enum AssetIds {104 ForeignAssetId(ForeignAssetId),105 NativeAssetId(NativeCurrency),106}107108pub trait TryAsForeing<T, F> {109 fn try_as_foreing(asset: T) -> Option<F>;110}111112impl TryAsForeing<AssetIds, ForeignAssetId> for AssetIds {113 fn try_as_foreing(asset: AssetIds) -> Option<ForeignAssetId> {114 match asset {115 AssetIds::ForeignAssetId(id) => Some(id),116 _ => None,117 }118 }119}120121pub type ForeignAssetId = u32;122pub type CurrencyId = AssetIds;123124mod impl_fungibles;125mod weights;126127pub use module::*;128pub use weights::WeightInfo;129130131pub type BalanceOf<T> =132 <<T as Config>::Currency as Currency<<T as frame_system::Config>::AccountId>>::Balance;133134135pub trait AssetIdMapping<ForeignAssetId, MultiLocation, AssetMetadata> {136 137 fn get_asset_metadata(foreign_asset_id: ForeignAssetId) -> Option<AssetMetadata>;138 139 fn get_multi_location(foreign_asset_id: ForeignAssetId) -> Option<MultiLocation>;140 141 fn get_currency_id(multi_location: MultiLocation) -> Option<CurrencyId>;142}143144pub struct XcmForeignAssetIdMapping<T>(sp_std::marker::PhantomData<T>);145146impl<T: Config> AssetIdMapping<ForeignAssetId, MultiLocation, AssetMetadata<BalanceOf<T>>>147 for XcmForeignAssetIdMapping<T>148{149 fn get_asset_metadata(foreign_asset_id: ForeignAssetId) -> Option<AssetMetadata<BalanceOf<T>>> {150 log::trace!(target: "fassets::asset_metadatas", "call");151 Pallet::<T>::asset_metadatas(AssetIds::ForeignAssetId(foreign_asset_id))152 }153154 fn get_multi_location(foreign_asset_id: ForeignAssetId) -> Option<MultiLocation> {155 log::trace!(target: "fassets::get_multi_location", "call");156 Pallet::<T>::foreign_asset_locations(foreign_asset_id)157 }158159 fn get_currency_id(multi_location: MultiLocation) -> Option<CurrencyId> {160 log::trace!(target: "fassets::get_currency_id", "call");161 Some(AssetIds::ForeignAssetId(162 Pallet::<T>::location_to_currency_ids(multi_location).unwrap_or(0),163 ))164 }165}166167#[frame_support::pallet]168pub mod module {169 use super::*;170171 #[pallet::config]172 pub trait Config:173 frame_system::Config174 + pallet_common::Config175 + pallet_fungible::Config176 + orml_tokens::Config177 + pallet_balances::Config178 {179 180 type Event: From<Event<Self>> + IsType<<Self as frame_system::Config>::Event>;181182 183 type Currency: Currency<Self::AccountId>;184185 186 type RegisterOrigin: EnsureOrigin<Self::Origin>;187188 189 type WeightInfo: WeightInfo;190 }191192 #[derive(Clone, Eq, PartialEq, RuntimeDebug, Encode, Decode, TypeInfo)]193 pub struct AssetMetadata<Balance> {194 pub name: Vec<u8>,195 pub symbol: Vec<u8>,196 pub decimals: u8,197 pub minimal_balance: Balance,198 }199200 #[pallet::error]201 pub enum Error<T> {202 203 204 BadLocation,205 206 MultiLocationExisted,207 208 AssetIdNotExists,209 210 AssetIdExisted,211 }212213 #[pallet::event]214 #[pallet::generate_deposit(fn deposit_event)]215 pub enum Event<T: Config> {216 217 ForeignAssetRegistered {218 asset_id: ForeignAssetId,219 asset_address: MultiLocation,220 metadata: AssetMetadata<BalanceOf<T>>,221 },222 223 ForeignAssetUpdated {224 asset_id: ForeignAssetId,225 asset_address: MultiLocation,226 metadata: AssetMetadata<BalanceOf<T>>,227 },228 229 AssetRegistered {230 asset_id: AssetIds,231 metadata: AssetMetadata<BalanceOf<T>>,232 },233 234 AssetUpdated {235 asset_id: AssetIds,236 metadata: AssetMetadata<BalanceOf<T>>,237 },238 }239240 241 242 243 #[pallet::storage]244 #[pallet::getter(fn next_foreign_asset_id)]245 pub type NextForeignAssetId<T: Config> = StorageValue<_, ForeignAssetId, ValueQuery>;246 247 248 249 #[pallet::storage]250 #[pallet::getter(fn foreign_asset_locations)]251 pub type ForeignAssetLocations<T: Config> =252 StorageMap<_, Twox64Concat, ForeignAssetId, MultiLocation, OptionQuery>;253254 255 256 257 #[pallet::storage]258 #[pallet::getter(fn location_to_currency_ids)]259 pub type LocationToCurrencyIds<T: Config> =260 StorageMap<_, Twox64Concat, MultiLocation, ForeignAssetId, OptionQuery>;261262 263 264 265 #[pallet::storage]266 #[pallet::getter(fn asset_metadatas)]267 pub type AssetMetadatas<T: Config> =268 StorageMap<_, Twox64Concat, AssetIds, AssetMetadata<BalanceOf<T>>, OptionQuery>;269270 271 272 #[pallet::storage]273 #[pallet::getter(fn asset_binding)]274 pub type AssetBinding<T: Config> =275 StorageMap<_, Twox64Concat, ForeignAssetId, CollectionId, OptionQuery>;276277 #[pallet::pallet]278 #[pallet::without_storage_info]279 pub struct Pallet<T>(_);280281 #[pallet::call]282 impl<T: Config> Pallet<T> {283 #[pallet::weight(<T as Config>::WeightInfo::register_foreign_asset())]284 #[transactional]285 pub fn register_foreign_asset(286 origin: OriginFor<T>,287 owner: T::AccountId,288 location: Box<VersionedMultiLocation>,289 metadata: Box<AssetMetadata<BalanceOf<T>>>,290 ) -> DispatchResult {291 T::RegisterOrigin::ensure_origin(origin.clone())?;292293 let location: MultiLocation = (*location)294 .try_into()295 .map_err(|()| Error::<T>::BadLocation)?;296297 let md = metadata.clone();298 let name: Vec<u16> = md.name.into_iter().map(|x| x as u16).collect::<Vec<u16>>();299 let mut description: Vec<u16> = "Foreing assets collection for "300 .encode_utf16()301 .collect::<Vec<u16>>();302 description.append(&mut name.clone());303304 let data: CreateCollectionData<T::AccountId> = CreateCollectionData {305 name: name.try_into().unwrap(),306 description: description.try_into().unwrap(),307 mode: CollectionMode::Fungible(18),308 ..Default::default()309 };310311 let bounded_collection_id = <PalletFungible<T>>::init_foreign_collection(312 CrossAccountId::from_sub(owner),313 data,314 )?;315 let foreign_asset_id =316 Self::do_register_foreign_asset(&location, &metadata, bounded_collection_id)?;317318 Self::deposit_event(Event::<T>::ForeignAssetRegistered {319 asset_id: foreign_asset_id,320 asset_address: location,321 metadata: *metadata,322 });323 Ok(())324 }325326 #[pallet::weight(<T as Config>::WeightInfo::update_foreign_asset())]327 #[transactional]328 pub fn update_foreign_asset(329 origin: OriginFor<T>,330 foreign_asset_id: ForeignAssetId,331 location: Box<VersionedMultiLocation>,332 metadata: Box<AssetMetadata<BalanceOf<T>>>,333 ) -> DispatchResult {334 T::RegisterOrigin::ensure_origin(origin)?;335336 let location: MultiLocation = (*location)337 .try_into()338 .map_err(|()| Error::<T>::BadLocation)?;339 Self::do_update_foreign_asset(foreign_asset_id, &location, &metadata)?;340341 Self::deposit_event(Event::<T>::ForeignAssetUpdated {342 asset_id: foreign_asset_id,343 asset_address: location,344 metadata: *metadata,345 });346 Ok(())347 }348 }349}350351impl<T: Config> Pallet<T> {352 fn get_next_foreign_asset_id() -> Result<ForeignAssetId, DispatchError> {353 NextForeignAssetId::<T>::try_mutate(|current| -> Result<ForeignAssetId, DispatchError> {354 let id = *current;355 *current = current356 .checked_add(One::one())357 .ok_or(ArithmeticError::Overflow)?;358 Ok(id)359 })360 }361362 fn do_register_foreign_asset(363 location: &MultiLocation,364 metadata: &AssetMetadata<BalanceOf<T>>,365 bounded_collection_id: CollectionId,366 ) -> Result<ForeignAssetId, DispatchError> {367 let foreign_asset_id = Self::get_next_foreign_asset_id()?;368 LocationToCurrencyIds::<T>::try_mutate(location, |maybe_currency_ids| -> DispatchResult {369 ensure!(370 maybe_currency_ids.is_none(),371 Error::<T>::MultiLocationExisted372 );373 *maybe_currency_ids = Some(foreign_asset_id);374 375376 ForeignAssetLocations::<T>::try_mutate(377 foreign_asset_id,378 |maybe_location| -> DispatchResult {379 ensure!(maybe_location.is_none(), Error::<T>::MultiLocationExisted);380 *maybe_location = Some(location.clone());381382 AssetMetadatas::<T>::try_mutate(383 AssetIds::ForeignAssetId(foreign_asset_id),384 |maybe_asset_metadatas| -> DispatchResult {385 ensure!(maybe_asset_metadatas.is_none(), Error::<T>::AssetIdExisted);386 *maybe_asset_metadatas = Some(metadata.clone());387 Ok(())388 },389 )390 },391 )?;392393 AssetBinding::<T>::try_mutate(foreign_asset_id, |collection_id| -> DispatchResult {394 *collection_id = Some(bounded_collection_id);395 Ok(())396 })397 })?;398399 Ok(foreign_asset_id)400 }401402 fn do_update_foreign_asset(403 foreign_asset_id: ForeignAssetId,404 location: &MultiLocation,405 metadata: &AssetMetadata<BalanceOf<T>>,406 ) -> DispatchResult {407 ForeignAssetLocations::<T>::try_mutate(408 foreign_asset_id,409 |maybe_multi_locations| -> DispatchResult {410 let old_multi_locations = maybe_multi_locations411 .as_mut()412 .ok_or(Error::<T>::AssetIdNotExists)?;413414 AssetMetadatas::<T>::try_mutate(415 AssetIds::ForeignAssetId(foreign_asset_id),416 |maybe_asset_metadatas| -> DispatchResult {417 ensure!(418 maybe_asset_metadatas.is_some(),419 Error::<T>::AssetIdNotExists420 );421422 423 if location != old_multi_locations {424 LocationToCurrencyIds::<T>::remove(old_multi_locations.clone());425 LocationToCurrencyIds::<T>::try_mutate(426 location,427 |maybe_currency_ids| -> DispatchResult {428 ensure!(429 maybe_currency_ids.is_none(),430 Error::<T>::MultiLocationExisted431 );432 433 *maybe_currency_ids = Some(foreign_asset_id);434 Ok(())435 },436 )?;437 }438 *maybe_asset_metadatas = Some(metadata.clone());439 *old_multi_locations = location.clone();440 Ok(())441 },442 )443 },444 )445 }446}447448use sp_runtime::SaturatedConversion;449use sp_runtime::traits::Saturating;450pub use frame_support::{451 traits::{452 fungibles::{Balanced, CreditOf},453 tokens::currency::Currency as CurrencyT,454 OnUnbalanced as OnUnbalancedT,455 },456 weights::{WeightToFeePolynomial, WeightToFee},457};458459use xcm::latest::{Fungibility::Fungible as XcmFungible};460461pub struct FreeForAll<462 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,463 AssetId: Get<MultiLocation>,464 AccountId,465 Currency: CurrencyT<AccountId>,466 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,467>(468 Weight,469 Currency::Balance,470 PhantomData<(WeightToFee, AssetId, AccountId, Currency, OnUnbalanced)>,471);472473impl<474 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,475 AssetId: Get<MultiLocation>,476 AccountId,477 Currency: CurrencyT<AccountId>,478 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,479 > WeightTrader for FreeForAll<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>480{481 fn new() -> Self {482 Self(0, Zero::zero(), PhantomData)483 }484485 fn buy_weight(&mut self, weight: Weight, payment: Assets) -> Result<Assets, XcmError> {486 log::trace!(target: "fassets::weight", "buy_weight weight: {:?}, payment: {:?}", weight, payment);487 Ok(payment)488 }489}490impl<491 WeightToFee: WeightToFeePolynomial<Balance = Currency::Balance>,492 AssetId: Get<MultiLocation>,493 AccountId,494 Currency: CurrencyT<AccountId>,495 OnUnbalanced: OnUnbalancedT<Currency::NegativeImbalance>,496 > Drop for FreeForAll<WeightToFee, AssetId, AccountId, Currency, OnUnbalanced>497{498 fn drop(&mut self) {499 OnUnbalanced::on_unbalanced(Currency::issue(self.1));500 }501}