Asset Hub: Asset Conversion and Swap Weight Trader

CHANGELOG.md

@@ -17,6 +17,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 - Refund any leases that are not migrated to Coretime (have holes in them/have not yet started) ([polkadot-fellows/runtimes#206](https://github.com/polkadot-fellows/runtimes/pull/206))
 - Enable Elastic Scaling node side feature for Kusama ([polkadot-fellows/runtimes#205](https://github.com/polkadot-fellows/runtimes/pull/205))
 - Cancel Parachain Auctions ([polkadot-fellows/runtimes#215](https://github.com/polkadot-fellows/runtimes/pull/215))
+- Asset Conversion setup for Polkadot Asset Hub, and XCM Swap Weight Trader for both Asset Hubs ([polkadot-fellows/runtimes#218](https://github.com/polkadot-fellows/runtimes/pull/218))
 
 ### Changed
 

integration-tests/emulated/chains/parachains/assets/asset-hub-polkadot/src/lib.rs

@@ -45,6 +45,8 @@ decl_test_parachains! {
 			Balances: asset_hub_polkadot_runtime::Balances,
 			Assets: asset_hub_polkadot_runtime::Assets,
 			ForeignAssets: asset_hub_polkadot_runtime::ForeignAssets,
+			PoolAssets: asset_hub_polkadot_runtime::PoolAssets,
+			AssetConversion: asset_hub_polkadot_runtime::AssetConversion,
 		}
 	},
 }

integration-tests/emulated/tests/assets/asset-hub-kusama/src/tests/swap.rs

@@ -71,7 +71,7 @@ fn swap_locally_on_chain_using_local_assets() {
 			2_000_000_000_000,
 			0,
 			0,
-			AssetHubKusamaSender::get().into()
+			AssetHubKusamaSender::get()
 		));
 
 		assert_expected_events!(
@@ -89,7 +89,7 @@ fn swap_locally_on_chain_using_local_assets() {
 				path,
 				100,
 				1,
-				AssetHubKusamaSender::get().into(),
+				AssetHubKusamaSender::get(),
 				true
 			)
 		);
@@ -112,7 +112,7 @@ fn swap_locally_on_chain_using_local_assets() {
 			                                                      * retrieved. */
 			0,
 			0,
-			AssetHubKusamaSender::get().into(),
+			AssetHubKusamaSender::get(),
 		));
 	});
 }
@@ -150,8 +150,8 @@ fn swap_locally_on_chain_using_foreign_assets() {
 	let penpal_as_seen_by_ah = AssetHubKusama::sibling_location_of(PenpalA::para_id());
 	let sov_penpal_on_ahk = AssetHubKusama::sovereign_account_id_of(penpal_as_seen_by_ah);
 	AssetHubKusama::fund_accounts(vec![
-		(AssetHubKusamaSender::get().into(), 5_000_000 * KUSAMA_ED), /* An account to swap dot
-		                                                              * for something else. */
+		(AssetHubKusamaSender::get(), 5_000_000 * KUSAMA_ED), /* An account to swap dot
+		                                                       * for something else. */
 	]);
 
 	AssetHubKusama::execute_with(|| {
@@ -163,7 +163,7 @@ fn swap_locally_on_chain_using_foreign_assets() {
 		type RuntimeEvent = <AssetHubKusama as Chain>::RuntimeEvent;
 		// 3. Mint foreign asset (in reality this should be a teleport or some such)
 		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::ForeignAssets::mint(
-			<AssetHubKusama as Chain>::RuntimeOrigin::signed(sov_penpal_on_ahk.clone().into()),
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(sov_penpal_on_ahk.clone()),
 			foreign_asset_at_asset_hub_kusama,
 			sov_penpal_on_ahk.clone().into(),
 			3_000_000_000_000,
@@ -199,7 +199,7 @@ fn swap_locally_on_chain_using_foreign_assets() {
 			2_000_000_000_000,
 			0,
 			0,
-			sov_penpal_on_ahk.clone().into()
+			sov_penpal_on_ahk.clone()
 		));
 
 		assert_expected_events!(
@@ -220,7 +220,7 @@ fn swap_locally_on_chain_using_foreign_assets() {
 				path,
 				100000,
 				1000,
-				AssetHubKusamaSender::get().into(),
+				AssetHubKusamaSender::get(),
 				true
 			)
 		);
@@ -243,7 +243,7 @@ fn swap_locally_on_chain_using_foreign_assets() {
 			1414213562273 - 2_000_000_000, // all but the 2 EDs can't be retrieved.
 			0,
 			0,
-			sov_penpal_on_ahk.clone().into(),
+			sov_penpal_on_ahk.clone(),
 		));
 	});
 }
@@ -264,15 +264,15 @@ fn cannot_create_pool_from_pool_assets() {
 
 		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::PoolAssets::create(
 			<AssetHubKusama as Chain>::RuntimeOrigin::signed(pool_owner_account_id.clone()),
-			ASSET_ID.into(),
+			ASSET_ID,
 			pool_owner_account_id.clone().into(),
 			1000,
 		));
 		assert!(<AssetHubKusama as AssetHubKusamaPallet>::PoolAssets::asset_exists(ASSET_ID));
 
 		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::PoolAssets::mint(
 			<AssetHubKusama as Chain>::RuntimeOrigin::signed(pool_owner_account_id),
-			ASSET_ID.into(),
+			ASSET_ID,
 			AssetHubKusamaSender::get().into(),
 			3_000_000_000_000,
 		));
@@ -287,3 +287,133 @@ fn cannot_create_pool_from_pool_assets() {
 		);
 	});
 }
+
+#[test]
+fn pay_xcm_fee_with_some_asset_swapped_for_native() {
+	let asset_native = asset_hub_kusama_runtime::xcm_config::KsmLocationV3::get();
+	let asset_one = xcm::v3::Location {
+		parents: 0,
+		interior: [
+			xcm::v3::Junction::PalletInstance(ASSETS_PALLET_ID),
+			xcm::v3::Junction::GeneralIndex(ASSET_ID.into()),
+		]
+		.into(),
+	};
+	let penpal = AssetHubKusama::sovereign_account_id_of(AssetHubKusama::sibling_location_of(
+		PenpalA::para_id(),
+	));
+
+	AssetHubKusama::execute_with(|| {
+		type RuntimeEvent = <AssetHubKusama as Chain>::RuntimeEvent;
+
+		// set up pool with ASSET_ID <> NATIVE pair
+		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::Assets::create(
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(AssetHubKusamaSender::get()),
+			ASSET_ID.into(),
+			AssetHubKusamaSender::get().into(),
+			ASSET_MIN_BALANCE,
+		));
+		assert!(<AssetHubKusama as AssetHubKusamaPallet>::Assets::asset_exists(ASSET_ID));
+
+		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::Assets::mint(
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(AssetHubKusamaSender::get()),
+			ASSET_ID.into(),
+			AssetHubKusamaSender::get().into(),
+			3_000_000_000_000,
+		));
+
+		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::AssetConversion::create_pool(
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(AssetHubKusamaSender::get()),
+			Box::new(asset_native),
+			Box::new(asset_one),
+		));
+
+		assert_expected_events!(
+			AssetHubKusama,
+			vec![
+				RuntimeEvent::AssetConversion(pallet_asset_conversion::Event::PoolCreated { .. }) => {},
+			]
+		);
+
+		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::AssetConversion::add_liquidity(
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(AssetHubKusamaSender::get()),
+			Box::new(asset_native),
+			Box::new(asset_one),
+			1_000_000_000_000,
+			2_000_000_000_000,
+			0,
+			0,
+			AssetHubKusamaSender::get()
+		));
+
+		assert_expected_events!(
+			AssetHubKusama,
+			vec![
+				RuntimeEvent::AssetConversion(pallet_asset_conversion::Event::LiquidityAdded {lp_token_minted, .. }) => { lp_token_minted: *lp_token_minted == 1414213562273, },
+			]
+		);
+
+		// ensure `penpal` sovereign account has no native tokens and mint some `ASSET_ID`
+		assert_eq!(
+			<AssetHubKusama as AssetHubKusamaPallet>::Balances::free_balance(penpal.clone()),
+			0
+		);
+
+		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::Assets::touch_other(
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(AssetHubKusamaSender::get()),
+			ASSET_ID.into(),
+			penpal.clone().into(),
+		));
+
+		assert_ok!(<AssetHubKusama as AssetHubKusamaPallet>::Assets::mint(
+			<AssetHubKusama as Chain>::RuntimeOrigin::signed(AssetHubKusamaSender::get()),
+			ASSET_ID.into(),
+			penpal.clone().into(),
+			10_000_000_000_000,
+		));
+	});
+
+	PenpalA::execute_with(|| {
+		// send xcm transact from `penpal` account which has only `ASSET_ID` tokens on
+		// `AssetHubKusama`
+		let call = AssetHubKusama::force_create_asset_call(
+			ASSET_ID + 1000,
+			penpal.clone(),
+			true,
+			ASSET_MIN_BALANCE,
+		);
+
+		let penpal_root = <PenpalA as Chain>::RuntimeOrigin::root();
+		let fee_amount = 4_000_000_000_000u128;
+		let asset_one =
+			([PalletInstance(ASSETS_PALLET_ID), GeneralIndex(ASSET_ID.into())], fee_amount).into();
+		let asset_hub_location = PenpalA::sibling_location_of(AssetHubKusama::para_id()).into();
+		let xcm = xcm_transact_paid_execution(
+			call,
+			OriginKind::SovereignAccount,
+			asset_one,
+			penpal.clone(),
+		);
+
+		assert_ok!(<PenpalA as PenpalAPallet>::PolkadotXcm::send(
+			penpal_root,
+			bx!(asset_hub_location),
+			bx!(xcm),
+		));
+
+		PenpalA::assert_xcm_pallet_sent();
+	});
+
+	AssetHubKusama::execute_with(|| {
+		type RuntimeEvent = <AssetHubKusama as Chain>::RuntimeEvent;
+
+		AssetHubKusama::assert_xcmp_queue_success(None);
+		assert_expected_events!(
+			AssetHubKusama,
+			vec![
+				RuntimeEvent::AssetConversion(pallet_asset_conversion::Event::SwapCreditExecuted { .. },) => {},
+				RuntimeEvent::MessageQueue(pallet_message_queue::Event::Processed { success: true,.. }) => {},
+			]
+		);
+	});
+}

integration-tests/emulated/tests/assets/asset-hub-polkadot/Cargo.toml

@@ -16,6 +16,7 @@ sp-runtime = { version = "32.0.0" }
 frame-support = { version = "29.0.0" }
 pallet-balances = { version = "29.0.0" }
 pallet-assets = { version = "30.0.0" }
+pallet-asset-conversion = { version = "11.0.0" }
 pallet-treasury = { version = "28.0.0" }
 pallet-message-queue = { version = "32.0.0" }
 

integration-tests/emulated/tests/assets/asset-hub-polkadot/src/tests/mod.rs

@@ -18,6 +18,7 @@ mod fellowship_treasury;
 mod reserve_transfer;
 mod send;
 mod set_xcm_versions;
+mod swap;
 mod teleport;
 mod treasury;