pezpallet-xcm 7.0.0

// Copyright (C) Parity Technologies (UK) Ltd. and Dijital Kurdistan Tech Institute
// This file is part of Pezkuwi.

// Pezkuwi is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// Pezkuwi is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with Pezkuwi.  If not, see <http://www.gnu.org/licenses/>.

#![cfg(test)]

use crate::{
	mock::*,
	tests::{ALICE, BOB, FEE_AMOUNT, INITIAL_BALANCE, SEND_AMOUNT},
	xcm_helpers::find_xcm_sent_message_id,
	DispatchResult, OriginFor,
};
use pezframe_support::{
	assert_err, assert_ok,
	traits::{tokens::fungibles::Inspect, Currency},
	weights::Weight,
};
use pezkuwi_teyrchain_primitives::primitives::Id as ParaId;
use pezsp_runtime::traits::AccountIdConversion;
use xcm::prelude::*;
use xcm_executor::traits::ConvertLocation;

/// Test `limited_teleport_assets`
///
/// Asserts that the sender's balance is decreased as a result of execution of
/// local effects.
#[test]
fn limited_teleport_assets_works() {
	let origin_location: Location = AccountId32 { network: None, id: ALICE.into() }.into();
	let expected_beneficiary: Location = AccountId32 { network: None, id: BOB.into() }.into();
	let weight_limit = WeightLimit::Limited(Weight::from_parts(5000, 5000));
	let expected_weight_limit = weight_limit.clone();

	let balances = vec![
		(ALICE, INITIAL_BALANCE),
		(ParaId::from(OTHER_PARA_ID).into_account_truncating(), INITIAL_BALANCE),
	];
	let dest = RelayLocation::get().into();
	new_test_ext_with_balances(balances).execute_with(|| {
		let weight = BaseXcmWeight::get() * 2;
		assert_eq!(Balances::total_balance(&ALICE), INITIAL_BALANCE);
		// call extrinsic
		assert_ok!(XcmPallet::limited_teleport_assets(
			RuntimeOrigin::signed(ALICE),
			Box::new(RelayLocation::get().into()),
			Box::new(expected_beneficiary.clone().into()),
			Box::new((Here, SEND_AMOUNT).into()),
			Box::new(RelayLocation::get().into()),
			weight_limit,
		));
		assert_eq!(Balances::total_balance(&ALICE), INITIAL_BALANCE - SEND_AMOUNT);
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				Xcm(vec![
					ReceiveTeleportedAsset((Here, SEND_AMOUNT).into()),
					ClearOrigin,
					buy_limited_execution((Here, SEND_AMOUNT), expected_weight_limit),
					DepositAsset {
						assets: AllCounted(1).into(),
						beneficiary: expected_beneficiary
					},
				]),
			)]
		);
		let versioned_sent = VersionedXcm::from(sent_xcm().into_iter().next().unwrap().1);
		let _check_v3_ok: xcm::v3::Xcm<()> = versioned_sent.try_into().unwrap();

		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location,
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
	});
}

/// `limited_teleport_assets` should fail for filtered assets
#[test]
fn limited_teleport_filtered_assets_disallowed() {
	let beneficiary: Location = AccountId32 { network: None, id: BOB.into() }.into();
	new_test_ext_with_balances(vec![(ALICE, INITIAL_BALANCE)]).execute_with(|| {
		let result = XcmPallet::limited_teleport_assets(
			RuntimeOrigin::signed(ALICE),
			Box::new(FilteredTeleportLocation::get().into()),
			Box::new(beneficiary.into()),
			Box::new(FilteredTeleportAsset::get().into()),
			Box::new(FilteredTeleportAsset::get().id.into()),
			Unlimited,
		);
		let expected_result = Err(crate::Error::<Test>::Filtered.into());
		assert_eq!(result, expected_result);
	});
}

/// Test `reserve_transfer_assets_with_paid_router_works`
///
/// Asserts that the sender's balance is decreased and the beneficiary's balance
/// is increased. Verifies the correct message is sent and event is emitted.
/// Verifies that XCM router fees (`SendXcm::validate` -> `Assets`) are withdrawn from correct
/// user account and deposited to a correct target account (`XcmFeesTargetAccount`).
#[test]
fn reserve_transfer_assets_with_paid_router_works() {
	let user_account = AccountId::from(XCM_FEES_NOT_WAIVED_USER_ACCOUNT);
	let paid_para_id = Para3000::get();
	let balances = vec![
		(user_account.clone(), INITIAL_BALANCE),
		(ParaId::from(paid_para_id).into_account_truncating(), INITIAL_BALANCE),
		(XcmFeesTargetAccount::get(), INITIAL_BALANCE),
	];
	new_test_ext_with_balances(balances).execute_with(|| {
		let xcm_router_fee_amount = Para3000PaymentAmount::get();
		let weight = BaseXcmWeight::get();
		let dest: Location =
			Junction::AccountId32 { network: None, id: user_account.clone().into() }.into();
		assert_eq!(Balances::total_balance(&user_account), INITIAL_BALANCE);
		assert_ok!(XcmPallet::limited_reserve_transfer_assets(
			RuntimeOrigin::signed(user_account.clone()),
			Box::new(Teyrchain(paid_para_id).into()),
			Box::new(dest.clone().into()),
			Box::new((Here, SEND_AMOUNT).into()),
			Box::new(Here.into()),
			Unlimited,
		));

		// XCM_FEES_NOT_WAIVED_USER_ACCOUNT spent amount
		assert_eq!(
			Balances::free_balance(user_account),
			INITIAL_BALANCE - SEND_AMOUNT - xcm_router_fee_amount
		);

		// Destination account (teyrchain account) has amount
		let para_acc: AccountId = ParaId::from(paid_para_id).into_account_truncating();
		assert_eq!(Balances::free_balance(para_acc), INITIAL_BALANCE + SEND_AMOUNT);

		// XcmFeesTargetAccount where should lend xcm_router_fee_amount
		assert_eq!(
			Balances::free_balance(XcmFeesTargetAccount::get()),
			INITIAL_BALANCE + xcm_router_fee_amount
		);

		let dest_para: Location = Teyrchain(paid_para_id).into();
		assert_eq!(
			sent_xcm(),
			vec![(
				dest_para,
				Xcm(vec![
					ReserveAssetDeposited((Parent, SEND_AMOUNT).into()),
					ClearOrigin,
					buy_execution((Parent, SEND_AMOUNT)),
					DepositAsset { assets: AllCounted(1).into(), beneficiary: dest.clone() },
				]),
			)]
		);
		let mut last_events = last_events(5).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		// balances events
		last_events.next().unwrap();
		last_events.next().unwrap();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: dest,
				fees: Para3000PaymentAssets::get(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
	});
}

pub(crate) fn set_up_foreign_asset(
	reserve_para_id: u32,
	inner_junction: Option<Junction>,
	beneficiary: AccountId,
	initial_amount: u128,
	is_sufficient: bool,
) -> (Location, AccountId, Location) {
	let reserve_location =
		RelayLocation::get().pushed_with_interior(Teyrchain(reserve_para_id)).unwrap();
	let reserve_sovereign_account =
		SovereignAccountOf::convert_location(&reserve_location).unwrap();

	let foreign_asset_id_location = if let Some(junction) = inner_junction {
		reserve_location.clone().pushed_with_interior(junction).unwrap()
	} else {
		reserve_location.clone()
	};

	// create sufficient (to be used as fees as well) foreign asset (0 total issuance)
	assert_ok!(AssetsPallet::force_create(
		RuntimeOrigin::root(),
		foreign_asset_id_location.clone(),
		BOB,
		is_sufficient,
		1
	));
	// this asset should have been teleported/reserve-transferred in, but for this test we just
	// mint it locally.
	assert_ok!(AssetsPallet::mint(
		RuntimeOrigin::signed(BOB),
		foreign_asset_id_location.clone(),
		beneficiary,
		initial_amount
	));

	(reserve_location, reserve_sovereign_account, foreign_asset_id_location)
}

// Helper function that provides assets list with fee and transfer assets
pub(crate) fn into_assets_checked(
	fee_asset: Asset,
	transfer_asset: Asset,
) -> (Assets, Asset, Asset) {
	let assets: Assets = vec![fee_asset.clone(), transfer_asset.clone()].into();
	(assets, fee_asset, transfer_asset)
}

/// Test `tested_call` with local asset reserve and local fee reserve.
///
/// Transferring native asset (local reserve) to some `OTHER_PARA_ID` (no teleport trust).
/// Using native asset for fees as well.
///
/// Verifies `expected_result`
fn local_asset_reserve_and_local_fee_reserve_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![
		(ALICE, INITIAL_BALANCE),
		(ParaId::from(OTHER_PARA_ID).into_account_truncating(), INITIAL_BALANCE),
	];

	let origin_location: Location =
		Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let weight_limit = WeightLimit::Limited(Weight::from_parts(5000, 5000));
	let expected_weight_limit = weight_limit.clone();
	let expected_beneficiary = beneficiary.clone();
	let dest: Location = Teyrchain(OTHER_PARA_ID).into();

	new_test_ext_with_balances(balances).execute_with(|| {
		let weight = BaseXcmWeight::get();
		assert_eq!(Balances::total_balance(&ALICE), INITIAL_BALANCE);
		// call extrinsic
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new((Here, SEND_AMOUNT).into()),
			Box::new(Here.into()),
			weight_limit,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}
		// Alice spent amount
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE - SEND_AMOUNT);
		// Destination account (teyrchain account) has amount
		let para_acc: AccountId = ParaId::from(OTHER_PARA_ID).into_account_truncating();
		assert_eq!(Balances::free_balance(para_acc), INITIAL_BALANCE + SEND_AMOUNT);
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				Xcm(vec![
					ReserveAssetDeposited((Parent, SEND_AMOUNT).into()),
					ClearOrigin,
					buy_limited_execution((Parent, SEND_AMOUNT), expected_weight_limit),
					DepositAsset {
						assets: AllCounted(1).into(),
						beneficiary: expected_beneficiary.clone()
					},
				]),
			)]
		);
		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location,
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
	});
}

/// Test `transfer_assets` with local asset reserve and local fee reserve works.
#[test]
fn transfer_assets_with_local_asset_reserve_and_local_fee_reserve_works() {
	let expected_result = Ok(());
	local_asset_reserve_and_local_fee_reserve_call(XcmPallet::transfer_assets, expected_result);
}

/// Test `limited_reserve_transfer_assets` with local asset reserve and local fee reserve works.
#[test]
fn reserve_transfer_assets_with_local_asset_reserve_and_local_fee_reserve_works() {
	let expected_result = Ok(());
	local_asset_reserve_and_local_fee_reserve_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with local asset reserve and local fee reserve disallowed.
#[test]
fn teleport_assets_with_local_asset_reserve_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	local_asset_reserve_and_local_fee_reserve_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with destination asset reserve and local fee reserve.
///
/// Transferring foreign asset (`FOREIGN_ASSET_RESERVE_PARA_ID` reserve) to
/// `FOREIGN_ASSET_RESERVE_PARA_ID` (no teleport trust).
/// Using native asset (local reserve) for fees.
///
/// Asserts that the sender's balance is decreased and the beneficiary's balance
/// is increased. Verifies the correct message is sent and event is emitted.
///
/// Verifies `expected_result`.
fn destination_asset_reserve_and_local_fee_reserve_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let weight = BaseXcmWeight::get() * 3;
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location =
		Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create non-sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (reserve_location, reserve_sovereign_account, foreign_asset_id_location) =
			set_up_foreign_asset(
				FOREIGN_ASSET_RESERVE_PARA_ID,
				Some(FOREIGN_ASSET_INNER_JUNCTION),
				ALICE,
				foreign_initial_amount,
				false,
			);

		// transfer destination is reserve location (no teleport trust)
		let dest = reserve_location;

		let (assets, fee_asset, xfer_asset) = into_assets_checked(
			// native asset for fee - local reserve
			(Location::here(), FEE_AMOUNT).into(),
			// foreign asset to transfer - destination reserve
			(foreign_asset_id_location.clone(), SEND_AMOUNT).into(),
		);

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_fee = fee_asset.clone().reanchored(&dest, &context).unwrap();
		let expected_asset = xfer_asset.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);

		// Alice spent (transferred) amount
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount - SEND_AMOUNT
		);
		// Alice used native asset for fees
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE - FEE_AMOUNT);
		// Destination account (teyrchain account) added native reserve used as fee to balances
		assert_eq!(Balances::free_balance(reserve_sovereign_account.clone()), FEE_AMOUNT);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), reserve_sovereign_account),
			0
		);
		// Verify total and active issuance of foreign BLA have decreased (burned on
		// reserve-withdraw)
		let expected_issuance = foreign_initial_amount - SEND_AMOUNT;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				// `fees` are being sent through local-reserve transfer because fee reserve is
				// local chain; `assets` are burned on source and withdrawn from SA here
				Xcm(vec![
					ReserveAssetDeposited((Parent, FEE_AMOUNT).into()),
					buy_limited_execution(expected_fee, Unlimited),
					WithdrawAsset(expected_asset.into()),
					ClearOrigin,
					DepositAsset { assets: AllCounted(2).into(), beneficiary: beneficiary.clone() },
				])
			)]
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location,
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
	});
}

/// Test `transfer_assets` with destination asset reserve and local fee reserve.
#[test]
fn transfer_assets_with_destination_asset_reserve_and_local_fee_reserve_works() {
	let expected_result = Ok(());
	destination_asset_reserve_and_local_fee_reserve_call(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with destination asset reserve and local fee reserve
/// disallowed.
#[test]
fn reserve_transfer_assets_with_destination_asset_reserve_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	destination_asset_reserve_and_local_fee_reserve_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with destination asset reserve and local fee reserve
/// disallowed.
#[test]
fn teleport_assets_with_destination_asset_reserve_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	destination_asset_reserve_and_local_fee_reserve_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with remote asset reserve and local fee reserve is disallowed.
///
/// Transferring foreign asset (reserve on `FOREIGN_ASSET_RESERVE_PARA_ID`) to `OTHER_PARA_ID`.
/// Using native (local reserve) as fee should be disallowed.
fn remote_asset_reserve_and_local_fee_reserve_call_disallowed<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create non-sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (_, _, foreign_asset_id_location) = set_up_foreign_asset(
			FOREIGN_ASSET_RESERVE_PARA_ID,
			Some(FOREIGN_ASSET_INNER_JUNCTION),
			ALICE,
			foreign_initial_amount,
			false,
		);

		// transfer destination is OTHER_PARA_ID (foreign asset needs to go through its reserve
		// chain)
		let dest = RelayLocation::get().pushed_with_interior(Teyrchain(OTHER_PARA_ID)).unwrap();

		let (assets, fee_asset, _) = into_assets_checked(
			// native asset for fee - local reserve
			(Location::here(), FEE_AMOUNT).into(),
			// foreign asset to transfer - remote reserve
			(foreign_asset_id_location.clone(), SEND_AMOUNT).into(),
		);

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// try the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);

		// Alice transferred nothing
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		// Alice spent native asset for fees
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Verify total and active issuance of foreign BLA asset have decreased (burned on
		// reserve-withdraw)
		let expected_issuance = foreign_initial_amount;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_issuance);
	});
}

/// Test `transfer_assets` with remote asset reserve and local fee reserve is disallowed.
#[test]
fn transfer_assets_with_remote_asset_reserve_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::InvalidAssetUnsupportedReserve.into());
	remote_asset_reserve_and_local_fee_reserve_call_disallowed(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with remote asset reserve and local fee reserve is
/// disallowed.
#[test]
fn reserve_transfer_assets_with_remote_asset_reserve_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	remote_asset_reserve_and_local_fee_reserve_call_disallowed(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with remote asset reserve and local fee reserve is disallowed.
#[test]
fn teleport_assets_with_remote_asset_reserve_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	remote_asset_reserve_and_local_fee_reserve_call_disallowed(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with local asset reserve and destination fee reserve.
///
/// Transferring native asset (local reserve) to `USDC_RESERVE_PARA_ID` (no teleport trust). Using
/// foreign asset (`USDC_RESERVE_PARA_ID` reserve) for fees.
///
/// Asserts that the sender's balance is decreased and the beneficiary's balance
/// is increased. Verifies the correct message is sent and event is emitted.
///
/// Verifies `expected_result`.
fn local_asset_reserve_and_destination_fee_reserve_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location =
		Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDC
		let usdc_initial_local_amount = 142;
		let (usdc_reserve_location, usdc_chain_sovereign_account, usdc_id_location) =
			set_up_foreign_asset(
				USDC_RESERVE_PARA_ID,
				Some(USDC_INNER_JUNCTION),
				ALICE,
				usdc_initial_local_amount,
				true,
			);

		// native assets transfer to fee reserve location (no teleport trust)
		let dest = usdc_reserve_location;

		let (assets, fee_asset, xfer_asset) = into_assets_checked(
			// usdc for fees (is sufficient on local chain too) - destination reserve
			(usdc_id_location.clone(), FEE_AMOUNT).into(),
			// native asset to transfer (not used for fees) - local reserve
			(Location::here(), SEND_AMOUNT).into(),
		);

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_fee = fee_asset.clone().reanchored(&dest, &context).unwrap();
		let expected_asset = xfer_asset.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let weight = BaseXcmWeight::get() * 3;
		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location.clone(),
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));

		// Alice spent (fees) amount
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount - FEE_AMOUNT
		);
		// Alice used native asset for transfer
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE - SEND_AMOUNT);
		// Sovereign account of dest teyrchain holds `SEND_AMOUNT` native asset in local reserve
		assert_eq!(Balances::free_balance(usdc_chain_sovereign_account.clone()), SEND_AMOUNT);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), usdc_chain_sovereign_account),
			0
		);
		// Verify total and active issuance of USDC have decreased (burned on reserve-withdraw)
		let expected_issuance = usdc_initial_local_amount - FEE_AMOUNT;
		assert_eq!(AssetsPallet::total_issuance(usdc_id_location.clone()), expected_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdc_id_location), expected_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				Xcm(vec![
					// fees are being sent through destination-reserve transfer because fee reserve
					// is destination chain
					WithdrawAsset(expected_fee.clone().into()),
					buy_limited_execution(expected_fee, Unlimited),
					// transfer is through local-reserve transfer because `assets` (native asset)
					// have local reserve
					ReserveAssetDeposited(expected_asset.into()),
					ClearOrigin,
					DepositAsset { assets: AllCounted(2).into(), beneficiary },
				])
			)]
		);
	});
}

/// Test `transfer_assets` with local asset reserve and destination fee reserve.
#[test]
fn transfer_assets_with_local_asset_reserve_and_destination_fee_reserve_works() {
	let expected_result = Ok(());
	local_asset_reserve_and_destination_fee_reserve_call(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with local asset reserve and destination fee reserve
/// disallowed.
#[test]
fn reserve_transfer_assets_with_local_asset_reserve_and_destination_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	local_asset_reserve_and_destination_fee_reserve_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with local asset reserve and destination fee reserve disallowed.
#[test]
fn teleport_assets_with_local_asset_reserve_and_destination_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	local_asset_reserve_and_destination_fee_reserve_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with destination asset reserve and destination fee reserve.
///
/// Verifies `expected_result`
fn destination_asset_reserve_and_destination_fee_reserve_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location =
		Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// we'll send just this foreign asset back to its reserve location and use it for fees as
		// well
		let foreign_initial_amount = 142;
		let (reserve_location, reserve_sovereign_account, foreign_asset_id_location) =
			set_up_foreign_asset(
				FOREIGN_ASSET_RESERVE_PARA_ID,
				Some(FOREIGN_ASSET_INNER_JUNCTION),
				ALICE,
				foreign_initial_amount,
				true,
			);

		// transfer destination is reserve location
		let dest = reserve_location;
		let assets: Assets = vec![(foreign_asset_id_location.clone(), SEND_AMOUNT).into()].into();
		let fee_asset_id = foreign_asset_id_location.clone();

		// reanchor according to test-case
		let mut expected_assets = assets.clone();
		expected_assets.reanchor(&dest, &UniversalLocation::get()).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset_id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let weight = BaseXcmWeight::get() * 2;
		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location.clone(),
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));

		// Alice spent (transferred) amount
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount - SEND_AMOUNT
		);
		// Alice's native asset balance is untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Reserve sovereign account has same balances
		assert_eq!(Balances::free_balance(reserve_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), reserve_sovereign_account),
			0
		);
		// Verify total and active issuance of foreign BLA have decreased (burned on
		// reserve-withdraw)
		let expected_issuance = foreign_initial_amount - SEND_AMOUNT;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				Teyrchain(FOREIGN_ASSET_RESERVE_PARA_ID).into(),
				Xcm(vec![
					WithdrawAsset(expected_assets.clone()),
					ClearOrigin,
					buy_limited_execution(expected_assets.get(0).unwrap().clone(), Unlimited),
					DepositAsset { assets: AllCounted(1).into(), beneficiary: beneficiary.clone() },
				]),
			)]
		);
	});
}

/// Test `transfer_assets` with destination asset reserve and destination fee reserve.
#[test]
fn transfer_assets_with_destination_asset_reserve_and_destination_fee_reserve_works() {
	let expected_result = Ok(());
	destination_asset_reserve_and_destination_fee_reserve_call(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with destination asset reserve and destination fee
/// reserve.
#[test]
fn reserve_transfer_assets_with_destination_asset_reserve_and_destination_fee_reserve_works() {
	let expected_result = Ok(());
	destination_asset_reserve_and_destination_fee_reserve_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with destination asset reserve and destination fee reserve
/// disallowed.
#[test]
fn teleport_assets_with_destination_asset_reserve_and_destination_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	destination_asset_reserve_and_destination_fee_reserve_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `transfer_assets` with remote asset reserve and destination fee reserve is disallowed.
///
/// Transferring foreign asset (reserve on `FOREIGN_ASSET_RESERVE_PARA_ID`) to
/// `USDC_RESERVE_PARA_ID`. Using USDC (destination reserve) as fee.
fn remote_asset_reserve_and_destination_fee_reserve_call_disallowed<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDC
		let usdc_initial_local_amount = 42;
		let (usdc_chain, _, usdc_id_location) = set_up_foreign_asset(
			USDC_RESERVE_PARA_ID,
			Some(USDC_INNER_JUNCTION),
			ALICE,
			usdc_initial_local_amount,
			true,
		);

		// create non-sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (_, _, foreign_asset_id_location) = set_up_foreign_asset(
			FOREIGN_ASSET_RESERVE_PARA_ID,
			Some(FOREIGN_ASSET_INNER_JUNCTION),
			ALICE,
			foreign_initial_amount,
			false,
		);

		// transfer destination is USDC chain (foreign asset BLA needs to go through its separate
		// reserve chain)
		let dest = usdc_chain;

		let (assets, fee_asset, _) = into_assets_checked(
			// USDC for fees (is sufficient on local chain too) - destination reserve
			(usdc_id_location.clone(), FEE_AMOUNT).into(),
			// foreign asset to transfer (not used for fees) - remote reserve
			(foreign_asset_id_location.clone(), SEND_AMOUNT).into(),
		);

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);

		// Alice native asset untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		let expected_usdc_issuance = usdc_initial_local_amount;
		assert_eq!(AssetsPallet::total_issuance(usdc_id_location.clone()), expected_usdc_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdc_id_location.clone()), expected_usdc_issuance);
		let expected_bla_issuance = foreign_initial_amount;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_bla_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_bla_issuance);
	});
}

/// Test `transfer_assets` with remote asset reserve and destination fee reserve is disallowed.
#[test]
fn transfer_assets_with_remote_asset_reserve_and_destination_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::InvalidAssetUnsupportedReserve.into());
	remote_asset_reserve_and_destination_fee_reserve_call_disallowed(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with remote asset reserve and destination fee reserve is
/// disallowed.
#[test]
fn reserve_transfer_assets_with_remote_asset_reserve_and_destination_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	remote_asset_reserve_and_destination_fee_reserve_call_disallowed(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with remote asset reserve and destination fee reserve is
/// disallowed.
#[test]
fn teleport_assets_with_remote_asset_reserve_and_destination_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	remote_asset_reserve_and_destination_fee_reserve_call_disallowed(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with local asset reserve and remote fee reserve is disallowed.
///
/// Transferring native asset (local reserve) to `OTHER_PARA_ID` (no teleport trust). Using foreign
/// asset (`USDC_RESERVE_PARA_ID` remote reserve) for fees.
fn local_asset_reserve_and_remote_fee_reserve_call_disallowed<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDC
		let usdc_initial_local_amount = 142;
		let (_, usdc_chain_sovereign_account, usdc_id_location) = set_up_foreign_asset(
			USDC_RESERVE_PARA_ID,
			Some(USDC_INNER_JUNCTION),
			ALICE,
			usdc_initial_local_amount,
			true,
		);

		// transfer destination is some other teyrchain != fee reserve location (no teleport trust)
		let dest = RelayLocation::get().pushed_with_interior(Teyrchain(OTHER_PARA_ID)).unwrap();
		let dest_sovereign_account = SovereignAccountOf::convert_location(&dest).unwrap();

		let (assets, fee_asset, _) = into_assets_checked(
			// USDC for fees (is sufficient on local chain too) - remote reserve
			(usdc_id_location.clone(), FEE_AMOUNT).into(),
			// native asset to transfer (not used for fees) - local reserve
			(Location::here(), SEND_AMOUNT).into(),
		);

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Sovereign account of reserve teyrchain is unchanged
		assert_eq!(Balances::free_balance(usdc_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), usdc_chain_sovereign_account),
			0
		);
		assert_eq!(Balances::free_balance(dest_sovereign_account), 0);
		let expected_usdc_issuance = usdc_initial_local_amount;
		assert_eq!(AssetsPallet::total_issuance(usdc_id_location.clone()), expected_usdc_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdc_id_location), expected_usdc_issuance);
	});
}

/// Test `transfer_assets` with local asset reserve and remote fee reserve is disallowed.
#[test]
fn transfer_assets_with_local_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::InvalidAssetUnsupportedReserve.into());
	local_asset_reserve_and_remote_fee_reserve_call_disallowed(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with local asset reserve and remote fee reserve is
/// disallowed.
#[test]
fn reserve_transfer_assets_with_local_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	local_asset_reserve_and_remote_fee_reserve_call_disallowed(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with local asset reserve and remote fee reserve is disallowed.
#[test]
fn teleport_assets_with_local_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	local_asset_reserve_and_remote_fee_reserve_call_disallowed(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with destination asset reserve and remote fee reserve is disallowed.
///
/// Transferring native asset (local reserve) to `OTHER_PARA_ID` (no teleport trust). Using foreign
/// asset (`USDC_RESERVE_PARA_ID` remote reserve) for fees.
fn destination_asset_reserve_and_remote_fee_reserve_call_disallowed<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDC
		let usdc_initial_local_amount = 42;
		let (_, usdc_chain_sovereign_account, usdc_id_location) = set_up_foreign_asset(
			USDC_RESERVE_PARA_ID,
			Some(USDC_INNER_JUNCTION),
			ALICE,
			usdc_initial_local_amount,
			true,
		);

		// create non-sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (reserve_location, foreign_sovereign_account, foreign_asset_id_location) =
			set_up_foreign_asset(
				FOREIGN_ASSET_RESERVE_PARA_ID,
				Some(FOREIGN_ASSET_INNER_JUNCTION),
				ALICE,
				foreign_initial_amount,
				false,
			);

		// transfer destination is asset reserve location
		let dest = reserve_location;
		let dest_sovereign_account = foreign_sovereign_account;

		let (assets, fee_asset, _) = into_assets_checked(
			// USDC for fees (is sufficient on local chain too) - remote reserve
			(usdc_id_location.clone(), FEE_AMOUNT).into(),
			// foreign asset to transfer (not used for fees) - destination reserve
			(foreign_asset_id_location.clone(), SEND_AMOUNT).into(),
		);

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		// Alice native asset untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(usdc_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), usdc_chain_sovereign_account),
			0
		);
		assert_eq!(Balances::free_balance(dest_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), dest_sovereign_account),
			0
		);
		let expected_usdc_issuance = usdc_initial_local_amount;
		assert_eq!(AssetsPallet::total_issuance(usdc_id_location.clone()), expected_usdc_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdc_id_location.clone()), expected_usdc_issuance);
		let expected_bla_issuance = foreign_initial_amount;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_bla_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_bla_issuance);
	});
}

/// Test `transfer_assets` with destination asset reserve and remote fee reserve is disallowed.
#[test]
fn transfer_assets_with_destination_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::InvalidAssetUnsupportedReserve.into());
	destination_asset_reserve_and_remote_fee_reserve_call_disallowed(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with destination asset reserve and remote fee reserve is
/// disallowed.
#[test]
fn reserve_transfer_assets_with_destination_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	destination_asset_reserve_and_remote_fee_reserve_call_disallowed(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with destination asset reserve and remote fee reserve is
/// disallowed.
#[test]
fn teleport_assets_with_destination_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	destination_asset_reserve_and_remote_fee_reserve_call_disallowed(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with remote asset reserve and (same) remote fee reserve.
///
/// Transferring native asset (local reserve) to `OTHER_PARA_ID` (no teleport trust). Using foreign
/// asset (`USDC_RESERVE_PARA_ID` remote reserve) for fees.
///
/// ```nocompile
///    | chain `A`           |  chain `C`                      |  chain `B`
///    | Here (source)       |  USDC_RESERVE_PARA_ID           |  OTHER_PARA_ID (destination)
///    |                     |  `fees` reserve                 |
///    |                     |  `assets` reserve               |
///    |
///    |  1. `A` executes `InitiateReserveWithdraw(both)` dest `C`
///    |     -----------------> `C` executes `DepositReserveAsset(both)` dest `B`
///    |                             --------------------------> `DepositAsset(both)`
/// ```
///
/// Verifies `expected_result`
fn remote_asset_reserve_and_remote_fee_reserve_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDC
		let usdc_initial_local_amount = 142;
		let (usdc_chain, usdc_chain_sovereign_account, usdc_id_location) = set_up_foreign_asset(
			USDC_RESERVE_PARA_ID,
			Some(USDC_INNER_JUNCTION),
			ALICE,
			usdc_initial_local_amount,
			true,
		);

		// transfer destination is some other teyrchain
		let dest = RelayLocation::get().pushed_with_interior(Teyrchain(OTHER_PARA_ID)).unwrap();

		let assets: Assets = vec![(usdc_id_location.clone(), SEND_AMOUNT).into()].into();
		let fee_asset_id: AssetId = usdc_id_location.clone().into();

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_dest_on_reserve = dest.clone().reanchored(&usdc_chain, &context).unwrap();
		let fees = assets.inner().iter().find(|a| a.id == fee_asset_id).unwrap();
		let (fees_half_1, fees_half_2) = XcmPallet::halve_fees(fees.clone()).unwrap();
		let mut expected_assets_on_reserve = assets.clone();
		expected_assets_on_reserve.reanchor(&usdc_chain, &context).unwrap();
		let expected_fee_on_reserve = fees_half_1.reanchored(&usdc_chain, &context).unwrap();
		let expected_fee_on_dest = fees_half_2.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset_id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		assert!(matches!(
			last_event(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted { outcome: Outcome::Complete { .. } })
		));

		// Alice spent (transferred) amount
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount - SEND_AMOUNT
		);
		// Alice's native asset balance is untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Destination account (teyrchain account) has expected (same) balances
		assert_eq!(Balances::free_balance(usdc_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), usdc_chain_sovereign_account),
			0
		);
		// Verify total and active issuance of USDC have decreased (burned on reserve-withdraw)
		let expected_usdc_issuance = usdc_initial_local_amount - SEND_AMOUNT;
		assert_eq!(AssetsPallet::total_issuance(usdc_id_location.clone()), expected_usdc_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdc_id_location.clone()), expected_usdc_issuance);

		// Verify sent XCM program
		let expected_hash =
			find_xcm_sent_message_id::<Test>(all_events()).expect("Missing XcmPallet::Sent event");
		assert_eq!(
			sent_xcm(),
			vec![(
				// first message sent to reserve chain
				usdc_chain,
				Xcm(vec![
					WithdrawAsset(expected_assets_on_reserve),
					ClearOrigin,
					BuyExecution { fees: expected_fee_on_reserve, weight_limit: Unlimited },
					DepositReserveAsset {
						assets: Wild(AllCounted(1)),
						// final destination is `dest` as seen by `reserve`
						dest: expected_dest_on_reserve,
						// message sent onward to `dest`
						xcm: Xcm(vec![
							buy_limited_execution(expected_fee_on_dest, Unlimited),
							DepositAsset { assets: AllCounted(1).into(), beneficiary }
						])
					},
					SetTopic(expected_hash),
				])
			)],
		);
	});
}

/// Test `transfer_assets` with remote asset reserve and (same) remote fee reserve.
#[test]
fn transfer_assets_with_remote_asset_reserve_and_remote_fee_reserve_works() {
	let expected_result = Ok(());
	remote_asset_reserve_and_remote_fee_reserve_call(XcmPallet::transfer_assets, expected_result);
}

/// Test `limited_reserve_transfer_assets` with remote asset reserve and (same) remote fee reserve.
#[test]
fn reserve_transfer_assets_with_remote_asset_reserve_and_remote_fee_reserve_works() {
	let expected_result = Ok(());
	remote_asset_reserve_and_remote_fee_reserve_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with remote asset reserve and (same) remote fee reserve
/// disallowed.
#[test]
fn teleport_assets_with_remote_asset_reserve_and_remote_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	remote_asset_reserve_and_remote_fee_reserve_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with local asset reserve and teleported fee.
///
/// Transferring native asset (local reserve) to `USDT_PARA_ID`. Using teleport-trusted USDT for
/// fees.
///
/// Verifies `expected_result`
fn local_asset_reserve_and_teleported_fee_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location =
		Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDT
		let usdt_initial_local_amount = 42;
		let (usdt_chain, usdt_chain_sovereign_account, usdt_id_location) =
			set_up_foreign_asset(USDT_PARA_ID, None, ALICE, usdt_initial_local_amount, true);

		// native assets transfer destination is USDT chain (teleport trust only for USDT)
		let dest = usdt_chain;

		let (assets, fee_asset, xfer_asset) = into_assets_checked(
			// USDT for fees (is sufficient on local chain too) - teleported
			(usdt_id_location.clone(), FEE_AMOUNT).into(),
			// native asset to transfer (not used for fees) - local reserve
			(Location::here(), SEND_AMOUNT).into(),
		);

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_fee = fee_asset.clone().reanchored(&dest, &context).unwrap();
		let expected_asset = xfer_asset.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let weight = BaseXcmWeight::get() * 3;
		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location.clone(),
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
		// Alice spent (fees) amount
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount - FEE_AMOUNT
		);
		// Alice used native asset for transfer
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE - SEND_AMOUNT);
		// Sovereign account of dest teyrchain holds `SEND_AMOUNT` native asset in local reserve
		assert_eq!(Balances::free_balance(usdt_chain_sovereign_account.clone()), SEND_AMOUNT);
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), usdt_chain_sovereign_account),
			0
		);
		// Verify total and active issuance have decreased (teleported)
		let expected_usdt_issuance = usdt_initial_local_amount - FEE_AMOUNT;
		assert_eq!(AssetsPallet::total_issuance(usdt_id_location.clone()), expected_usdt_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdt_id_location), expected_usdt_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				Xcm(vec![
					// fees are teleported to destination chain
					ReceiveTeleportedAsset(expected_fee.clone().into()),
					buy_limited_execution(expected_fee, Unlimited),
					// transfer is through local-reserve transfer because `assets` (native
					// asset) have local reserve
					ReserveAssetDeposited(expected_asset.into()),
					ClearOrigin,
					DepositAsset { assets: AllCounted(2).into(), beneficiary },
				])
			)]
		);
	});
}

/// Test `transfer_assets` with local asset reserve and teleported fee.
#[test]
fn transfer_assets_with_local_asset_reserve_and_teleported_fee_works() {
	let expected_result = Ok(());
	local_asset_reserve_and_teleported_fee_call(XcmPallet::transfer_assets, expected_result);
}

/// Test `limited_reserve_transfer_assets` with local asset reserve and teleported fee disallowed.
#[test]
fn reserve_transfer_assets_with_local_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	local_asset_reserve_and_teleported_fee_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with local asset reserve and teleported fee disallowed.
#[test]
fn teleport_assets_with_local_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	local_asset_reserve_and_teleported_fee_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with destination asset reserve and teleported fee.
///
/// Transferring foreign asset (destination reserve) to `FOREIGN_ASSET_RESERVE_PARA_ID`. Using
/// teleport-trusted USDT for fees.
///
/// Verifies `expected_result`
fn destination_asset_reserve_and_teleported_fee_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location =
		Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDT
		let usdt_initial_local_amount = 42;
		let (_, usdt_chain_sovereign_account, usdt_id_location) =
			set_up_foreign_asset(USDT_PARA_ID, None, ALICE, usdt_initial_local_amount, true);

		// create non-sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (reserve_location, foreign_sovereign_account, foreign_asset_id_location) =
			set_up_foreign_asset(
				FOREIGN_ASSET_RESERVE_PARA_ID,
				Some(FOREIGN_ASSET_INNER_JUNCTION),
				ALICE,
				foreign_initial_amount,
				false,
			);

		// transfer destination is asset reserve location
		let dest = reserve_location;
		let dest_sovereign_account = foreign_sovereign_account;

		let (assets, fee_asset, xfer_asset) = into_assets_checked(
			// USDT for fees (is sufficient on local chain too) - teleported
			(usdt_id_location.clone(), FEE_AMOUNT).into(),
			// foreign asset to transfer (not used for fees) - destination reserve
			(foreign_asset_id_location.clone(), SEND_AMOUNT).into(),
		);

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_fee = fee_asset.clone().reanchored(&dest, &context).unwrap();
		let expected_asset = xfer_asset.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let weight = BaseXcmWeight::get() * 4;
		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location.clone(),
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
		// Alice native asset untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Alice spent USDT for fees
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount - FEE_AMOUNT
		);
		// Alice transferred BLA
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount - SEND_AMOUNT
		);
		// Verify balances of USDT reserve teyrchain
		assert_eq!(Balances::free_balance(usdt_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), usdt_chain_sovereign_account),
			0
		);
		// Verify balances of transferred-asset reserve teyrchain
		assert_eq!(Balances::free_balance(dest_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), dest_sovereign_account),
			0
		);
		// Verify total and active issuance of USDT have decreased (teleported)
		let expected_usdt_issuance = usdt_initial_local_amount - FEE_AMOUNT;
		assert_eq!(AssetsPallet::total_issuance(usdt_id_location.clone()), expected_usdt_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdt_id_location.clone()), expected_usdt_issuance);
		// Verify total and active issuance of foreign BLA asset have decreased (burned on
		// reserve-withdraw)
		let expected_bla_issuance = foreign_initial_amount - SEND_AMOUNT;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_bla_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_bla_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				Xcm(vec![
					// fees are teleported to destination chain
					ReceiveTeleportedAsset(expected_fee.clone().into()),
					buy_limited_execution(expected_fee, Unlimited),
					// assets are withdrawn from origin's local SA
					WithdrawAsset(expected_asset.into()),
					ClearOrigin,
					DepositAsset { assets: AllCounted(2).into(), beneficiary },
				])
			)]
		);
	});
}

/// Test `transfer_assets` with destination asset reserve and teleported fee.
#[test]
fn transfer_assets_with_destination_asset_reserve_and_teleported_fee_works() {
	let expected_result = Ok(());
	destination_asset_reserve_and_teleported_fee_call(XcmPallet::transfer_assets, expected_result);
}

/// Test `limited_reserve_transfer_assets` with destination asset reserve and teleported fee
/// disallowed.
#[test]
fn reserve_transfer_assets_with_destination_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	destination_asset_reserve_and_teleported_fee_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with destination asset reserve and teleported fee disallowed.
#[test]
fn teleport_assets_with_destination_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	destination_asset_reserve_and_teleported_fee_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with remote asset reserve and teleported fee is disallowed.
///
/// Transferring foreign asset (reserve on `FOREIGN_ASSET_RESERVE_PARA_ID`) to `USDT_PARA_ID`.
/// Using teleport-trusted USDT for fees.
fn remote_asset_reserve_and_teleported_fee_reserve_call_disallowed<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDT
		let usdt_initial_local_amount = 42;
		let (usdt_chain, usdt_chain_sovereign_account, usdt_id_location) =
			set_up_foreign_asset(USDT_PARA_ID, None, ALICE, usdt_initial_local_amount, true);

		// create non-sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (_, reserve_sovereign_account, foreign_asset_id_location) = set_up_foreign_asset(
			FOREIGN_ASSET_RESERVE_PARA_ID,
			Some(FOREIGN_ASSET_INNER_JUNCTION),
			ALICE,
			foreign_initial_amount,
			false,
		);

		// transfer destination is USDT chain (foreign asset needs to go through its reserve chain)
		let dest = usdt_chain;

		let (assets, fee_asset, _) = into_assets_checked(
			// USDT for fees (is sufficient on local chain too) - teleported
			(usdt_id_location.clone(), FEE_AMOUNT).into(),
			// foreign asset to transfer (not used for fees) - remote reserve
			(foreign_asset_id_location.clone(), SEND_AMOUNT).into(),
		);

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// try the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		// Alice native asset untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(usdt_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), usdt_chain_sovereign_account),
			0
		);
		assert_eq!(Balances::free_balance(reserve_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), reserve_sovereign_account),
			0
		);
		let expected_usdt_issuance = usdt_initial_local_amount;
		assert_eq!(AssetsPallet::total_issuance(usdt_id_location.clone()), expected_usdt_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdt_id_location.clone()), expected_usdt_issuance);
		let expected_bla_issuance = foreign_initial_amount;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_bla_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_bla_issuance);
	});
}

/// Test `transfer_assets` with remote asset reserve and teleported fee is disallowed.
#[test]
fn transfer_assets_with_remote_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::InvalidAssetUnsupportedReserve.into());
	remote_asset_reserve_and_teleported_fee_reserve_call_disallowed(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with remote asset reserve and teleported fee is
/// disallowed.
#[test]
fn reserve_transfer_assets_with_remote_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::TooManyReserves.into());
	remote_asset_reserve_and_teleported_fee_reserve_call_disallowed(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with remote asset reserve and teleported fee is disallowed.
#[test]
fn teleport_assets_with_remote_asset_reserve_and_teleported_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	remote_asset_reserve_and_teleported_fee_reserve_call_disallowed(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `reserve_transfer_assets` single asset which is teleportable - should fail.
///
/// Attempting to reserve-transfer teleport-trusted USDT to `USDT_PARA_ID` should fail.
#[test]
fn reserve_transfer_assets_with_teleportable_asset_disallowed() {
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();

	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDT
		let usdt_initial_local_amount = 42;
		let (usdt_chain, usdt_chain_sovereign_account, usdt_id_location) =
			set_up_foreign_asset(USDT_PARA_ID, None, ALICE, usdt_initial_local_amount, true);

		// transfer destination is USDT chain (foreign asset needs to go through its reserve chain)
		let dest = usdt_chain;
		let assets: Assets = vec![(usdt_id_location.clone(), FEE_AMOUNT).into()].into();
		let fee_asset_id = usdt_id_location.clone();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let res = XcmPallet::limited_reserve_transfer_assets(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset_id.into()),
			Unlimited,
		);
		assert_err!(res, crate::Error::<Test>::Filtered);
		// Alice native asset is still same
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Alice USDT balance is still same
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		// No USDT moved to sovereign account of reserve teyrchain
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), usdt_chain_sovereign_account),
			0
		);
		// Verify total and active issuance of USDT are still the same
		assert_eq!(
			AssetsPallet::total_issuance(usdt_id_location.clone()),
			usdt_initial_local_amount
		);
		assert_eq!(AssetsPallet::active_issuance(usdt_id_location), usdt_initial_local_amount);
	});
}

/// Test `transfer_assets` with teleportable fee that is filtered - should fail.
#[test]
fn transfer_assets_with_filtered_teleported_fee_disallowed() {
	let beneficiary: Location = AccountId32 { network: None, id: BOB.into() }.into();
	new_test_ext_with_balances(vec![(ALICE, INITIAL_BALANCE)]).execute_with(|| {
		let (assets, fee_asset, _) = into_assets_checked(
			// FilteredTeleportAsset for fees - teleportable but filtered
			FilteredTeleportAsset::get().into(),
			// native asset to transfer (not used for fees) - local reserve
			(Location::here(), SEND_AMOUNT).into(),
		);
		let result = XcmPallet::transfer_assets(
			RuntimeOrigin::signed(ALICE),
			Box::new(FilteredTeleportLocation::get().into()),
			Box::new(beneficiary.into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_err!(result, crate::Error::<Test>::Filtered);
	});
}

/// Test failure to complete execution of local XCM instructions reverts intermediate side-effects.
///
/// Extrinsic will execute XCM to withdraw & burn reserve-based assets, then fail sending XCM to
/// reserve chain for releasing reserve assets. Assert that the previous instructions (withdraw &
/// burn) effects are reverted.
#[test]
fn intermediary_error_reverts_side_effects() {
	use pezsp_tracing::{
		test_log_capture::init_log_capture,
		tracing::{subscriber, Level},
	};

	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset USDC
		let usdc_initial_local_amount = 142;
		let (_, usdc_chain_sovereign_account, usdc_id_location) = set_up_foreign_asset(
			USDC_RESERVE_PARA_ID,
			Some(USDC_INNER_JUNCTION),
			ALICE,
			usdc_initial_local_amount,
			true,
		);

		// transfer destination is some other teyrchain
		let dest = RelayLocation::get().pushed_with_interior(Teyrchain(OTHER_PARA_ID)).unwrap();

		let assets: Assets = vec![(usdc_id_location.clone(), SEND_AMOUNT).into()].into();
		let fee_asset_id = usdc_id_location.clone();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// introduce artificial error in sending outbound XCM
		set_send_xcm_artificial_failure(true);

		// do the transfer - extrinsic should completely fail on xcm send failure
		let (log_capture, subscriber) = init_log_capture(Level::DEBUG, true);
		subscriber::with_default(subscriber, || {
			let result = XcmPallet::limited_reserve_transfer_assets(
				RuntimeOrigin::signed(ALICE),
				Box::new(dest.into()),
				Box::new(beneficiary.into()),
				Box::new(assets.into()),
				Box::new(fee_asset_id.into()),
				Unlimited,
			);
			assert!(result.is_err());

			// Ensure the log occurs before `XcmEventEmitter::emit_process_failure_event` is called.
			assert!(log_capture.contains(
				"xcm::process: XCM execution failed at instruction index=2 error=Transport(\"Intentional send failure used in tests\")"
			), "Expected transport error log message not found");

			// Verify that `XcmPallet::ProcessXcmError` was NOT emitted, indicating a rollback.
			let process_xcm_error_emitted = System::events().iter().any(|r| {
				matches!(r.event, RuntimeEvent::XcmPallet(crate::Event::ProcessXcmError { .. }))
			});
			assert!(
				!process_xcm_error_emitted,
				"Expected no `XcmPallet::ProcessXcmError` event due to rollback, but it was emitted"
			);
		});

		// Alice no changes
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), ALICE),
			usdc_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Destination account (teyrchain account) no changes
		assert_eq!(Balances::free_balance(usdc_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdc_id_location.clone(), usdc_chain_sovereign_account),
			0
		);
		// Verify total and active issuance of USDC has not changed
		assert_eq!(
			AssetsPallet::total_issuance(usdc_id_location.clone()),
			usdc_initial_local_amount
		);
		assert_eq!(AssetsPallet::active_issuance(usdc_id_location), usdc_initial_local_amount);
		// Verify no XCM program sent
		assert_eq!(sent_xcm(), vec![]);
	});
}

/// Test `tested_call` with teleportable asset and local fee reserve.
///
/// Transferring USDT to `USDT_PARA_ID` (teleport trust). Using native asset (local reserve) for
/// fees.
///
/// Verifies `expected_result`
fn teleport_asset_using_local_fee_reserve_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let weight = BaseXcmWeight::get() * 3;
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location = AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create non-sufficient foreign asset USDT
		let usdt_initial_local_amount = 42;
		let (usdt_chain, usdt_chain_sovereign_account, usdt_id_location) =
			set_up_foreign_asset(USDT_PARA_ID, None, ALICE, usdt_initial_local_amount, false);

		// transfer destination is reserve location (no teleport trust)
		let dest = usdt_chain;

		let (assets, fee_asset, xfer_asset) = into_assets_checked(
			// native asset for fee - local reserve
			(Location::here(), FEE_AMOUNT).into(),
			// USDT to transfer - destination reserve
			(usdt_id_location.clone(), SEND_AMOUNT).into(),
		);

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_fee = fee_asset.clone().reanchored(&dest, &context).unwrap();
		let expected_asset = xfer_asset.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);

		// Alice spent (transferred) amount
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount - SEND_AMOUNT
		);
		// Alice used native asset for fees
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE - FEE_AMOUNT);
		// Destination account (teyrchain account) added native reserve to balances
		assert_eq!(Balances::free_balance(usdt_chain_sovereign_account.clone()), FEE_AMOUNT);
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), usdt_chain_sovereign_account),
			0
		);
		// Verify total and active issuance of foreign BLA have decreased (burned on
		// reserve-withdraw)
		let expected_issuance = usdt_initial_local_amount - SEND_AMOUNT;
		assert_eq!(AssetsPallet::total_issuance(usdt_id_location.clone()), expected_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdt_id_location), expected_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				// `fees` are being sent through local-reserve transfer because fee reserve is
				// local chain; `assets` are burned on source and withdrawn from SA here
				Xcm(vec![
					ReserveAssetDeposited(expected_fee.clone().into()),
					buy_limited_execution(expected_fee, Unlimited),
					ReceiveTeleportedAsset(expected_asset.into()),
					ClearOrigin,
					DepositAsset { assets: AllCounted(2).into(), beneficiary },
				])
			)]
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location,
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
	});
}

/// Test `transfer_assets` with teleportable asset and local fee reserve.
#[test]
fn transfer_assets_with_teleportable_asset_and_local_fee_reserve_works() {
	let expected_result = Ok(());
	teleport_asset_using_local_fee_reserve_call(XcmPallet::transfer_assets, expected_result);
}

/// Test `limited_reserve_transfer_assets` with teleportable asset and local fee reserve disallowed.
#[test]
fn reserve_transfer_assets_with_teleportable_asset_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	teleport_asset_using_local_fee_reserve_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with teleportable asset and local fee reserve disallowed.
#[test]
fn teleport_assets_with_teleportable_asset_and_local_fee_reserve_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	teleport_asset_using_local_fee_reserve_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` with teleported asset reserve and destination fee.
///
/// Transferring USDT to `FOREIGN_ASSET_RESERVE_PARA_ID` (teleport trust). Using foreign asset
/// (destination reserve) for fees.
///
/// Verifies `expected_result`
fn teleported_asset_using_destination_reserve_fee_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let balances = vec![(ALICE, INITIAL_BALANCE)];
	let origin_location: Location = AccountId32 { network: None, id: ALICE.into() }.into();
	let beneficiary: Location = AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset BLA to be used for fees
		let foreign_initial_amount = 142;
		let (reserve_location, foreign_sovereign_account, foreign_asset_id_location) =
			set_up_foreign_asset(
				FOREIGN_ASSET_RESERVE_PARA_ID,
				Some(FOREIGN_ASSET_INNER_JUNCTION),
				ALICE,
				foreign_initial_amount,
				true,
			);

		// create non-sufficient foreign asset USDT
		let usdt_initial_local_amount = 42;
		let (_, usdt_chain_sovereign_account, usdt_id_location) =
			set_up_foreign_asset(USDT_PARA_ID, None, ALICE, usdt_initial_local_amount, false);

		// transfer destination is BLA reserve location
		let dest = reserve_location;
		let dest_sovereign_account = foreign_sovereign_account;

		let (assets, fee_asset, xfer_asset) = into_assets_checked(
			// foreign asset BLA used for fees - destination reserve
			(foreign_asset_id_location.clone(), FEE_AMOUNT).into(),
			// USDT to transfer - teleported
			(usdt_id_location.clone(), SEND_AMOUNT).into(),
		);

		// reanchor according to test-case
		let context = UniversalLocation::get();
		let expected_fee = fee_asset.clone().reanchored(&dest, &context).unwrap();
		let expected_asset = xfer_asset.reanchored(&dest, &context).unwrap();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount
		);
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(ALICE),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(assets.into()),
			Box::new(fee_asset.id.into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let weight = BaseXcmWeight::get() * 4;
		let mut last_events = last_events(3).into_iter();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::FeesPaid {
				paying: origin_location,
				fees: Assets::new(),
			})
		);
		assert!(matches!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent { .. })
		));
		// Alice native asset untouched
		assert_eq!(Balances::free_balance(ALICE), INITIAL_BALANCE);
		// Alice spent USDT for fees
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), ALICE),
			usdt_initial_local_amount - SEND_AMOUNT
		);
		// Alice transferred BLA
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), ALICE),
			foreign_initial_amount - FEE_AMOUNT
		);
		// Verify balances of USDT reserve teyrchain
		assert_eq!(Balances::free_balance(usdt_chain_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(usdt_id_location.clone(), usdt_chain_sovereign_account),
			0
		);
		// Verify balances of transferred-asset reserve teyrchain
		assert_eq!(Balances::free_balance(dest_sovereign_account.clone()), 0);
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), dest_sovereign_account),
			0
		);
		// Verify total and active issuance of USDT have decreased (teleported)
		let expected_usdt_issuance = usdt_initial_local_amount - SEND_AMOUNT;
		assert_eq!(AssetsPallet::total_issuance(usdt_id_location.clone()), expected_usdt_issuance);
		assert_eq!(AssetsPallet::active_issuance(usdt_id_location), expected_usdt_issuance);
		// Verify total and active issuance of foreign BLA asset have decreased (burned on
		// reserve-withdraw)
		let expected_bla_issuance = foreign_initial_amount - FEE_AMOUNT;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_bla_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_bla_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				dest,
				Xcm(vec![
					// fees are withdrawn from origin's local SA
					WithdrawAsset(expected_fee.clone().into()),
					buy_limited_execution(expected_fee, Unlimited),
					// assets are teleported to destination chain
					ReceiveTeleportedAsset(expected_asset.into()),
					ClearOrigin,
					DepositAsset { assets: AllCounted(2).into(), beneficiary },
				])
			)]
		);
	});
}

/// Test `transfer_assets` with teleported asset reserve and destination fee.
#[test]
fn transfer_teleported_assets_using_destination_reserve_fee_works() {
	let expected_result = Ok(());
	teleported_asset_using_destination_reserve_fee_call(
		XcmPallet::transfer_assets,
		expected_result,
	);
}

/// Test `limited_reserve_transfer_assets` with teleported asset reserve and destination fee
/// disallowed.
#[test]
fn reserve_transfer_teleported_assets_using_destination_reserve_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	teleported_asset_using_destination_reserve_fee_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}

/// Test `limited_teleport_assets` with teleported asset reserve and destination fee disallowed.
#[test]
fn teleport_assets_using_destination_reserve_fee_disallowed() {
	let expected_result = Err(crate::Error::<Test>::Filtered.into());
	teleported_asset_using_destination_reserve_fee_call(
		XcmPallet::limited_teleport_assets,
		expected_result,
	);
}

/// Test `tested_call` transferring single asset using remote reserve.
///
/// Transferring Para3000 asset (`Para3000` reserve) to
/// `OTHER_PARA_ID` (no teleport trust), therefore triggering remote reserve.
/// Using the same asset asset (Para3000 reserve) for fees.
///
/// Asserts that the sender's balance is decreased and the beneficiary's balance
/// is increased. Verifies the correct message is sent and event is emitted.
///
/// Verifies that XCM router fees (`SendXcm::validate` -> `Assets`) are withdrawn from correct
/// user account and deposited to a correct target account (`XcmFeesTargetAccount`).
/// Verifies `expected_result`.
fn remote_asset_reserve_and_remote_fee_reserve_paid_call<Call>(
	tested_call: Call,
	expected_result: DispatchResult,
) where
	Call: FnOnce(
		OriginFor<Test>,
		Box<VersionedLocation>,
		Box<VersionedLocation>,
		Box<VersionedAssets>,
		Box<VersionedAssetId>,
		WeightLimit,
	) -> DispatchResult,
{
	let weight = BaseXcmWeight::get() * 3;
	let user_account = AccountId::from(XCM_FEES_NOT_WAIVED_USER_ACCOUNT);
	let xcm_router_fee_amount = Para3000PaymentAmount::get();
	let paid_para_id = Para3000::get();
	let balances = vec![
		(user_account.clone(), INITIAL_BALANCE),
		(ParaId::from(paid_para_id).into_account_truncating(), INITIAL_BALANCE),
		(XcmFeesTargetAccount::get(), INITIAL_BALANCE),
	];
	let beneficiary: Location = Junction::AccountId32 { network: None, id: ALICE.into() }.into();
	new_test_ext_with_balances(balances).execute_with(|| {
		// create sufficient foreign asset BLA
		let foreign_initial_amount = 142;
		let (reserve_location, _, foreign_asset_id_location) = set_up_foreign_asset(
			paid_para_id,
			None,
			user_account.clone(),
			foreign_initial_amount,
			true,
		);

		// transfer destination is another chain that is not the reserve location
		// the goal is to trigger the remoteReserve case
		let dest = RelayLocation::get().pushed_with_interior(Teyrchain(OTHER_PARA_ID)).unwrap();

		let transferred_asset: Assets = (foreign_asset_id_location.clone(), SEND_AMOUNT).into();

		// balances checks before
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), user_account.clone()),
			foreign_initial_amount
		);
		assert_eq!(Balances::free_balance(user_account.clone()), INITIAL_BALANCE);

		// do the transfer
		let result = tested_call(
			RuntimeOrigin::signed(user_account.clone()),
			Box::new(dest.clone().into()),
			Box::new(beneficiary.clone().into()),
			Box::new(transferred_asset.into()),
			Box::new(foreign_asset_id_location.clone().into()),
			Unlimited,
		);
		assert_eq!(result, expected_result);
		if expected_result.is_err() {
			// short-circuit here for tests where we expect failure
			return;
		}

		let context = UniversalLocation::get();
		let foreign_id_location_reanchored =
			foreign_asset_id_location.clone().reanchored(&dest, &context).unwrap();
		let dest_reanchored = dest.reanchored(&reserve_location, &context).unwrap();
		let sent_msg_id = find_xcm_sent_message_id::<Test>(all_events()).unwrap();
		let sent_message = Xcm(vec![
			WithdrawAsset((Location::here(), SEND_AMOUNT).into()),
			ClearOrigin,
			buy_execution((Location::here(), SEND_AMOUNT / 2)),
			DepositReserveAsset {
				assets: Wild(AllCounted(1)),
				// final destination is `dest` as seen by `reserve`
				dest: dest_reanchored,
				// message sent onward to `dest`
				xcm: Xcm(vec![
					buy_execution((foreign_id_location_reanchored, SEND_AMOUNT / 2)),
					DepositAsset { assets: AllCounted(1).into(), beneficiary },
				]),
			},
			SetTopic(sent_msg_id),
		]);

		let mut last_events = last_events(7).into_iter();
		// asset events
		// forceCreate
		last_events.next().unwrap();
		// mint tokens
		last_events.next().unwrap();
		// burn tokens
		last_events.next().unwrap();
		// balance events
		// burn delivery fee
		last_events.next().unwrap();
		// mint delivery fee
		last_events.next().unwrap();
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Sent {
				origin: user_account.clone().into(),
				destination: Teyrchain(paid_para_id).into(),
				message: Xcm::default(),
				message_id: sent_msg_id,
			})
		);
		assert_eq!(
			last_events.next().unwrap(),
			RuntimeEvent::XcmPallet(crate::Event::Attempted {
				outcome: Outcome::Complete { used: weight }
			})
		);

		// user account spent (transferred) amount
		assert_eq!(
			AssetsPallet::balance(foreign_asset_id_location.clone(), user_account.clone()),
			foreign_initial_amount - SEND_AMOUNT
		);

		// user account spent delivery fees
		assert_eq!(Balances::free_balance(user_account), INITIAL_BALANCE - xcm_router_fee_amount);

		// XcmFeesTargetAccount where should lend xcm_router_fee_amount
		assert_eq!(
			Balances::free_balance(XcmFeesTargetAccount::get()),
			INITIAL_BALANCE + xcm_router_fee_amount
		);

		// Verify total and active issuance of foreign BLA have decreased (burned on
		// reserve-withdraw)
		let expected_issuance = foreign_initial_amount - SEND_AMOUNT;
		assert_eq!(
			AssetsPallet::total_issuance(foreign_asset_id_location.clone()),
			expected_issuance
		);
		assert_eq!(AssetsPallet::active_issuance(foreign_asset_id_location), expected_issuance);

		// Verify sent XCM program
		assert_eq!(
			sent_xcm(),
			vec![(
				// `assets` are burned on source and withdrawn from SA in remote reserve chain
				reserve_location,
				sent_message,
			)]
		);
	});
}
/// Test `transfer_assets` with remote asset reserve and remote fee reserve.
#[test]
fn transfer_assets_with_remote_asset_reserve_and_remote_asset_fee_reserve_paid_works() {
	let expected_result = Ok(());
	remote_asset_reserve_and_remote_fee_reserve_paid_call(
		XcmPallet::transfer_assets,
		expected_result,
	);
}
/// Test `limited_reserve_transfer_assets` with remote asset reserve and remote fee reserve.
#[test]
fn limited_reserve_transfer_assets_with_remote_asset_reserve_and_remote_asset_fee_reserve_paid_works(
) {
	let expected_result = Ok(());
	remote_asset_reserve_and_remote_fee_reserve_paid_call(
		XcmPallet::limited_reserve_transfer_assets,
		expected_result,
	);
}