Native barrier impl

traits/src/lib.rs

@@ -38,6 +38,7 @@ pub mod nft;
 pub mod price;
 pub mod rewards;
 pub mod xcm_transfer;
+pub mod native_barrier;
 
 /// New data handler
 #[impl_trait_for_tuples::impl_for_tuples(30)]

traits/src/native_barrier.rs

@@ -0,0 +1,8 @@
+use frame_support::dispatch::DispatchResult;
+pub trait NativeBarrier<AccountId, Balance> {
+	fn update_native_barrier(account_id: &AccountId, amount: Balance);
+	fn ensure_limit_not_exceeded(account_id: &AccountId, amount: Balance) -> DispatchResult;
+}
+pub trait NativeChecker<CurrencyId> {
+	fn is_native(currency_id: &CurrencyId) -> bool;
+}

xtokens/src/lib.rs

@@ -44,6 +44,7 @@ use xcm_executor::traits::{InvertLocation, WeightBounds};
 pub use module::*;
 use orml_traits::{
 	location::{Parse, Reserve},
+	native_barrier::{NativeBarrier, NativeChecker},
 	GetByKey, XcmTransfer,
 };
 
@@ -102,6 +103,9 @@ pub mod module {
 		/// Asset locations filter for outgoing transfers
 		type OutgoingAssetsFilter: Contains<Self::CurrencyId>;
 
+		///
+		type NativeBarrierType: NativeBarrier<Self::AccountId, Self::Balance> + NativeChecker<Self::CurrencyId>;
+
 		/// Means of measuring the weight consumed by an XCM message locally.
 		type Weigher: WeightBounds<Self::RuntimeCall>;
 
@@ -397,6 +401,9 @@ pub mod module {
 				Error::<T>::AssetDisabledForOutgoingTransfers
 			);
 
+			if <T::NativeBarrierType>::is_native(&currency_id) {
+				<T::NativeBarrierType>::ensure_limit_not_exceeded(&who, amount)?;
+			}
 			let location: MultiLocation =
 				T::CurrencyIdConvert::convert(currency_id).ok_or(Error::<T>::NotCrossChainTransferableCurrency)?;
 
@@ -423,6 +430,10 @@ pub mod module {
 				Error::<T>::AssetDisabledForOutgoingTransfers
 			);
 
+			if <T::NativeBarrierType>::is_native(&currency_id) {
+				<T::NativeBarrierType>::ensure_limit_not_exceeded(&who, amount)?;
+			}
+
 			let location: MultiLocation =
 				T::CurrencyIdConvert::convert(currency_id).ok_or(Error::<T>::NotCrossChainTransferableCurrency)?;
 
@@ -503,6 +514,10 @@ pub mod module {
 					Error::<T>::AssetDisabledForOutgoingTransfers
 				);
 
+				if <T::NativeBarrierType>::is_native(&currency_id) {
+					<T::NativeBarrierType>::ensure_limit_not_exceeded(&who, *amount)?;
+				}
+
 				let location: MultiLocation = T::CurrencyIdConvert::convert(currency_id.clone())
 					.ok_or(Error::<T>::NotCrossChainTransferableCurrency)?;
 				ensure!(!amount.is_zero(), Error::<T>::ZeroAmount);