git.delta.rocks / unique-network / refs/commits / ceb84596992e

difftreelog

Merge pull request #801 from UniqueNetwork/fix/xcm-qtz-unq-tests

Yaroslav Bolyukin2022-12-22parents: #b9448b5 #3e66406.patch.diff
in: master
Fix xcm

10 files changed

modifiedpallets/foreign-assets/src/lib.rsdiffbeforeafterboth
--- a/pallets/foreign-assets/src/lib.rs
+++ b/pallets/foreign-assets/src/lib.rs
@@ -161,9 +161,7 @@
 
 	fn get_currency_id(multi_location: MultiLocation) -> Option<CurrencyId> {
 		log::trace!(target: "fassets::get_currency_id", "call");
-		Some(AssetIds::ForeignAssetId(
-			Pallet::<T>::location_to_currency_ids(multi_location).unwrap_or(0),
-		))
+		Pallet::<T>::location_to_currency_ids(multi_location).map(|id| AssetIds::ForeignAssetId(id))
 	}
 }
 
modifiedruntime/common/config/xcm/foreignassets.rsdiffbeforeafterboth
--- a/runtime/common/config/xcm/foreignassets.rs
+++ b/runtime/common/config/xcm/foreignassets.rs
@@ -18,7 +18,7 @@
 	traits::{Contains, Get, fungibles},
 	parameter_types,
 };
-use sp_runtime::traits::{Zero, Convert};
+use sp_runtime::traits::Convert;
 use xcm::v1::{Junction::*, MultiLocation, Junctions::*};
 use xcm::latest::MultiAsset;
 use xcm_builder::{FungiblesAdapter, ConvertedConcreteAssetId};
@@ -38,16 +38,16 @@
 	pub CheckingAccount: AccountId = PolkadotXcm::check_account();
 }
 
-/// Allow checking in assets that have issuance > 0.
-pub struct NonZeroIssuance<AccountId, ForeignAssets>(PhantomData<(AccountId, ForeignAssets)>);
+/// No teleports are allowed
+pub struct NoTeleports<AccountId, ForeignAssets>(PhantomData<(AccountId, ForeignAssets)>);
 
 impl<AccountId, ForeignAssets> Contains<<ForeignAssets as fungibles::Inspect<AccountId>>::AssetId>
-	for NonZeroIssuance<AccountId, ForeignAssets>
+	for NoTeleports<AccountId, ForeignAssets>
 where
 	ForeignAssets: fungibles::Inspect<AccountId>,
 {
-	fn contains(id: &<ForeignAssets as fungibles::Inspect<AccountId>>::AssetId) -> bool {
-		!ForeignAssets::total_issuance(*id).is_zero()
+	fn contains(_id: &<ForeignAssets as fungibles::Inspect<AccountId>>::AssetId) -> bool {
+		false
 	}
 }
 
@@ -84,7 +84,7 @@
 			Some(AssetIds::ForeignAssetId(foreign_asset_id)) => {
 				ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(foreign_asset_id))
 			}
-			_ => ConvertAssetId::convert_ref(AssetIds::ForeignAssetId(0)),
+			_ => Err(()),
 		}
 	}
 
@@ -132,9 +132,8 @@
 	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, ForeignAssets>,
+	// No teleports are allowed
+	NoTeleports<AccountId, ForeignAssets>,
 	// The account to use for tracking teleports.
 	CheckingAccount,
 >;
modifiedruntime/common/config/xcm/mod.rsdiffbeforeafterboth
--- a/runtime/common/config/xcm/mod.rs
+++ b/runtime/common/config/xcm/mod.rs
@@ -186,6 +186,9 @@
 			TransferReserveAsset { dest: dst, .. } => {
 				allowed |= allowed_locations.contains(dst);
 			}
+			InitiateReserveWithdraw { reserve: dst, .. } => {
+				allowed |= allowed_locations.contains(dst);
+			}
 			_ => {}
 		});
 
modifiedtests/src/config.tsdiffbeforeafterboth
--- a/tests/src/config.ts
+++ b/tests/src/config.ts
@@ -25,6 +25,8 @@
   moonbeamUrl: process.env.moonbeamUrl || 'ws://127.0.0.1:9947',
   moonriverUrl: process.env.moonbeamUrl || 'ws://127.0.0.1:9947',
   westmintUrl: process.env.westmintUrl || 'ws://127.0.0.1:9948',
+  statemineUrl: process.env.statemineUrl || 'ws://127.0.0.1:9948',
+  statemintUrl: process.env.statemintUrl || 'ws://127.0.0.1:9948',
 };
 
 export default config;
modifiedtests/src/util/index.tsdiffbeforeafterboth
--- a/tests/src/util/index.ts
+++ b/tests/src/util/index.ts
@@ -11,7 +11,7 @@
 import config from '../config';
 import {ChainHelperBase} from './playgrounds/unique';
 import {ILogger} from './playgrounds/types';
-import {DevUniqueHelper, SilentLogger, SilentConsole, DevMoonbeamHelper, DevMoonriverHelper, DevAcalaHelper, DevKaruraHelper, DevRelayHelper, DevWestmintHelper} from './playgrounds/unique.dev';
+import {DevUniqueHelper, SilentLogger, SilentConsole, DevMoonbeamHelper, DevMoonriverHelper, DevAcalaHelper, DevKaruraHelper, DevRelayHelper, DevWestmintHelper, DevStatemineHelper, DevStatemintHelper} from './playgrounds/unique.dev';
 
 chai.use(chaiAsPromised);
 chai.use(chaiSubset);
@@ -65,6 +65,14 @@
   return usingPlaygroundsGeneral<DevWestmintHelper>(DevWestmintHelper, url, code);
 };
 
+export const usingStateminePlaygrounds = (url: string, code: (helper: DevWestmintHelper, privateKey: (seed: string) => Promise<IKeyringPair>) => Promise<void>) => {
+  return usingPlaygroundsGeneral<DevStatemineHelper>(DevWestmintHelper, url, code);
+};
+
+export const usingStatemintPlaygrounds = (url: string, code: (helper: DevWestmintHelper, privateKey: (seed: string) => Promise<IKeyringPair>) => Promise<void>) => {
+  return usingPlaygroundsGeneral<DevStatemintHelper>(DevWestmintHelper, url, code);
+};
+
 export const usingRelayPlaygrounds = (url: string, code: (helper: DevRelayHelper, privateKey: (seed: string) => Promise<IKeyringPair>) => Promise<void>) => {
   return usingPlaygroundsGeneral<DevRelayHelper>(DevRelayHelper, url, code);
 };
modifiedtests/src/util/playgrounds/unique.dev.tsdiffbeforeafterboth
--- a/tests/src/util/playgrounds/unique.dev.ts
+++ b/tests/src/util/playgrounds/unique.dev.ts
@@ -118,7 +118,16 @@
   }
 }
 
-export class DevRelayHelper extends RelayHelper {}
+export class DevRelayHelper extends RelayHelper {
+  wait: WaitGroup;
+
+  constructor(logger: { log: (msg: any, level: any) => void, level: any }, options: {[key: string]: any} = {}) {
+    options.helperBase = options.helperBase ?? DevRelayHelper;
+
+    super(logger, options);
+    this.wait = new WaitGroup(this);
+  }
+}
 
 export class DevWestmintHelper extends WestmintHelper {
   wait: WaitGroup;
@@ -131,12 +140,17 @@
   }
 }
 
+export class DevStatemineHelper extends DevWestmintHelper {}
+
+export class DevStatemintHelper extends DevWestmintHelper {}
+
 export class DevMoonbeamHelper extends MoonbeamHelper {
   account: MoonbeamAccountGroup;
   wait: WaitGroup;
 
   constructor(logger: { log: (msg: any, level: any) => void, level: any }, options: {[key: string]: any} = {}) {
     options.helperBase = options.helperBase ?? DevMoonbeamHelper;
+    options.notePreimagePallet = options.notePreimagePallet ?? 'democracy';
 
     super(logger, options);
     this.account = new MoonbeamAccountGroup(this);
@@ -144,7 +158,12 @@
   }
 }
 
-export class DevMoonriverHelper extends DevMoonbeamHelper {}
+export class DevMoonriverHelper extends DevMoonbeamHelper {
+  constructor(logger: { log: (msg: any, level: any) => void, level: any }, options: {[key: string]: any} = {}) {
+    options.notePreimagePallet = options.notePreimagePallet ?? 'preimage';
+    super(logger, options);
+  }
+}
 
 export class DevAcalaHelper extends AcalaHelper {
   wait: WaitGroup;
modifiedtests/src/util/playgrounds/unique.tsdiffbeforeafterboth
--- a/tests/src/util/playgrounds/unique.ts
+++ b/tests/src/util/playgrounds/unique.ts
@@ -2740,21 +2740,72 @@
     this.palletName = palletName;
   }
 
-  async limitedReserveTransferAssets(signer: TSigner, destination: any, beneficiary: any, assets: any, feeAssetItem: number, weightLimit: number) {
-    await this.helper.executeExtrinsic(signer, `api.tx.${this.palletName}.limitedReserveTransferAssets`, [destination, beneficiary, assets, feeAssetItem, {Limited: weightLimit}], true);
+  async limitedReserveTransferAssets(signer: TSigner, destination: any, beneficiary: any, assets: any, feeAssetItem: number, weightLimit: any) {
+    await this.helper.executeExtrinsic(signer, `api.tx.${this.palletName}.limitedReserveTransferAssets`, [destination, beneficiary, assets, feeAssetItem, weightLimit], true);
+  }
+
+  async teleportAssets(signer: TSigner, destination: any, beneficiary: any, assets: any, feeAssetItem: number) {
+    await this.helper.executeExtrinsic(signer, `api.tx.${this.palletName}.teleportAssets`, [destination, beneficiary, assets, feeAssetItem], true);
+  }
+
+  async teleportNativeAsset(signer: TSigner, destinationParaId: number, targetAccount: Uint8Array, amount: bigint) {
+    const destination = {
+      V1: {
+        parents: 0,
+        interior: {
+          X1: {
+            Parachain: destinationParaId,
+          },
+        },
+      },
+    };
+
+    const beneficiary = {
+      V1: {
+        parents: 0,
+        interior: {
+          X1: {
+            AccountId32: {
+              network: 'Any',
+              id: targetAccount,
+            },
+          },
+        },
+      },
+    };
+
+    const assets = {
+      V1: [
+        {
+          id: {
+            Concrete: {
+              parents: 0,
+              interior: 'Here',
+            },
+          },
+          fun: {
+            Fungible: amount,
+          },
+        },
+      ],
+    };
+
+    const feeAssetItem = 0;
+
+    await this.teleportAssets(signer, destination, beneficiary, assets, feeAssetItem);
   }
 }
 
 class XTokensGroup<T extends ChainHelperBase> extends HelperGroup<T> {
-  async transfer(signer: TSigner, currencyId: any, amount: bigint, destination: any, destWeight: number) {
+  async transfer(signer: TSigner, currencyId: any, amount: bigint, destination: any, destWeight: any) {
     await this.helper.executeExtrinsic(signer, 'api.tx.xTokens.transfer', [currencyId, amount, destination, destWeight], true);
   }
 
-  async transferMultiasset(signer: TSigner, asset: any, destination: any, destWeight: number) {
+  async transferMultiasset(signer: TSigner, asset: any, destination: any, destWeight: any) {
     await this.helper.executeExtrinsic(signer, 'api.tx.xTokens.transferMultiasset', [asset, destination, destWeight], true);
   }
 
-  async transferMulticurrencies(signer: TSigner, currencies: any[], feeItem: number, destLocation: any, destWeight: number) {
+  async transferMulticurrencies(signer: TSigner, currencies: any[], feeItem: number, destLocation: any, destWeight: any) {
     await this.helper.executeExtrinsic(signer, 'api.tx.xTokens.transferMulticurrencies', [currencies, feeItem, destLocation, destWeight], true);
   }
 }
@@ -2823,12 +2874,19 @@
 }
 
 class MoonbeamDemocracyGroup extends HelperGroup<MoonbeamHelper> {
+  notePreimagePallet: string;
+
+  constructor(helper: MoonbeamHelper, options: {[key: string]: any} = {}) {
+    super(helper);
+    this.notePreimagePallet = options.notePreimagePallet;
+  }
+
   async notePreimage(signer: TSigner, encodedProposal: string) {
-    await this.helper.executeExtrinsic(signer, 'api.tx.democracy.notePreimage', [encodedProposal], true);
+    await this.helper.executeExtrinsic(signer, `api.tx.${this.notePreimagePallet}.notePreimage`, [encodedProposal], true);
   }
 
-  externalProposeMajority(proposalHash: string) {
-    return this.helper.constructApiCall('api.tx.democracy.externalProposeMajority', [proposalHash]);
+  externalProposeMajority(proposal: any) {
+    return this.helper.constructApiCall('api.tx.democracy.externalProposeMajority', [proposal]);
   }
 
   fastTrack(proposalHash: string, votingPeriod: number, delayPeriod: number) {
@@ -2857,7 +2915,7 @@
     await this.helper.executeExtrinsic(signer, `api.tx.${this.collective}.vote`, [proposalHash, proposalIndex, approve], true);
   }
 
-  async close(signer: TSigner, proposalHash: string, proposalIndex: number, weightBound: number, lengthBound: number) {
+  async close(signer: TSigner, proposalHash: string, proposalIndex: number, weightBound: any, lengthBound: number) {
     await this.helper.executeExtrinsic(signer, `api.tx.${this.collective}.close`, [proposalHash, proposalIndex, weightBound, lengthBound], true);
   }
 
@@ -2917,11 +2975,13 @@
 }
 
 export class RelayHelper extends XcmChainHelper {
+  balance: SubstrateBalanceGroup<RelayHelper>;
   xcm: XcmGroup<RelayHelper>;
 
   constructor(logger?: ILogger, options: {[key: string]: any} = {}) {
     super(logger, options.helperBase ?? RelayHelper);
 
+    this.balance = new SubstrateBalanceGroup(this);
     this.xcm = new XcmGroup(this, 'xcmPallet');
   }
 }
@@ -2960,7 +3020,7 @@
     this.assetManager = new MoonbeamAssetManagerGroup(this);
     this.assets = new AssetsGroup(this);
     this.xTokens = new XTokensGroup(this);
-    this.democracy = new MoonbeamDemocracyGroup(this);
+    this.democracy = new MoonbeamDemocracyGroup(this, options);
     this.collective = {
       council: new MoonbeamCollectiveGroup(this, 'councilCollective'),
       techCommittee: new MoonbeamCollectiveGroup(this, 'techCommitteeCollective'),
modifiedtests/src/xcm/xcmOpal.test.tsdiffbeforeafterboth
--- a/tests/src/xcm/xcmOpal.test.ts
+++ b/tests/src/xcm/xcmOpal.test.ts
@@ -31,6 +31,7 @@
 const ASSET_METADATA_DESCRIPTION = 'USDT';
 const ASSET_METADATA_MINIMAL_BALANCE = 1n;
 
+const RELAY_DECIMALS = 12;
 const WESTMINT_DECIMALS = 12;
 
 const TRANSFER_AMOUNT = 1_000_000_000_000_000_000n;
@@ -147,9 +148,8 @@
       };
 
       const feeAssetItem = 0;
-      const weightLimit = 5_000_000_000;
 
-      await helper.xcm.limitedReserveTransferAssets(alice, destination, beneficiary, assets, feeAssetItem, weightLimit);
+      await helper.xcm.limitedReserveTransferAssets(alice, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
     });
   
   });
@@ -202,16 +202,15 @@
       };
 
       const feeAssetItem = 0;
-      const weightLimit = 5000000000;
 
       balanceStmnBefore = await helper.balance.getSubstrate(alice.address);
-      await helper.xcm.limitedReserveTransferAssets(alice, dest, beneficiary, assets, feeAssetItem, weightLimit);
+      await helper.xcm.limitedReserveTransferAssets(alice, dest, beneficiary, assets, feeAssetItem, 'Unlimited');
 
       balanceStmnAfter = await helper.balance.getSubstrate(alice.address);
 
       // common good parachain take commission in it native token
       console.log(
-        'Opal to Westmint transaction fees on Westmint: %s WND',
+        '[Westmint -> Opal] transaction fees on Westmint: %s WND',
         helper.util.bigIntToDecimals(balanceStmnBefore - balanceStmnAfter, WESTMINT_DECIMALS),
       );
       expect(balanceStmnBefore > balanceStmnAfter).to.be.true;
@@ -227,18 +226,19 @@
 
     balanceOpalAfter = await helper.balance.getSubstrate(alice.address);
 
-    // commission has not paid in USDT token
-    expect(free == TRANSFER_AMOUNT).to.be.true;
     console.log(
-      'Opal to Westmint transaction fees on Opal: %s USDT',
-      helper.util.bigIntToDecimals(TRANSFER_AMOUNT - free),
+      '[Westmint -> Opal] transaction fees on Opal: %s USDT',
+      helper.util.bigIntToDecimals(TRANSFER_AMOUNT - free, ASSET_METADATA_DECIMALS),
     );
+    console.log(
+      '[Westmint -> Opal] transaction fees on Opal: %s OPL',
+      helper.util.bigIntToDecimals(balanceOpalAfter - balanceOpalBefore),
+    );
+
+    // commission has not paid in USDT token
+    expect(free == TRANSFER_AMOUNT).to.be.true;
     // ... and parachain native token
     expect(balanceOpalAfter == balanceOpalBefore).to.be.true;
-    console.log(
-      'Opal to Westmint transaction fees on Opal: %s WND',
-      helper.util.bigIntToDecimals(balanceOpalAfter - balanceOpalBefore, WESTMINT_DECIMALS),
-    );    
   });
 
   itSub('Should connect and send USDT from Unique to Statemine back', async ({helper}) => {
@@ -276,9 +276,8 @@
     ];
 
     const feeItem = 1;
-    const destWeight = 500000000000;
 
-    await helper.xTokens.transferMulticurrencies(alice, currencies, feeItem, destination, destWeight);
+    await helper.xTokens.transferMulticurrencies(alice, currencies, feeItem, destination, 'Unlimited');
     
     // the commission has been paid in parachain native token
     balanceOpalFinal = await helper.balance.getSubstrate(alice.address);
@@ -339,9 +338,8 @@
       };
 
       const feeAssetItem = 0;
-      const weightLimit = 5_000_000_000;
 
-      await helper.xcm.limitedReserveTransferAssets(bob, destination, beneficiary, assets, feeAssetItem, weightLimit);
+      await helper.xcm.limitedReserveTransferAssets(bob, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
     });
   
     await helper.wait.newBlocks(3);
@@ -363,20 +361,23 @@
   });
 
   itSub('Should connect and send Relay token back', async ({helper}) => {
+    let relayTokenBalanceBefore: bigint;
+    let relayTokenBalanceAfter: bigint;
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      relayTokenBalanceBefore = await helper.balance.getSubstrate(bob.address);
+    });
+
     const destination = {
       V1: {
         parents: 1,
-        interior: {X2: [
-          {
-            Parachain: STATEMINE_CHAIN,
-          },
-          {
+        interior: {
+          X1:{
             AccountId32: {
               network: 'Any',
               id: bob.addressRaw,
             },
           },
-        ]},
+        },
       },
     };
 
@@ -390,11 +391,19 @@
     ];
 
     const feeItem = 0;
-    const destWeight = 500000000000;
 
-    await helper.xTokens.transferMulticurrencies(bob, currencies, feeItem, destination, destWeight);
+    await helper.xTokens.transferMulticurrencies(bob, currencies, feeItem, destination, 'Unlimited');
 
     balanceBobFinal = await helper.balance.getSubstrate(bob.address);
-    console.log('Relay (Westend) to Opal transaction fees: %s OPL', balanceBobAfter - balanceBobFinal);
+    console.log('[Opal -> Relay (Westend)] transaction fees: %s OPL',  helper.util.bigIntToDecimals(balanceBobAfter - balanceBobFinal));
+
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      await helper.wait.newBlocks(10);
+      relayTokenBalanceAfter = await helper.balance.getSubstrate(bob.address);
+
+      const diff = relayTokenBalanceAfter - relayTokenBalanceBefore;
+      console.log('[Opal -> Relay (Westend)] actually delivered: %s WND', helper.util.bigIntToDecimals(diff, RELAY_DECIMALS));
+      expect(diff > 0, 'Relay tokens was not delivered back').to.be.true;
+    });
   });
 });
modifiedtests/src/xcm/xcmQuartz.test.tsdiffbeforeafterboth
17import {IKeyringPair} from '@polkadot/types/types';17import {IKeyringPair} from '@polkadot/types/types';
18import {blake2AsHex} from '@polkadot/util-crypto';18import {blake2AsHex} from '@polkadot/util-crypto';
19import config from '../config';19import config from '../config';
20import {XcmV2TraitsOutcome, XcmV2TraitsError} from '../interfaces';20import {XcmV2TraitsError} from '../interfaces';
21import {itSub, expect, describeXCM, usingPlaygrounds, usingKaruraPlaygrounds, usingRelayPlaygrounds, usingMoonriverPlaygrounds} from '../util';21import {itSub, expect, describeXCM, usingPlaygrounds, usingKaruraPlaygrounds, usingRelayPlaygrounds, usingMoonriverPlaygrounds, usingStateminePlaygrounds} from '../util';
2222
23const QUARTZ_CHAIN = 2095;23const QUARTZ_CHAIN = 2095;
24const STATEMINE_CHAIN = 1000;
24const KARURA_CHAIN = 2000;25const KARURA_CHAIN = 2000;
25const MOONRIVER_CHAIN = 2023;26const MOONRIVER_CHAIN = 2023;
2627
28const STATEMINE_PALLET_INSTANCE = 50;
29
27const relayUrl = config.relayUrl;30const relayUrl = config.relayUrl;
31const statemineUrl = config.statemineUrl;
28const karuraUrl = config.karuraUrl;32const karuraUrl = config.karuraUrl;
29const moonriverUrl = config.moonriverUrl;33const moonriverUrl = config.moonriverUrl;
3034
35const RELAY_DECIMALS = 12;
36const STATEMINE_DECIMALS = 12;
31const KARURA_DECIMALS = 12;37const KARURA_DECIMALS = 12;
3238
33const TRANSFER_AMOUNT = 2000000000000000000000000n;39const TRANSFER_AMOUNT = 2000000000000000000000000n;
3440
41const FUNDING_AMOUNT = 3_500_000_0000_000_000n;
42
43const TRANSFER_AMOUNT_RELAY = 50_000_000_000_000_000n;
44
45const USDT_ASSET_ID = 100;
46const USDT_ASSET_METADATA_DECIMALS = 18;
47const USDT_ASSET_METADATA_NAME = 'USDT';
48const USDT_ASSET_METADATA_DESCRIPTION = 'USDT';
49const USDT_ASSET_METADATA_MINIMAL_BALANCE = 1n;
50const USDT_ASSET_AMOUNT = 10_000_000_000_000_000_000_000_000n;
51
52describeXCM('[XCM] Integration test: Exchanging USDT with Statemine', () => {
53 let alice: IKeyringPair;
54 let bob: IKeyringPair;
55
56 let balanceStmnBefore: bigint;
57 let balanceStmnAfter: bigint;
58
59 let balanceQuartzBefore: bigint;
60 let balanceQuartzAfter: bigint;
61 let balanceQuartzFinal: bigint;
62
63 let balanceBobBefore: bigint;
64 let balanceBobAfter: bigint;
65 let balanceBobFinal: bigint;
66
67 let balanceBobRelayTokenBefore: bigint;
68 let balanceBobRelayTokenAfter: bigint;
69
70
71 before(async () => {
72 await usingPlaygrounds(async (_helper, privateKey) => {
73 alice = await privateKey('//Alice');
74 bob = await privateKey('//Bob'); // sovereign account on Statemine(t) funds donor
75 });
76
77 await usingRelayPlaygrounds(relayUrl, async (helper) => {
78 // Fund accounts on Statemine(t)
79 await helper.xcm.teleportNativeAsset(alice, STATEMINE_CHAIN, alice.addressRaw, FUNDING_AMOUNT);
80 await helper.xcm.teleportNativeAsset(alice, STATEMINE_CHAIN, bob.addressRaw, FUNDING_AMOUNT);
81 });
82
83 await usingStateminePlaygrounds(statemineUrl, async (helper) => {
84 const sovereignFundingAmount = 3_500_000_000n;
85
86 await helper.assets.create(
87 alice,
88 USDT_ASSET_ID,
89 alice.address,
90 USDT_ASSET_METADATA_MINIMAL_BALANCE,
91 );
92 await helper.assets.setMetadata(
93 alice,
94 USDT_ASSET_ID,
95 USDT_ASSET_METADATA_NAME,
96 USDT_ASSET_METADATA_DESCRIPTION,
97 USDT_ASSET_METADATA_DECIMALS,
98 );
99 await helper.assets.mint(
100 alice,
101 USDT_ASSET_ID,
102 alice.address,
103 USDT_ASSET_AMOUNT,
104 );
105
106 // funding parachain sovereing account on Statemine(t).
107 // The sovereign account should be created before any action
108 // (the assets pallet on Statemine(t) check if the sovereign account exists)
109 const parachainSovereingAccount = helper.address.paraSiblingSovereignAccount(QUARTZ_CHAIN);
110 await helper.balance.transferToSubstrate(bob, parachainSovereingAccount, sovereignFundingAmount);
111 });
112
113
114 await usingPlaygrounds(async (helper) => {
115 const location = {
116 V1: {
117 parents: 1,
118 interior: {X3: [
119 {
120 Parachain: STATEMINE_CHAIN,
121 },
122 {
123 PalletInstance: STATEMINE_PALLET_INSTANCE,
124 },
125 {
126 GeneralIndex: USDT_ASSET_ID,
127 },
128 ]},
129 },
130 };
131
132 const metadata =
133 {
134 name: USDT_ASSET_ID,
135 symbol: USDT_ASSET_METADATA_NAME,
136 decimals: USDT_ASSET_METADATA_DECIMALS,
137 minimalBalance: USDT_ASSET_METADATA_MINIMAL_BALANCE,
138 };
139 await helper.getSudo().foreignAssets.register(alice, alice.address, location, metadata);
140 balanceQuartzBefore = await helper.balance.getSubstrate(alice.address);
141 });
142
143
144 // Providing the relay currency to the quartz sender account
145 // (fee for USDT XCM are paid in relay tokens)
146 await usingRelayPlaygrounds(relayUrl, async (helper) => {
147 const destination = {
148 V1: {
149 parents: 0,
150 interior: {X1: {
151 Parachain: QUARTZ_CHAIN,
152 },
153 },
154 }};
155
156 const beneficiary = {
157 V1: {
158 parents: 0,
159 interior: {X1: {
160 AccountId32: {
161 network: 'Any',
162 id: alice.addressRaw,
163 },
164 }},
165 },
166 };
167
168 const assets = {
169 V1: [
170 {
171 id: {
172 Concrete: {
173 parents: 0,
174 interior: 'Here',
175 },
176 },
177 fun: {
178 Fungible: TRANSFER_AMOUNT_RELAY,
179 },
180 },
181 ],
182 };
183
184 const feeAssetItem = 0;
185
186 await helper.xcm.limitedReserveTransferAssets(alice, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
187 });
188
189 });
190
191 itSub('Should connect and send USDT from Statemine to Quartz', async ({helper}) => {
192 await usingStateminePlaygrounds(statemineUrl, async (helper) => {
193 const dest = {
194 V1: {
195 parents: 1,
196 interior: {X1: {
197 Parachain: QUARTZ_CHAIN,
198 },
199 },
200 }};
201
202 const beneficiary = {
203 V1: {
204 parents: 0,
205 interior: {X1: {
206 AccountId32: {
207 network: 'Any',
208 id: alice.addressRaw,
209 },
210 }},
211 },
212 };
213
214 const assets = {
215 V1: [
216 {
217 id: {
218 Concrete: {
219 parents: 0,
220 interior: {
221 X2: [
222 {
223 PalletInstance: STATEMINE_PALLET_INSTANCE,
224 },
225 {
226 GeneralIndex: USDT_ASSET_ID,
227 },
228 ]},
229 },
230 },
231 fun: {
232 Fungible: TRANSFER_AMOUNT,
233 },
234 },
235 ],
236 };
237
238 const feeAssetItem = 0;
239
240 balanceStmnBefore = await helper.balance.getSubstrate(alice.address);
241 await helper.xcm.limitedReserveTransferAssets(alice, dest, beneficiary, assets, feeAssetItem, 'Unlimited');
242
243 balanceStmnAfter = await helper.balance.getSubstrate(alice.address);
244
245 // common good parachain take commission in it native token
246 console.log(
247 '[Statemine -> Quartz] transaction fees on Statemine: %s WND',
248 helper.util.bigIntToDecimals(balanceStmnBefore - balanceStmnAfter, STATEMINE_DECIMALS),
249 );
250 expect(balanceStmnBefore > balanceStmnAfter).to.be.true;
251
252 });
253
254
255 // ensure that asset has been delivered
256 await helper.wait.newBlocks(3);
257
258 // expext collection id will be with id 1
259 const free = await helper.ft.getBalance(1, {Substrate: alice.address});
260
261 balanceQuartzAfter = await helper.balance.getSubstrate(alice.address);
262
263 console.log(
264 '[Statemine -> Quartz] transaction fees on Quartz: %s USDT',
265 helper.util.bigIntToDecimals(TRANSFER_AMOUNT - free, USDT_ASSET_METADATA_DECIMALS),
266 );
267 console.log(
268 '[Statemine -> Quartz] transaction fees on Quartz: %s QTZ',
269 helper.util.bigIntToDecimals(balanceQuartzAfter - balanceQuartzBefore),
270 );
271 // commission has not paid in USDT token
272 expect(free).to.be.equal(TRANSFER_AMOUNT);
273 // ... and parachain native token
274 expect(balanceQuartzAfter == balanceQuartzBefore).to.be.true;
275 });
276
277 itSub('Should connect and send USDT from Quartz to Statemine back', async ({helper}) => {
278 const destination = {
279 V1: {
280 parents: 1,
281 interior: {X2: [
282 {
283 Parachain: STATEMINE_CHAIN,
284 },
285 {
286 AccountId32: {
287 network: 'Any',
288 id: alice.addressRaw,
289 },
290 },
291 ]},
292 },
293 };
294
295 const relayFee = 400_000_000_000_000n;
296 const currencies: [any, bigint][] = [
297 [
298 {
299 ForeignAssetId: 0,
300 },
301 TRANSFER_AMOUNT,
302 ],
303 [
304 {
305 NativeAssetId: 'Parent',
306 },
307 relayFee,
308 ],
309 ];
310
311 const feeItem = 1;
312
313 await helper.xTokens.transferMulticurrencies(alice, currencies, feeItem, destination, 'Unlimited');
314
315 // the commission has been paid in parachain native token
316 balanceQuartzFinal = await helper.balance.getSubstrate(alice.address);
317 console.log('[Quartz -> Statemine] transaction fees on Quartz: %s QTZ', helper.util.bigIntToDecimals(balanceQuartzFinal - balanceQuartzAfter));
318 expect(balanceQuartzAfter > balanceQuartzFinal).to.be.true;
319
320 await usingStateminePlaygrounds(statemineUrl, async (helper) => {
321 await helper.wait.newBlocks(3);
322
323 // The USDT token never paid fees. Its amount not changed from begin value.
324 // Also check that xcm transfer has been succeeded
325 expect((await helper.assets.account(USDT_ASSET_ID, alice.address))! == USDT_ASSET_AMOUNT).to.be.true;
326 });
327 });
328
329 itSub('Should connect and send Relay token to Quartz', async ({helper}) => {
330 balanceBobBefore = await helper.balance.getSubstrate(bob.address);
331 balanceBobRelayTokenBefore = await helper.tokens.accounts(bob.address, {NativeAssetId: 'Parent'});
332
333 await usingRelayPlaygrounds(relayUrl, async (helper) => {
334 const destination = {
335 V1: {
336 parents: 0,
337 interior: {X1: {
338 Parachain: QUARTZ_CHAIN,
339 },
340 },
341 }};
342
343 const beneficiary = {
344 V1: {
345 parents: 0,
346 interior: {X1: {
347 AccountId32: {
348 network: 'Any',
349 id: bob.addressRaw,
350 },
351 }},
352 },
353 };
354
355 const assets = {
356 V1: [
357 {
358 id: {
359 Concrete: {
360 parents: 0,
361 interior: 'Here',
362 },
363 },
364 fun: {
365 Fungible: TRANSFER_AMOUNT_RELAY,
366 },
367 },
368 ],
369 };
370
371 const feeAssetItem = 0;
372
373 await helper.xcm.limitedReserveTransferAssets(bob, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
374 });
375
376 await helper.wait.newBlocks(3);
377
378 balanceBobAfter = await helper.balance.getSubstrate(bob.address);
379 balanceBobRelayTokenAfter = await helper.tokens.accounts(bob.address, {NativeAssetId: 'Parent'});
380
381 const wndFeeOnQuartz = balanceBobRelayTokenAfter - TRANSFER_AMOUNT_RELAY - balanceBobRelayTokenBefore;
382 const wndDiffOnQuartz = balanceBobRelayTokenAfter - balanceBobRelayTokenBefore;
383 console.log(
384 '[Relay (Westend) -> Quartz] transaction fees: %s QTZ',
385 helper.util.bigIntToDecimals(balanceBobAfter - balanceBobBefore),
386 );
387 console.log(
388 '[Relay (Westend) -> Quartz] transaction fees: %s WND',
389 helper.util.bigIntToDecimals(wndFeeOnQuartz, STATEMINE_DECIMALS),
390 );
391 console.log('[Relay (Westend) -> Quartz] actually delivered: %s WND', wndDiffOnQuartz);
392 expect(wndFeeOnQuartz == 0n, 'No incoming WND fees should be taken').to.be.true;
393 expect(balanceBobBefore == balanceBobAfter, 'No incoming QTZ fees should be taken').to.be.true;
394 });
395
396 itSub('Should connect and send Relay token back', async ({helper}) => {
397 let relayTokenBalanceBefore: bigint;
398 let relayTokenBalanceAfter: bigint;
399 await usingRelayPlaygrounds(relayUrl, async (helper) => {
400 relayTokenBalanceBefore = await helper.balance.getSubstrate(bob.address);
401 });
402
403 const destination = {
404 V1: {
405 parents: 1,
406 interior: {
407 X1:{
408 AccountId32: {
409 network: 'Any',
410 id: bob.addressRaw,
411 },
412 },
413 },
414 },
415 };
416
417 const currencies: any = [
418 [
419 {
420 NativeAssetId: 'Parent',
421 },
422 TRANSFER_AMOUNT_RELAY,
423 ],
424 ];
425
426 const feeItem = 0;
427
428 await helper.xTokens.transferMulticurrencies(bob, currencies, feeItem, destination, 'Unlimited');
429
430 balanceBobFinal = await helper.balance.getSubstrate(bob.address);
431 console.log('[Quartz -> Relay (Westend)] transaction fees: %s QTZ', helper.util.bigIntToDecimals(balanceBobAfter - balanceBobFinal));
432
433 await usingRelayPlaygrounds(relayUrl, async (helper) => {
434 await helper.wait.newBlocks(10);
435 relayTokenBalanceAfter = await helper.balance.getSubstrate(bob.address);
436
437 const diff = relayTokenBalanceAfter - relayTokenBalanceBefore;
438 console.log('[Quartz -> Relay (Westend)] actually delivered: %s WND', helper.util.bigIntToDecimals(diff, RELAY_DECIMALS));
439 expect(diff > 0, 'Relay tokens was not delivered back').to.be.true;
440 });
441 });
442});
443
35describeXCM('[XCM] Integration test: Exchanging tokens with Karura', () => {444describeXCM('[XCM] Integration test: Exchanging tokens with Karura', () => {
36 let alice: IKeyringPair;445 let alice: IKeyringPair;
123 };532 };
124533
125 const feeAssetItem = 0;534 const feeAssetItem = 0;
126 const weightLimit = 5000000000;
127535
128 await helper.xcm.limitedReserveTransferAssets(randomAccount, destination, beneficiary, assets, feeAssetItem, weightLimit);536 await helper.xcm.limitedReserveTransferAssets(randomAccount, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
129 balanceQuartzTokenMiddle = await helper.balance.getSubstrate(randomAccount.address);537 balanceQuartzTokenMiddle = await helper.balance.getSubstrate(randomAccount.address);
130538
131 const qtzFees = balanceQuartzTokenInit - balanceQuartzTokenMiddle - TRANSFER_AMOUNT;539 const qtzFees = balanceQuartzTokenInit - balanceQuartzTokenMiddle - TRANSFER_AMOUNT;
540 expect(qtzFees > 0n, 'Negative fees QTZ, looks like nothing was transferred').to.be.true;
132 console.log('[Quartz -> Karura] transaction fees on Quartz: %s QTZ', helper.util.bigIntToDecimals(qtzFees));541 console.log('[Quartz -> Karura] transaction fees on Quartz: %s QTZ', helper.util.bigIntToDecimals(qtzFees));
133 expect(qtzFees > 0n).to.be.true;
134542
135 await usingKaruraPlaygrounds(karuraUrl, async (helper) => {543 await usingKaruraPlaygrounds(karuraUrl, async (helper) => {
136 await helper.wait.newBlocks(3);544 await helper.wait.newBlocks(3);
173 ForeignAsset: 0,581 ForeignAsset: 0,
174 };582 };
175583
176 const destWeight = 50000000;584 await helper.xTokens.transfer(randomAccount, id, TRANSFER_AMOUNT, destination, 'Unlimited');
177
178 await helper.xTokens.transfer(randomAccount, id, TRANSFER_AMOUNT, destination, destWeight);
179 balanceKaruraTokenFinal = await helper.balance.getSubstrate(randomAccount.address);585 balanceKaruraTokenFinal = await helper.balance.getSubstrate(randomAccount.address);
180 balanceQuartzForeignTokenFinal = await helper.tokens.accounts(randomAccount.address, id);586 balanceQuartzForeignTokenFinal = await helper.tokens.accounts(randomAccount.address, id);
181587
188 );594 );
189 console.log('[Karura -> Quartz] outcome %s QTZ', helper.util.bigIntToDecimals(qtzOutcomeTransfer));595 console.log('[Karura -> Quartz] outcome %s QTZ', helper.util.bigIntToDecimals(qtzOutcomeTransfer));
190596
191 expect(karFees > 0).to.be.true;597 expect(karFees > 0, 'Negative fees KAR, looks like nothing was transferred').to.be.true;
192 expect(qtzOutcomeTransfer == TRANSFER_AMOUNT).to.be.true;598 expect(qtzOutcomeTransfer == TRANSFER_AMOUNT).to.be.true;
193 });599 });
194600
216 });622 });
217 });623 });
218624
219 itSub('Quartz rejects tokens from the Relay', async ({helper}) => {
220 await usingRelayPlaygrounds(relayUrl, async (helper) => {
221 const destination = {
222 V1: {
223 parents: 0,
224 interior: {X1: {
225 Parachain: QUARTZ_CHAIN,
226 },
227 },
228 }};
229
230 const beneficiary = {
231 V1: {
232 parents: 0,
233 interior: {X1: {
234 AccountId32: {
235 network: 'Any',
236 id: alice.addressRaw,
237 },
238 }},
239 },
240 };
241
242 const assets = {
243 V1: [
244 {
245 id: {
246 Concrete: {
247 parents: 0,
248 interior: 'Here',
249 },
250 },
251 fun: {
252 Fungible: 50_000_000_000_000_000n,
253 },
254 },
255 ],
256 };
257
258 const feeAssetItem = 0;
259 const weightLimit = 5_000_000_000;
260
261 await helper.xcm.limitedReserveTransferAssets(alice, destination, beneficiary, assets, feeAssetItem, weightLimit);
262 });
263
264 const maxWaitBlocks = 3;
265
266 const dmpQueueExecutedDownward = await helper.wait.event(maxWaitBlocks, 'dmpQueue', 'ExecutedDownward');
267
268 expect(
269 dmpQueueExecutedDownward != null,
270 '[Relay] dmpQueue.ExecutedDownward event is expected',
271 ).to.be.true;
272
273 const event = dmpQueueExecutedDownward!.event;
274 const outcome = event.data[1] as XcmV2TraitsOutcome;
275
276 expect(
277 outcome.isIncomplete,
278 '[Relay] The outcome of the XCM should be `Incomplete`',
279 ).to.be.true;
280
281 const incomplete = outcome.asIncomplete;
282 expect(
283 incomplete[1].toString() == 'AssetNotFound',
284 '[Relay] The XCM error should be `AssetNotFound`',
285 ).to.be.true;
286 });
287
288 itSub('Quartz rejects KAR tokens from Karura', async ({helper}) => {625 itSub('Quartz rejects KAR tokens from Karura', async ({helper}) => {
289 await usingKaruraPlaygrounds(karuraUrl, async (helper) => {626 await usingKaruraPlaygrounds(karuraUrl, async (helper) => {
290 const destination = {627 const destination = {
308 Token: 'KAR',645 Token: 'KAR',
309 };646 };
310647
311 const destWeight = 50000000;648 await helper.xTokens.transfer(alice, id, 100_000_000_000n, destination, 'Unlimited');
312
313 await helper.xTokens.transfer(alice, id, 100_000_000_000n, destination, destWeight);
314 });649 });
315650
316 const maxWaitBlocks = 3;651 const maxWaitBlocks = 3;
326 const outcome = event.data[1] as XcmV2TraitsError;661 const outcome = event.data[1] as XcmV2TraitsError;
327662
328 expect(663 expect(
329 outcome.isUntrustedReserveLocation,664 outcome.isFailedToTransactAsset,
330 '[Karura] The XCM error should be `UntrustedReserveLocation`',665 '[Karura] The XCM error should be `FailedToTransactAsset`',
331 ).to.be.true;666 ).to.be.true;
332 });667 });
333});668});
420755
421 // >>> Propose external motion through council >>>756 // >>> Propose external motion through council >>>
422 console.log('Propose external motion through council.......');757 console.log('Propose external motion through council.......');
423 const externalMotion = helper.democracy.externalProposeMajority(proposalHash);758 const externalMotion = helper.democracy.externalProposeMajority({Legacy: proposalHash});
424 const encodedMotion = externalMotion?.method.toHex() || '';759 const encodedMotion = externalMotion?.method.toHex() || '';
425 const motionHash = blake2AsHex(encodedMotion);760 const motionHash = blake2AsHex(encodedMotion);
426 console.log('Motion hash is %s', motionHash);761 console.log('Motion hash is %s', motionHash);
431 await helper.collective.council.vote(dorothyAccount, motionHash, councilProposalIdx, true);766 await helper.collective.council.vote(dorothyAccount, motionHash, councilProposalIdx, true);
432 await helper.collective.council.vote(baltatharAccount, motionHash, councilProposalIdx, true);767 await helper.collective.council.vote(baltatharAccount, motionHash, councilProposalIdx, true);
433768
434 await helper.collective.council.close(dorothyAccount, motionHash, councilProposalIdx, 1_000_000_000, externalMotion.encodedLength);769 await helper.collective.council.close(
770 dorothyAccount,
771 motionHash,
772 councilProposalIdx,
773 {
774 refTime: 1_000_000_000,
775 proofSize: 1_000_000,
776 },
777 externalMotion.encodedLength,
778 );
435 console.log('Propose external motion through council.......DONE');779 console.log('Propose external motion through council.......DONE');
436 // <<< Propose external motion through council <<<780 // <<< Propose external motion through council <<<
437781
448 await helper.collective.techCommittee.vote(baltatharAccount, fastTrackHash, techProposalIdx, true);792 await helper.collective.techCommittee.vote(baltatharAccount, fastTrackHash, techProposalIdx, true);
449 await helper.collective.techCommittee.vote(alithAccount, fastTrackHash, techProposalIdx, true);793 await helper.collective.techCommittee.vote(alithAccount, fastTrackHash, techProposalIdx, true);
450794
451 await helper.collective.techCommittee.close(baltatharAccount, fastTrackHash, techProposalIdx, 1_000_000_000, fastTrack.encodedLength);795 await helper.collective.techCommittee.close(
796 baltatharAccount,
797 fastTrackHash,
798 techProposalIdx,
799 {
800 refTime: 1_000_000_000,
801 proofSize: 1_000_000,
802 },
803 fastTrack.encodedLength,
804 );
452 console.log('Fast track proposal through technical committee.......DONE');805 console.log('Fast track proposal through technical committee.......DONE');
453 // <<< Fast track proposal through technical committee <<<806 // <<< Fast track proposal through technical committee <<<
454807
504 },857 },
505 };858 };
506 const amount = TRANSFER_AMOUNT;859 const amount = TRANSFER_AMOUNT;
507 const destWeight = 850000000;
508860
509 await helper.xTokens.transfer(randomAccountQuartz, currencyId, amount, dest, destWeight);861 await helper.xTokens.transfer(randomAccountQuartz, currencyId, amount, dest, 'Unlimited');
510862
511 balanceQuartzTokenMiddle = await helper.balance.getSubstrate(randomAccountQuartz.address);863 balanceQuartzTokenMiddle = await helper.balance.getSubstrate(randomAccountQuartz.address);
512 expect(balanceQuartzTokenMiddle < balanceQuartzTokenInit).to.be.true;864 expect(balanceQuartzTokenMiddle < balanceQuartzTokenInit).to.be.true;
513865
514 const transactionFees = balanceQuartzTokenInit - balanceQuartzTokenMiddle - TRANSFER_AMOUNT;866 const transactionFees = balanceQuartzTokenInit - balanceQuartzTokenMiddle - TRANSFER_AMOUNT;
515 console.log('[Quartz -> Moonriver] transaction fees on Quartz: %s QTZ', helper.util.bigIntToDecimals(transactionFees));867 console.log('[Quartz -> Moonriver] transaction fees on Quartz: %s QTZ', helper.util.bigIntToDecimals(transactionFees));
516 expect(transactionFees > 0).to.be.true;868 expect(transactionFees > 0, 'Negative fees QTZ, looks like nothing was transferred').to.be.true;
517869
518 await usingMoonriverPlaygrounds(moonriverUrl, async (helper) => {870 await usingMoonriverPlaygrounds(moonriverUrl, async (helper) => {
519 await helper.wait.newBlocks(3);871 await helper.wait.newBlocks(3);
559 },911 },
560 },912 },
561 };913 };
562 const destWeight = 50000000;
563914
564 await helper.xTokens.transferMultiasset(randomAccountMoonriver, asset, destination, destWeight);915 await helper.xTokens.transferMultiasset(randomAccountMoonriver, asset, destination, 'Unlimited');
565916
566 balanceMovrTokenFinal = await helper.balance.getEthereum(randomAccountMoonriver.address);917 balanceMovrTokenFinal = await helper.balance.getEthereum(randomAccountMoonriver.address);
567918
568 const movrFees = balanceMovrTokenMiddle - balanceMovrTokenFinal;919 const movrFees = balanceMovrTokenMiddle - balanceMovrTokenFinal;
569 console.log('[Moonriver -> Quartz] transaction fees on Moonriver: %s MOVR', helper.util.bigIntToDecimals(movrFees));920 console.log('[Moonriver -> Quartz] transaction fees on Moonriver: %s MOVR', helper.util.bigIntToDecimals(movrFees));
570 expect(movrFees > 0).to.be.true;921 expect(movrFees > 0, 'Negative fees MOVR, looks like nothing was transferred').to.be.true;
571922
572 const qtzRandomAccountAsset = await helper.assets.account(assetId, randomAccountMoonriver.address);923 const qtzRandomAccountAsset = await helper.assets.account(assetId, randomAccountMoonriver.address);
573924
modifiedtests/src/xcm/xcmUnique.test.tsdiffbeforeafterboth
--- a/tests/src/xcm/xcmUnique.test.ts
+++ b/tests/src/xcm/xcmUnique.test.ts
@@ -17,21 +17,430 @@
 import {IKeyringPair} from '@polkadot/types/types';
 import {blake2AsHex} from '@polkadot/util-crypto';
 import config from '../config';
-import {XcmV2TraitsError, XcmV2TraitsOutcome} from '../interfaces';
-import {itSub, expect, describeXCM, usingPlaygrounds, usingAcalaPlaygrounds, usingRelayPlaygrounds, usingMoonbeamPlaygrounds} from '../util';
+import {XcmV2TraitsError} from '../interfaces';
+import {itSub, expect, describeXCM, usingPlaygrounds, usingAcalaPlaygrounds, usingRelayPlaygrounds, usingMoonbeamPlaygrounds, usingStatemintPlaygrounds} from '../util';
 
 const UNIQUE_CHAIN = 2037;
+const STATEMINT_CHAIN = 1000;
 const ACALA_CHAIN = 2000;
 const MOONBEAM_CHAIN = 2004;
 
+const STATEMINT_PALLET_INSTANCE = 50;
+
 const relayUrl = config.relayUrl;
+const statemintUrl = config.statemintUrl;
 const acalaUrl = config.acalaUrl;
 const moonbeamUrl = config.moonbeamUrl;
 
+const RELAY_DECIMALS = 12;
+const STATEMINT_DECIMALS = 12;
 const ACALA_DECIMALS = 12;
 
 const TRANSFER_AMOUNT = 2000000000000000000000000n;
 
+const FUNDING_AMOUNT = 3_500_000_0000_000_000n; 
+
+const TRANSFER_AMOUNT_RELAY = 50_000_000_000_000_000n;
+
+const USDT_ASSET_ID = 100;
+const USDT_ASSET_METADATA_DECIMALS = 18;
+const USDT_ASSET_METADATA_NAME = 'USDT';
+const USDT_ASSET_METADATA_DESCRIPTION = 'USDT';
+const USDT_ASSET_METADATA_MINIMAL_BALANCE = 1n;
+const USDT_ASSET_AMOUNT = 10_000_000_000_000_000_000_000_000n;
+
+describeXCM('[XCM] Integration test: Exchanging USDT with Statemint', () => {
+  let alice: IKeyringPair;
+  let bob: IKeyringPair;
+  
+  let balanceStmnBefore: bigint;
+  let balanceStmnAfter: bigint;
+
+  let balanceUniqueBefore: bigint;
+  let balanceUniqueAfter: bigint;
+  let balanceUniqueFinal: bigint;
+
+  let balanceBobBefore: bigint;
+  let balanceBobAfter: bigint;
+  let balanceBobFinal: bigint;
+
+  let balanceBobRelayTokenBefore: bigint;
+  let balanceBobRelayTokenAfter: bigint;
+
+
+  before(async () => {
+    await usingPlaygrounds(async (_helper, privateKey) => {
+      alice = await privateKey('//Alice');
+      bob = await privateKey('//Bob'); // sovereign account on Statemint funds donor
+    });
+
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      // Fund accounts on Statemint
+      await helper.xcm.teleportNativeAsset(alice, STATEMINT_CHAIN, alice.addressRaw, FUNDING_AMOUNT);
+      await helper.xcm.teleportNativeAsset(alice, STATEMINT_CHAIN, bob.addressRaw, FUNDING_AMOUNT);
+    });
+
+    await usingStatemintPlaygrounds(statemintUrl, async (helper) => {
+      const sovereignFundingAmount = 3_500_000_000n; 
+
+      await helper.assets.create(
+        alice,
+        USDT_ASSET_ID,
+        alice.address,
+        USDT_ASSET_METADATA_MINIMAL_BALANCE,
+      );
+      await helper.assets.setMetadata(
+        alice,
+        USDT_ASSET_ID,
+        USDT_ASSET_METADATA_NAME,
+        USDT_ASSET_METADATA_DESCRIPTION,
+        USDT_ASSET_METADATA_DECIMALS,
+      );
+      await helper.assets.mint(
+        alice,
+        USDT_ASSET_ID,
+        alice.address,
+        USDT_ASSET_AMOUNT,
+      );
+
+      // funding parachain sovereing account on Statemint.
+      // The sovereign account should be created before any action
+      // (the assets pallet on Statemint check if the sovereign account exists)
+      const parachainSovereingAccount = helper.address.paraSiblingSovereignAccount(UNIQUE_CHAIN);
+      await helper.balance.transferToSubstrate(bob, parachainSovereingAccount, sovereignFundingAmount);
+    });
+
+
+    await usingPlaygrounds(async (helper) => {
+      const location = {
+        V1: {
+          parents: 1,
+          interior: {X3: [
+            {
+              Parachain: STATEMINT_CHAIN,
+            },
+            {
+              PalletInstance: STATEMINT_PALLET_INSTANCE,
+            },
+            {
+              GeneralIndex: USDT_ASSET_ID,
+            },
+          ]},
+        },
+      };
+
+      const metadata =
+      {
+        name: USDT_ASSET_ID,
+        symbol: USDT_ASSET_METADATA_NAME,
+        decimals: USDT_ASSET_METADATA_DECIMALS,
+        minimalBalance: USDT_ASSET_METADATA_MINIMAL_BALANCE,
+      };
+      await helper.getSudo().foreignAssets.register(alice, alice.address, location, metadata);
+      balanceUniqueBefore = await helper.balance.getSubstrate(alice.address);
+    });
+
+
+    // Providing the relay currency to the unique sender account
+    // (fee for USDT XCM are paid in relay tokens)
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      const destination = {
+        V1: {
+          parents: 0,
+          interior: {X1: {
+            Parachain: UNIQUE_CHAIN,
+          },
+          },
+        }};
+
+      const beneficiary = {
+        V1: {
+          parents: 0,
+          interior: {X1: {
+            AccountId32: {
+              network: 'Any',
+              id: alice.addressRaw,
+            },
+          }},
+        },
+      };
+
+      const assets = {
+        V1: [
+          {
+            id: {
+              Concrete: {
+                parents: 0,
+                interior: 'Here',
+              },
+            },
+            fun: {
+              Fungible: TRANSFER_AMOUNT_RELAY,
+            },
+          },
+        ],
+      };
+
+      const feeAssetItem = 0;
+
+      await helper.xcm.limitedReserveTransferAssets(alice, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
+    });
+  
+  });
+
+  itSub('Should connect and send USDT from Statemint to Unique', async ({helper}) => {
+    await usingStatemintPlaygrounds(statemintUrl, async (helper) => {
+      const dest = {
+        V1: {
+          parents: 1,
+          interior: {X1: {
+            Parachain: UNIQUE_CHAIN,
+          },
+          },
+        }};
+
+      const beneficiary = {
+        V1: {
+          parents: 0,
+          interior: {X1: {
+            AccountId32: {
+              network: 'Any',
+              id: alice.addressRaw,
+            },
+          }},
+        },
+      };
+
+      const assets = {
+        V1: [
+          {
+            id: {
+              Concrete: {
+                parents: 0,
+                interior: {
+                  X2: [
+                    {
+                      PalletInstance: STATEMINT_PALLET_INSTANCE,
+                    },
+                    {
+                      GeneralIndex: USDT_ASSET_ID,
+                    }, 
+                  ]},
+              },
+            },
+            fun: {
+              Fungible: TRANSFER_AMOUNT,
+            },
+          },
+        ],
+      };
+
+      const feeAssetItem = 0;
+
+      balanceStmnBefore = await helper.balance.getSubstrate(alice.address);
+      await helper.xcm.limitedReserveTransferAssets(alice, dest, beneficiary, assets, feeAssetItem, 'Unlimited');
+
+      balanceStmnAfter = await helper.balance.getSubstrate(alice.address);
+
+      // common good parachain take commission in it native token
+      console.log(
+        '[Statemint -> Unique] transaction fees on Statemint: %s WND',
+        helper.util.bigIntToDecimals(balanceStmnBefore - balanceStmnAfter, STATEMINT_DECIMALS),
+      );
+      expect(balanceStmnBefore > balanceStmnAfter).to.be.true;
+
+    });
+
+
+    // ensure that asset has been delivered
+    await helper.wait.newBlocks(3);
+
+    // expext collection id will be with id 1
+    const free = await helper.ft.getBalance(1, {Substrate: alice.address});
+
+    balanceUniqueAfter = await helper.balance.getSubstrate(alice.address);
+
+    console.log(
+      '[Statemint -> Unique] transaction fees on Unique: %s USDT',
+      helper.util.bigIntToDecimals(TRANSFER_AMOUNT - free, USDT_ASSET_METADATA_DECIMALS),
+    );
+    console.log(
+      '[Statemint -> Unique] transaction fees on Unique: %s UNQ',
+      helper.util.bigIntToDecimals(balanceUniqueAfter - balanceUniqueBefore),
+    );    
+    // commission has not paid in USDT token
+    expect(free).to.be.equal(TRANSFER_AMOUNT);
+    // ... and parachain native token
+    expect(balanceUniqueAfter == balanceUniqueBefore).to.be.true;
+  });
+
+  itSub('Should connect and send USDT from Unique to Statemint back', async ({helper}) => {
+    const destination = {
+      V1: {
+        parents: 1,
+        interior: {X2: [
+          {
+            Parachain: STATEMINT_CHAIN,
+          },
+          {
+            AccountId32: {
+              network: 'Any',
+              id: alice.addressRaw,
+            },
+          },
+        ]},
+      },
+    };
+
+    const relayFee = 400_000_000_000_000n;
+    const currencies: [any, bigint][] = [
+      [
+        {
+          ForeignAssetId: 0,
+        },
+        TRANSFER_AMOUNT,
+      ], 
+      [
+        {
+          NativeAssetId: 'Parent',
+        },
+        relayFee,
+      ],
+    ];
+
+    const feeItem = 1;
+
+    await helper.xTokens.transferMulticurrencies(alice, currencies, feeItem, destination, 'Unlimited');
+    
+    // the commission has been paid in parachain native token
+    balanceUniqueFinal = await helper.balance.getSubstrate(alice.address);
+    console.log('[Unique -> Statemint] transaction fees on Unique: %s UNQ', helper.util.bigIntToDecimals(balanceUniqueFinal - balanceUniqueAfter));
+    expect(balanceUniqueAfter > balanceUniqueFinal).to.be.true;
+
+    await usingStatemintPlaygrounds(statemintUrl, async (helper) => {
+      await helper.wait.newBlocks(3);
+      
+      // The USDT token never paid fees. Its amount not changed from begin value.
+      // Also check that xcm transfer has been succeeded 
+      expect((await helper.assets.account(USDT_ASSET_ID, alice.address))! == USDT_ASSET_AMOUNT).to.be.true;
+    });
+  });
+
+  itSub('Should connect and send Relay token to Unique', async ({helper}) => {
+    balanceBobBefore = await helper.balance.getSubstrate(bob.address);
+    balanceBobRelayTokenBefore = await helper.tokens.accounts(bob.address, {NativeAssetId: 'Parent'});
+
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      const destination = {
+        V1: {
+          parents: 0,
+          interior: {X1: {
+            Parachain: UNIQUE_CHAIN,
+          },
+          },
+        }};
+
+      const beneficiary = {
+        V1: {
+          parents: 0,
+          interior: {X1: {
+            AccountId32: {
+              network: 'Any',
+              id: bob.addressRaw,
+            },
+          }},
+        },
+      };
+
+      const assets = {
+        V1: [
+          {
+            id: {
+              Concrete: {
+                parents: 0,
+                interior: 'Here',
+              },
+            },
+            fun: {
+              Fungible: TRANSFER_AMOUNT_RELAY,
+            },
+          },
+        ],
+      };
+
+      const feeAssetItem = 0;
+
+      await helper.xcm.limitedReserveTransferAssets(bob, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
+    });
+  
+    await helper.wait.newBlocks(3);
+
+    balanceBobAfter = await helper.balance.getSubstrate(bob.address);  
+    balanceBobRelayTokenAfter = await helper.tokens.accounts(bob.address, {NativeAssetId: 'Parent'});
+
+    const wndFeeOnUnique = balanceBobRelayTokenAfter - TRANSFER_AMOUNT_RELAY - balanceBobRelayTokenBefore;
+    const wndDiffOnUnique = balanceBobRelayTokenAfter - balanceBobRelayTokenBefore;
+    console.log(
+      '[Relay (Westend) -> Unique] transaction fees: %s UNQ',
+      helper.util.bigIntToDecimals(balanceBobAfter - balanceBobBefore),
+    );
+    console.log(
+      '[Relay (Westend) -> Unique] transaction fees: %s WND',
+      helper.util.bigIntToDecimals(wndFeeOnUnique, STATEMINT_DECIMALS),
+    );
+    console.log('[Relay (Westend) -> Unique] actually delivered: %s WND', wndDiffOnUnique);
+    expect(wndFeeOnUnique == 0n, 'No incoming WND fees should be taken').to.be.true;
+    expect(balanceBobBefore == balanceBobAfter, 'No incoming UNQ fees should be taken').to.be.true;
+  });
+
+  itSub('Should connect and send Relay token back', async ({helper}) => {
+    let relayTokenBalanceBefore: bigint;
+    let relayTokenBalanceAfter: bigint;
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      relayTokenBalanceBefore = await helper.balance.getSubstrate(bob.address);
+    });
+
+    const destination = {
+      V1: {
+        parents: 1,
+        interior: {
+          X1:{
+            AccountId32: {
+              network: 'Any',
+              id: bob.addressRaw,
+            },
+          },
+        },
+      },
+    };
+
+    const currencies: any = [
+      [
+        {
+          NativeAssetId: 'Parent',
+        },
+        TRANSFER_AMOUNT_RELAY,
+      ],
+    ];
+
+    const feeItem = 0;
+
+    await helper.xTokens.transferMulticurrencies(bob, currencies, feeItem, destination, 'Unlimited');
+
+    balanceBobFinal = await helper.balance.getSubstrate(bob.address);
+    console.log('[Unique -> Relay (Westend)] transaction fees: %s UNQ',  helper.util.bigIntToDecimals(balanceBobAfter - balanceBobFinal));
+
+    await usingRelayPlaygrounds(relayUrl, async (helper) => {
+      await helper.wait.newBlocks(10);
+      relayTokenBalanceAfter = await helper.balance.getSubstrate(bob.address);
+
+      const diff = relayTokenBalanceAfter - relayTokenBalanceBefore;
+      console.log('[Unique -> Relay (Westend)] actually delivered: %s WND', helper.util.bigIntToDecimals(diff, RELAY_DECIMALS));
+      expect(diff > 0, 'Relay tokens was not delivered back').to.be.true;
+    });
+  });
+});
+
 describeXCM('[XCM] Integration test: Exchanging tokens with Acala', () => {
   let alice: IKeyringPair;
   let randomAccount: IKeyringPair;
@@ -124,15 +533,13 @@
     };
 
     const feeAssetItem = 0;
-    const weightLimit = 5000000000;
 
-    await helper.xcm.limitedReserveTransferAssets(randomAccount, destination, beneficiary, assets, feeAssetItem, weightLimit);
-
+    await helper.xcm.limitedReserveTransferAssets(randomAccount, destination, beneficiary, assets, feeAssetItem, 'Unlimited');
     balanceUniqueTokenMiddle = await helper.balance.getSubstrate(randomAccount.address);
 
     const unqFees = balanceUniqueTokenInit - balanceUniqueTokenMiddle - TRANSFER_AMOUNT;
     console.log('[Unique -> Acala] transaction fees on Unique: %s UNQ', helper.util.bigIntToDecimals(unqFees));
-    expect(unqFees > 0n).to.be.true;
+    expect(unqFees > 0n, 'Negative fees UNQ, looks like nothing was transferred').to.be.true;
 
     await usingAcalaPlaygrounds(acalaUrl, async (helper) => {
       await helper.wait.newBlocks(3);
@@ -176,10 +583,7 @@
         ForeignAsset: 0,
       };
 
-      const destWeight = 50000000;
-
-      await helper.xTokens.transfer(randomAccount, id, TRANSFER_AMOUNT, destination, destWeight);
-
+      await helper.xTokens.transfer(randomAccount, id, TRANSFER_AMOUNT, destination, 'Unlimited');
       balanceAcalaTokenFinal = await helper.balance.getSubstrate(randomAccount.address);
       balanceUniqueForeignTokenFinal = await helper.tokens.accounts(randomAccount.address, id);
 
@@ -192,7 +596,7 @@
       );
       console.log('[Acala -> Unique] outcome %s UNQ', helper.util.bigIntToDecimals(unqOutcomeTransfer));
 
-      expect(acaFees > 0).to.be.true;
+      expect(acaFees > 0, 'Negative fees ACA, looks like nothing was transferred').to.be.true;
       expect(unqOutcomeTransfer == TRANSFER_AMOUNT).to.be.true;
     });
 
@@ -219,76 +623,7 @@
       alice = await privateKey('//Alice');
     });
   });
-
-  itSub('Unique rejects tokens from the Relay', async ({helper}) => {
-    await usingRelayPlaygrounds(relayUrl, async (helper) => {
-      const destination = {
-        V1: {
-          parents: 0,
-          interior: {X1: {
-            Parachain: UNIQUE_CHAIN,
-          },
-          },
-        }};
 
-      const beneficiary = {
-        V1: {
-          parents: 0,
-          interior: {X1: {
-            AccountId32: {
-              network: 'Any',
-              id: alice.addressRaw,
-            },
-          }},
-        },
-      };
-
-      const assets = {
-        V1: [
-          {
-            id: {
-              Concrete: {
-                parents: 0,
-                interior: 'Here',
-              },
-            },
-            fun: {
-              Fungible: 50_000_000_000_000_000n,
-            },
-          },
-        ],
-      };
-
-      const feeAssetItem = 0;
-      const weightLimit = 5_000_000_000;
-
-      await helper.xcm.limitedReserveTransferAssets(alice, destination, beneficiary, assets, feeAssetItem, weightLimit);
-    });
-
-    const maxWaitBlocks = 3;
-
-    const dmpQueueExecutedDownward = await helper.wait.event(maxWaitBlocks, 'dmpQueue', 'ExecutedDownward');
-
-    expect(
-      dmpQueueExecutedDownward != null,
-      '[Relay] dmpQueue.ExecutedDownward event is expected',
-    ).to.be.true;
-
-    const event = dmpQueueExecutedDownward!.event;
-    const outcome = event.data[1] as XcmV2TraitsOutcome;
-
-    expect(
-      outcome.isIncomplete,
-      '[Relay] The outcome of the XCM should be `Incomplete`',
-    ).to.be.true;
-
-    const incomplete = outcome.asIncomplete;
-    expect(
-      incomplete[1].toString() == 'AssetNotFound',
-      '[Relay] The XCM error should be `AssetNotFound`',
-    ).to.be.true;
-  });
-
   itSub('Unique rejects ACA tokens from Acala', async ({helper}) => {
     await usingAcalaPlaygrounds(acalaUrl, async (helper) => {
       const destination = {
@@ -312,9 +647,7 @@
         Token: 'ACA',
       };
 
-      const destWeight = 50000000;
-
-      await helper.xTokens.transfer(alice, id, 100_000_000_000n, destination, destWeight);
+      await helper.xTokens.transfer(alice, id, 100_000_000_000n, destination, 'Unlimited');
     });
 
     const maxWaitBlocks = 3;
@@ -330,8 +663,8 @@
     const outcome = event.data[1] as XcmV2TraitsError;
 
     expect(
-      outcome.isUntrustedReserveLocation,
-      '[Acala] The XCM error should be `UntrustedReserveLocation`',
+      outcome.isFailedToTransactAsset,
+      '[Acala] The XCM error should be `FailedToTransactAsset`',
     ).to.be.true;
   });
 });
@@ -508,16 +841,15 @@
       },
     };
     const amount = TRANSFER_AMOUNT;
-    const destWeight = 850000000;
 
-    await helper.xTokens.transfer(randomAccountUnique, currencyId, amount, dest, destWeight);
+    await helper.xTokens.transfer(randomAccountUnique, currencyId, amount, dest, 'Unlimited');
 
     balanceUniqueTokenMiddle = await helper.balance.getSubstrate(randomAccountUnique.address);
     expect(balanceUniqueTokenMiddle < balanceUniqueTokenInit).to.be.true;
 
     const transactionFees = balanceUniqueTokenInit - balanceUniqueTokenMiddle - TRANSFER_AMOUNT;
     console.log('[Unique -> Moonbeam] transaction fees on Unique: %s UNQ', helper.util.bigIntToDecimals(transactionFees));
-    expect(transactionFees > 0).to.be.true;
+    expect(transactionFees > 0, 'Negative fees UNQ, looks like nothing was transferred').to.be.true;
 
     await usingMoonbeamPlaygrounds(moonbeamUrl, async (helper) => {
       await helper.wait.newBlocks(3);
@@ -572,7 +904,7 @@
 
       const glmrFees = balanceGlmrTokenMiddle - balanceGlmrTokenFinal;
       console.log('[Moonbeam -> Unique] transaction fees on Moonbeam: %s GLMR', helper.util.bigIntToDecimals(glmrFees));
-      expect(glmrFees > 0).to.be.true;
+      expect(glmrFees > 0, 'Negative fees GLMR, looks like nothing was transferred').to.be.true;
 
       const unqRandomAccountAsset = await helper.assets.account(assetId, randomAccountMoonbeam.address);