Grcov report - integration

1

// Copyright 2019-2025 PureStake Inc.

2

// This file is part of Moonbeam.

3

4

// Moonbeam is free software: you can redistribute it and/or modify

5

// it under the terms of the GNU General Public License as published by

6

// the Free Software Foundation, either version 3 of the License, or

7

// (at your option) any later version.

8

9

// Moonbeam is distributed in the hope that it will be useful,

10

// but WITHOUT ANY WARRANTY; without even the implied warranty of

11

// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

12

// GNU General Public License for more details.

13

14

// You should have received a copy of the GNU General Public License

15

// along with Moonbeam.  If not, see <http://www.gnu.org/licenses/>.

16

17

//! Moonriver Runtime Integration Tests

18

19

#![cfg(test)]

20

21

mod common;

22

23

use common::*;

24

use std::cell::Cell;

25

use std::rc::Rc;

26

27

use fp_evm::{Context, IsPrecompileResult};

28

use frame_support::{

29

	assert_noop, assert_ok,

30

	dispatch::DispatchClass,

31

	traits::{

32

		fungible::Inspect, Currency as CurrencyT, EnsureOrigin, OnInitialize, PalletInfo,

33

		StorageInfo, StorageInfoTrait,

34

},

35

	weights::{constants::WEIGHT_REF_TIME_PER_SECOND, Weight},

36

	StorageHasher, Twox128,

37

};

38

use moonbeam_xcm_benchmarks::weights::XcmWeight;

39

use moonkit_xcm_primitives::AccountIdAssetIdConversion;

40

use moonriver_runtime::currency::{GIGAWEI, WEI};

41

use moonriver_runtime::runtime_params::dynamic_params;

42

use moonriver_runtime::{

43

	asset_config::ForeignAssetInstance,

44

	xcm_config::{CurrencyId, SelfReserve},

45

	AssetId, Balances, CrowdloanRewards, EvmForeignAssets, Executive, OpenTechCommitteeCollective,

46

	PolkadotXcm, Precompiles, RuntimeBlockWeights, TransactionPayment,

47

	TransactionPaymentAsGasPrice, Treasury, TreasuryCouncilCollective, XcmTransactor,

48

	FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX, WEEKS,

49

};

50

use nimbus_primitives::NimbusId;

51

use pallet_evm::PrecompileSet;

52

use pallet_evm_precompileset_assets_erc20::{SELECTOR_LOG_APPROVAL, SELECTOR_LOG_TRANSFER};

53

use pallet_transaction_payment::Multiplier;

54

use pallet_xcm_transactor::{Currency, CurrencyPayment, TransactWeights};

55

use parity_scale_codec::Encode;

56

use polkadot_parachain::primitives::Sibling;

57

use precompile_utils::{

58

	precompile_set::{is_precompile_or_fail, IsActivePrecompile},

59

	prelude::*,

60

	testing::*,

61

};

62

use sha3::{Digest, Keccak256};

63

use sp_core::{ByteArray, Get, Pair, H160, U256};

64

use sp_runtime::{

65

	traits::{Convert, Dispatchable},

66

	BuildStorage, DispatchError, ModuleError,

67

};

68

use std::str::from_utf8;

69

use xcm::latest::prelude::*;

70

use xcm::{VersionedAssets, VersionedLocation};

71

use xcm_builder::{ParentIsPreset, SiblingParachainConvertsVia};

72

use xcm_executor::traits::ConvertLocation;

73

use xcm_primitives::split_location_into_chain_part_and_beneficiary;

74

75

type BatchPCall = pallet_evm_precompile_batch::BatchPrecompileCall<Runtime>;

76

type CrowdloanRewardsPCall =

77

	pallet_evm_precompile_crowdloan_rewards::CrowdloanRewardsPrecompileCall<Runtime>;

78

type XcmUtilsPCall = pallet_evm_precompile_xcm_utils::XcmUtilsPrecompileCall<

79

	Runtime,

80

	moonriver_runtime::xcm_config::XcmExecutorConfig,

81

>;

82

type XtokensPCall = pallet_evm_precompile_xtokens::XtokensPrecompileCall<Runtime>;

83

type ForeignAssetsPCall = pallet_evm_precompileset_assets_erc20::Erc20AssetsPrecompileSetCall<

84

	Runtime,

85

	ForeignAssetInstance,

86

>;

87

type XcmTransactorV2PCall =

88

	pallet_evm_precompile_xcm_transactor::v2::XcmTransactorPrecompileV2Call<Runtime>;

89

90

const BASE_FEE_GENESIS: u128 = 100 * GIGAWEI;

91

92

3

fn currency_to_asset(currency_id: CurrencyId, amount: u128) -> Asset {

93

3

	Asset {

94

3

		id: AssetId(

95

3

			<moonriver_runtime::Runtime as pallet_xcm_transactor::Config>::CurrencyIdToLocation::convert(

96

3

				currency_id,

97

3

98

3

			.unwrap(),

99

3

),

100

3

		fun: Fungibility::Fungible(amount),

101

3

102

3

103

104

#[test]

105

1

fn xcmp_queue_controller_origin_is_root() {

106

1

	// important for the XcmExecutionManager impl of PauseExecution which uses root origin

107

1

	// to suspend/resume XCM execution in xcmp_queue::on_idle

108

1

	assert_ok!(

109

1

		<moonriver_runtime::Runtime as cumulus_pallet_xcmp_queue::Config

110

1

		>::ControllerOrigin::ensure_origin(root_origin())

111

1

);

112

1

113

114

#[test]

115

1

fn verify_pallet_prefixes() {

116

30

	fn is_pallet_prefix<P: 'static>(name: &str) {

117

30

		// Compares the unhashed pallet prefix in the `StorageInstance` implementation by every

118

30

		// storage item in the pallet P. This pallet prefix is used in conjunction with the

119

30

		// item name to get the unique storage key: hash(PalletPrefix) + hash(StorageName)

120

30

		// https://github.com/paritytech/substrate/blob/master/frame/support/procedural/src/pallet/

121

30

		// expand/storage.rs#L389-L401

122

30

		assert_eq!(

123

30

			<moonriver_runtime::Runtime as frame_system::Config>::PalletInfo::name::<P>(),

124

30

			Some(name)

125

30

);

126

30

127

	// TODO: use StorageInfoTrait from https://github.com/paritytech/substrate/pull/9246

128

	// This is now available with polkadot-v0.9.9 dependencies

129

1

	is_pallet_prefix::<moonriver_runtime::System>("System");

130

1

	is_pallet_prefix::<moonriver_runtime::Utility>("Utility");

131

1

	is_pallet_prefix::<moonriver_runtime::ParachainSystem>("ParachainSystem");

132

1

	is_pallet_prefix::<moonriver_runtime::TransactionPayment>("TransactionPayment");

133

1

	is_pallet_prefix::<moonriver_runtime::ParachainInfo>("ParachainInfo");

134

1

	is_pallet_prefix::<moonriver_runtime::EthereumChainId>("EthereumChainId");

135

1

	is_pallet_prefix::<moonriver_runtime::EVM>("EVM");

136

1

	is_pallet_prefix::<moonriver_runtime::Ethereum>("Ethereum");

137

1

	is_pallet_prefix::<moonriver_runtime::ParachainStaking>("ParachainStaking");

138

1

	is_pallet_prefix::<moonriver_runtime::MaintenanceMode>("MaintenanceMode");

139

1

	is_pallet_prefix::<moonriver_runtime::Scheduler>("Scheduler");

140

1

	is_pallet_prefix::<moonriver_runtime::OpenTechCommitteeCollective>(

141

1

		"OpenTechCommitteeCollective",

142

1

);

143

1

	is_pallet_prefix::<moonriver_runtime::Treasury>("Treasury");

144

1

	is_pallet_prefix::<moonriver_runtime::AuthorInherent>("AuthorInherent");

145

1

	is_pallet_prefix::<moonriver_runtime::AuthorFilter>("AuthorFilter");

146

1

	is_pallet_prefix::<moonriver_runtime::CrowdloanRewards>("CrowdloanRewards");

147

1

	is_pallet_prefix::<moonriver_runtime::AuthorMapping>("AuthorMapping");

148

1

	is_pallet_prefix::<moonriver_runtime::Identity>("Identity");

149

1

	is_pallet_prefix::<moonriver_runtime::XcmpQueue>("XcmpQueue");

150

1

	is_pallet_prefix::<moonriver_runtime::CumulusXcm>("CumulusXcm");

151

1

	is_pallet_prefix::<moonriver_runtime::PolkadotXcm>("PolkadotXcm");

152

1

	is_pallet_prefix::<moonriver_runtime::Assets>("Assets");

153

1

	is_pallet_prefix::<moonriver_runtime::AssetManager>("AssetManager");

154

1

	is_pallet_prefix::<moonriver_runtime::Migrations>("Migrations");

155

1

	is_pallet_prefix::<moonriver_runtime::XcmTransactor>("XcmTransactor");

156

1

	is_pallet_prefix::<moonriver_runtime::ProxyGenesisCompanion>("ProxyGenesisCompanion");

157

1

	is_pallet_prefix::<moonriver_runtime::MoonbeamOrbiters>("MoonbeamOrbiters");

158

1

	is_pallet_prefix::<moonriver_runtime::TreasuryCouncilCollective>("TreasuryCouncilCollective");

159

1

	is_pallet_prefix::<moonriver_runtime::MoonbeamLazyMigrations>("MoonbeamLazyMigrations");

160

1

	is_pallet_prefix::<moonriver_runtime::RelayStorageRoots>("RelayStorageRoots");

161

1

162

14

	let prefix = |pallet_name, storage_name| {

163

14

		let mut res = [0u8; 32];

164

14

		res[0..16].copy_from_slice(&Twox128::hash(pallet_name));

165

14

		res[16..32].copy_from_slice(&Twox128::hash(storage_name));

166

14

		res.to_vec()

167

14

};

168

1

	assert_eq!(

169

1

		<moonriver_runtime::Timestamp as StorageInfoTrait>::storage_info(),

170

1

		vec![

171

1

			StorageInfo {

172

1

				pallet_name: b"Timestamp".to_vec(),

173

1

				storage_name: b"Now".to_vec(),

174

1

				prefix: prefix(b"Timestamp", b"Now"),

175

1

				max_values: Some(1),

176

1

				max_size: Some(8),

177

1

},

178

1

			StorageInfo {

179

1

				pallet_name: b"Timestamp".to_vec(),

180

1

				storage_name: b"DidUpdate".to_vec(),

181

1

				prefix: prefix(b"Timestamp", b"DidUpdate"),

182

1

				max_values: Some(1),

183

1

				max_size: Some(1),

184

1

185

1

186

1

);

187

1

	assert_eq!(

188

1

		<moonriver_runtime::Balances as StorageInfoTrait>::storage_info(),

189

1

		vec![

190

1

			StorageInfo {

191

1

				pallet_name: b"Balances".to_vec(),

192

1

				storage_name: b"TotalIssuance".to_vec(),

193

1

				prefix: prefix(b"Balances", b"TotalIssuance"),

194

1

				max_values: Some(1),

195

1

				max_size: Some(16),

196

1

},

197

1

			StorageInfo {

198

1

				pallet_name: b"Balances".to_vec(),

199

1

				storage_name: b"InactiveIssuance".to_vec(),

200

1

				prefix: prefix(b"Balances", b"InactiveIssuance"),

201

1

				max_values: Some(1),

202

1

				max_size: Some(16),

203

1

},

204

1

			StorageInfo {

205

1

				pallet_name: b"Balances".to_vec(),

206

1

				storage_name: b"Account".to_vec(),

207

1

				prefix: prefix(b"Balances", b"Account"),

208

1

				max_values: None,

209

1

				max_size: Some(100),

210

1

},

211

1

			StorageInfo {

212

1

				pallet_name: b"Balances".to_vec(),

213

1

				storage_name: b"Locks".to_vec(),

214

1

				prefix: prefix(b"Balances", b"Locks"),

215

1

				max_values: None,

216

1

				max_size: Some(1287),

217

1

},

218

1

			StorageInfo {

219

1

				pallet_name: b"Balances".to_vec(),

220

1

				storage_name: b"Reserves".to_vec(),

221

1

				prefix: prefix(b"Balances", b"Reserves"),

222

1

				max_values: None,

223

1

				max_size: Some(1037),

224

1

},

225

1

			StorageInfo {

226

1

				pallet_name: b"Balances".to_vec(),

227

1

				storage_name: b"Holds".to_vec(),

228

1

				prefix: prefix(b"Balances", b"Holds"),

229

1

				max_values: None,

230

1

				max_size: Some(55),

231

1

},

232

1

			StorageInfo {

233

1

				pallet_name: b"Balances".to_vec(),

234

1

				storage_name: b"Freezes".to_vec(),

235

1

				prefix: prefix(b"Balances", b"Freezes"),

236

1

				max_values: None,

237

1

				max_size: Some(37),

238

1

},

239

1

240

1

);

241

1

	assert_eq!(

242

1

		<moonriver_runtime::Proxy as StorageInfoTrait>::storage_info(),

243

1

		vec![

244

1

			StorageInfo {

245

1

				pallet_name: b"Proxy".to_vec(),

246

1

				storage_name: b"Proxies".to_vec(),

247

1

				prefix: prefix(b"Proxy", b"Proxies"),

248

1

				max_values: None,

249

1

				max_size: Some(845),

250

1

},

251

1

			StorageInfo {

252

1

				pallet_name: b"Proxy".to_vec(),

253

1

				storage_name: b"Announcements".to_vec(),

254

1

				prefix: prefix(b"Proxy", b"Announcements"),

255

1

				max_values: None,

256

1

				max_size: Some(1837),

257

1

258

1

259

1

);

260

1

	assert_eq!(

261

1

		<moonriver_runtime::MaintenanceMode as StorageInfoTrait>::storage_info(),

262

1

		vec![StorageInfo {

263

1

			pallet_name: b"MaintenanceMode".to_vec(),

264

1

			storage_name: b"MaintenanceMode".to_vec(),

265

1

			prefix: prefix(b"MaintenanceMode", b"MaintenanceMode"),

266

1

			max_values: Some(1),

267

1

			max_size: None,

268

1

},]

269

1

);

270

1

	assert_eq!(

271

1

		<moonriver_runtime::RelayStorageRoots as StorageInfoTrait>::storage_info(),

272

1

		vec![

273

1

			StorageInfo {

274

1

				pallet_name: b"RelayStorageRoots".to_vec(),

275

1

				storage_name: b"RelayStorageRoot".to_vec(),

276

1

				prefix: prefix(b"RelayStorageRoots", b"RelayStorageRoot"),

277

1

				max_values: None,

278

1

				max_size: Some(44),

279

1

},

280

1

			StorageInfo {

281

1

				pallet_name: b"RelayStorageRoots".to_vec(),

282

1

				storage_name: b"RelayStorageRootKeys".to_vec(),

283

1

				prefix: prefix(b"RelayStorageRoots", b"RelayStorageRootKeys"),

284

1

				max_values: Some(1),

285

1

				max_size: Some(121),

286

1

},

287

1

288

1

);

289

1

290

291

#[test]

292

1

fn test_collectives_storage_item_prefixes() {

293

7

	for StorageInfo { pallet_name, .. } in

294

8

		<moonriver_runtime::TreasuryCouncilCollective as StorageInfoTrait>::storage_info()

295

296

7

		assert_eq!(pallet_name, b"TreasuryCouncilCollective".to_vec());

297

298

299

7

	for StorageInfo { pallet_name, .. } in

300

8

		<moonriver_runtime::OpenTechCommitteeCollective as StorageInfoTrait>::storage_info()

301

302

7

		assert_eq!(pallet_name, b"OpenTechCommitteeCollective".to_vec());

303

304

1

305

306

#[test]

307

1

fn collective_set_members_root_origin_works() {

308

1

	ExtBuilder::default().build().execute_with(|| {

309

1

		// TreasuryCouncilCollective

310

1

		assert_ok!(TreasuryCouncilCollective::set_members(

311

1

			<Runtime as frame_system::Config>::RuntimeOrigin::root(),

312

1

			vec![AccountId::from(ALICE), AccountId::from(BOB)],

313

1

			Some(AccountId::from(ALICE)),

314

1

315

1

));

316

		// OpenTechCommitteeCollective

317

1

		assert_ok!(OpenTechCommitteeCollective::set_members(

318

1

			<Runtime as frame_system::Config>::RuntimeOrigin::root(),

319

1

			vec![AccountId::from(ALICE), AccountId::from(BOB)],

320

1

			Some(AccountId::from(ALICE)),

321

1

322

1

));

323

1

});

324

1

325

326

#[test]

327

1

fn collective_set_members_general_admin_origin_works() {

328

	use moonriver_runtime::{

329

		governance::custom_origins::Origin as CustomOrigin, OriginCaller, Utility,

330

};

331

332

1

	ExtBuilder::default().build().execute_with(|| {

333

1

		let root_caller = <Runtime as frame_system::Config>::RuntimeOrigin::root();

334

1

		let alice = AccountId::from(ALICE);

335

1

336

1

		// TreasuryCouncilCollective

337

1

		let _ = Utility::dispatch_as(

338

1

			root_caller.clone(),

339

1

			Box::new(OriginCaller::Origins(CustomOrigin::GeneralAdmin)),

340

1

			Box::new(

341

1

				pallet_collective::Call::<Runtime, pallet_collective::Instance3>::set_members {

342

1

					new_members: vec![alice, AccountId::from(BOB)],

343

1

					prime: Some(alice),

344

1

					old_count: 2,

345

1

346

1

				.into(),

347

1

),

348

1

);

349

1

		// OpenTechCommitteeCollective

350

1

		let _ = Utility::dispatch_as(

351

1

			root_caller,

352

1

			Box::new(OriginCaller::Origins(CustomOrigin::GeneralAdmin)),

353

1

			Box::new(

354

1

				pallet_collective::Call::<Runtime, pallet_collective::Instance4>::set_members {

355

1

					new_members: vec![alice, AccountId::from(BOB)],

356

1

					prime: Some(alice),

357

1

					old_count: 2,

358

1

359

1

				.into(),

360

1

),

361

1

);

362

1

363

1

		assert_eq!(

364

1

			System::events()

365

1

				.into_iter()

366

2

				.filter_map(|r| {

367

2

					match r.event {

368

2

						RuntimeEvent::Utility(pallet_utility::Event::DispatchedAs { result })

369

2

							if result.is_ok() =>

370

2

371

2

							Some(true)

372

373

						_ => None,

374

375

2

})

376

1

				.collect::<Vec<_>>()

377

1

				.len(),

378

1

379

1

380

1

});

381

1

382

383

#[test]

384

1

fn collective_set_members_signed_origin_does_not_work() {

385

1

	let alice = AccountId::from(ALICE);

386

1

	ExtBuilder::default().build().execute_with(|| {

387

1

		// TreasuryCouncilCollective

388

1

		assert!(TreasuryCouncilCollective::set_members(

389

1

			<Runtime as frame_system::Config>::RuntimeOrigin::signed(alice),

390

1

			vec![AccountId::from(ALICE), AccountId::from(BOB)],

391

1

			Some(AccountId::from(ALICE)),

392

1

393

1

394

1

		.is_err());

395

		// OpenTechCommitteeCollective

396

1

		assert!(OpenTechCommitteeCollective::set_members(

397

1

			<Runtime as frame_system::Config>::RuntimeOrigin::signed(alice),

398

1

			vec![AccountId::from(ALICE), AccountId::from(BOB)],

399

1

			Some(AccountId::from(ALICE)),

400

1

401

1

402

1

		.is_err());

403

1

});

404

1

405

406

#[test]

407

1

fn verify_pallet_indices() {

408

32

	fn is_pallet_index<P: 'static>(index: usize) {

409

32

		assert_eq!(

410

32

			<moonriver_runtime::Runtime as frame_system::Config>::PalletInfo::index::<P>(),

411

32

			Some(index)

412

32

);

413

32

414

	// System support

415

1

	is_pallet_index::<moonriver_runtime::System>(0);

416

1

	is_pallet_index::<moonriver_runtime::ParachainSystem>(1);

417

1

	is_pallet_index::<moonriver_runtime::Timestamp>(3);

418

1

	is_pallet_index::<moonriver_runtime::ParachainInfo>(4);

419

1

	// Monetary

420

1

	is_pallet_index::<moonriver_runtime::Balances>(10);

421

1

	is_pallet_index::<moonriver_runtime::TransactionPayment>(11);

422

1

	// Consensus support

423

1

	is_pallet_index::<moonriver_runtime::ParachainStaking>(20);

424

1

	is_pallet_index::<moonriver_runtime::AuthorInherent>(21);

425

1

	is_pallet_index::<moonriver_runtime::AuthorFilter>(22);

426

1

	is_pallet_index::<moonriver_runtime::AuthorMapping>(23);

427

1

	is_pallet_index::<moonriver_runtime::MoonbeamOrbiters>(24);

428

1

	// Handy utilities

429

1

	is_pallet_index::<moonriver_runtime::Utility>(30);

430

1

	is_pallet_index::<moonriver_runtime::Proxy>(31);

431

1

	is_pallet_index::<moonriver_runtime::MaintenanceMode>(32);

432

1

	is_pallet_index::<moonriver_runtime::Identity>(33);

433

1

	is_pallet_index::<moonriver_runtime::Migrations>(34);

434

1

	is_pallet_index::<moonriver_runtime::ProxyGenesisCompanion>(35);

435

1

	is_pallet_index::<moonriver_runtime::MoonbeamLazyMigrations>(37);

436

1

	// Ethereum compatibility

437

1

	is_pallet_index::<moonriver_runtime::EthereumChainId>(50);

438

1

	is_pallet_index::<moonriver_runtime::EVM>(51);

439

1

	is_pallet_index::<moonriver_runtime::Ethereum>(52);

440

1

	// Governance

441

1

	is_pallet_index::<moonriver_runtime::Scheduler>(60);

442

1

	// is_pallet_index::<moonriver_runtime::Democracy>(61); Removed

443

1

	// Council

444

1

	// is_pallet_index::<moonriver_runtime::CouncilCollective>(70); Removed

445

1

	// is_pallet_index::<moonriver_runtime::TechCommitteeCollective>(71); Removed

446

1

	is_pallet_index::<moonriver_runtime::TreasuryCouncilCollective>(72);

447

1

	is_pallet_index::<moonriver_runtime::OpenTechCommitteeCollective>(73);

448

1

	// Treasury

449

1

	is_pallet_index::<moonriver_runtime::Treasury>(80);

450

1

	// Crowdloan

451

1

	is_pallet_index::<moonriver_runtime::CrowdloanRewards>(90);

452

1

	// XCM Stuff

453

1

	is_pallet_index::<moonriver_runtime::XcmpQueue>(100);

454

1

	is_pallet_index::<moonriver_runtime::CumulusXcm>(101);

455

1

	is_pallet_index::<moonriver_runtime::PolkadotXcm>(103);

456

1

	is_pallet_index::<moonriver_runtime::Assets>(104);

457

1

	is_pallet_index::<moonriver_runtime::AssetManager>(105);

458

1

	// is_pallet_index::<moonriver_runtime::XTokens>(106); Removed

459

1

	is_pallet_index::<moonriver_runtime::XcmTransactor>(107);

460

1

461

462

#[test]

463

1

fn verify_reserved_indices() {

464

1

	let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

465

1

		.build_storage()

466

1

		.unwrap()

467

1

		.into();

468

1

469

1

	t.execute_with(|| {

470

		use frame_metadata::*;

471

1

		let metadata = moonriver_runtime::Runtime::metadata();

472

1

		let metadata = match metadata.1 {

473

1

			RuntimeMetadata::V14(metadata) => metadata,

474

			_ => panic!("metadata has been bumped, test needs to be updated"),

475

};

476

		// 40: Sudo

477

		// 53: BaseFee

478

		// 108: pallet_assets::<Instance1>

479

1

		let reserved = vec![40, 53, 108];

480

1

		let existing = metadata

481

1

			.pallets

482

1

			.iter()

483

50

			.map(|p| p.index)

484

1

			.collect::<Vec<u8>>();

485

3

		assert!(reserved.iter().all(|index| !existing.contains(index)));

486

1

});

487

1

488

489

#[test]

490

1

fn verify_proxy_type_indices() {

491

1

	assert_eq!(moonriver_runtime::ProxyType::Any as u8, 0);

492

1

	assert_eq!(moonriver_runtime::ProxyType::NonTransfer as u8, 1);

493

1

	assert_eq!(moonriver_runtime::ProxyType::Governance as u8, 2);

494

1

	assert_eq!(moonriver_runtime::ProxyType::Staking as u8, 3);

495

1

	assert_eq!(moonriver_runtime::ProxyType::CancelProxy as u8, 4);

496

1

	assert_eq!(moonriver_runtime::ProxyType::Balances as u8, 5);

497

1

	assert_eq!(moonriver_runtime::ProxyType::AuthorMapping as u8, 6);

498

1

	assert_eq!(moonriver_runtime::ProxyType::IdentityJudgement as u8, 7);

499

1

500

501

#[test]

502

1

fn join_collator_candidates() {

503

1

	ExtBuilder::default()

504

1

		.with_balances(vec![

505

1

			(AccountId::from(ALICE), 20_000 * MOVR),

506

1

			(AccountId::from(BOB), 20_000 * MOVR),

507

1

			(AccountId::from(CHARLIE), 10_100 * MOVR),

508

1

			(AccountId::from(DAVE), 10_000 * MOVR),

509

1

])

510

1

		.with_collators(vec![

511

1

			(AccountId::from(ALICE), 10_000 * MOVR),

512

1

			(AccountId::from(BOB), 10_000 * MOVR),

513

1

])

514

1

		.with_delegations(vec![

515

1

			(AccountId::from(CHARLIE), AccountId::from(ALICE), 50 * MOVR),

516

1

			(AccountId::from(CHARLIE), AccountId::from(BOB), 50 * MOVR),

517

1

])

518

1

		.build()

519

1

		.execute_with(|| {

520

1

			assert_noop!(

521

1

				ParachainStaking::join_candidates(

522

1

					origin_of(AccountId::from(ALICE)),

523

1

					10_000 * MOVR,

524

1

					2u32

525

1

),

526

1

				pallet_parachain_staking::Error::<Runtime>::CandidateExists

527

1

);

528

1

			assert_noop!(

529

1

				ParachainStaking::join_candidates(

530

1

					origin_of(AccountId::from(CHARLIE)),

531

1

					10_000 * MOVR,

532

1

					2u32

533

1

),

534

1

				pallet_parachain_staking::Error::<Runtime>::DelegatorExists

535

1

);

536

1

			assert!(System::events().is_empty());

537

1

			assert_ok!(ParachainStaking::join_candidates(

538

1

				origin_of(AccountId::from(DAVE)),

539

1

				10_000 * MOVR,

540

1

				2u32

541

1

));

542

1

			assert_eq!(

543

1

				last_event(),

544

1

				RuntimeEvent::ParachainStaking(

545

1

					pallet_parachain_staking::Event::JoinedCollatorCandidates {

546

1

						account: AccountId::from(DAVE),

547

1

						amount_locked: 10_000 * MOVR,

548

1

						new_total_amt_locked: 30_100 * MOVR

549

1

550

1

551

1

);

552

1

			let candidates = ParachainStaking::candidate_pool();

553

1

			assert_eq!(candidates.0[0].owner, AccountId::from(ALICE));

554

1

			assert_eq!(candidates.0[0].amount, 10_050 * MOVR);

555

1

			assert_eq!(candidates.0[1].owner, AccountId::from(BOB));

556

1

			assert_eq!(candidates.0[1].amount, 10_050 * MOVR);

557

1

			assert_eq!(candidates.0[2].owner, AccountId::from(DAVE));

558

1

			assert_eq!(candidates.0[2].amount, 10_000 * MOVR);

559

1

});

560

1

561

562

#[test]

563

1

fn transfer_through_evm_to_stake() {

564

1

	ExtBuilder::default()

565

1

		.with_balances(vec![(AccountId::from(ALICE), 20_000 * MOVR)])

566

1

		.build()

567

1

		.execute_with(|| {

568

1

			// Charlie has no balance => fails to stake

569

1

			assert_noop!(

570

1

				ParachainStaking::join_candidates(

571

1

					origin_of(AccountId::from(CHARLIE)),

572

1

					10_000 * MOVR,

573

1

					2u32

574

1

),

575

1

				DispatchError::Module(ModuleError {

576

1

					index: 20,

577

1

					error: [8, 0, 0, 0],

578

1

					message: Some("InsufficientBalance")

579

1

})

580

1

);

581

			// Alice transfer from free balance 20000 MOVR to Bob

582

1

			assert_ok!(Balances::transfer_allow_death(

583

1

				origin_of(AccountId::from(ALICE)),

584

1

				AccountId::from(BOB),

585

1

				20_000 * MOVR,

586

1

));

587

1

			assert_eq!(Balances::free_balance(AccountId::from(BOB)), 20_000 * MOVR);

588

589

1

			let gas_limit = 100000u64;

590

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

591

1

			// Bob transfers 10000 MOVR to Charlie via EVM

592

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

593

1

				source: H160::from(BOB),

594

1

				target: H160::from(CHARLIE),

595

1

				input: vec![],

596

1

				value: (10_000 * MOVR).into(),

597

1

				gas_limit,

598

1

				max_fee_per_gas: gas_price,

599

1

				max_priority_fee_per_gas: None,

600

1

				nonce: None,

601

1

				access_list: Vec::new(),

602

1

})

603

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

604

1

			assert_eq!(

605

1

				Balances::free_balance(AccountId::from(CHARLIE)),

606

1

				10_000 * MOVR,

607

1

);

608

609

			// Charlie can stake now

610

1

			assert_ok!(ParachainStaking::join_candidates(

611

1

				origin_of(AccountId::from(CHARLIE)),

612

1

				10_000 * MOVR,

613

1

				2u32,

614

1

			),);

615

1

			let candidates = ParachainStaking::candidate_pool();

616

1

			assert_eq!(candidates.0[0].owner, AccountId::from(CHARLIE));

617

1

			assert_eq!(candidates.0[0].amount, 10_000 * MOVR);

618

1

});

619

1

620

621

#[test]

622

1

fn reward_block_authors() {

623

1

	ExtBuilder::default()

624

1

		.with_balances(vec![

625

1

			// Alice gets 100 extra tokens for her mapping deposit

626

1

			(AccountId::from(ALICE), 20_100 * MOVR),

627

1

			(AccountId::from(BOB), 10_000 * MOVR),

628

1

])

629

1

		.with_collators(vec![(AccountId::from(ALICE), 10_000 * MOVR)])

630

1

		.with_delegations(vec![(

631

1

			AccountId::from(BOB),

632

1

			AccountId::from(ALICE),

633

1

			500 * MOVR,

634

1

)])

635

1

		.with_mappings(vec![(

636

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

637

1

			AccountId::from(ALICE),

638

1

)])

639

1

		.build()

640

1

		.execute_with(|| {

641

1

			increase_last_relay_slot_number(1);

642

1

643

1

			// Just before round 3

644

1

			run_to_block(2399, Some(NimbusId::from_slice(&ALICE_NIMBUS).unwrap()));

645

1

646

1

			// no rewards doled out yet

647

1

			assert_eq!(

648

1

				Balances::usable_balance(AccountId::from(ALICE)),

649

1

				10_100 * MOVR,

650

1

);

651

1

			assert_eq!(Balances::usable_balance(AccountId::from(BOB)), 9500 * MOVR,);

652

1

			run_to_block(2401, Some(NimbusId::from_slice(&ALICE_NIMBUS).unwrap()));

653

1

654

1

			// rewards minted and distributed

655

1

			assert_eq!(

656

1

				Balances::usable_balance(AccountId::from(ALICE)),

657

1

				11547666666208000000000,

658

1

);

659

1

			assert_eq!(

660

1

				Balances::usable_balance(AccountId::from(BOB)),

661

1

				9557333332588000000000,

662

1

);

663

1

});

664

1

665

666

#[test]

667

1

fn reward_block_authors_with_parachain_bond_reserved() {

668

1

	ExtBuilder::default()

669

1

		.with_balances(vec![

670

1

			// Alice gets 100 extra tokens for her mapping deposit

671

1

			(AccountId::from(ALICE), 20_100 * MOVR),

672

1

			(AccountId::from(BOB), 10_000 * MOVR),

673

1

			(AccountId::from(CHARLIE), MOVR),

674

1

])

675

1

		.with_collators(vec![(AccountId::from(ALICE), 10_000 * MOVR)])

676

1

		.with_delegations(vec![(

677

1

			AccountId::from(BOB),

678

1

			AccountId::from(ALICE),

679

1

			500 * MOVR,

680

1

)])

681

1

		.with_mappings(vec![(

682

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

683

1

			AccountId::from(ALICE),

684

1

)])

685

1

		.build()

686

1

		.execute_with(|| {

687

1

			increase_last_relay_slot_number(1);

688

1

			assert_ok!(ParachainStaking::set_parachain_bond_account(

689

1

				root_origin(),

690

1

				AccountId::from(CHARLIE),

691

1

			),);

692

693

			// Stop just before round 2

694

1

			run_to_block(1199, Some(NimbusId::from_slice(&ALICE_NIMBUS).unwrap()));

695

1

696

1

			// no collator rewards doled out yet

697

1

			assert_eq!(

698

1

				Balances::usable_balance(AccountId::from(ALICE)),

699

1

				10_100 * MOVR,

700

1

);

701

1

			assert_eq!(Balances::usable_balance(AccountId::from(BOB)), 9500 * MOVR,);

702

703

			// Go to round 2

704

1

			run_to_block(1201, Some(NimbusId::from_slice(&ALICE_NIMBUS).unwrap()));

705

1

706

1

			// 30% reserved for parachain bond

707

1

			assert_eq!(

708

1

				Balances::usable_balance(AccountId::from(CHARLIE)),

709

1

				452515000000000000000,

710

1

);

711

712

			// Go to round 3

713

1

			run_to_block(2401, Some(NimbusId::from_slice(&ALICE_NIMBUS).unwrap()));

714

1

715

1

			// rewards minted and distributed

716

1

			assert_eq!(

717

1

				Balances::usable_balance(AccountId::from(ALICE)),

718

1

				11117700475903800000000,

719

1

);

720

1

			assert_eq!(

721

1

				Balances::usable_balance(AccountId::from(BOB)),

722

1

				9535834523343675000000,

723

1

);

724

			// 30% reserved for parachain bond again

725

1

			assert_eq!(

726

1

				Balances::usable_balance(AccountId::from(CHARLIE)),

727

1

				910802725000000000000,

728

1

);

729

1

});

730

1

731

732

#[test]

733

1

fn initialize_crowdloan_addresses_with_batch_and_pay() {

734

1

	ExtBuilder::default()

735

1

		.with_balances(vec![

736

1

			(AccountId::from(ALICE), 2_000 * MOVR),

737

1

			(AccountId::from(BOB), 1_000 * MOVR),

738

1

])

739

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

740

1

		.with_mappings(vec![(

741

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

742

1

			AccountId::from(ALICE),

743

1

)])

744

1

		.with_crowdloan_fund(3_000_000 * MOVR)

745

1

		.build()

746

1

		.execute_with(|| {

747

1

			// set parachain inherent data

748

1

			set_parachain_inherent_data();

749

1

			let init_block = CrowdloanRewards::init_vesting_block();

750

1

			// This matches the previous vesting

751

1

			let end_block = init_block + 48 * WEEKS;

752

1

			// Batch calls always succeed. We just need to check the inner event

753

1

			assert_ok!(

754

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch_all {

755

1

					calls: vec![

756

1

						RuntimeCall::CrowdloanRewards(

757

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

758

1

								rewards: vec![(

759

1

									[4u8; 32].into(),

760

1

									Some(AccountId::from(CHARLIE)),

761

1

									1_500_000 * MOVR

762

1

)]

763

1

764

1

),

765

1

						RuntimeCall::CrowdloanRewards(

766

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

767

1

								rewards: vec![(

768

1

									[5u8; 32].into(),

769

1

									Some(AccountId::from(DAVE)),

770

1

									1_500_000 * MOVR

771

1

)]

772

1

773

1

),

774

1

						RuntimeCall::CrowdloanRewards(

775

1

							pallet_crowdloan_rewards::Call::<Runtime>::complete_initialization {

776

1

								lease_ending_block: end_block

777

1

778

1

779

1

780

1

})

781

1

				.dispatch(root_origin())

782

1

);

783

			// 30 percent initial payout

784

1

			assert_eq!(Balances::balance(&AccountId::from(CHARLIE)), 450_000 * MOVR);

785

			// 30 percent initial payout

786

1

			assert_eq!(Balances::balance(&AccountId::from(DAVE)), 450_000 * MOVR);

787

1

			let expected = RuntimeEvent::Utility(pallet_utility::Event::BatchCompleted);

788

1

			assert_eq!(last_event(), expected);

789

			// This one should fail, as we already filled our data

790

1

			assert_ok!(

791

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch {

792

1

					calls: vec![RuntimeCall::CrowdloanRewards(

793

1

						pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

794

1

							rewards: vec![([4u8; 32].into(), Some(AccountId::from(ALICE)), 432000)]

795

1

796

1

)]

797

1

})

798

1

				.dispatch(root_origin())

799

1

);

800

1

			let expected_fail = RuntimeEvent::Utility(pallet_utility::Event::BatchInterrupted {

801

1

				index: 0,

802

1

				error: DispatchError::Module(ModuleError {

803

1

					index: 90,

804

1

					error: [8, 0, 0, 0],

805

1

					message: None,

806

1

}),

807

1

});

808

1

			assert_eq!(last_event(), expected_fail);

809

			// Claim 1 block.

810

1

			assert_ok!(CrowdloanRewards::claim(origin_of(AccountId::from(CHARLIE))));

811

1

			assert_ok!(CrowdloanRewards::claim(origin_of(AccountId::from(DAVE))));

812

813

1

			let vesting_period = 48 * WEEKS as u128;

814

1

			let per_block = (1_050_000 * MOVR) / vesting_period;

815

1

816

1

			assert_eq!(

817

1

				CrowdloanRewards::accounts_payable(&AccountId::from(CHARLIE))

818

1

					.unwrap()

819

1

					.claimed_reward,

820

1

				(450_000 * MOVR) + per_block

821

1

);

822

1

			assert_eq!(

823

1

				CrowdloanRewards::accounts_payable(&AccountId::from(DAVE))

824

1

					.unwrap()

825

1

					.claimed_reward,

826

1

				(450_000 * MOVR) + per_block

827

1

);

828

			// The total claimed reward should be equal to the account balance at this point.

829

1

			assert_eq!(

830

1

				Balances::balance(&AccountId::from(CHARLIE)),

831

1

				(450_000 * MOVR) + per_block

832

1

);

833

1

			assert_eq!(

834

1

				Balances::balance(&AccountId::from(DAVE)),

835

1

				(450_000 * MOVR) + per_block

836

1

);

837

1

			assert_noop!(

838

1

				CrowdloanRewards::claim(origin_of(AccountId::from(ALICE))),

839

1

				pallet_crowdloan_rewards::Error::<Runtime>::NoAssociatedClaim

840

1

);

841

1

});

842

1

843

844

#[test]

845

1

fn initialize_crowdloan_address_and_change_with_relay_key_sig() {

846

1

	ExtBuilder::default()

847

1

		.with_balances(vec![

848

1

			(AccountId::from(ALICE), 2_000 * MOVR),

849

1

			(AccountId::from(BOB), 1_000 * MOVR),

850

1

])

851

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

852

1

		.with_mappings(vec![(

853

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

854

1

			AccountId::from(ALICE),

855

1

)])

856

1

		.with_crowdloan_fund(3_000_000 * MOVR)

857

1

		.build()

858

1

		.execute_with(|| {

859

1

			// set parachain inherent data

860

1

			set_parachain_inherent_data();

861

1

			let init_block = CrowdloanRewards::init_vesting_block();

862

1

			// This matches the previous vesting

863

1

			let end_block = init_block + 4 * WEEKS;

864

1

865

1

			let (pair1, _) = sp_core::sr25519::Pair::generate();

866

1

			let (pair2, _) = sp_core::sr25519::Pair::generate();

867

1

868

1

			let public1 = pair1.public();

869

1

			let public2 = pair2.public();

870

1

871

1

			// signature:

872

1

			// WRAP_BYTES|| NetworkIdentifier|| new_account || previous_account || WRAP_BYTES

873

1

			let mut message = pallet_crowdloan_rewards::WRAPPED_BYTES_PREFIX.to_vec();

874

1

			message.append(&mut b"moonriver-".to_vec());

875

1

			message.append(&mut AccountId::from(DAVE).encode());

876

1

			message.append(&mut AccountId::from(CHARLIE).encode());

877

1

			message.append(&mut pallet_crowdloan_rewards::WRAPPED_BYTES_POSTFIX.to_vec());

878

1

			let signature1 = pair1.sign(&message);

879

1

			let signature2 = pair2.sign(&message);

880

1

881

1

			// Batch calls always succeed. We just need to check the inner event

882

1

			assert_ok!(

883

1

				// two relay accounts pointing at the same reward account

884

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch_all {

885

1

					calls: vec![

886

1

						RuntimeCall::CrowdloanRewards(

887

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

888

1

								rewards: vec![(

889

1

									public1.into(),

890

1

									Some(AccountId::from(CHARLIE)),

891

1

									1_500_000 * MOVR

892

1

)]

893

1

894

1

),

895

1

						RuntimeCall::CrowdloanRewards(

896

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

897

1

								rewards: vec![(

898

1

									public2.into(),

899

1

									Some(AccountId::from(CHARLIE)),

900

1

									1_500_000 * MOVR

901

1

)]

902

1

903

1

),

904

1

						RuntimeCall::CrowdloanRewards(

905

1

							pallet_crowdloan_rewards::Call::<Runtime>::complete_initialization {

906

1

								lease_ending_block: end_block

907

1

908

1

909

1

910

1

})

911

1

				.dispatch(root_origin())

912

1

);

913

			// 30 percent initial payout

914

1

			assert_eq!(Balances::balance(&AccountId::from(CHARLIE)), 900_000 * MOVR);

915

916

			// this should fail, as we are only providing one signature

917

1

			assert_noop!(

918

1

				CrowdloanRewards::change_association_with_relay_keys(

919

1

					origin_of(AccountId::from(CHARLIE)),

920

1

					AccountId::from(DAVE),

921

1

					AccountId::from(CHARLIE),

922

1

					vec![(public1.into(), signature1.clone().into())]

923

1

),

924

1

				pallet_crowdloan_rewards::Error::<Runtime>::InsufficientNumberOfValidProofs

925

1

);

926

927

			// this should be valid

928

1

			assert_ok!(CrowdloanRewards::change_association_with_relay_keys(

929

1

				origin_of(AccountId::from(CHARLIE)),

930

1

				AccountId::from(DAVE),

931

1

				AccountId::from(CHARLIE),

932

1

				vec![

933

1

					(public1.into(), signature1.into()),

934

1

					(public2.into(), signature2.into())

935

1

936

1

));

937

938

1

			assert_eq!(

939

1

				CrowdloanRewards::accounts_payable(&AccountId::from(DAVE))

940

1

					.unwrap()

941

1

					.claimed_reward,

942

1

				(900_000 * MOVR)

943

1

);

944

1

});

945

1

946

947

#[test]

948

1

fn claim_via_precompile() {

949

1

	ExtBuilder::default()

950

1

		.with_balances(vec![

951

1

			(AccountId::from(ALICE), 2_000 * MOVR),

952

1

			(AccountId::from(BOB), 1_000 * MOVR),

953

1

])

954

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

955

1

		.with_mappings(vec![(

956

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

957

1

			AccountId::from(ALICE),

958

1

)])

959

1

		.with_crowdloan_fund(3_000_000 * MOVR)

960

1

		.build()

961

1

		.execute_with(|| {

962

1

			// set parachain inherent data

963

1

			set_parachain_inherent_data();

964

1

			let init_block = CrowdloanRewards::init_vesting_block();

965

1

			// This matches the previous vesting

966

1

			let end_block = init_block + 4 * WEEKS;

967

1

			// Batch calls always succeed. We just need to check the inner event

968

1

			assert_ok!(

969

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch_all {

970

1

					calls: vec![

971

1

						RuntimeCall::CrowdloanRewards(

972

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

973

1

								rewards: vec![(

974

1

									[4u8; 32].into(),

975

1

									Some(AccountId::from(CHARLIE)),

976

1

									1_500_000 * MOVR

977

1

)]

978

1

979

1

),

980

1

						RuntimeCall::CrowdloanRewards(

981

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

982

1

								rewards: vec![(

983

1

									[5u8; 32].into(),

984

1

									Some(AccountId::from(DAVE)),

985

1

									1_500_000 * MOVR

986

1

)]

987

1

988

1

),

989

1

						RuntimeCall::CrowdloanRewards(

990

1

							pallet_crowdloan_rewards::Call::<Runtime>::complete_initialization {

991

1

								lease_ending_block: end_block

992

1

993

1

994

1

995

1

})

996

1

				.dispatch(root_origin())

997

1

);

998

999

1

			assert!(CrowdloanRewards::initialized());

1000

1001

			// 30 percent initial payout

1002

1

			assert_eq!(Balances::balance(&AccountId::from(CHARLIE)), 450_000 * MOVR);

1003

			// 30 percent initial payout

1004

1

			assert_eq!(Balances::balance(&AccountId::from(DAVE)), 450_000 * MOVR);

1005

1006

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1007

1

1008

1

			// Alice uses the crowdloan precompile to claim through the EVM

1009

1

			let gas_limit = 100000u64;

1010

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1011

1

1012

1

			// Construct the call data (selector, amount)

1013

1

			let mut call_data = Vec::<u8>::from([0u8; 4]);

1014

1

			call_data[0..4].copy_from_slice(&Keccak256::digest(b"claim()")[0..4]);

1015

1

1016

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1017

1

				source: H160::from(CHARLIE),

1018

1

				target: crowdloan_precompile_address,

1019

1

				input: call_data,

1020

1

				value: U256::zero(), // No value sent in EVM

1021

1

				gas_limit,

1022

1

				max_fee_per_gas: gas_price,

1023

1

				max_priority_fee_per_gas: None,

1024

1

				nonce: None, // Use the next nonce

1025

1

				access_list: Vec::new(),

1026

1

})

1027

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1028

1029

1

			let vesting_period = 4 * WEEKS as u128;

1030

1

			let per_block = (1_050_000 * MOVR) / vesting_period;

1031

1

1032

1

			assert_eq!(

1033

1

				CrowdloanRewards::accounts_payable(&AccountId::from(CHARLIE))

1034

1

					.unwrap()

1035

1

					.claimed_reward,

1036

1

				(450_000 * MOVR) + per_block

1037

1

);

1038

1

})

1039

1

1040

1041

#[test]

1042

1

fn is_contributor_via_precompile() {

1043

1

	ExtBuilder::default()

1044

1

		.with_balances(vec![

1045

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1046

1

			(AccountId::from(BOB), 1_000 * MOVR),

1047

1

])

1048

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

1049

1

		.with_mappings(vec![(

1050

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

1051

1

			AccountId::from(ALICE),

1052

1

)])

1053

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1054

1

		.build()

1055

1

		.execute_with(|| {

1056

1

			// set parachain inherent data

1057

1

			set_parachain_inherent_data();

1058

1

			let init_block = CrowdloanRewards::init_vesting_block();

1059

1

			// This matches the previous vesting

1060

1

			let end_block = init_block + 4 * WEEKS;

1061

1

			// Batch calls always succeed. We just need to check the inner event

1062

1

			assert_ok!(

1063

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch_all {

1064

1

					calls: vec![

1065

1

						RuntimeCall::CrowdloanRewards(

1066

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

1067

1

								rewards: vec![(

1068

1

									[4u8; 32].into(),

1069

1

									Some(AccountId::from(CHARLIE)),

1070

1

									1_500_000 * MOVR

1071

1

)]

1072

1

1073

1

),

1074

1

						RuntimeCall::CrowdloanRewards(

1075

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

1076

1

								rewards: vec![(

1077

1

									[5u8; 32].into(),

1078

1

									Some(AccountId::from(DAVE)),

1079

1

									1_500_000 * MOVR

1080

1

)]

1081

1

1082

1

),

1083

1

						RuntimeCall::CrowdloanRewards(

1084

1

							pallet_crowdloan_rewards::Call::<Runtime>::complete_initialization {

1085

1

								lease_ending_block: end_block

1086

1

1087

1

1088

1

1089

1

})

1090

1

				.dispatch(root_origin())

1091

1

);

1092

1093

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1094

1

1095

1

			// Assert precompile reports Bob is not a contributor

1096

1

			Precompiles::new()

1097

1

				.prepare_test(

1098

1

					ALICE,

1099

1

					crowdloan_precompile_address,

1100

1

					CrowdloanRewardsPCall::is_contributor {

1101

1

						contributor: Address(AccountId::from(BOB).into()),

1102

1

},

1103

1

1104

1

				.expect_cost(3338)

1105

1

				.expect_no_logs()

1106

1

				.execute_returns(false);

1107

1

1108

1

			// Assert precompile reports Charlie is a nominator

1109

1

			Precompiles::new()

1110

1

				.prepare_test(

1111

1

					ALICE,

1112

1

					crowdloan_precompile_address,

1113

1

					CrowdloanRewardsPCall::is_contributor {

1114

1

						contributor: Address(AccountId::from(CHARLIE).into()),

1115

1

},

1116

1

1117

1

				.expect_cost(3338)

1118

1

				.expect_no_logs()

1119

1

				.execute_returns(true);

1120

1

})

1121

1

1122

1123

#[test]

1124

1

fn reward_info_via_precompile() {

1125

1

	ExtBuilder::default()

1126

1

		.with_balances(vec![

1127

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1128

1

			(AccountId::from(BOB), 1_000 * MOVR),

1129

1

])

1130

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

1131

1

		.with_mappings(vec![(

1132

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

1133

1

			AccountId::from(ALICE),

1134

1

)])

1135

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1136

1

		.build()

1137

1

		.execute_with(|| {

1138

1

			// set parachain inherent data

1139

1

			set_parachain_inherent_data();

1140

1

			let init_block = CrowdloanRewards::init_vesting_block();

1141

1

			// This matches the previous vesting

1142

1

			let end_block = init_block + 4 * WEEKS;

1143

1

			// Batch calls always succeed. We just need to check the inner event

1144

1

			assert_ok!(

1145

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch_all {

1146

1

					calls: vec![

1147

1

						RuntimeCall::CrowdloanRewards(

1148

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

1149

1

								rewards: vec![(

1150

1

									[4u8; 32].into(),

1151

1

									Some(AccountId::from(CHARLIE)),

1152

1

									1_500_000 * MOVR

1153

1

)]

1154

1

1155

1

),

1156

1

						RuntimeCall::CrowdloanRewards(

1157

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

1158

1

								rewards: vec![(

1159

1

									[5u8; 32].into(),

1160

1

									Some(AccountId::from(DAVE)),

1161

1

									1_500_000 * MOVR

1162

1

)]

1163

1

1164

1

),

1165

1

						RuntimeCall::CrowdloanRewards(

1166

1

							pallet_crowdloan_rewards::Call::<Runtime>::complete_initialization {

1167

1

								lease_ending_block: end_block

1168

1

1169

1

1170

1

1171

1

})

1172

1

				.dispatch(root_origin())

1173

1

);

1174

1175

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1176

1

1177

1

			let expected_total: U256 = (1_500_000 * MOVR).into();

1178

1

			let expected_claimed: U256 = (450_000 * MOVR).into();

1179

1

1180

1

			// Assert precompile reports correct Charlie reward info.

1181

1

			Precompiles::new()

1182

1

				.prepare_test(

1183

1

					ALICE,

1184

1

					crowdloan_precompile_address,

1185

1

					CrowdloanRewardsPCall::reward_info {

1186

1

						contributor: Address(AccountId::from(CHARLIE).into()),

1187

1

},

1188

1

1189

1

				.expect_cost(3338)

1190

1

				.expect_no_logs()

1191

1

				.execute_returns((expected_total, expected_claimed));

1192

1

})

1193

1

1194

1195

#[test]

1196

1

fn update_reward_address_via_precompile() {

1197

1

	ExtBuilder::default()

1198

1

		.with_balances(vec![

1199

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1200

1

			(AccountId::from(BOB), 1_000 * MOVR),

1201

1

])

1202

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

1203

1

		.with_mappings(vec![(

1204

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

1205

1

			AccountId::from(ALICE),

1206

1

)])

1207

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1208

1

		.build()

1209

1

		.execute_with(|| {

1210

1

			// set parachain inherent data

1211

1

			set_parachain_inherent_data();

1212

1

			let init_block = CrowdloanRewards::init_vesting_block();

1213

1

			// This matches the previous vesting

1214

1

			let end_block = init_block + 4 * WEEKS;

1215

1

			// Batch calls always succeed. We just need to check the inner event

1216

1

			assert_ok!(

1217

1

				RuntimeCall::Utility(pallet_utility::Call::<Runtime>::batch_all {

1218

1

					calls: vec![

1219

1

						RuntimeCall::CrowdloanRewards(

1220

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

1221

1

								rewards: vec![(

1222

1

									[4u8; 32].into(),

1223

1

									Some(AccountId::from(CHARLIE)),

1224

1

									1_500_000 * MOVR

1225

1

)]

1226

1

1227

1

),

1228

1

						RuntimeCall::CrowdloanRewards(

1229

1

							pallet_crowdloan_rewards::Call::<Runtime>::initialize_reward_vec {

1230

1

								rewards: vec![(

1231

1

									[5u8; 32].into(),

1232

1

									Some(AccountId::from(DAVE)),

1233

1

									1_500_000 * MOVR

1234

1

)]

1235

1

1236

1

),

1237

1

						RuntimeCall::CrowdloanRewards(

1238

1

							pallet_crowdloan_rewards::Call::<Runtime>::complete_initialization {

1239

1

								lease_ending_block: end_block

1240

1

1241

1

1242

1

1243

1

})

1244

1

				.dispatch(root_origin())

1245

1

);

1246

1247

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1248

1

1249

1

			// Charlie uses the crowdloan precompile to update address through the EVM

1250

1

			let gas_limit = 100000u64;

1251

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1252

1

1253

1

			// Construct the input data to check if Bob is a contributor

1254

1

			let mut call_data = Vec::<u8>::from([0u8; 36]);

1255

1

			call_data[0..4]

1256

1

				.copy_from_slice(&Keccak256::digest(b"update_reward_address(address)")[0..4]);

1257

1

			call_data[16..36].copy_from_slice(&ALICE);

1258

1

1259

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1260

1

				source: H160::from(CHARLIE),

1261

1

				target: crowdloan_precompile_address,

1262

1

				input: call_data,

1263

1

				value: U256::zero(), // No value sent in EVM

1264

1

				gas_limit,

1265

1

				max_fee_per_gas: gas_price,

1266

1

				max_priority_fee_per_gas: None,

1267

1

				nonce: None, // Use the next nonce

1268

1

				access_list: Vec::new(),

1269

1

})

1270

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1271

1272

1

			assert!(CrowdloanRewards::accounts_payable(&AccountId::from(CHARLIE)).is_none());

1273

1

			assert_eq!(

1274

1

				CrowdloanRewards::accounts_payable(&AccountId::from(ALICE))

1275

1

					.unwrap()

1276

1

					.claimed_reward,

1277

1

				(450_000 * MOVR)

1278

1

);

1279

1

})

1280

1

1281

1282

1

fn run_with_system_weight<F>(w: Weight, mut assertions: F)

1283

1

where

1284

1

	F: FnMut() -> (),

1285

1

1286

1

	let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

1287

1

		.build_storage()

1288

1

		.unwrap()

1289

1

		.into();

1290

1

	t.execute_with(|| {

1291

1

		System::set_block_consumed_resources(w, 0);

1292

1

		assertions()

1293

1

});

1294

1

1295

1296

#[test]

1297

#[rustfmt::skip]

1298

1

fn length_fee_is_sensible() {

1299

	use sp_runtime::testing::TestXt;

1300

1301

	// tests that length fee is sensible for a few hypothetical transactions

1302

1

	ExtBuilder::default().build().execute_with(|| {

1303

1

		let call = frame_system::Call::remark::<Runtime> { remark: vec![] };

1304

1

		let uxt: TestXt<_, ()> = TestXt::new_signed(RuntimeCall::System(call), 1u64, (), ());

1305

1

1306

9

		let calc_fee = |len: u32| -> Balance {

1307

9

			moonriver_runtime::TransactionPayment::query_fee_details(uxt.clone(), len)

1308

9

				.inclusion_fee

1309

9

				.expect("fee should be calculated")

1310

9

				.len_fee

1311

9

};

1312

1313

		//                  left: cost of length fee, right: size in bytes

1314

		//                             /------------- proportional component: O(N * 1B)

1315

		//                             |           /- exponential component: O(N ** 3)

1316

		//                             |           |

1317

1

		assert_eq!(                    1_000_000_001, calc_fee(1));

1318

1

		assert_eq!(                   10_000_001_000, calc_fee(10));

1319

1

		assert_eq!(                  100_001_000_000, calc_fee(100));

1320

1

		assert_eq!(                1_001_000_000_000, calc_fee(1_000));

1321

1

		assert_eq!(               11_000_000_000_000, calc_fee(10_000)); // inflection point

1322

1

		assert_eq!(            1_100_000_000_000_000, calc_fee(100_000));

1323

1

		assert_eq!(        1_001_000_000_000_000_000, calc_fee(1_000_000)); // one MOVR, ~ 1MB

1324

1

		assert_eq!(    1_000_010_000_000_000_000_000, calc_fee(10_000_000));

1325

1

		assert_eq!(1_000_000_100_000_000_000_000_000, calc_fee(100_000_000));

1326

1

});

1327

1

1328

1329

#[test]

1330

1

fn multiplier_can_grow_from_zero() {

1331

	use frame_support::traits::Get;

1332

1333

1

	let minimum_multiplier = moonriver_runtime::MinimumMultiplier::get();

1334

1

	let target = moonriver_runtime::TargetBlockFullness::get()

1335

1

		* RuntimeBlockWeights::get()

1336

1

			.get(DispatchClass::Normal)

1337

1

			.max_total

1338

1

			.unwrap();

1339

1

	// if the min is too small, then this will not change, and we are doomed forever.

1340

1

	// the weight is 1/100th bigger than target.

1341

1

	run_with_system_weight(target * 101 / 100, || {

1342

1

		let next =

1343

1

			moonriver_runtime::SlowAdjustingFeeUpdate::<Runtime>::convert(minimum_multiplier);

1344

1

		assert!(

1345

1

			next > minimum_multiplier,

1346

			"{:?} !>= {:?}",

1347

			next,

1348

			minimum_multiplier

1349

);

1350

1

})

1351

1

1352

1353

#[test]

1354

1

fn ethereum_invalid_transaction() {

1355

1

	ExtBuilder::default().build().execute_with(|| {

1356

1

		// Ensure an extrinsic not containing enough gas limit to store the transaction

1357

1

		// on chain is rejected.

1358

1

		assert_eq!(

1359

1

			Executive::apply_extrinsic(unchecked_eth_tx(INVALID_ETH_TX)),

1360

1

			Err(

1361

1

				sp_runtime::transaction_validity::TransactionValidityError::Invalid(

1362

1

					sp_runtime::transaction_validity::InvalidTransaction::Custom(0u8)

1363

1

1364

1

1365

1

);

1366

1

});

1367

1

1368

1369

#[test]

1370

1

fn initial_gas_fee_is_correct() {

1371

	use fp_evm::FeeCalculator;

1372

1373

1

	ExtBuilder::default().build().execute_with(|| {

1374

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1375

1

		assert_eq!(multiplier, Multiplier::from(10u128));

1376

1377

1

		assert_eq!(

1378

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1379

1

1380

1

				3_125_000_000u128.into(),

1381

1

				Weight::from_parts(41_742_000u64, 0)

1382

1

1383

1

);

1384

1

});

1385

1

1386

1387

#[test]

1388

1

fn min_gas_fee_is_correct() {

1389

	use fp_evm::FeeCalculator;

1390

	use frame_support::traits::Hooks;

1391

1392

1

	ExtBuilder::default().build().execute_with(|| {

1393

1

		pallet_transaction_payment::NextFeeMultiplier::<Runtime>::put(Multiplier::from(0));

1394

1

		TransactionPayment::on_finalize(System::block_number()); // should trigger min to kick in

1395

1

1396

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1397

1

		assert_eq!(multiplier, Multiplier::from(1u128));

1398

1399

1

		assert_eq!(

1400

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1401

1

			(312_500_000u128.into(), Weight::from_parts(41_742_000u64, 0))

1402

1

);

1403

1

});

1404

1

1405

1406

#[test]

1407

1

fn transfer_ed_0_substrate() {

1408

1

	ExtBuilder::default()

1409

1

		.with_balances(vec![

1410

1

			(AccountId::from(ALICE), (1 * MOVR) + (1 * WEI)),

1411

1

			(AccountId::from(BOB), existential_deposit()),

1412

1

])

1413

1

		.build()

1414

1

		.execute_with(|| {

1415

1

			// Substrate transfer

1416

1

			assert_ok!(Balances::transfer_allow_death(

1417

1

				origin_of(AccountId::from(ALICE)),

1418

1

				AccountId::from(BOB),

1419

1

				1 * MOVR,

1420

1

));

1421

			// 1 WEI is left in the account

1422

1

			assert_eq!(Balances::free_balance(AccountId::from(ALICE)), 1 * WEI);

1423

1

});

1424

1

1425

1426

#[test]

1427

1

fn transfer_ed_0_evm() {

1428

1

	ExtBuilder::default()

1429

1

		.with_balances(vec![

1430

1

1431

1

				AccountId::from(ALICE),

1432

1

				((1 * MOVR) + (21_000 * BASE_FEE_GENESIS)) + (1 * WEI),

1433

1

),

1434

1

			(AccountId::from(BOB), existential_deposit()),

1435

1

])

1436

1

		.build()

1437

1

		.execute_with(|| {

1438

1

			set_parachain_inherent_data();

1439

1

			// EVM transfer

1440

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1441

1

				source: H160::from(ALICE),

1442

1

				target: H160::from(BOB),

1443

1

				input: Vec::new(),

1444

1

				value: (1 * MOVR).into(),

1445

1

				gas_limit: 21_000u64,

1446

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1447

1

				max_priority_fee_per_gas: Some(U256::from(BASE_FEE_GENESIS)),

1448

1

				nonce: Some(U256::from(0)),

1449

1

				access_list: Vec::new(),

1450

1

})

1451

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1452

			// 1 WEI is left in the account

1453

1

			assert_eq!(Balances::free_balance(AccountId::from(ALICE)), 1 * WEI,);

1454

1

});

1455

1

1456

1457

#[test]

1458

1

fn refund_ed_0_evm() {

1459

1

	ExtBuilder::default()

1460

1

		.with_balances(vec![

1461

1

1462

1

				AccountId::from(ALICE),

1463

1

				((1 * MOVR) + (21_777 * BASE_FEE_GENESIS) + existential_deposit()),

1464

1

),

1465

1

			(AccountId::from(BOB), existential_deposit()),

1466

1

])

1467

1

		.build()

1468

1

		.execute_with(|| {

1469

1

			set_parachain_inherent_data();

1470

1

			// EVM transfer that zeroes ALICE

1471

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1472

1

				source: H160::from(ALICE),

1473

1

				target: H160::from(BOB),

1474

1

				input: Vec::new(),

1475

1

				value: (1 * MOVR).into(),

1476

1

				gas_limit: 21_777u64,

1477

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1478

1

				max_priority_fee_per_gas: Some(U256::from(BASE_FEE_GENESIS)),

1479

1

				nonce: Some(U256::from(0)),

1480

1

				access_list: Vec::new(),

1481

1

})

1482

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1483

			// ALICE is refunded

1484

1

			assert_eq!(

1485

1

				Balances::free_balance(AccountId::from(ALICE)),

1486

1

				777 * BASE_FEE_GENESIS + existential_deposit(),

1487

1

);

1488

1

});

1489

1

1490

1491

#[test]

1492

1

fn author_does_receive_priority_fee() {

1493

1

	ExtBuilder::default()

1494

1

		.with_balances(vec![(

1495

1

			AccountId::from(BOB),

1496

1

			(1 * MOVR) + (21_000 * (500 * GIGAWEI)),

1497

1

)])

1498

1

		.build()

1499

1

		.execute_with(|| {

1500

1

			// Some block author as seen by pallet-evm.

1501

1

			let author = AccountId::from(<pallet_evm::Pallet<Runtime>>::find_author());

1502

1

			pallet_author_inherent::Author::<Runtime>::put(author);

1503

1

			// Currently the default impl of the evm uses `deposit_into_existing`.

1504

1

			// If we were to use this implementation, and for an author to receive eventual tips,

1505

1

			// the account needs to be somehow initialized, otherwise the deposit would fail.

1506

1

			Balances::make_free_balance_be(&author, 100 * MOVR);

1507

1

1508

1

			// EVM transfer.

1509

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1510

1

				source: H160::from(BOB),

1511

1

				target: H160::from(ALICE),

1512

1

				input: Vec::new(),

1513

1

				value: (1 * MOVR).into(),

1514

1

				gas_limit: 21_000u64,

1515

1

				max_fee_per_gas: U256::from(300 * GIGAWEI),

1516

1

				max_priority_fee_per_gas: Some(U256::from(200 * GIGAWEI)),

1517

1

				nonce: Some(U256::from(0)),

1518

1

				access_list: Vec::new(),

1519

1

})

1520

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1521

1522

1

			let priority_fee = 200 * GIGAWEI * 21_000;

1523

1

			// Author free balance increased by priority fee.

1524

1

			assert_eq!(Balances::free_balance(author), 100 * MOVR + priority_fee,);

1525

1

});

1526

1

1527

1528

#[test]

1529

1

fn total_issuance_after_evm_transaction_with_priority_fee() {

1530

	use fp_evm::FeeCalculator;

1531

1

	ExtBuilder::default()

1532

1

		.with_balances(vec![

1533

1

1534

1

				AccountId::from(BOB),

1535

1

				(1 * MOVR) + (21_000 * (2 * BASE_FEE_GENESIS) + existential_deposit()),

1536

1

),

1537

1

1538

1

				<pallet_treasury::TreasuryAccountId<Runtime> as sp_core::TypedGet>::get(),

1539

1

				existential_deposit(),

1540

1

),

1541

1

])

1542

1

		.build()

1543

1

		.execute_with(|| {

1544

1

			let issuance_before = <Runtime as pallet_evm::Config>::Currency::total_issuance();

1545

1

			let author = AccountId::from(<pallet_evm::Pallet<Runtime>>::find_author());

1546

1

			pallet_author_inherent::Author::<Runtime>::put(author);

1547

1

			// EVM transfer.

1548

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1549

1

				source: H160::from(BOB),

1550

1

				target: H160::from(ALICE),

1551

1

				input: Vec::new(),

1552

1

				value: (1 * MOVR).into(),

1553

1

				gas_limit: 21_000u64,

1554

1

				max_fee_per_gas: U256::from(2u128 * BASE_FEE_GENESIS),

1555

1

				max_priority_fee_per_gas: Some(U256::from(2u128 * BASE_FEE_GENESIS)),

1556

1

				nonce: Some(U256::from(0)),

1557

1

				access_list: Vec::new(),

1558

1

})

1559

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1560

1561

1

			let issuance_after = <Runtime as pallet_evm::Config>::Currency::total_issuance();

1562

1

1563

1

			let base_fee = TransactionPaymentAsGasPrice::min_gas_price().0.as_u128();

1564

1

1565

1

			let base_fee: Balance = base_fee * 21_000;

1566

1

1567

1

			let treasury_proportion = dynamic_params::runtime_config::FeesTreasuryProportion::get();

1568

1

1569

1

			// only base fee is split between being burned and sent to treasury

1570

1

			let treasury_base_fee_part: Balance = treasury_proportion.mul_floor(base_fee);

1571

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1572

1

1573

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1574

1575

1

			assert_eq!(moonriver_runtime::Treasury::pot(), treasury_base_fee_part);

1576

1

});

1577

1

1578

1579

#[test]

1580

1

fn total_issuance_after_evm_transaction_without_priority_fee() {

1581

	use fp_evm::FeeCalculator;

1582

1

	ExtBuilder::default()

1583

1

		.with_balances(vec![

1584

1

1585

1

				AccountId::from(BOB),

1586

1

				(1 * MOVR) + (21_000 * (2 * BASE_FEE_GENESIS) + existential_deposit()),

1587

1

),

1588

1

1589

1

				<pallet_treasury::TreasuryAccountId<Runtime> as sp_core::TypedGet>::get(),

1590

1

				existential_deposit(),

1591

1

),

1592

1

])

1593

1

		.build()

1594

1

		.execute_with(|| {

1595

1

			let issuance_before = <Runtime as pallet_evm::Config>::Currency::total_issuance();

1596

1

			// EVM transfer.

1597

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::<Runtime>::call {

1598

1

				source: H160::from(BOB),

1599

1

				target: H160::from(ALICE),

1600

1

				input: Vec::new(),

1601

1

				value: (1 * MOVR).into(),

1602

1

				gas_limit: 21_000u64,

1603

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1604

1

				max_priority_fee_per_gas: None,

1605

1

				nonce: Some(U256::from(0)),

1606

1

				access_list: Vec::new(),

1607

1

})

1608

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

1609

1610

1

			let issuance_after = <Runtime as pallet_evm::Config>::Currency::total_issuance();

1611

1

1612

1

			let base_fee = TransactionPaymentAsGasPrice::min_gas_price().0.as_u128();

1613

1

1614

1

			let base_fee: Balance = base_fee * 21_000;

1615

1

1616

1

			let treasury_proportion = dynamic_params::runtime_config::FeesTreasuryProportion::get();

1617

1

1618

1

			// only base fee is split between being burned and sent to treasury

1619

1

			let treasury_base_fee_part: Balance = treasury_proportion.mul_floor(base_fee);

1620

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1621

1

1622

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1623

1624

1

			assert_eq!(moonriver_runtime::Treasury::pot(), treasury_base_fee_part);

1625

1

});

1626

1

1627

1628

#[test]

1629

1

fn root_can_change_default_xcm_vers() {

1630

1

	ExtBuilder::default()

1631

1

		.with_balances(vec![

1632

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1633

1

			(AccountId::from(BOB), 1_000 * MOVR),

1634

1

])

1635

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1636

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

1637

1

			metadata: AssetRegistrarMetadata {

1638

1

				name: b"RelayToken".to_vec(),

1639

1

				symbol: b"Relay".to_vec(),

1640

1

				decimals: 12,

1641

1

				is_frozen: false,

1642

1

},

1643

1

			balances: vec![(AccountId::from(ALICE), 1_000_000_000_000_000)],

1644

1

			is_sufficient: true,

1645

1

}])

1646

1

		.build()

1647

1

		.execute_with(|| {

1648

1

			let source_location = AssetType::Xcm(xcm::v3::Location::parent());

1649

1

			let dest = Location {

1650

1

				parents: 1,

1651

1

				interior: [AccountId32 {

1652

1

					network: None,

1653

1

					id: [1u8; 32],

1654

1

}]

1655

1

				.into(),

1656

1

};

1657

1

			let source_id: moonriver_runtime::AssetId = source_location.clone().into();

1658

1

			let asset = currency_to_asset(CurrencyId::ForeignAsset(source_id), 100_000_000_000_000);

1659

1

			let (chain_part, beneficiary) =

1660

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

1661

1

			// Default XCM version is not set yet, so xtokens should fail because it does not

1662

1

			// know with which version to send

1663

1

			assert_noop!(

1664

1

				PolkadotXcm::transfer_assets(

1665

1

					origin_of(AccountId::from(ALICE)),

1666

1

					Box::new(xcm::VersionedLocation::from(chain_part.clone())),

1667

1

					Box::new(xcm::VersionedLocation::from(beneficiary.clone())),

1668

1

					Box::new(VersionedAssets::from(asset.clone())),

1669

1

0,

1670

1

					WeightLimit::Limited(4000000000.into())

1671

1

),

1672

1

				pallet_xcm::Error::<Runtime>::SendFailure

1673

1

);

1674

1675

			// Root sets the defaultXcm

1676

1

			assert_ok!(PolkadotXcm::force_default_xcm_version(

1677

1

				root_origin(),

1678

1

				Some(3)

1679

1

));

1680

1681

			// Now transferring does not fail

1682

1

			assert_ok!(PolkadotXcm::transfer_assets(

1683

1

				origin_of(AccountId::from(ALICE)),

1684

1

				Box::new(xcm::VersionedLocation::from(chain_part)),

1685

1

				Box::new(xcm::VersionedLocation::from(beneficiary)),

1686

1

				Box::new(VersionedAssets::from(asset.clone())),

1687

1

0,

1688

1

				WeightLimit::Limited(4000000000.into())

1689

1

));

1690

1

})

1691

1

1692

1693

#[test]

1694

1

fn asset_can_be_registered() {

1695

1

	ExtBuilder::default().build().execute_with(|| {

1696

1

		let source_location = AssetType::Xcm(xcm::v3::Location::parent());

1697

1

		let source_id: moonriver_runtime::AssetId = source_location.clone().into();

1698

1

		let asset_metadata = AssetRegistrarMetadata {

1699

1

			name: b"RelayToken".to_vec(),

1700

1

			symbol: b"Relay".to_vec(),

1701

1

			decimals: 12,

1702

1

			is_frozen: false,

1703

1

};

1704

1

		assert_ok!(AssetManager::register_foreign_asset(

1705

1

			moonriver_runtime::RuntimeOrigin::root(),

1706

1

			source_location,

1707

1

			asset_metadata,

1708

1

			1u128,

1709

1

			true

1710

1

));

1711

1

		assert!(AssetManager::asset_id_type(source_id).is_some());

1712

1

});

1713

1

1714

1715

#[test]

1716

1

fn xcm_asset_erc20_precompiles_supply_and_balance() {

1717

1

	ExtBuilder::default()

1718

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1719

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

1720

1

			metadata: AssetRegistrarMetadata {

1721

1

				name: b"RelayToken".to_vec(),

1722

1

				symbol: b"Relay".to_vec(),

1723

1

				decimals: 12,

1724

1

				is_frozen: false,

1725

1

},

1726

1

			balances: vec![(AccountId::from(ALICE), 1_000 * MOVR)],

1727

1

			is_sufficient: true,

1728

1

}])

1729

1

		.with_balances(vec![

1730

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1731

1

			(AccountId::from(BOB), 1_000 * MOVR),

1732

1

])

1733

1

		.build()

1734

1

		.execute_with(|| {

1735

1

			// We have the assetId that corresponds to the relay chain registered

1736

1

			let relay_asset_id: AssetId = AssetType::Xcm(xcm::v3::Location::parent()).into();

1737

1

1738

1

			// Its address is

1739

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1740

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1741

1

				relay_asset_id,

1742

1

);

1743

1

1744

1

			// Assert the asset has been created with the correct supply

1745

1

			assert_eq!(

1746

1

				moonriver_runtime::Assets::total_supply(relay_asset_id),

1747

1

				1_000 * MOVR

1748

1

);

1749

1750

			// Access totalSupply through precompile. Important that the context is correct

1751

1

			Precompiles::new()

1752

1

				.prepare_test(

1753

1

					ALICE,

1754

1

					asset_precompile_address,

1755

1

					ForeignAssetsPCall::total_supply {},

1756

1

1757

1

				.expect_cost(5007)

1758

1

				.expect_no_logs()

1759

1

				.execute_returns(U256::from(1000 * MOVR));

1760

1

1761

1

			// Access balanceOf through precompile

1762

1

			Precompiles::new()

1763

1

				.prepare_test(

1764

1

					ALICE,

1765

1

					asset_precompile_address,

1766

1

					ForeignAssetsPCall::balance_of {

1767

1

						who: Address(ALICE.into()),

1768

1

},

1769

1

1770

1

				.expect_cost(5007)

1771

1

				.expect_no_logs()

1772

1

				.execute_returns(U256::from(1000 * MOVR));

1773

1

});

1774

1

1775

1776

#[test]

1777

1

fn xcm_asset_erc20_precompiles_transfer() {

1778

1

	ExtBuilder::default()

1779

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1780

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

1781

1

			metadata: AssetRegistrarMetadata {

1782

1

				name: b"RelayToken".to_vec(),

1783

1

				symbol: b"Relay".to_vec(),

1784

1

				decimals: 12,

1785

1

				is_frozen: false,

1786

1

},

1787

1

			balances: vec![(AccountId::from(ALICE), 1_000 * MOVR)],

1788

1

			is_sufficient: true,

1789

1

}])

1790

1

		.with_balances(vec![

1791

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1792

1

			(AccountId::from(BOB), 1_000 * MOVR),

1793

1

])

1794

1

		.build()

1795

1

		.execute_with(|| {

1796

1

			// We have the assetId that corresponds to the relay chain registered

1797

1

			let relay_asset_id: AssetId = AssetType::Xcm(xcm::v3::Location::parent()).into();

1798

1

1799

1

			// Its address is

1800

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1801

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1802

1

				relay_asset_id,

1803

1

);

1804

1

1805

1

			// Transfer tokens from Aice to Bob, 400 MOVR.

1806

1

			Precompiles::new()

1807

1

				.prepare_test(

1808

1

					ALICE,

1809

1

					asset_precompile_address,

1810

1

					ForeignAssetsPCall::transfer {

1811

1

						to: Address(BOB.into()),

1812

1

						value: { 400 * MOVR }.into(),

1813

1

},

1814

1

1815

1

				.expect_cost(26682)

1816

1

				.expect_log(log3(

1817

1

					asset_precompile_address,

1818

1

					SELECTOR_LOG_TRANSFER,

1819

1

					H160::from(ALICE),

1820

1

					H160::from(BOB),

1821

1

					solidity::encode_event_data(U256::from(400 * MOVR)),

1822

1

))

1823

1

				.execute_returns(true);

1824

1

1825

1

			// Make sure BOB has 400 MOVR

1826

1

			Precompiles::new()

1827

1

				.prepare_test(

1828

1

					BOB,

1829

1

					asset_precompile_address,

1830

1

					ForeignAssetsPCall::balance_of {

1831

1

						who: Address(BOB.into()),

1832

1

},

1833

1

1834

1

				.expect_cost(5007)

1835

1

				.expect_no_logs()

1836

1

				.execute_returns(U256::from(400 * MOVR));

1837

1

});

1838

1

1839

1840

#[test]

1841

1

fn xcm_asset_erc20_precompiles_approve() {

1842

1

	ExtBuilder::default()

1843

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1844

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

1845

1

			metadata: AssetRegistrarMetadata {

1846

1

				name: b"RelayToken".to_vec(),

1847

1

				symbol: b"Relay".to_vec(),

1848

1

				decimals: 12,

1849

1

				is_frozen: false,

1850

1

},

1851

1

			balances: vec![(AccountId::from(ALICE), 1_000 * MOVR)],

1852

1

			is_sufficient: true,

1853

1

}])

1854

1

		.with_balances(vec![

1855

1

			(AccountId::from(ALICE), 2_000 * MOVR),

1856

1

			(AccountId::from(BOB), 1_000 * MOVR),

1857

1

])

1858

1

		.build()

1859

1

		.execute_with(|| {

1860

1

			// We have the assetId that corresponds to the relay chain registered

1861

1

			let relay_asset_id: AssetId = AssetType::Xcm(xcm::v3::Location::parent()).into();

1862

1

1863

1

			// Its address is

1864

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1865

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1866

1

				relay_asset_id,

1867

1

);

1868

1

1869

1

			// Aprove Bob for spending 400 MOVR from Alice

1870

1

			Precompiles::new()

1871

1

				.prepare_test(

1872

1

					ALICE,

1873

1

					asset_precompile_address,

1874

1

					ForeignAssetsPCall::approve {

1875

1

						spender: Address(BOB.into()),

1876

1

						value: { 400 * MOVR }.into(),

1877

1

},

1878

1

1879

1

				.expect_cost(17333)

1880

1

				.expect_log(log3(

1881

1

					asset_precompile_address,

1882

1

					SELECTOR_LOG_APPROVAL,

1883

1

					H160::from(ALICE),

1884

1

					H160::from(BOB),

1885

1

					solidity::encode_event_data(U256::from(400 * MOVR)),

1886

1

))

1887

1

				.execute_returns(true);

1888

1

1889

1

			// Transfer tokens from Alice to Charlie by using BOB as origin

1890

1

			Precompiles::new()

1891

1

				.prepare_test(

1892

1

					BOB,

1893

1

					asset_precompile_address,

1894

1

					ForeignAssetsPCall::transfer_from {

1895

1

						from: Address(ALICE.into()),

1896

1

						to: Address(CHARLIE.into()),

1897

1

						value: { 400 * MOVR }.into(),

1898

1

},

1899

1

1900

1

				.expect_cost(31980)

1901

1

				.expect_log(log3(

1902

1

					asset_precompile_address,

1903

1

					SELECTOR_LOG_TRANSFER,

1904

1

					H160::from(ALICE),

1905

1

					H160::from(CHARLIE),

1906

1

					solidity::encode_event_data(U256::from(400 * MOVR)),

1907

1

))

1908

1

				.execute_returns(true);

1909

1

1910

1

			// Make sure CHARLIE has 400 MOVR

1911

1

			Precompiles::new()

1912

1

				.prepare_test(

1913

1

					CHARLIE,

1914

1

					asset_precompile_address,

1915

1

					ForeignAssetsPCall::balance_of {

1916

1

						who: Address(CHARLIE.into()),

1917

1

},

1918

1

1919

1

				.expect_cost(5007)

1920

1

				.expect_no_logs()

1921

1

				.execute_returns(U256::from(400 * MOVR));

1922

1

});

1923

1

1924

1925

#[test]

1926

1

fn xtokens_precompiles_transfer() {

1927

2

	fn run_test_variant(evm_native: bool) {

1928

2

		let mut builder = ExtBuilder::default();

1929

2

1930

2

		if evm_native {

1931

1

			builder = builder.with_evm_native_foreign_assets();

1932

1

1933

1934

2

		let asset_type = AssetType::Xcm(xcm::v3::Location::parent());

1935

2

		builder

1936

2

			.with_xcm_assets(vec![XcmAssetInitialization {

1937

2

				asset_type: asset_type.clone(),

1938

2

				metadata: AssetRegistrarMetadata {

1939

2

					name: b"RelayToken".to_vec(),

1940

2

					symbol: b"Relay".to_vec(),

1941

2

					decimals: 12,

1942

2

					is_frozen: false,

1943

2

},

1944

2

				balances: vec![(AccountId::from(ALICE), 1_000_000_000_000_000)],

1945

2

				is_sufficient: true,

1946

2

}])

1947

2

			.with_balances(vec![

1948

2

				(AccountId::from(ALICE), 2_000 * MOVR),

1949

2

				(AccountId::from(BOB), 1_000 * MOVR),

1950

2

])

1951

2

			.with_safe_xcm_version(3)

1952

2

			.build()

1953

2

			.execute_with(|| {

1954

2

				let xtokens_precompile_address = H160::from_low_u64_be(2052);

1955

2

1956

2

				// We have the assetId that corresponds to the relay chain registered

1957

2

				let relay_asset_id: AssetId = AssetType::Xcm(xcm::v3::Location::parent()).into();

1958

2

1959

2

				// Its address is

1960

2

				let asset_precompile_address = Runtime::asset_id_to_account(

1961

2

					FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1962

2

					relay_asset_id,

1963

2

);

1964

2

1965

2

				// Alice has 1000 tokens. She should be able to send through precompile

1966

2

				let destination = Location::new(

1967

2

1,

1968

2

					[Junction::AccountId32 {

1969

2

						network: None,

1970

2

						id: [1u8; 32],

1971

2

}],

1972

2

);

1973

2

1974

2

				let inside = Rc::new(Cell::new(false));

1975

2

				let inside2 = inside.clone();

1976

2

1977

2

				// We use the address of the asset as an identifier of the asset we want to transfer

1978

2

				Precompiles::new()

1979

2

					.prepare_test(

1980

2

						ALICE,

1981

2

						xtokens_precompile_address,

1982

2

						XtokensPCall::transfer {

1983

2

							currency_address: Address(asset_precompile_address.into()),

1984

2

							amount: 500_000_000_000_000u128.into(),

1985

2

							destination,

1986

2

							weight: 4_000_000,

1987

2

},

1988

2

1989

2

					.expect_cost(if evm_native { 178519 } else { 26919 })

1990

2

					.expect_no_logs()

1991

2

					// We expect an evm subcall ERC20.burnFrom

1992

2

					.with_subcall_handle(move |subcall| {

1993

1

						let Subcall {

1994

1

							address,

1995

1

							transfer,

1996

1

							input,

1997

1

							target_gas: _,

1998

1

							is_static,

1999

1

							context,

2000

1

						} = subcall;

2001

1

2002

1

						assert_eq!(context.caller, EvmForeignAssets::account_id().into());

2003

2004

1

						let asset_id: u128 = asset_type.clone().into();

2005

1

						let expected_address: H160 = Runtime::asset_id_to_account(

2006

1

							FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

2007

1

							asset_id,

2008

1

2009

1

						.into();

2010

1

						assert_eq!(address, expected_address);

2011

1

						assert_eq!(is_static, false);

2012

2013

1

						assert!(transfer.is_none());

2014

2015

1

						assert_eq!(context.address, expected_address);

2016

1

						assert_eq!(context.apparent_value, 0u8.into());

2017

2018

1

						assert_eq!(&input[..4], &keccak256!("burnFrom(address,uint256)")[..4]);

2019

1

						assert_eq!(&input[4..16], &[0u8; 12]);

2020

1

						assert_eq!(&input[16..36], ALICE);

2021

2022

1

						inside2.set(true);

2023

1

2024

1

						SubcallOutput {

2025

1

							output: Default::default(),

2026

1

							cost: 149_000,

2027

1

							logs: vec![],

2028

1

							..SubcallOutput::succeed()

2029

1

2030

2

})

2031

2

					.execute_returns(())

2032

2

})

2033

2

2034

2035

1

	run_test_variant(false);

2036

1

	run_test_variant(true);

2037

1

2038

2039

#[test]

2040

1

fn xtokens_precompiles_transfer_multiasset() {

2041

1

	ExtBuilder::default()

2042

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2043

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

2044

1

			metadata: AssetRegistrarMetadata {

2045

1

				name: b"RelayToken".to_vec(),

2046

1

				symbol: b"Relay".to_vec(),

2047

1

				decimals: 12,

2048

1

				is_frozen: false,

2049

1

},

2050

1

			balances: vec![(AccountId::from(ALICE), 1_000_000_000_000_000)],

2051

1

			is_sufficient: true,

2052

1

}])

2053

1

		.with_balances(vec![

2054

1

			(AccountId::from(ALICE), 2_000 * MOVR),

2055

1

			(AccountId::from(BOB), 1_000 * MOVR),

2056

1

])

2057

1

		.with_safe_xcm_version(3)

2058

1

		.build()

2059

1

		.execute_with(|| {

2060

1

			let xtokens_precompile_address = H160::from_low_u64_be(2052);

2061

1

2062

1

			// Alice has 1000 tokens. She should be able to send through precompile

2063

1

			let destination = Location::new(

2064

1

1,

2065

1

				[Junction::AccountId32 {

2066

1

					network: None,

2067

1

					id: [1u8; 32],

2068

1

}],

2069

1

);

2070

1

2071

1

			// This time we transfer it through TransferMultiAsset

2072

1

			// Instead of the address, we encode directly the multilocation referencing the asset

2073

1

			Precompiles::new()

2074

1

				.prepare_test(

2075

1

					ALICE,

2076

1

					xtokens_precompile_address,

2077

1

					XtokensPCall::transfer_multiasset {

2078

1

						// We want to transfer the relay token

2079

1

						asset: Location::parent(),

2080

1

						amount: 500_000_000_000_000u128.into(),

2081

1

						destination,

2082

1

						weight: 4_000_000,

2083

1

},

2084

1

2085

1

				.expect_cost(26919)

2086

1

				.expect_no_logs()

2087

1

				.execute_returns(());

2088

1

})

2089

1

2090

2091

#[test]

2092

1

fn make_sure_polkadot_xcm_cannot_be_called() {

2093

1

	ExtBuilder::default()

2094

1

		.with_balances(vec![

2095

1

			(AccountId::from(ALICE), 2_000 * MOVR),

2096

1

			(AccountId::from(BOB), 1_000 * MOVR),

2097

1

])

2098

1

		.with_collators(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

2099

1

		.with_mappings(vec![(

2100

1

			NimbusId::from_slice(&ALICE_NIMBUS).unwrap(),

2101

1

			AccountId::from(ALICE),

2102

1

)])

2103

1

		.build()

2104

1

		.execute_with(|| {

2105

1

			let dest = Location {

2106

1

				parents: 1,

2107

1

				interior: [AccountId32 {

2108

1

					network: None,

2109

1

					id: [1u8; 32],

2110

1

}]

2111

1

				.into(),

2112

1

};

2113

1

			let assets: Assets = [Asset {

2114

1

				id: AssetId(moonriver_runtime::xcm_config::SelfLocation::get()),

2115

1

				fun: Fungible(1000),

2116

1

}]

2117

1

			.to_vec()

2118

1

			.into();

2119

1

			assert_noop!(

2120

1

				RuntimeCall::PolkadotXcm(pallet_xcm::Call::<Runtime>::reserve_transfer_assets {

2121

1

					dest: Box::new(VersionedLocation::from(dest.clone())),

2122

1

					beneficiary: Box::new(VersionedLocation::from(dest)),

2123

1

					assets: Box::new(VersionedAssets::from(assets)),

2124

1

					fee_asset_item: 0,

2125

1

})

2126

1

				.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::signed(

2127

1

					AccountId::from(ALICE)

2128

1

)),

2129

1

				frame_system::Error::<Runtime>::CallFiltered

2130

1

);

2131

1

});

2132

1

2133

2134

#[test]

2135

1

fn transactor_cannot_use_more_than_max_weight() {

2136

1

	ExtBuilder::default()

2137

1

		.with_balances(vec![

2138

1

			(AccountId::from(ALICE), 2_000 * MOVR),

2139

1

			(AccountId::from(BOB), 1_000 * MOVR),

2140

1

])

2141

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2142

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

2143

1

			metadata: AssetRegistrarMetadata {

2144

1

				name: b"RelayToken".to_vec(),

2145

1

				symbol: b"Relay".to_vec(),

2146

1

				decimals: 12,

2147

1

				is_frozen: false,

2148

1

},

2149

1

			balances: vec![(AccountId::from(ALICE), 1_000_000_000_000_000)],

2150

1

			is_sufficient: true,

2151

1

}])

2152

1

		.build()

2153

1

		.execute_with(|| {

2154

1

			let source_location = AssetType::Xcm(xcm::v3::Location::parent());

2155

1

			let source_id: moonriver_runtime::AssetId = source_location.clone().into();

2156

1

			assert_ok!(XcmTransactor::register(

2157

1

				root_origin(),

2158

1

				AccountId::from(ALICE),

2159

1

0,

2160

1

));

2161

2162

			// Root can set transact info

2163

1

			assert_ok!(XcmTransactor::set_transact_info(

2164

1

				root_origin(),

2165

1

				Box::new(xcm::VersionedLocation::from(Location::parent())),

2166

1

				// Relay charges 1000 for every instruction, and we have 3, so 3000

2167

1

				3000.into(),

2168

1

				20000.into(),

2169

1

				None

2170

1

));

2171

2172

			// Root can set transact info

2173

1

			assert_ok!(XcmTransactor::set_fee_per_second(

2174

1

				root_origin(),

2175

1

				Box::new(xcm::VersionedLocation::from(Location::parent())),

2176

1

2177

1

));

2178

2179

1

			assert_noop!(

2180

1

				XcmTransactor::transact_through_derivative(

2181

1

					origin_of(AccountId::from(ALICE)),

2182

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2183

1

0,

2184

1

					CurrencyPayment {

2185

1

						currency: Currency::AsMultiLocation(Box::new(

2186

1

							xcm::VersionedLocation::from(Location::parent())

2187

1

)),

2188

1

						fee_amount: None

2189

1

},

2190

1

					vec![],

2191

1

					// 2000 is the max

2192

1

					TransactWeights {

2193

1

						transact_required_weight_at_most: 17001.into(),

2194

1

						overall_weight: None

2195

1

},

2196

1

					false

2197

1

),

2198

1

				pallet_xcm_transactor::Error::<Runtime>::MaxWeightTransactReached

2199

1

);

2200

1

			assert_noop!(

2201

1

				XcmTransactor::transact_through_derivative(

2202

1

					origin_of(AccountId::from(ALICE)),

2203

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2204

1

0,

2205

1

					CurrencyPayment {

2206

1

						currency: Currency::AsCurrencyId(CurrencyId::ForeignAsset(source_id)),

2207

1

						fee_amount: None

2208

1

},

2209

1

					vec![],

2210

1

					// 20000 is the max

2211

1

					TransactWeights {

2212

1

						transact_required_weight_at_most: 17001.into(),

2213

1

						overall_weight: None

2214

1

},

2215

1

					false

2216

1

),

2217

1

				pallet_xcm_transactor::Error::<Runtime>::MaxWeightTransactReached

2218

1

);

2219

1

})

2220

1

2221

2222

#[test]

2223

1

fn transact_through_signed_precompile_works_v2() {

2224

1

	ExtBuilder::default()

2225

1

		.with_balances(vec![

2226

1

			(AccountId::from(ALICE), 2_000 * MOVR),

2227

1

			(AccountId::from(BOB), 1_000 * MOVR),

2228

1

])

2229

1

		.with_safe_xcm_version(3)

2230

1

		.build()

2231

1

		.execute_with(|| {

2232

1

			// Destination

2233

1

			let dest = Location::parent();

2234

1

2235

1

			let fee_payer_asset = Location::parent();

2236

1

2237

1

			let bytes = vec![1u8, 2u8, 3u8];

2238

1

2239

1

			let total_weight = 1_000_000_000u64;

2240

1

2241

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2242

1

2243

1

			Precompiles::new()

2244

1

				.prepare_test(

2245

1

					ALICE,

2246

1

					xcm_transactor_v2_precompile_address,

2247

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2248

1

						dest,

2249

1

						fee_asset: fee_payer_asset,

2250

1

						weight: 4_000_000,

2251

1

						call: bytes.into(),

2252

1

						fee_amount: u128::from(total_weight).into(),

2253

1

						overall_weight: total_weight,

2254

1

},

2255

1

2256

1

				.expect_cost(25383)

2257

1

				.expect_no_logs()

2258

1

				.execute_returns(());

2259

1

});

2260

1

2261

2262

#[test]

2263

1

fn transact_through_signed_cannot_send_to_local_chain() {

2264

1

	ExtBuilder::default()

2265

1

		.with_balances(vec![

2266

1

			(AccountId::from(ALICE), 2_000 * MOVR),

2267

1

			(AccountId::from(BOB), 1_000 * MOVR),

2268

1

])

2269

1

		.with_safe_xcm_version(3)

2270

1

		.build()

2271

1

		.execute_with(|| {

2272

1

			// Destination

2273

1

			let dest = Location::here();

2274

1

2275

1

			let fee_payer_asset = Location::parent();

2276

1

2277

1

			let bytes = vec![1u8, 2u8, 3u8];

2278

1

2279

1

			let total_weight = 1_000_000_000u64;

2280

1

2281

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2282

1

2283

1

			Precompiles::new()

2284

1

				.prepare_test(

2285

1

					ALICE,

2286

1

					xcm_transactor_v2_precompile_address,

2287

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2288

1

						dest,

2289

1

						fee_asset: fee_payer_asset,

2290

1

						weight: 4_000_000,

2291

1

						call: bytes.into(),

2292

1

						fee_amount: u128::from(total_weight).into(),

2293

1

						overall_weight: total_weight,

2294

1

},

2295

1

2296

1

				.execute_reverts(|output| {

2297

1

					from_utf8(&output)

2298

1

						.unwrap()

2299

1

						.contains("Dispatched call failed with error:")

2300

1

						&& from_utf8(&output).unwrap().contains("ErrorValidating")

2301

1

});

2302

1

});

2303

1

2304

2305

#[test]

2306

1

fn call_xtokens_with_fee() {

2307

1

	ExtBuilder::default()

2308

1

		.with_balances(vec![

2309

1

			(AccountId::from(ALICE), 2_000 * MOVR),

2310

1

			(AccountId::from(BOB), 1_000 * MOVR),

2311

1

])

2312

1

		.with_safe_xcm_version(3)

2313

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2314

1

			asset_type: AssetType::Xcm(xcm::v3::Location::parent()),

2315

1

			metadata: AssetRegistrarMetadata {

2316

1

				name: b"RelayToken".to_vec(),

2317

1

				symbol: b"Relay".to_vec(),

2318

1

				decimals: 12,

2319

1

				is_frozen: false,

2320

1

},

2321

1

			balances: vec![(AccountId::from(ALICE), 1_000_000_000_000_000)],

2322

1

			is_sufficient: true,

2323

1

}])

2324

1

		.build()

2325

1

		.execute_with(|| {

2326

1

			let source_location = AssetType::Xcm(xcm::v3::Location::parent());

2327

1

			let dest = Location {

2328

1

				parents: 1,

2329

1

				interior: [AccountId32 {

2330

1

					network: None,

2331

1

					id: [1u8; 32],

2332

1

}]

2333

1

				.into(),

2334

1

};

2335

1

			let source_id: moonriver_runtime::AssetId = source_location.clone().into();

2336

1

2337

1

			let before_balance =

2338

1

				moonriver_runtime::Assets::balance(source_id, &AccountId::from(ALICE));

2339

1

2340

1

			let asset = currency_to_asset(CurrencyId::ForeignAsset(source_id), 100_000_000_000_000);

2341

1

			let asset_fee = currency_to_asset(CurrencyId::ForeignAsset(source_id), 100);

2342

1

			let (chain_part, beneficiary) =

2343

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

2344

1

2345

1

			// We are able to transfer with fee

2346

1

			assert_ok!(PolkadotXcm::transfer_assets(

2347

1

				origin_of(AccountId::from(ALICE)),

2348

1

				Box::new(VersionedLocation::from(chain_part)),

2349

1

				Box::new(VersionedLocation::from(beneficiary)),

2350

1

				Box::new(VersionedAssets::from(vec![asset_fee, asset])),

2351

1

0,

2352

1

				WeightLimit::Limited(4000000000.into()),

2353

1

			),);

2354

2355

1

			let after_balance =

2356

1

				moonriver_runtime::Assets::balance(source_id, &AccountId::from(ALICE));

2357

1

			// At least these much (plus fees) should have been charged

2358

1

			assert_eq!(before_balance - 100_000_000_000_000 - 100, after_balance);

2359

1

});

2360

1

2361

2362

#[test]

2363

1

fn test_xcm_utils_ml_tp_account() {

2364

1

	ExtBuilder::default().build().execute_with(|| {

2365

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2366

1

		let expected_address_parent: H160 =

2367

1

			ParentIsPreset::<AccountId>::convert_location(&Location::parent())

2368

1

				.unwrap()

2369

1

				.into();

2370

1

2371

1

		Precompiles::new()

2372

1

			.prepare_test(

2373

1

				ALICE,

2374

1

				xcm_utils_precompile_address,

2375

1

				XcmUtilsPCall::multilocation_to_address {

2376

1

					location: Location::parent(),

2377

1

},

2378

1

2379

1

			.expect_cost(3338)

2380

1

			.expect_no_logs()

2381

1

			.execute_returns(Address(expected_address_parent));

2382

1

2383

1

		let parachain_2000_multilocation = Location::new(1, [Parachain(2000)]);

2384

1

		let expected_address_parachain: H160 =

2385

1

			SiblingParachainConvertsVia::<Sibling, AccountId>::convert_location(

2386

1

				&parachain_2000_multilocation,

2387

1

2388

1

			.unwrap()

2389

1

			.into();

2390

1

2391

1

		Precompiles::new()

2392

1

			.prepare_test(

2393

1

				ALICE,

2394

1

				xcm_utils_precompile_address,

2395

1

				XcmUtilsPCall::multilocation_to_address {

2396

1

					location: parachain_2000_multilocation,

2397

1

},

2398

1

2399

1

			.expect_cost(3338)

2400

1

			.expect_no_logs()

2401

1

			.execute_returns(Address(expected_address_parachain));

2402

1

2403

1

		let alice_in_parachain_2000_location = Location::new(

2404

1

1,

2405

1

2406

1

				Parachain(2000),

2407

1

				AccountKey20 {

2408

1

					network: None,

2409

1

					key: ALICE,

2410

1

},

2411

1

],

2412

1

);

2413

1

		let expected_address_alice_in_parachain_2000 =

2414

1

			xcm_builder::HashedDescription::<

2415

1

				AccountId,

2416

1

				xcm_builder::DescribeFamily<xcm_builder::DescribeAllTerminal>,

2417

1

			>::convert_location(&alice_in_parachain_2000_location)

2418

1

			.unwrap()

2419

1

			.into();

2420

1

2421

1

		Precompiles::new()

2422

1

			.prepare_test(

2423

1

				ALICE,

2424

1

				xcm_utils_precompile_address,

2425

1

				XcmUtilsPCall::multilocation_to_address {

2426

1

					location: alice_in_parachain_2000_location,

2427

1

},

2428

1

2429

1

			.expect_cost(3338)

2430

1

			.expect_no_logs()

2431

1

			.execute_returns(Address(expected_address_alice_in_parachain_2000));

2432

1

});

2433

1

2434

2435

#[test]

2436

1

fn test_xcm_utils_weight_message() {

2437

1

	ExtBuilder::default().build().execute_with(|| {

2438

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2439

1

		let expected_weight =

2440

1

			XcmWeight::<moonriver_runtime::Runtime, RuntimeCall>::clear_origin().ref_time();

2441

1

2442

1

		let message: Vec<u8> = xcm::VersionedXcm::<()>::V5(Xcm(vec![ClearOrigin])).encode();

2443

1

2444

1

		let input = XcmUtilsPCall::weight_message {

2445

1

			message: message.into(),

2446

1

};

2447

1

2448

1

		Precompiles::new()

2449

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2450

1

			.expect_cost(1669)

2451

1

			.expect_no_logs()

2452

1

			.execute_returns(expected_weight);

2453

1

});

2454

1

2455

2456

#[test]

2457

1

fn test_xcm_utils_get_units_per_second() {

2458

1

	ExtBuilder::default().build().execute_with(|| {

2459

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2460

1

		let location = SelfReserve::get();

2461

1

2462

1

		let input = XcmUtilsPCall::get_units_per_second { location };

2463

1

2464

1

		let expected_units =

2465

1

			WEIGHT_REF_TIME_PER_SECOND as u128 * moonriver_runtime::currency::WEIGHT_FEE;

2466

1

2467

1

		Precompiles::new()

2468

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2469

1

			.expect_cost(3338)

2470

1

			.expect_no_logs()

2471

1

			.execute_returns(expected_units);

2472

1

});

2473

1

2474

2475

#[test]

2476

1

fn precompile_existence() {

2477

1

	ExtBuilder::default().build().execute_with(|| {

2478

1

		let precompiles = Precompiles::new();

2479

1

		let precompile_addresses: std::collections::BTreeSet<_> = vec![

2480

1

			1, 2, 3, 4, 5, 6, 7, 8, 9, 256, 1024, 1025, 1026, 2048, 2049, 2050, 2051, 2052, 2053,

2481

1

			2054, 2055, 2056, 2057, 2058, 2059, 2060, 2061, 2062, 2063, 2064, 2065, 2066, 2067,

2482

1

			2068, 2069, 2070, 2071, 2072, 2073, 2074,

2483

1

2484

1

		.into_iter()

2485

1

		.map(H160::from_low_u64_be)

2486

1

		.collect();

2487

2488

3001

		for i in 0..3000 {

2489

3000

			let address = H160::from_low_u64_be(i);

2490

3000

2491

3000

			if precompile_addresses.contains(&address) {

2492

40

				assert!(

2493

40

					is_precompile_or_fail::<Runtime>(address, 100_000u64).expect("to be ok"),

2494

					"is_precompile({}) should return true",

2495

2496

);

2497

2498

40

				assert!(

2499

40

					precompiles

2500

40

						.execute(&mut MockHandle::new(

2501

40

							address,

2502

40

							Context {

2503

40

								address,

2504

40

								caller: H160::zero(),

2505

40

								apparent_value: U256::zero()

2506

40

2507

40

),)

2508

40

						.is_some(),

2509

					"execute({},..) should return Some(_)",

2510

2511

);

2512

			} else {

2513

2960

				assert!(

2514

2960

					!is_precompile_or_fail::<Runtime>(address, 100_000u64).expect("to be ok"),

2515

					"is_precompile({}) should return false",

2516

2517

);

2518

2519

2960

				assert!(

2520

2960

					precompiles

2521

2960

						.execute(&mut MockHandle::new(

2522

2960

							address,

2523

2960

							Context {

2524

2960

								address,

2525

2960

								caller: H160::zero(),

2526

2960

								apparent_value: U256::zero()

2527

2960

2528

2960

),)

2529

2960

						.is_none(),

2530

					"execute({},..) should return None",

2531

2532

);

2533

2534

2535

1

});

2536

1

2537

2538

#[test]

2539

1

fn removed_precompiles() {

2540

1

	ExtBuilder::default().build().execute_with(|| {

2541

1

		let precompiles = Precompiles::new();

2542

1

		let removed_precompiles = [1025, 1027, 2051, 2062, 2063];

2543

2544

3000

		for i in 1..3000 {

2545

2999

			let address = H160::from_low_u64_be(i);

2546

2999

2547

2999

			if !is_precompile_or_fail::<Runtime>(address, 100_000u64).expect("to be ok") {

2548

2959

				continue;

2549

40

2550

40

2551

40

			if !removed_precompiles.contains(&i) {

2552

36

				assert!(

2553

36

					match precompiles.is_active_precompile(address, 100_000u64) {

2554

36

						IsPrecompileResult::Answer { is_precompile, .. } => is_precompile,

2555

						_ => false,

2556

},

2557

					"{i} should be an active precompile"

2558

);

2559

36

				continue;

2560

4

2561

4

2562

4

			assert!(

2563

4

				!match precompiles.is_active_precompile(address, 100_000u64) {

2564

4

					IsPrecompileResult::Answer { is_precompile, .. } => is_precompile,

2565

					_ => false,

2566

},

2567

				"{i} shouldn't be an active precompile"

2568

);

2569

2570

4

			precompiles

2571

4

				.prepare_test(Alice, address, [])

2572

4

				.execute_reverts(|out| out == b"Removed precompile");

2573

4

2574

1

})

2575

1

2576

2577

#[test]

2578

1

fn deal_with_fees_handles_tip() {

2579

	use frame_support::traits::OnUnbalanced;

2580

	use moonbeam_runtime_common::deal_with_fees::DealWithSubstrateFeesAndTip;

2581

	use moonriver_runtime::Treasury;

2582

2583

1

	ExtBuilder::default().build().execute_with(|| {

2584

1

		set_parachain_inherent_data();

2585

1

		// This test validates the functionality of the `DealWithSubstrateFeesAndTip` trait implementation

2586

1

		// in the Moonriver runtime. It verifies that:

2587

1

		// - The correct proportion of the fee is sent to the treasury.

2588

1

		// - The remaining fee is burned (removed from the total supply).

2589

1

		// - The entire tip is sent to the block author.

2590

1

2591

1

		// The test details:

2592

1

		// 1. Simulate issuing a `fee` of 100 and a `tip` of 1000.

2593

1

		// 2. Confirm the initial total supply is 1,100 (equal to the sum of the issued fee and tip).

2594

1

		// 3. Confirm the treasury's balance is initially 0.

2595

1

		// 4. Execute the `DealWithSubstrateFeesAndTip::on_unbalanceds` function with the `fee` and `tip`.

2596

1

		// 5. Validate that the treasury's balance has increased by 20% of the fee (based on FeesTreasuryProportion).

2597

1

		// 6. Validate that 80% of the fee is burned, and the total supply decreases accordingly.

2598

1

		// 7. Validate that the entire tip (100%) is sent to the block author (collator).

2599

1

2600

1

		// Step 1: Issue the fee and tip amounts.

2601

1

		let fee = <pallet_balances::Pallet<Runtime> as frame_support::traits::fungible::Balanced<

2602

1

			AccountId,

2603

1

		>>::issue(100);

2604

1

		let tip = <pallet_balances::Pallet<Runtime> as frame_support::traits::fungible::Balanced<

2605

1

			AccountId,

2606

1

		>>::issue(1000);

2607

1

2608

1

		// Step 2: Validate the initial supply and balances.

2609

1

		let total_supply_before = Balances::total_issuance();

2610

1

		let block_author = pallet_author_inherent::Pallet::<Runtime>::get();

2611

1

		let block_author_balance_before = Balances::free_balance(&block_author);

2612

1

		assert_eq!(total_supply_before, 1_100);

2613

1

		assert_eq!(Balances::free_balance(&Treasury::account_id()), 0);

2614

2615

		// Step 3: Execute the fees handling logic.

2616

1

		DealWithSubstrateFeesAndTip::<

2617

1

			Runtime,

2618

1

			dynamic_params::runtime_config::FeesTreasuryProportion,

2619

1

		>::on_unbalanceds(vec![fee, tip].into_iter());

2620

1

2621

1

		// Step 4: Compute the split between treasury and burned fees based on FeesTreasuryProportion (20%).

2622

1

		let treasury_proportion = dynamic_params::runtime_config::FeesTreasuryProportion::get();

2623

1

2624

1

		let treasury_fee_part: Balance = treasury_proportion.mul_floor(100);

2625

1

		let burnt_fee_part: Balance = 100 - treasury_fee_part;

2626

1

2627

1

		// Step 5: Validate the treasury received 20% of the fee.

2628

1

		assert_eq!(

2629

1

			Balances::free_balance(&Treasury::account_id()),

2630

1

			treasury_fee_part,

2631

1

);

2632

2633

		// Step 6: Verify that 80% of the fee was burned (removed from the total supply).

2634

1

		let total_supply_after = Balances::total_issuance();

2635

1

		assert_eq!(total_supply_before - total_supply_after, burnt_fee_part,);

2636

2637

		// Step 7: Validate that the block author (collator) received 100% of the tip.

2638

1

		let block_author_balance_after = Balances::free_balance(&block_author);

2639

1

		assert_eq!(

2640

1

			block_author_balance_after - block_author_balance_before,

2641

1

			1000,

2642

1

);

2643

1

});

2644

1

2645

2646

#[test]

2647

1

fn evm_revert_substrate_events() {

2648

1

	ExtBuilder::default()

2649

1

		.with_balances(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

2650

1

		.build()

2651

1

		.execute_with(|| {

2652

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2653

1

2654

1

			// Batch a transfer followed by an invalid call to batch.

2655

1

			// Thus BatchAll will revert the transfer.

2656

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::call {

2657

1

				source: ALICE.into(),

2658

1

				target: batch_precompile_address,

2659

1

				input: BatchPCall::batch_all {

2660

1

					to: vec![Address(BOB.into()), Address(batch_precompile_address)].into(),

2661

1

					value: vec![U256::from(1 * MOVR), U256::zero()].into(),

2662

1

					call_data: vec![].into(),

2663

1

					gas_limit: vec![].into()

2664

1

2665

1

				.into(),

2666

1

				value: U256::zero(), // No value sent in EVM

2667

1

				gas_limit: 500_000,

2668

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2669

1

				max_priority_fee_per_gas: None,

2670

1

				nonce: Some(U256::from(0)),

2671

1

				access_list: Vec::new(),

2672

1

})

2673

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

2674

2675

1

			let transfer_count = System::events()

2676

1

				.iter()

2677

6

				.filter(|r| match r.event {

2678

					RuntimeEvent::Balances(pallet_balances::Event::Transfer { .. }) => true,

2679

6

					_ => false,

2680

6

})

2681

1

				.count();

2682

1

2683

1

			assert_eq!(transfer_count, 0, "there should be no transfer event");

2684

1

});

2685

1

2686

2687

#[test]

2688

1

fn evm_success_keeps_substrate_events() {

2689

1

	ExtBuilder::default()

2690

1

		.with_balances(vec![(AccountId::from(ALICE), 1_000 * MOVR)])

2691

1

		.build()

2692

1

		.execute_with(|| {

2693

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2694

1

2695

1

			assert_ok!(RuntimeCall::EVM(pallet_evm::Call::call {

2696

1

				source: ALICE.into(),

2697

1

				target: batch_precompile_address,

2698

1

				input: BatchPCall::batch_all {

2699

1

					to: vec![Address(BOB.into())].into(),

2700

1

					value: vec![U256::from(1 * MOVR)].into(),

2701

1

					call_data: vec![].into(),

2702

1

					gas_limit: vec![].into()

2703

1

2704

1

				.into(),

2705

1

				value: U256::zero(), // No value sent in EVM

2706

1

				gas_limit: 500_000,

2707

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2708

1

				max_priority_fee_per_gas: None,

2709

1

				nonce: Some(U256::from(0)),

2710

1

				access_list: Vec::new(),

2711

1

})

2712

1

			.dispatch(<Runtime as frame_system::Config>::RuntimeOrigin::root()));

2713

2714

1

			let transfer_count = System::events()

2715

1

				.iter()

2716

10

				.filter(|r| match r.event {

2717

1

					RuntimeEvent::Balances(pallet_balances::Event::Transfer { .. }) => true,

2718

9

					_ => false,

2719

10

})

2720

1

				.count();

2721

1

2722

1

			assert_eq!(transfer_count, 1, "there should be 1 transfer event");

2723

1

});

2724

1

2725

2726

#[cfg(test)]

2727

mod treasury_tests {

2728

	use super::*;

2729

	use frame_support::traits::fungible::NativeOrWithId;

2730

	use moonriver_runtime::XcmWeightTrader;

2731

	use sp_core::bounded_vec;

2732

	use sp_runtime::traits::Hash;

2733

2734

4

	fn expect_events(events: Vec<RuntimeEvent>) {

2735

4

		let block_events: Vec<RuntimeEvent> =

2736

29

			System::events().into_iter().map(|r| r.event).collect();

2737

4

2738

7

		assert!(events.iter().all(|evt| block_events.contains(evt)))

2739

4

2740

2741

7

	fn next_block() {

2742

7

		System::reset_events();

2743

7

		System::set_block_number(System::block_number() + 1u32);

2744

7

		System::on_initialize(System::block_number());

2745

7

		Treasury::on_initialize(System::block_number());

2746

7

2747

2748

3

	fn get_asset_balance(id: &u128, account: &AccountId) -> U256 {

2749

3

		pallet_moonbeam_foreign_assets::Pallet::<Runtime>::balance(id.clone(), account.clone())

2750

3

			.expect("failed to get account balance")

2751

3

2752

2753

	#[test]

2754

1

	fn test_treasury_spend_local_with_council_origin() {

2755

1

		let initial_treasury_balance = 1_000 * MOVR;

2756

1

		ExtBuilder::default()

2757

1

			.with_balances(vec![

2758

1

				(AccountId::from(ALICE), 2_000 * MOVR),

2759

1

				(Treasury::account_id(), initial_treasury_balance),

2760

1

])

2761

1

			.build()

2762

1

			.execute_with(|| {

2763

1

				let spend_amount = 100u128 * MOVR;

2764

1

				let spend_beneficiary = AccountId::from(BOB);

2765

1

2766

1

				next_block();

2767

1

2768

1

				// TreasuryCouncilCollective

2769

1

				assert_ok!(TreasuryCouncilCollective::set_members(

2770

1

					root_origin(),

2771

1

					vec![AccountId::from(ALICE)],

2772

1

					Some(AccountId::from(ALICE)),

2773

1

2774

1

));

2775

2776

1

				next_block();

2777

1

2778

1

				// Perform treasury spending

2779

1

				let valid_from = System::block_number() + 5u32;

2780

1

				let proposal = RuntimeCall::Treasury(pallet_treasury::Call::spend {

2781

1

					amount: spend_amount,

2782

1

					asset_kind: Box::new(NativeOrWithId::Native),

2783

1

					beneficiary: Box::new(AccountId::from(BOB)),

2784

1

					valid_from: Some(valid_from),

2785

1

});

2786

1

				assert_ok!(TreasuryCouncilCollective::propose(

2787

1

					origin_of(AccountId::from(ALICE)),

2788

1

1,

2789

1

					Box::new(proposal.clone()),

2790

1

					1_000

2791

1

));

2792

2793

1

				let payout_period =

2794

1

					<<Runtime as pallet_treasury::Config>::PayoutPeriod as Get<u32>>::get();

2795

1

				let expected_events = [

2796

1

					RuntimeEvent::Treasury(pallet_treasury::Event::AssetSpendApproved {

2797

1

						index: 0,

2798

1

						asset_kind: NativeOrWithId::Native,

2799

1

						amount: spend_amount,

2800

1

						beneficiary: spend_beneficiary,

2801

1

						valid_from,

2802

1

						expire_at: payout_period + valid_from,

2803

1

}),

2804

1

					RuntimeEvent::TreasuryCouncilCollective(pallet_collective::Event::Executed {

2805

1

						proposal_hash: sp_runtime::traits::BlakeTwo256::hash_of(&proposal),

2806

1

						result: Ok(()),

2807

1

}),

2808

1

2809

1

				.to_vec();

2810

1

				expect_events(expected_events);

2811

2812

6

				while System::block_number() < valid_from {

2813

5

					next_block();

2814

5

2815

2816

1

				assert_ok!(Treasury::payout(origin_of(spend_beneficiary), 0));

2817

2818

1

				let expected_events = [

2819

1

					RuntimeEvent::Treasury(pallet_treasury::Event::Paid {

2820

1

						index: 0,

2821

1

						payment_id: (),

2822

1

}),

2823

1

					RuntimeEvent::Balances(pallet_balances::Event::Transfer {

2824

1

						from: Treasury::account_id(),

2825

1

						to: spend_beneficiary,

2826

1

						amount: spend_amount,

2827

1

}),

2828

1

2829

1

				.to_vec();

2830

1

				expect_events(expected_events);

2831

1

});

2832

1

2833

2834

	#[test]

2835

1

	fn test_treasury_spend_foreign_asset_with_council_origin() {

2836

1

		let initial_treasury_balance = 1_000 * MOVR;

2837

1

		let asset_id = 1000100010001000u128;

2838

1

		ExtBuilder::default()

2839

1

			.with_balances(vec![(AccountId::from(ALICE), 2_000 * MOVR)])

2840

1

			.build()

2841

1

			.execute_with(|| {

2842

1

				let spend_amount = 100u128 * MOVR;

2843

1

				let spend_beneficiary = AccountId::from(BOB);

2844

1

2845

1

				let asset_location: Location = Location {

2846

1

					parents: 1,

2847

1

					interior: Junctions::Here,

2848

1

};

2849

1

2850

1

				assert_ok!(EvmForeignAssets::create_foreign_asset(

2851

1

					root_origin(),

2852

1

					asset_id,

2853

1

					asset_location.clone(),

2854

1

12,

2855

1

					bounded_vec![b'M', b'T'],

2856

1

					bounded_vec![b'M', b'y', b'T', b'o', b'k'],

2857

1

));

2858

2859

1

				assert_ok!(XcmWeightTrader::add_asset(

2860

1

					root_origin(),

2861

1

					asset_location,

2862

1

					1u128

2863

1

));

2864

2865

1

				assert_ok!(EvmForeignAssets::mint_into(

2866

1

					asset_id,

2867

1

					Treasury::account_id(),

2868

1

					initial_treasury_balance.into()

2869

1

));

2870

2871

1

				assert_eq!(

2872

1

					get_asset_balance(&asset_id, &Treasury::account_id()),

2873

1

					initial_treasury_balance.into(),

2874

					"Treasury balance not updated"

2875

);

2876

2877

				// TreasuryCouncilCollective

2878

1

				assert_ok!(TreasuryCouncilCollective::set_members(

2879

1

					root_origin(),

2880

1

					vec![AccountId::from(ALICE)],

2881

1

					Some(AccountId::from(ALICE)),

2882

1

2883

1

));

2884

2885

				// Perform treasury spending

2886

1

				let proposal = RuntimeCall::Treasury(pallet_treasury::Call::spend {

2887

1

					amount: spend_amount,

2888

1

					asset_kind: Box::new(NativeOrWithId::WithId(asset_id)),

2889

1

					beneficiary: Box::new(spend_beneficiary),

2890

1

					valid_from: None,

2891

1

});

2892

1

				assert_ok!(TreasuryCouncilCollective::propose(

2893

1

					origin_of(AccountId::from(ALICE)),

2894

1

1,

2895

1

					Box::new(proposal.clone()),

2896

1

					1_000

2897

1

));

2898

2899

1

				let payout_period =

2900

1

					<<Runtime as pallet_treasury::Config>::PayoutPeriod as Get<u32>>::get();

2901

1

2902

1

				let current_block = System::block_number();

2903

1

				let expected_events = [

2904

1

					RuntimeEvent::Treasury(pallet_treasury::Event::AssetSpendApproved {

2905

1

						index: 0,

2906

1

						asset_kind: NativeOrWithId::WithId(asset_id),

2907

1

						amount: spend_amount,

2908

1

						beneficiary: spend_beneficiary,

2909

1

						valid_from: current_block,

2910

1

						expire_at: current_block + payout_period,

2911

1

}),

2912

1

					RuntimeEvent::TreasuryCouncilCollective(pallet_collective::Event::Executed {

2913

1

						proposal_hash: sp_runtime::traits::BlakeTwo256::hash_of(&proposal),

2914

1

						result: Ok(()),

2915

1

}),

2916

1

2917

1

				.to_vec();

2918

1

				expect_events(expected_events);

2919

1

2920

1

				assert_ok!(Treasury::payout(origin_of(spend_beneficiary), 0));

2921

2922

1

				expect_events(vec![RuntimeEvent::Treasury(pallet_treasury::Event::Paid {

2923

1

					index: 0,

2924

1

					payment_id: (),

2925

1

				})]);

2926

1

2927

1

				assert_eq!(

2928

1

					get_asset_balance(&asset_id, &Treasury::account_id()),

2929

1

					(initial_treasury_balance - spend_amount).into(),

2930

					"Treasury balance not updated"

2931

);

2932

2933

1

				assert_eq!(

2934

1

					get_asset_balance(&asset_id, &spend_beneficiary),

2935

1

					spend_amount.into(),

2936

					"Treasury payout failed"

2937

);

2938

1

});

2939

1

2940

2941

2942

#[cfg(test)]

2943

mod fee_tests {

2944

	use super::*;

2945

	use fp_evm::FeeCalculator;

2946

	use frame_support::{

2947

		traits::{ConstU128, OnFinalize},

2948

		weights::{ConstantMultiplier, WeightToFee},

2949

};

2950

	use moonriver_runtime::{

2951

		currency, LengthToFee, MinimumMultiplier, RuntimeBlockWeights, SlowAdjustingFeeUpdate,

2952

		TargetBlockFullness, TransactionPaymentAsGasPrice, NORMAL_WEIGHT, WEIGHT_PER_GAS,

2953

};

2954

	use sp_core::Get;

2955

	use sp_runtime::{BuildStorage, FixedPointNumber, Perbill};

2956

2957

1

	fn run_with_system_weight<F>(w: Weight, mut assertions: F)

2958

1

	where

2959

1

		F: FnMut() -> (),

2960

1

2961

1

		let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

2962

1

			.build_storage()

2963

1

			.unwrap()

2964

1

			.into();

2965

1

		t.execute_with(|| {

2966

1

			System::set_block_consumed_resources(w, 0);

2967

1

			assertions()

2968

1

});

2969

1

2970

2971

	#[test]

2972

1

	fn test_multiplier_can_grow_from_zero() {

2973

1

		let minimum_multiplier = MinimumMultiplier::get();

2974

1

		let target = TargetBlockFullness::get()

2975

1

			* RuntimeBlockWeights::get()

2976

1

				.get(DispatchClass::Normal)

2977

1

				.max_total

2978

1

				.unwrap();

2979

1

		// if the min is too small, then this will not change, and we are doomed forever.

2980

1

		// the weight is 1/100th bigger than target.

2981

1

		run_with_system_weight(target * 101 / 100, || {

2982

1

			let next = SlowAdjustingFeeUpdate::<Runtime>::convert(minimum_multiplier);

2983

1

			assert!(

2984

1

				next > minimum_multiplier,

2985

				"{:?} !>= {:?}",

2986

				next,

2987

				minimum_multiplier

2988

);

2989

1

})

2990

1

2991

2992

	#[test]

2993

1

	fn test_fee_calculation() {

2994

1

		let base_extrinsic = RuntimeBlockWeights::get()

2995

1

			.get(DispatchClass::Normal)

2996

1

			.base_extrinsic;

2997

1

		let multiplier = sp_runtime::FixedU128::from_float(0.999000000000000000);

2998

1

		let extrinsic_len = 100u32;

2999

1

		let extrinsic_weight = Weight::from_parts(5_000u64, 1);

3000

1

		let tip = 42u128;

3001

		type WeightToFeeImpl = ConstantMultiplier<u128, ConstU128<{ currency::WEIGHT_FEE }>>;

3002

		type LengthToFeeImpl = LengthToFee;

3003

3004

		// base_fee + (multiplier * extrinsic_weight_fee) + extrinsic_length_fee + tip

3005

1

		let expected_fee = WeightToFeeImpl::weight_to_fee(&base_extrinsic)

3006

1

			+ multiplier.saturating_mul_int(WeightToFeeImpl::weight_to_fee(&extrinsic_weight))

3007

1

			+ LengthToFeeImpl::weight_to_fee(&(Weight::from_parts(extrinsic_len as u64, 1)))

3008

1

			+ tip;

3009

1

3010

1

		let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

3011

1

			.build_storage()

3012

1

			.unwrap()

3013

1

			.into();

3014

1

		t.execute_with(|| {

3015

1

			pallet_transaction_payment::NextFeeMultiplier::<Runtime>::set(multiplier);

3016

1

			let actual_fee = TransactionPayment::compute_fee(

3017

1

				extrinsic_len,

3018

1

				&frame_support::dispatch::DispatchInfo {

3019

1

					class: DispatchClass::Normal,

3020

1

					pays_fee: frame_support::dispatch::Pays::Yes,

3021

1

					call_weight: extrinsic_weight,

3022

1

					extension_weight: Weight::zero(),

3023

1

},

3024

1

				tip,

3025

1

);

3026

1

3027

1

			assert_eq!(

3028

				expected_fee,

3029

				actual_fee,

3030

				"The actual fee did not match the expected fee, diff {}",

3031

				actual_fee - expected_fee

3032

);

3033

1

});

3034

1

3035

3036

	#[test]

3037

1

	fn test_min_gas_price_is_deterministic() {

3038

1

		let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

3039

1

			.build_storage()

3040

1

			.unwrap()

3041

1

			.into();

3042

1

		t.execute_with(|| {

3043

1

			let multiplier = sp_runtime::FixedU128::from_u32(1);

3044

1

			pallet_transaction_payment::NextFeeMultiplier::<Runtime>::set(multiplier);

3045

1

			let actual = TransactionPaymentAsGasPrice::min_gas_price().0;

3046

1

			let expected: U256 = multiplier

3047

1

				.saturating_mul_int(currency::WEIGHT_FEE.saturating_mul(WEIGHT_PER_GAS as u128))

3048

1

				.into();

3049

1

3050

1

			assert_eq!(expected, actual);

3051

1

});

3052

1

3053

3054

	#[test]

3055

1

	fn test_min_gas_price_has_no_precision_loss_from_saturating_mul_int() {

3056

1

		let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

3057

1

			.build_storage()

3058

1

			.unwrap()

3059

1

			.into();

3060

1

		t.execute_with(|| {

3061

1

			let multiplier_1 = sp_runtime::FixedU128::from_float(0.999593900000000000);

3062

1

			let multiplier_2 = sp_runtime::FixedU128::from_float(0.999593200000000000);

3063

1

3064

1

			pallet_transaction_payment::NextFeeMultiplier::<Runtime>::set(multiplier_1);

3065

1

			let a = TransactionPaymentAsGasPrice::min_gas_price();

3066

1

			pallet_transaction_payment::NextFeeMultiplier::<Runtime>::set(multiplier_2);

3067

1

			let b = TransactionPaymentAsGasPrice::min_gas_price();

3068

1

3069

1

			assert_ne!(

3070

				a, b,

3071

				"both gas prices were equal, unexpected precision loss incurred"

3072

);

3073

1

});

3074

1

3075

3076

	#[test]

3077

1

	fn test_fee_scenarios() {

3078

		use sp_runtime::FixedU128;

3079

1

		let mut t: sp_io::TestExternalities = frame_system::GenesisConfig::<Runtime>::default()

3080

1

			.build_storage()

3081

1

			.unwrap()

3082

1

			.into();

3083

1

		t.execute_with(|| {

3084

1

			let weight_fee_per_gas = (currency::WEIGHT_FEE).saturating_mul(WEIGHT_PER_GAS as u128);

3085

12

			let sim = |start_gas_price: u128, fullness: Perbill, num_blocks: u64| -> U256 {

3086

12

				let start_multiplier =

3087

12

					FixedU128::from_rational(start_gas_price, weight_fee_per_gas);

3088

12

				pallet_transaction_payment::NextFeeMultiplier::<Runtime>::set(start_multiplier);

3089

12

3090

12

				let block_weight = NORMAL_WEIGHT * fullness;

3091

3092

60004

				for i in 0..num_blocks {

3093

60004

					System::set_block_number(i as u32);

3094

60004

					System::set_block_consumed_resources(block_weight, 0);

3095

60004

					TransactionPayment::on_finalize(i as u32);

3096

60004

3097

3098

12

				TransactionPaymentAsGasPrice::min_gas_price().0

3099

12

};

3100

3101

			// The expected values are the ones observed during test execution,

3102

			// they are expected to change when parameters that influence

3103

			// the fee calculation are changed, and should be updated accordingly.

3104

			// If a test fails when nothing specific to fees has changed,

3105

			// it may indicate an unexpected collateral effect and should be investigated

3106

3107

1

			assert_eq!(

3108

1

				sim(100_000_000, Perbill::from_percent(0), 1),

3109

1

				U256::from(312_500_000u128), // lower bound enforced

3110

1

);

3111

1

			assert_eq!(

3112

1

				sim(100_000_000, Perbill::from_percent(25), 1),

3113

1

				U256::from(312_500_000u128),

3114

1

);

3115

1

			assert_eq!(

3116

1

				sim(100_000_000, Perbill::from_percent(50), 1),

3117

1

				U256::from(312_687_556u128), // slightly higher than lower bound

3118

1

);

3119

1

			assert_eq!(

3120

1

				sim(100_000_000, Perbill::from_percent(100), 1),

3121

1

				U256::from(313_313_556u128),

3122

1

);

3123

3124

			// 1 "real" hour (at 6-second blocks)

3125

1

			assert_eq!(

3126

1

				sim(100_000_000, Perbill::from_percent(0), 600),

3127

1

				U256::from(312_500_000u128),

3128

1

);

3129

1

			assert_eq!(

3130

1

				sim(100_000_000, Perbill::from_percent(25), 600),

3131

1

				U256::from(312_500_000u128),

3132

1

);

3133

1

			assert_eq!(

3134

1

				sim(100_000_000, Perbill::from_percent(50), 600),

3135

1

				U256::from(447_915_432u128),

3136

1

);

3137

1

			assert_eq!(

3138

1

				sim(100_000_000, Perbill::from_percent(100), 600),

3139

1

				U256::from(1_487_129_030u128),

3140

1

);

3141

3142

			// 1 "real" day (at 6-second blocks)

3143

1

			assert_eq!(

3144

1

				sim(100_000_000, Perbill::from_percent(0), 14400),

3145

1

				U256::from(312_500_000u128), // lower bound enforced

3146

1

);

3147

1

			assert_eq!(

3148

1

				sim(100_000_000, Perbill::from_percent(25), 14400),

3149

1

				U256::from(312_500_000u128),

3150

1

);

3151

1

			assert_eq!(

3152

1

				sim(100_000_000, Perbill::from_percent(50), 14400),

3153

1

				U256::from(1_766_664_654_709u128),

3154

1

);

3155

1

			assert_eq!(

3156

1

				sim(100_000_000, Perbill::from_percent(100), 14400),

3157

1

				U256::from(31_250_000_000_000u128), // upper bound enforced

3158

1

);

3159

1

});

3160

1

3161