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::traits::fungible::Inspect;

29

use frame_support::{

30

	assert_noop, assert_ok,

31

	dispatch::DispatchClass,

32

	traits::{

33

		Currency as CurrencyT, EnsureOrigin, OnInitialize, PalletInfo, StorageInfo,

34

		StorageInfoTrait,

35

},

36

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

37

	StorageHasher, Twox128,

38

};

39

use moonbeam_xcm_benchmarks::weights::XcmWeight;

40

use moonkit_xcm_primitives::AccountIdAssetIdConversion;

41

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

42

use moonriver_runtime::runtime_params::dynamic_params;

43

use moonriver_runtime::{

44

	asset_config::ForeignAssetInstance,

45

	xcm_config::{CurrencyId, SelfReserve},

46

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

47

	PolkadotXcm, Precompiles, RuntimeBlockWeights, TransactionPayment,

48

	TransactionPaymentAsGasPrice, Treasury, TreasuryCouncilCollective, XcmTransactor,

49

	FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX, WEEKS,

50

};

51

use nimbus_primitives::NimbusId;

52

use pallet_evm::PrecompileSet;

53

use pallet_evm_precompileset_assets_erc20::{SELECTOR_LOG_APPROVAL, SELECTOR_LOG_TRANSFER};

54

use pallet_transaction_payment::Multiplier;

55

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

56

use parity_scale_codec::Encode;

57

use polkadot_parachain::primitives::Sibling;

58

use precompile_utils::{

59

	precompile_set::{is_precompile_or_fail, IsActivePrecompile},

60

	prelude::*,

61

	testing::*,

62

};

63

use sha3::{Digest, Keccak256};

64

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

65

use sp_runtime::{

66

	traits::{Convert, Dispatchable},

67

	BuildStorage, DispatchError, ModuleError,

68

};

69

use std::str::from_utf8;

70

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

71

use xcm::{VersionedAssets, VersionedLocation};

72

use xcm_builder::{ParentIsPreset, SiblingParachainConvertsVia};

73

use xcm_executor::traits::ConvertLocation;

74

use xcm_primitives::split_location_into_chain_part_and_beneficiary;

75

76

type BatchPCall = pallet_evm_precompile_batch::BatchPrecompileCall<Runtime>;

77

type CrowdloanRewardsPCall =

78

	pallet_evm_precompile_crowdloan_rewards::CrowdloanRewardsPrecompileCall<Runtime>;

79

type XcmUtilsPCall = pallet_evm_precompile_xcm_utils::XcmUtilsPrecompileCall<

80

	Runtime,

81

	moonriver_runtime::xcm_config::XcmExecutorConfig,

82

>;

83

type XtokensPCall = pallet_evm_precompile_xtokens::XtokensPrecompileCall<Runtime>;

84

type ForeignAssetsPCall = pallet_evm_precompileset_assets_erc20::Erc20AssetsPrecompileSetCall<

85

	Runtime,

86

	ForeignAssetInstance,

87

>;

88

type XcmTransactorV2PCall =

89

	pallet_evm_precompile_xcm_transactor::v2::XcmTransactorPrecompileV2Call<Runtime>;

90

91

const BASE_FEE_GENESIS: u128 = 100 * GIGAWEI;

92

93

3

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

94

3

	Asset {

95

3

		id: AssetId(

96

3

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

97

3

				currency_id,

98

3

99

3

			.unwrap(),

100

3

),

101

3

		fun: Fungibility::Fungible(amount),

102

3

103

3

104

105

#[test]

106

1

fn xcmp_queue_controller_origin_is_root() {

107

1

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

108

1

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

109

1

	assert_ok!(

110

1

		<moonriver_runtime::Runtime as cumulus_pallet_xcmp_queue::Config

111

1

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

112

1

);

113

1

114

115

#[test]

116

1

fn verify_pallet_prefixes() {

117

30

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

118

30

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

119

30

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

120

30

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

121

30

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

122

30

		// expand/storage.rs#L389-L401

123

30

		assert_eq!(

124

30

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

125

30

			Some(name)

126

30

);

127

30

128

1

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

129

1

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

130

1

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

131

1

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

132

1

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

133

1

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

134

1

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

135

1

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

136

1

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

137

1

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

138

1

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

139

1

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

140

1

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

141

1

	is_pallet_prefix::<moonriver_runtime::OpenTechCommitteeCollective>(

142

1

		"OpenTechCommitteeCollective",

143

1

);

144

1

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

145

1

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

146

1

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

147

1

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

148

1

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

149

1

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

150

1

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

151

1

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

152

1

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

153

1

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

154

1

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

155

1

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

156

1

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

157

1

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

158

1

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

159

1

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

160

1

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

161

1

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

162

1

163

14

	let prefix = |pallet_name, storage_name| {

164

14

		let mut res = [0u8; 32];

165

14

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

166

14

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

167

14

		res.to_vec()

168

14

};

169

1

	assert_eq!(

170

1

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

171

1

		vec![

172

1

			StorageInfo {

173

1

				pallet_name: b"Timestamp".to_vec(),

174

1

				storage_name: b"Now".to_vec(),

175

1

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

176

1

				max_values: Some(1),

177

1

				max_size: Some(8),

178

1

},

179

1

			StorageInfo {

180

1

				pallet_name: b"Timestamp".to_vec(),

181

1

				storage_name: b"DidUpdate".to_vec(),

182

1

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

183

1

				max_values: Some(1),

184

1

				max_size: Some(1),

185

1

186

1

187

1

);

188

1

	assert_eq!(

189

1

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

190

1

		vec![

191

1

			StorageInfo {

192

1

				pallet_name: b"Balances".to_vec(),

193

1

				storage_name: b"TotalIssuance".to_vec(),

194

1

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

195

1

				max_values: Some(1),

196

1

				max_size: Some(16),

197

1

},

198

1

			StorageInfo {

199

1

				pallet_name: b"Balances".to_vec(),

200

1

				storage_name: b"InactiveIssuance".to_vec(),

201

1

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

202

1

				max_values: Some(1),

203

1

				max_size: Some(16),

204

1

},

205

1

			StorageInfo {

206

1

				pallet_name: b"Balances".to_vec(),

207

1

				storage_name: b"Account".to_vec(),

208

1

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

209

1

				max_values: None,

210

1

				max_size: Some(100),

211

1

},

212

1

			StorageInfo {

213

1

				pallet_name: b"Balances".to_vec(),

214

1

				storage_name: b"Locks".to_vec(),

215

1

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

216

1

				max_values: None,

217

1

				max_size: Some(1287),

218

1

},

219

1

			StorageInfo {

220

1

				pallet_name: b"Balances".to_vec(),

221

1

				storage_name: b"Reserves".to_vec(),

222

1

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

223

1

				max_values: None,

224

1

				max_size: Some(1037),

225

1

},

226

1

			StorageInfo {

227

1

				pallet_name: b"Balances".to_vec(),

228

1

				storage_name: b"Holds".to_vec(),

229

1

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

230

1

				max_values: None,

231

1

				max_size: Some(55),

232

1

},

233

1

			StorageInfo {

234

1

				pallet_name: b"Balances".to_vec(),

235

1

				storage_name: b"Freezes".to_vec(),

236

1

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

237

1

				max_values: None,

238

1

				max_size: Some(37),

239

1

},

240

1

241

1

);

242

1

	assert_eq!(

243

1

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

244

1

		vec![

245

1

			StorageInfo {

246

1

				pallet_name: b"Proxy".to_vec(),

247

1

				storage_name: b"Proxies".to_vec(),

248

1

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

249

1

				max_values: None,

250

1

				max_size: Some(845),

251

1

},

252

1

			StorageInfo {

253

1

				pallet_name: b"Proxy".to_vec(),

254

1

				storage_name: b"Announcements".to_vec(),

255

1

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

256

1

				max_values: None,

257

1

				max_size: Some(1837),

258

1

259

1

260

1

);

261

1

	assert_eq!(

262

1

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

263

1

		vec![StorageInfo {

264

1

			pallet_name: b"MaintenanceMode".to_vec(),

265

1

			storage_name: b"MaintenanceMode".to_vec(),

266

1

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

267

1

			max_values: Some(1),

268

1

			max_size: None,

269

1

},]

270

1

);

271

1

	assert_eq!(

272

1

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

273

1

		vec![

274

1

			StorageInfo {

275

1

				pallet_name: b"RelayStorageRoots".to_vec(),

276

1

				storage_name: b"RelayStorageRoot".to_vec(),

277

1

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

278

1

				max_values: None,

279

1

				max_size: Some(44),

280

1

},

281

1

			StorageInfo {

282

1

				pallet_name: b"RelayStorageRoots".to_vec(),

283

1

				storage_name: b"RelayStorageRootKeys".to_vec(),

284

1

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

285

1

				max_values: Some(1),

286

1

				max_size: Some(121),

287

1

},

288

1

289

1

);

290

1

291

292

#[test]

293

1

fn test_collectives_storage_item_prefixes() {

294

6

	for StorageInfo { pallet_name, .. } in

295

7

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

296

297

6

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

298

299

300

6

	for StorageInfo { pallet_name, .. } in

301

7

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

302

303

6

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

304

305

1

306

307

#[test]

308

1

fn collective_set_members_root_origin_works() {

309

1

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

310

1

		// TreasuryCouncilCollective

311

1

		assert_ok!(TreasuryCouncilCollective::set_members(

312

1

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

313

1

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

314

1

			Some(AccountId::from(ALICE)),

315

1

316

1

));

317

		// OpenTechCommitteeCollective

318

1

		assert_ok!(OpenTechCommitteeCollective::set_members(

319

1

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

320

1

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

321

1

			Some(AccountId::from(ALICE)),

322

1

323

1

));

324

1

});

325

1

326

327

#[test]

328

1

fn collective_set_members_general_admin_origin_works() {

329

1

	use moonriver_runtime::{

330

1

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

331

1

};

332

1

333

1

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

334

1

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

335

1

		let alice = AccountId::from(ALICE);

336

1

337

1

		// TreasuryCouncilCollective

338

1

		let _ = Utility::dispatch_as(

339

1

			root_caller.clone(),

340

1

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

341

1

			Box::new(

342

1

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

343

1

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

344

1

					prime: Some(alice),

345

1

					old_count: 2,

346

1

347

1

				.into(),

348

1

),

349

1

);

350

1

		// OpenTechCommitteeCollective

351

1

		let _ = Utility::dispatch_as(

352

1

			root_caller,

353

1

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

354

1

			Box::new(

355

1

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

356

1

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

357

1

					prime: Some(alice),

358

1

					old_count: 2,

359

1

360

1

				.into(),

361

1

),

362

1

);

363

1

364

1

		assert_eq!(

365

1

			System::events()

366

1

				.into_iter()

367

2

				.filter_map(|r| {

368

2

					match r.event {

369

2

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

370

2

							if result.is_ok() =>

371

2

372

2

							Some(true)

373

374

						_ => None,

375

376

2

})

377

1

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

378

1

				.len(),

379

1

380

1

381

1

});

382

1

383

384

#[test]

385

1

fn collective_set_members_signed_origin_does_not_work() {

386

1

	let alice = AccountId::from(ALICE);

387

1

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

388

1

		// TreasuryCouncilCollective

389

1

		assert!(TreasuryCouncilCollective::set_members(

390

1

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

391

1

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

392

1

			Some(AccountId::from(ALICE)),

393

1

394

1

395

1

		.is_err());

396

		// OpenTechCommitteeCollective

397

1

		assert!(OpenTechCommitteeCollective::set_members(

398

1

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

399

1

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

400

1

			Some(AccountId::from(ALICE)),

401

1

402

1

403

1

		.is_err());

404

1

});

405

1

406

407

#[test]

408

1

fn verify_pallet_indices() {

409

32

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

410

32

		assert_eq!(

411

32

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

412

32

			Some(index)

413

32

);

414

32

415

1

	// System support

416

1

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

417

1

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

418

1

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

419

1

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

420

1

	// Monetary

421

1

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

422

1

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

423

1

	// Consensus support

424

1

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

425

1

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

426

1

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

427

1

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

428

1

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

429

1

	// Handy utilities

430

1

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

431

1

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

432

1

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

433

1

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

434

1

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

435

1

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

436

1

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

437

1

	// Ethereum compatibility

438

1

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

439

1

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

440

1

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

441

1

	// Governance

442

1

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

443

1

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

444

1

	// Council

445

1

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

446

1

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

447

1

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

448

1

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

449

1

	// Treasury

450

1

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

451

1

	// Crowdloan

452

1

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

453

1

	// XCM Stuff

454

1

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

455

1

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

456

1

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

457

1

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

458

1

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

459

1

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

460

1

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

461

1

462

463

#[test]

464

1

fn verify_reserved_indices() {

465

1

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

466

1

		.build_storage()

467

1

		.unwrap()

468

1

		.into();

469

1

470

1

	t.execute_with(|| {

471

1

		use frame_metadata::*;

472

1

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

473

1

		let metadata = match metadata.1 {

474

1

			RuntimeMetadata::V14(metadata) => metadata,

475

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

476

};

477

		// 40: Sudo

478

		// 53: BaseFee

479

		// 108: pallet_assets::<Instance1>

480

1

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

481

1

		let existing = metadata

482

1

			.pallets

483

1

			.iter()

484

49

			.map(|p| p.index)

485

1

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

486

3

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

487

1

});

488

1

489

490

#[test]

491

1

fn verify_proxy_type_indices() {

492

1

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

493

1

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

494

1

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

495

1

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

496

1

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

497

1

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

498

1

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

499

1

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

500

1

501

502

#[test]

503

1

fn join_collator_candidates() {

504

1

	ExtBuilder::default()

505

1

		.with_balances(vec![

506

1

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

507

1

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

508

1

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

509

1

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

510

1

])

511

1

		.with_collators(vec![

512

1

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

513

1

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

514

1

])

515

1

		.with_delegations(vec![

516

1

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

517

1

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

518

1

])

519

1

		.build()

520

1

		.execute_with(|| {

521

1

			assert_noop!(

522

1

				ParachainStaking::join_candidates(

523

1

					origin_of(AccountId::from(ALICE)),

524

1

					10_000 * MOVR,

525

1

					2u32

526

1

),

527

1

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

528

1

);

529

1

			assert_noop!(

530

1

				ParachainStaking::join_candidates(

531

1

					origin_of(AccountId::from(CHARLIE)),

532

1

					10_000 * MOVR,

533

1

					2u32

534

1

),

535

1

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

536

1

);

537

1

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

538

1

			assert_ok!(ParachainStaking::join_candidates(

539

1

				origin_of(AccountId::from(DAVE)),

540

1

				10_000 * MOVR,

541

1

				2u32

542

1

));

543

1

			assert_eq!(

544

1

				last_event(),

545

1

				RuntimeEvent::ParachainStaking(

546

1

					pallet_parachain_staking::Event::JoinedCollatorCandidates {

547

1

						account: AccountId::from(DAVE),

548

1

						amount_locked: 10_000 * MOVR,

549

1

						new_total_amt_locked: 30_100 * MOVR

550

1

551

1

552

1

);

553

1

			let candidates = ParachainStaking::candidate_pool();

554

1

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

555

1

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

556

1

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

557

1

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

558

1

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

559

1

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

560

1

});

561

1

562

563

#[test]

564

1

fn transfer_through_evm_to_stake() {

565

1

	ExtBuilder::default()

566

1

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

567

1

		.build()

568

1

		.execute_with(|| {

569

1

			// Charlie has no balance => fails to stake

570

1

			assert_noop!(

571

1

				ParachainStaking::join_candidates(

572

1

					origin_of(AccountId::from(CHARLIE)),

573

1

					10_000 * MOVR,

574

1

					2u32

575

1

),

576

1

				DispatchError::Module(ModuleError {

577

1

					index: 20,

578

1

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

579

1

					message: Some("InsufficientBalance")

580

1

})

581

1

);

582

			// Alice transfer from free balance 20000 MOVR to Bob

583

1

			assert_ok!(Balances::transfer_allow_death(

584

1

				origin_of(AccountId::from(ALICE)),

585

1

				AccountId::from(BOB),

586

1

				20_000 * MOVR,

587

1

));

588

1

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

589

590

1

			let gas_limit = 100000u64;

591

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

592

1

			// Bob transfers 10000 MOVR to Charlie via EVM

593

1

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

594

1

				source: H160::from(BOB),

595

1

				target: H160::from(CHARLIE),

596

1

				input: vec![],

597

1

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

598

1

				gas_limit,

599

1

				max_fee_per_gas: gas_price,

600

1

				max_priority_fee_per_gas: None,

601

1

				nonce: None,

602

1

				access_list: Vec::new(),

603

1

})

604

1

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

605

1

			assert_eq!(

606

1

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

607

1

				10_000 * MOVR,

608

1

);

609

610

			// Charlie can stake now

611

1

			assert_ok!(ParachainStaking::join_candidates(

612

1

				origin_of(AccountId::from(CHARLIE)),

613

1

				10_000 * MOVR,

614

1

				2u32,

615

1

			),);

616

1

			let candidates = ParachainStaking::candidate_pool();

617

1

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

618

1

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

619

1

});

620

1

621

622

#[test]

623

1

fn reward_block_authors() {

624

1

	ExtBuilder::default()

625

1

		.with_balances(vec![

626

1

			// Alice gets 100 extra tokens for her mapping deposit

627

1

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

628

1

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

629

1

])

630

1

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

631

1

		.with_delegations(vec![(

632

1

			AccountId::from(BOB),

633

1

			AccountId::from(ALICE),

634

1

			500 * MOVR,

635

1

)])

636

1

		.with_mappings(vec![(

637

1

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

638

1

			AccountId::from(ALICE),

639

1

)])

640

1

		.build()

641

1

		.execute_with(|| {

642

1

			increase_last_relay_slot_number(1);

643

1

644

1

			// Just before round 3

645

1

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

646

1

647

1

			// no rewards doled out yet

648

1

			assert_eq!(

649

1

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

650

1

				10_100 * MOVR,

651

1

);

652

1

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

653

1

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

654

1

655

1

			// rewards minted and distributed

656

1

			assert_eq!(

657

1

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

658

1

				11547666666208000000000,

659

1

);

660

1

			assert_eq!(

661

1

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

662

1

				9557333332588000000000,

663

1

);

664

1

});

665

1

666

667

#[test]

668

1

fn reward_block_authors_with_parachain_bond_reserved() {

669

1

	ExtBuilder::default()

670

1

		.with_balances(vec![

671

1

			// Alice gets 100 extra tokens for her mapping deposit

672

1

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

673

1

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

674

1

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

675

1

])

676

1

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

677

1

		.with_delegations(vec![(

678

1

			AccountId::from(BOB),

679

1

			AccountId::from(ALICE),

680

1

			500 * MOVR,

681

1

)])

682

1

		.with_mappings(vec![(

683

1

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

684

1

			AccountId::from(ALICE),

685

1

)])

686

1

		.build()

687

1

		.execute_with(|| {

688

1

			increase_last_relay_slot_number(1);

689

1

			assert_ok!(ParachainStaking::set_parachain_bond_account(

690

1

				root_origin(),

691

1

				AccountId::from(CHARLIE),

692

1

			),);

693

694

			// Stop just before round 2

695

1

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

696

1

697

1

			// no collator rewards doled out yet

698

1

			assert_eq!(

699

1

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

700

1

				10_100 * MOVR,

701

1

);

702

1

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

703

704

			// Go to round 2

705

1

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

706

1

707

1

			// 30% reserved for parachain bond

708

1

			assert_eq!(

709

1

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

710

1

				452515000000000000000,

711

1

);

712

713

			// Go to round 3

714

1

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

715

1

716

1

			// rewards minted and distributed

717

1

			assert_eq!(

718

1

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

719

1

				11117700475903800000000,

720

1

);

721

1

			assert_eq!(

722

1

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

723

1

				9535834523343675000000,

724

1

);

725

			// 30% reserved for parachain bond again

726

1

			assert_eq!(

727

1

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

728

1

				910802725000000000000,

729

1

);

730

1

});

731

1

732

733

#[test]

734

1

fn initialize_crowdloan_addresses_with_batch_and_pay() {

735

1

	ExtBuilder::default()

736

1

		.with_balances(vec![

737

1

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

738

1

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

739

1

])

740

1

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

741

1

		.with_mappings(vec![(

742

1

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

743

1

			AccountId::from(ALICE),

744

1

)])

745

1

		.with_crowdloan_fund(3_000_000 * MOVR)

746

1

		.build()

747

1

		.execute_with(|| {

748

1

			// set parachain inherent data

749

1

			set_parachain_inherent_data();

750

1

			let init_block = CrowdloanRewards::init_vesting_block();

751

1

			// This matches the previous vesting

752

1

			let end_block = init_block + 48 * WEEKS;

753

1

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

754

1

			assert_ok!(

755

1

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

756

1

					calls: vec![

757

1

						RuntimeCall::CrowdloanRewards(

758

1

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

759

1

								rewards: vec![(

760

1

									[4u8; 32].into(),

761

1

									Some(AccountId::from(CHARLIE)),

762

1

									1_500_000 * MOVR

763

1

)]

764

1

765

1

),

766

1

						RuntimeCall::CrowdloanRewards(

767

1

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

768

1

								rewards: vec![(

769

1

									[5u8; 32].into(),

770

1

									Some(AccountId::from(DAVE)),

771

1

									1_500_000 * MOVR

772

1

)]

773

1

774

1

),

775

1

						RuntimeCall::CrowdloanRewards(

776

1

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

777

1

								lease_ending_block: end_block

778

1

779

1

780

1

781

1

})

782

1

				.dispatch(root_origin())

783

1

);

784

			// 30 percent initial payout

785

1

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

786

			// 30 percent initial payout

787

1

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

788

1

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

789

1

			assert_eq!(last_event(), expected);

790

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

791

1

			assert_ok!(

792

1

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

793

1

					calls: vec![RuntimeCall::CrowdloanRewards(

794

1

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

795

1

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

796

1

797

1

)]

798

1

})

799

1

				.dispatch(root_origin())

800

1

);

801

1

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

802

1

				index: 0,

803

1

				error: DispatchError::Module(ModuleError {

804

1

					index: 90,

805

1

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

806

1

					message: None,

807

1

}),

808

1

});

809

1

			assert_eq!(last_event(), expected_fail);

810

			// Claim 1 block.

811

1

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

812

1

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

813

814

1

			let vesting_period = 48 * WEEKS as u128;

815

1

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

816

1

817

1

			assert_eq!(

818

1

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

819

1

					.unwrap()

820

1

					.claimed_reward,

821

1

				(450_000 * MOVR) + per_block

822

1

);

823

1

			assert_eq!(

824

1

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

825

1

					.unwrap()

826

1

					.claimed_reward,

827

1

				(450_000 * MOVR) + per_block

828

1

);

829

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

830

1

			assert_eq!(

831

1

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

832

1

				(450_000 * MOVR) + per_block

833

1

);

834

1

			assert_eq!(

835

1

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

836

1

				(450_000 * MOVR) + per_block

837

1

);

838

1

			assert_noop!(

839

1

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

840

1

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

841

1

);

842

1

});

843

1

844

845

#[test]

846

1

fn initialize_crowdloan_address_and_change_with_relay_key_sig() {

847

1

	ExtBuilder::default()

848

1

		.with_balances(vec![

849

1

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

850

1

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

851

1

])

852

1

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

853

1

		.with_mappings(vec![(

854

1

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

855

1

			AccountId::from(ALICE),

856

1

)])

857

1

		.with_crowdloan_fund(3_000_000 * MOVR)

858

1

		.build()

859

1

		.execute_with(|| {

860

1

			// set parachain inherent data

861

1

			set_parachain_inherent_data();

862

1

			let init_block = CrowdloanRewards::init_vesting_block();

863

1

			// This matches the previous vesting

864

1

			let end_block = init_block + 4 * WEEKS;

865

1

866

1

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

867

1

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

868

1

869

1

			let public1 = pair1.public();

870

1

			let public2 = pair2.public();

871

1

872

1

			// signature:

873

1

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

874

1

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

875

1

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

876

1

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

877

1

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

878

1

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

879

1

			let signature1 = pair1.sign(&message);

880

1

			let signature2 = pair2.sign(&message);

881

1

882

1

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

883

1

			assert_ok!(

884

1

				// two relay accounts pointing at the same reward account

885

1

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

886

1

					calls: vec![

887

1

						RuntimeCall::CrowdloanRewards(

888

1

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

889

1

								rewards: vec![(

890

1

									public1.into(),

891

1

									Some(AccountId::from(CHARLIE)),

892

1

									1_500_000 * MOVR

893

1

)]

894

1

895

1

),

896

1

						RuntimeCall::CrowdloanRewards(

897

1

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

898

1

								rewards: vec![(

899

1

									public2.into(),

900

1

									Some(AccountId::from(CHARLIE)),

901

1

									1_500_000 * MOVR

902

1

)]

903

1

904

1

),

905

1

						RuntimeCall::CrowdloanRewards(

906

1

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

907

1

								lease_ending_block: end_block

908

1

909

1

910

1

911

1

})

912

1

				.dispatch(root_origin())

913

1

);

914

			// 30 percent initial payout

915

1

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

916

917

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

918

1

			assert_noop!(

919

1

				CrowdloanRewards::change_association_with_relay_keys(

920

1

					origin_of(AccountId::from(CHARLIE)),

921

1

					AccountId::from(DAVE),

922

1

					AccountId::from(CHARLIE),

923

1

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

924

1

),

925

1

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

926

1

);

927

928

			// this should be valid

929

1

			assert_ok!(CrowdloanRewards::change_association_with_relay_keys(

930

1

				origin_of(AccountId::from(CHARLIE)),

931

1

				AccountId::from(DAVE),

932

1

				AccountId::from(CHARLIE),

933

1

				vec![

934

1

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

935

1

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

936

1

937

1

));

938

939

1

			assert_eq!(

940

1

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

941

1

					.unwrap()

942

1

					.claimed_reward,

943

1

				(900_000 * MOVR)

944

1

);

945

1

});

946

1

947

948

#[test]

949

1

fn claim_via_precompile() {

950

1

	ExtBuilder::default()

951

1

		.with_balances(vec![

952

1

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

953

1

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

954

1

])

955

1

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

956

1

		.with_mappings(vec![(

957

1

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

958

1

			AccountId::from(ALICE),

959

1

)])

960

1

		.with_crowdloan_fund(3_000_000 * MOVR)

961

1

		.build()

962

1

		.execute_with(|| {

963

1

			// set parachain inherent data

964

1

			set_parachain_inherent_data();

965

1

			let init_block = CrowdloanRewards::init_vesting_block();

966

1

			// This matches the previous vesting

967

1

			let end_block = init_block + 4 * WEEKS;

968

1

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

969

1

			assert_ok!(

970

1

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

971

1

					calls: vec![

972

1

						RuntimeCall::CrowdloanRewards(

973

1

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

974

1

								rewards: vec![(

975

1

									[4u8; 32].into(),

976

1

									Some(AccountId::from(CHARLIE)),

977

1

									1_500_000 * MOVR

978

1

)]

979

1

980

1

),

981

1

						RuntimeCall::CrowdloanRewards(

982

1

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

983

1

								rewards: vec![(

984

1

									[5u8; 32].into(),

985

1

									Some(AccountId::from(DAVE)),

986

1

									1_500_000 * MOVR

987

1

)]

988

1

989

1

),

990

1

						RuntimeCall::CrowdloanRewards(

991

1

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

992

1

								lease_ending_block: end_block

993

1

994

1

995

1

996

1

})

997

1

				.dispatch(root_origin())

998

1

);

999

1000

1

			assert!(CrowdloanRewards::initialized());

1001

1002

			// 30 percent initial payout

1003

1

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

1004

			// 30 percent initial payout

1005

1

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

1006

1007

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1008

1

1009

1

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

1010

1

			let gas_limit = 100000u64;

1011

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1012

1

1013

1

			// Construct the call data (selector, amount)

1014

1

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

1015

1

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

1016

1

1017

1

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

1018

1

				source: H160::from(CHARLIE),

1019

1

				target: crowdloan_precompile_address,

1020

1

				input: call_data,

1021

1

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

1022

1

				gas_limit,

1023

1

				max_fee_per_gas: gas_price,

1024

1

				max_priority_fee_per_gas: None,

1025

1

				nonce: None, // Use the next nonce

1026

1

				access_list: Vec::new(),

1027

1

})

1028

1

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

1029

1030

1

			let vesting_period = 4 * WEEKS as u128;

1031

1

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

1032

1

1033

1

			assert_eq!(

1034

1

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

1035

1

					.unwrap()

1036

1

					.claimed_reward,

1037

1

				(450_000 * MOVR) + per_block

1038

1

);

1039

1

})

1040

1

1041

1042

#[test]

1043

1

fn is_contributor_via_precompile() {

1044

1

	ExtBuilder::default()

1045

1

		.with_balances(vec![

1046

1

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

1047

1

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

1048

1

])

1049

1

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

1050

1

		.with_mappings(vec![(

1051

1

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

1052

1

			AccountId::from(ALICE),

1053

1

)])

1054

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1055

1

		.build()

1056

1

		.execute_with(|| {

1057

1

			// set parachain inherent data

1058

1

			set_parachain_inherent_data();

1059

1

			let init_block = CrowdloanRewards::init_vesting_block();

1060

1

			// This matches the previous vesting

1061

1

			let end_block = init_block + 4 * WEEKS;

1062

1

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

1063

1

			assert_ok!(

1064

1

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

1065

1

					calls: vec![

1066

1

						RuntimeCall::CrowdloanRewards(

1067

1

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

1068

1

								rewards: vec![(

1069

1

									[4u8; 32].into(),

1070

1

									Some(AccountId::from(CHARLIE)),

1071

1

									1_500_000 * MOVR

1072

1

)]

1073

1

1074

1

),

1075

1

						RuntimeCall::CrowdloanRewards(

1076

1

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

1077

1

								rewards: vec![(

1078

1

									[5u8; 32].into(),

1079

1

									Some(AccountId::from(DAVE)),

1080

1

									1_500_000 * MOVR

1081

1

)]

1082

1

1083

1

),

1084

1

						RuntimeCall::CrowdloanRewards(

1085

1

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

1086

1

								lease_ending_block: end_block

1087

1

1088

1

1089

1

1090

1

})

1091

1

				.dispatch(root_origin())

1092

1

);

1093

1094

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1095

1

1096

1

			// Assert precompile reports Bob is not a contributor

1097

1

			Precompiles::new()

1098

1

				.prepare_test(

1099

1

					ALICE,

1100

1

					crowdloan_precompile_address,

1101

1

					CrowdloanRewardsPCall::is_contributor {

1102

1

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

1103

1

},

1104

1

1105

1

				.expect_cost(3338)

1106

1

				.expect_no_logs()

1107

1

				.execute_returns(false);

1108

1

1109

1

			// Assert precompile reports Charlie is a nominator

1110

1

			Precompiles::new()

1111

1

				.prepare_test(

1112

1

					ALICE,

1113

1

					crowdloan_precompile_address,

1114

1

					CrowdloanRewardsPCall::is_contributor {

1115

1

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

1116

1

},

1117

1

1118

1

				.expect_cost(3338)

1119

1

				.expect_no_logs()

1120

1

				.execute_returns(true);

1121

1

})

1122

1

1123

1124

#[test]

1125

1

fn reward_info_via_precompile() {

1126

1

	ExtBuilder::default()

1127

1

		.with_balances(vec![

1128

1

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

1129

1

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

1130

1

])

1131

1

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

1132

1

		.with_mappings(vec![(

1133

1

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

1134

1

			AccountId::from(ALICE),

1135

1

)])

1136

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1137

1

		.build()

1138

1

		.execute_with(|| {

1139

1

			// set parachain inherent data

1140

1

			set_parachain_inherent_data();

1141

1

			let init_block = CrowdloanRewards::init_vesting_block();

1142

1

			// This matches the previous vesting

1143

1

			let end_block = init_block + 4 * WEEKS;

1144

1

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

1145

1

			assert_ok!(

1146

1

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

1147

1

					calls: vec![

1148

1

						RuntimeCall::CrowdloanRewards(

1149

1

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

1150

1

								rewards: vec![(

1151

1

									[4u8; 32].into(),

1152

1

									Some(AccountId::from(CHARLIE)),

1153

1

									1_500_000 * MOVR

1154

1

)]

1155

1

1156

1

),

1157

1

						RuntimeCall::CrowdloanRewards(

1158

1

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

1159

1

								rewards: vec![(

1160

1

									[5u8; 32].into(),

1161

1

									Some(AccountId::from(DAVE)),

1162

1

									1_500_000 * MOVR

1163

1

)]

1164

1

1165

1

),

1166

1

						RuntimeCall::CrowdloanRewards(

1167

1

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

1168

1

								lease_ending_block: end_block

1169

1

1170

1

1171

1

1172

1

})

1173

1

				.dispatch(root_origin())

1174

1

);

1175

1176

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1177

1

1178

1

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

1179

1

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

1180

1

1181

1

			// Assert precompile reports correct Charlie reward info.

1182

1

			Precompiles::new()

1183

1

				.prepare_test(

1184

1

					ALICE,

1185

1

					crowdloan_precompile_address,

1186

1

					CrowdloanRewardsPCall::reward_info {

1187

1

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

1188

1

},

1189

1

1190

1

				.expect_cost(3338)

1191

1

				.expect_no_logs()

1192

1

				.execute_returns((expected_total, expected_claimed));

1193

1

})

1194

1

1195

1196

#[test]

1197

1

fn update_reward_address_via_precompile() {

1198

1

	ExtBuilder::default()

1199

1

		.with_balances(vec![

1200

1

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

1201

1

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

1202

1

])

1203

1

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

1204

1

		.with_mappings(vec![(

1205

1

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

1206

1

			AccountId::from(ALICE),

1207

1

)])

1208

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1209

1

		.build()

1210

1

		.execute_with(|| {

1211

1

			// set parachain inherent data

1212

1

			set_parachain_inherent_data();

1213

1

			let init_block = CrowdloanRewards::init_vesting_block();

1214

1

			// This matches the previous vesting

1215

1

			let end_block = init_block + 4 * WEEKS;

1216

1

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

1217

1

			assert_ok!(

1218

1

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

1219

1

					calls: vec![

1220

1

						RuntimeCall::CrowdloanRewards(

1221

1

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

1222

1

								rewards: vec![(

1223

1

									[4u8; 32].into(),

1224

1

									Some(AccountId::from(CHARLIE)),

1225

1

									1_500_000 * MOVR

1226

1

)]

1227

1

1228

1

),

1229

1

						RuntimeCall::CrowdloanRewards(

1230

1

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

1231

1

								rewards: vec![(

1232

1

									[5u8; 32].into(),

1233

1

									Some(AccountId::from(DAVE)),

1234

1

									1_500_000 * MOVR

1235

1

)]

1236

1

1237

1

),

1238

1

						RuntimeCall::CrowdloanRewards(

1239

1

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

1240

1

								lease_ending_block: end_block

1241

1

1242

1

1243

1

1244

1

})

1245

1

				.dispatch(root_origin())

1246

1

);

1247

1248

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1249

1

1250

1

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

1251

1

			let gas_limit = 100000u64;

1252

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1253

1

1254

1

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

1255

1

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

1256

1

			call_data[0..4]

1257

1

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

1258

1

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

1259

1

1260

1

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

1261

1

				source: H160::from(CHARLIE),

1262

1

				target: crowdloan_precompile_address,

1263

1

				input: call_data,

1264

1

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

1265

1

				gas_limit,

1266

1

				max_fee_per_gas: gas_price,

1267

1

				max_priority_fee_per_gas: None,

1268

1

				nonce: None, // Use the next nonce

1269

1

				access_list: Vec::new(),

1270

1

})

1271

1

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

1272

1273

1

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

1274

1

			assert_eq!(

1275

1

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

1276

1

					.unwrap()

1277

1

					.claimed_reward,

1278

1

				(450_000 * MOVR)

1279

1

);

1280

1

})

1281

1

1282

1283

1

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

1284

1

where

1285

1

	F: FnMut() -> (),

1286

1

1287

1

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

1288

1

		.build_storage()

1289

1

		.unwrap()

1290

1

		.into();

1291

1

	t.execute_with(|| {

1292

1

		System::set_block_consumed_resources(w, 0);

1293

1

		assertions()

1294

1

});

1295

1

1296

1297

#[test]

1298

#[rustfmt::skip]

1299

1

fn length_fee_is_sensible() {

1300

1

	use sp_runtime::testing::TestXt;

1301

1

1302

1

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

1303

1

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

1304

1

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

1305

1

		let uxt: TestXt<_, ()> = TestXt::new(call, Some((1u64, ())));

1306

1

1307

9

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

1308

9

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

1309

9

				.inclusion_fee

1310

9

				.expect("fee should be calculated")

1311

9

				.len_fee

1312

9

};

1313

1314

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

1315

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

1316

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

1317

		//                             |           |

1318

1

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

1319

1

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

1320

1

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

1321

1

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

1322

1

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

1323

1

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

1324

1

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

1325

1

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

1326

1

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

1327

1

});

1328

1

1329

1330

#[test]

1331

1

fn multiplier_can_grow_from_zero() {

1332

1

	use frame_support::traits::Get;

1333

1

1334

1

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

1335

1

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

1336

1

		* RuntimeBlockWeights::get()

1337

1

			.get(DispatchClass::Normal)

1338

1

			.max_total

1339

1

			.unwrap();

1340

1

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

1341

1

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

1342

1

	run_with_system_weight(target * 101 / 100, || {

1343

1

		let next =

1344

1

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

1345

1

		assert!(

1346

1

			next > minimum_multiplier,

1347

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

1348

			next,

1349

			minimum_multiplier

1350

);

1351

1

})

1352

1

1353

1354

#[test]

1355

1

fn ethereum_invalid_transaction() {

1356

1

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

1357

1

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

1358

1

		// on chain is rejected.

1359

1

		assert_eq!(

1360

1

			Executive::apply_extrinsic(unchecked_eth_tx(INVALID_ETH_TX)),

1361

1

			Err(

1362

1

				sp_runtime::transaction_validity::TransactionValidityError::Invalid(

1363

1

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

1364

1

1365

1

1366

1

);

1367

1

});

1368

1

1369

1370

#[test]

1371

1

fn initial_gas_fee_is_correct() {

1372

1

	use fp_evm::FeeCalculator;

1373

1

1374

1

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

1375

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1376

1

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

1377

1378

1

		assert_eq!(

1379

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1380

1

1381

1

				3_125_000_000u128.into(),

1382

1

				Weight::from_parts(41_742_000u64, 0)

1383

1

1384

1

);

1385

1

});

1386

1

1387

1388

#[test]

1389

1

fn min_gas_fee_is_correct() {

1390

1

	use fp_evm::FeeCalculator;

1391

1

	use frame_support::traits::Hooks;

1392

1

1393

1

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

1394

1

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

1395

1

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

1396

1

1397

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1398

1

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

1399

1400

1

		assert_eq!(

1401

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1402

1

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

1403

1

);

1404

1

});

1405

1

1406

1407

#[test]

1408

1

fn transfer_ed_0_substrate() {

1409

1

	ExtBuilder::default()

1410

1

		.with_balances(vec![

1411

1

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

1412

1

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

1413

1

])

1414

1

		.build()

1415

1

		.execute_with(|| {

1416

1

			// Substrate transfer

1417

1

			assert_ok!(Balances::transfer_allow_death(

1418

1

				origin_of(AccountId::from(ALICE)),

1419

1

				AccountId::from(BOB),

1420

1

				1 * MOVR,

1421

1

));

1422

			// 1 WEI is left in the account

1423

1

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

1424

1

});

1425

1

1426

1427

#[test]

1428

1

fn transfer_ed_0_evm() {

1429

1

	ExtBuilder::default()

1430

1

		.with_balances(vec![

1431

1

1432

1

				AccountId::from(ALICE),

1433

1

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

1434

1

),

1435

1

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

1436

1

])

1437

1

		.build()

1438

1

		.execute_with(|| {

1439

1

			set_parachain_inherent_data();

1440

1

			// EVM transfer

1441

1

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

1442

1

				source: H160::from(ALICE),

1443

1

				target: H160::from(BOB),

1444

1

				input: Vec::new(),

1445

1

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

1446

1

				gas_limit: 21_000u64,

1447

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1448

1

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

1449

1

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

1450

1

				access_list: Vec::new(),

1451

1

})

1452

1

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

1453

			// 1 WEI is left in the account

1454

1

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

1455

1

});

1456

1

1457

1458

#[test]

1459

1

fn refund_ed_0_evm() {

1460

1

	ExtBuilder::default()

1461

1

		.with_balances(vec![

1462

1

1463

1

				AccountId::from(ALICE),

1464

1

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

1465

1

),

1466

1

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

1467

1

])

1468

1

		.build()

1469

1

		.execute_with(|| {

1470

1

			set_parachain_inherent_data();

1471

1

			// EVM transfer that zeroes ALICE

1472

1

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

1473

1

				source: H160::from(ALICE),

1474

1

				target: H160::from(BOB),

1475

1

				input: Vec::new(),

1476

1

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

1477

1

				gas_limit: 21_777u64,

1478

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1479

1

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

1480

1

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

1481

1

				access_list: Vec::new(),

1482

1

})

1483

1

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

1484

			// ALICE is refunded

1485

1

			assert_eq!(

1486

1

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

1487

1

				777 * BASE_FEE_GENESIS + existential_deposit(),

1488

1

);

1489

1

});

1490

1

1491

1492

#[test]

1493

1

fn author_does_receive_priority_fee() {

1494

1

	ExtBuilder::default()

1495

1

		.with_balances(vec![(

1496

1

			AccountId::from(BOB),

1497

1

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

1498

1

)])

1499

1

		.build()

1500

1

		.execute_with(|| {

1501

1

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

1502

1

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

1503

1

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

1504

1

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

1505

1

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

1506

1

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

1507

1

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

1508

1

1509

1

			// EVM transfer.

1510

1

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

1511

1

				source: H160::from(BOB),

1512

1

				target: H160::from(ALICE),

1513

1

				input: Vec::new(),

1514

1

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

1515

1

				gas_limit: 21_000u64,

1516

1

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

1517

1

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

1518

1

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

1519

1

				access_list: Vec::new(),

1520

1

})

1521

1

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

1522

1523

1

			let priority_fee = 200 * GIGAWEI * 21_000;

1524

1

			// Author free balance increased by priority fee.

1525

1

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

1526

1

});

1527

1

1528

1529

#[test]

1530

1

fn total_issuance_after_evm_transaction_with_priority_fee() {

1531

1

	use fp_evm::FeeCalculator;

1532

1

	ExtBuilder::default()

1533

1

		.with_balances(vec![

1534

1

1535

1

				AccountId::from(BOB),

1536

1

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

1537

1

),

1538

1

1539

1

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

1540

1

				existential_deposit(),

1541

1

),

1542

1

])

1543

1

		.build()

1544

1

		.execute_with(|| {

1545

1

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

1546

1

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

1547

1

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

1548

1

			// EVM transfer.

1549

1

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

1550

1

				source: H160::from(BOB),

1551

1

				target: H160::from(ALICE),

1552

1

				input: Vec::new(),

1553

1

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

1554

1

				gas_limit: 21_000u64,

1555

1

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

1556

1

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

1557

1

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

1558

1

				access_list: Vec::new(),

1559

1

})

1560

1

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

1561

1562

1

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

1563

1

1564

1

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

1565

1

1566

1

			let base_fee: Balance = base_fee * 21_000;

1567

1

1568

1

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

1569

1

1570

1

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

1571

1

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

1572

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1573

1

1574

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1575

1576

1

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

1577

1

});

1578

1

1579

1580

#[test]

1581

1

fn total_issuance_after_evm_transaction_without_priority_fee() {

1582

1

	use fp_evm::FeeCalculator;

1583

1

	ExtBuilder::default()

1584

1

		.with_balances(vec![

1585

1

1586

1

				AccountId::from(BOB),

1587

1

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

1588

1

),

1589

1

1590

1

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

1591

1

				existential_deposit(),

1592

1

),

1593

1

])

1594

1

		.build()

1595

1

		.execute_with(|| {

1596

1

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

1597

1

			// EVM transfer.

1598

1

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

1599

1

				source: H160::from(BOB),

1600

1

				target: H160::from(ALICE),

1601

1

				input: Vec::new(),

1602

1

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

1603

1

				gas_limit: 21_000u64,

1604

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1605

1

				max_priority_fee_per_gas: None,

1606

1

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

1607

1

				access_list: Vec::new(),

1608

1

})

1609

1

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

1610

1611

1

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

1612

1

1613

1

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

1614

1

1615

1

			let base_fee: Balance = base_fee * 21_000;

1616

1

1617

1

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

1618

1

1619

1

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

1620

1

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

1621

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1622

1

1623

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1624

1625

1

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

1626

1

});

1627

1

1628

1629

#[test]

1630

1

fn root_can_change_default_xcm_vers() {

1631

1

	ExtBuilder::default()

1632

1

		.with_balances(vec![

1633

1

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

1634

1

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

1635

1

])

1636

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1637

1

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

1638

1

			metadata: AssetRegistrarMetadata {

1639

1

				name: b"RelayToken".to_vec(),

1640

1

				symbol: b"Relay".to_vec(),

1641

1

				decimals: 12,

1642

1

				is_frozen: false,

1643

1

},

1644

1

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

1645

1

			is_sufficient: true,

1646

1

}])

1647

1

		.build()

1648

1

		.execute_with(|| {

1649

1

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

1650

1

			let dest = Location {

1651

1

				parents: 1,

1652

1

				interior: [AccountId32 {

1653

1

					network: None,

1654

1

					id: [1u8; 32],

1655

1

}]

1656

1

				.into(),

1657

1

};

1658

1

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

1659

1

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

1660

1

			let (chain_part, beneficiary) =

1661

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

1662

1

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

1663

1

			// know with which version to send

1664

1

			assert_noop!(

1665

1

				PolkadotXcm::transfer_assets(

1666

1

					origin_of(AccountId::from(ALICE)),

1667

1

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

1668

1

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

1669

1

					Box::new(VersionedAssets::V4(asset.clone().into())),

1670

1

0,

1671

1

					WeightLimit::Limited(4000000000.into())

1672

1

),

1673

1

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

1674

1

);

1675

1676

			// Root sets the defaultXcm

1677

1

			assert_ok!(PolkadotXcm::force_default_xcm_version(

1678

1

				root_origin(),

1679

1

				Some(3)

1680

1

));

1681

1682

			// Now transferring does not fail

1683

1

			assert_ok!(PolkadotXcm::transfer_assets(

1684

1

				origin_of(AccountId::from(ALICE)),

1685

1

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

1686

1

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

1687

1

				Box::new(VersionedAssets::V4(asset.clone().into())),

1688

1

0,

1689

1

				WeightLimit::Limited(4000000000.into())

1690

1

));

1691

1

})

1692

1

1693

1694

#[test]

1695

1

fn asset_can_be_registered() {

1696

1

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

1697

1

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

1698

1

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

1699

1

		let asset_metadata = AssetRegistrarMetadata {

1700

1

			name: b"RelayToken".to_vec(),

1701

1

			symbol: b"Relay".to_vec(),

1702

1

			decimals: 12,

1703

1

			is_frozen: false,

1704

1

};

1705

1

		assert_ok!(AssetManager::register_foreign_asset(

1706

1

			moonriver_runtime::RuntimeOrigin::root(),

1707

1

			source_location,

1708

1

			asset_metadata,

1709

1

			1u128,

1710

1

			true

1711

1

));

1712

1

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

1713

1

});

1714

1

1715

1716

#[test]

1717

1

fn xcm_asset_erc20_precompiles_supply_and_balance() {

1718

1

	ExtBuilder::default()

1719

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1720

1

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

1721

1

			metadata: AssetRegistrarMetadata {

1722

1

				name: b"RelayToken".to_vec(),

1723

1

				symbol: b"Relay".to_vec(),

1724

1

				decimals: 12,

1725

1

				is_frozen: false,

1726

1

},

1727

1

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

1728

1

			is_sufficient: true,

1729

1

}])

1730

1

		.with_balances(vec![

1731

1

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

1732

1

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

1733

1

])

1734

1

		.build()

1735

1

		.execute_with(|| {

1736

1

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

1737

1

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

1738

1

1739

1

			// Its address is

1740

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1741

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1742

1

				relay_asset_id,

1743

1

);

1744

1

1745

1

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

1746

1

			assert_eq!(

1747

1

				moonriver_runtime::Assets::total_supply(relay_asset_id),

1748

1

				1_000 * MOVR

1749

1

);

1750

1751

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

1752

1

			Precompiles::new()

1753

1

				.prepare_test(

1754

1

					ALICE,

1755

1

					asset_precompile_address,

1756

1

					ForeignAssetsPCall::total_supply {},

1757

1

1758

1

				.expect_cost(5007)

1759

1

				.expect_no_logs()

1760

1

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

1761

1

1762

1

			// Access balanceOf through precompile

1763

1

			Precompiles::new()

1764

1

				.prepare_test(

1765

1

					ALICE,

1766

1

					asset_precompile_address,

1767

1

					ForeignAssetsPCall::balance_of {

1768

1

						who: Address(ALICE.into()),

1769

1

},

1770

1

1771

1

				.expect_cost(5007)

1772

1

				.expect_no_logs()

1773

1

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

1774

1

});

1775

1

1776

1777

#[test]

1778

1

fn xcm_asset_erc20_precompiles_transfer() {

1779

1

	ExtBuilder::default()

1780

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1781

1

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

1782

1

			metadata: AssetRegistrarMetadata {

1783

1

				name: b"RelayToken".to_vec(),

1784

1

				symbol: b"Relay".to_vec(),

1785

1

				decimals: 12,

1786

1

				is_frozen: false,

1787

1

},

1788

1

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

1789

1

			is_sufficient: true,

1790

1

}])

1791

1

		.with_balances(vec![

1792

1

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

1793

1

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

1794

1

])

1795

1

		.build()

1796

1

		.execute_with(|| {

1797

1

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

1798

1

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

1799

1

1800

1

			// Its address is

1801

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1802

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1803

1

				relay_asset_id,

1804

1

);

1805

1

1806

1

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

1807

1

			Precompiles::new()

1808

1

				.prepare_test(

1809

1

					ALICE,

1810

1

					asset_precompile_address,

1811

1

					ForeignAssetsPCall::transfer {

1812

1

						to: Address(BOB.into()),

1813

1

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

1814

1

},

1815

1

1816

1

				.expect_cost(26695)

1817

1

				.expect_log(log3(

1818

1

					asset_precompile_address,

1819

1

					SELECTOR_LOG_TRANSFER,

1820

1

					H160::from(ALICE),

1821

1

					H160::from(BOB),

1822

1

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

1823

1

))

1824

1

				.execute_returns(true);

1825

1

1826

1

			// Make sure BOB has 400 MOVR

1827

1

			Precompiles::new()

1828

1

				.prepare_test(

1829

1

					BOB,

1830

1

					asset_precompile_address,

1831

1

					ForeignAssetsPCall::balance_of {

1832

1

						who: Address(BOB.into()),

1833

1

},

1834

1

1835

1

				.expect_cost(5007)

1836

1

				.expect_no_logs()

1837

1

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

1838

1

});

1839

1

1840

1841

#[test]

1842

1

fn xcm_asset_erc20_precompiles_approve() {

1843

1

	ExtBuilder::default()

1844

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1845

1

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

1846

1

			metadata: AssetRegistrarMetadata {

1847

1

				name: b"RelayToken".to_vec(),

1848

1

				symbol: b"Relay".to_vec(),

1849

1

				decimals: 12,

1850

1

				is_frozen: false,

1851

1

},

1852

1

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

1853

1

			is_sufficient: true,

1854

1

}])

1855

1

		.with_balances(vec![

1856

1

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

1857

1

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

1858

1

])

1859

1

		.build()

1860

1

		.execute_with(|| {

1861

1

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

1862

1

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

1863

1

1864

1

			// Its address is

1865

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1866

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1867

1

				relay_asset_id,

1868

1

);

1869

1

1870

1

			// Aprove Bob for spending 400 MOVR from Alice

1871

1

			Precompiles::new()

1872

1

				.prepare_test(

1873

1

					ALICE,

1874

1

					asset_precompile_address,

1875

1

					ForeignAssetsPCall::approve {

1876

1

						spender: Address(BOB.into()),

1877

1

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

1878

1

},

1879

1

1880

1

				.expect_cost(17338)

1881

1

				.expect_log(log3(

1882

1

					asset_precompile_address,

1883

1

					SELECTOR_LOG_APPROVAL,

1884

1

					H160::from(ALICE),

1885

1

					H160::from(BOB),

1886

1

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

1887

1

))

1888

1

				.execute_returns(true);

1889

1

1890

1

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

1891

1

			Precompiles::new()

1892

1

				.prepare_test(

1893

1

					BOB,

1894

1

					asset_precompile_address,

1895

1

					ForeignAssetsPCall::transfer_from {

1896

1

						from: Address(ALICE.into()),

1897

1

						to: Address(CHARLIE.into()),

1898

1

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

1899

1

},

1900

1

1901

1

				.expect_cost(31998)

1902

1

				.expect_log(log3(

1903

1

					asset_precompile_address,

1904

1

					SELECTOR_LOG_TRANSFER,

1905

1

					H160::from(ALICE),

1906

1

					H160::from(CHARLIE),

1907

1

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

1908

1

))

1909

1

				.execute_returns(true);

1910

1

1911

1

			// Make sure CHARLIE has 400 MOVR

1912

1

			Precompiles::new()

1913

1

				.prepare_test(

1914

1

					CHARLIE,

1915

1

					asset_precompile_address,

1916

1

					ForeignAssetsPCall::balance_of {

1917

1

						who: Address(CHARLIE.into()),

1918

1

},

1919

1

1920

1

				.expect_cost(5007)

1921

1

				.expect_no_logs()

1922

1

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

1923

1

});

1924

1

1925

1926

#[test]

1927

1

fn xtokens_precompiles_transfer() {

1928

2

	fn run_test_variant(evm_native: bool) {

1929

2

		let mut builder = ExtBuilder::default();

1930

2

1931

2

		if evm_native {

1932

1

			builder = builder.with_evm_native_foreign_assets();

1933

1

1934

1

1935

2

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

1936

2

		builder

1937

2

			.with_xcm_assets(vec![XcmAssetInitialization {

1938

2

				asset_type: asset_type.clone(),

1939

2

				metadata: AssetRegistrarMetadata {

1940

2

					name: b"RelayToken".to_vec(),

1941

2

					symbol: b"Relay".to_vec(),

1942

2

					decimals: 12,

1943

2

					is_frozen: false,

1944

2

},

1945

2

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

1946

2

				is_sufficient: true,

1947

2

}])

1948

2

			.with_balances(vec![

1949

2

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

1950

2

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

1951

2

])

1952

2

			.with_safe_xcm_version(3)

1953

2

			.build()

1954

2

			.execute_with(|| {

1955

2

				let xtokens_precompile_address = H160::from_low_u64_be(2052);

1956

2

1957

2

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

1958

2

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

1959

2

1960

2

				// Its address is

1961

2

				let asset_precompile_address = Runtime::asset_id_to_account(

1962

2

					FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1963

2

					relay_asset_id,

1964

2

);

1965

2

1966

2

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

1967

2

				let destination = Location::new(

1968

2

1,

1969

2

					[Junction::AccountId32 {

1970

2

						network: None,

1971

2

						id: [1u8; 32],

1972

2

}],

1973

2

);

1974

2

1975

2

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

1976

2

				let inside2 = inside.clone();

1977

2

1978

2

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

1979

2

				Precompiles::new()

1980

2

					.prepare_test(

1981

2

						ALICE,

1982

2

						xtokens_precompile_address,

1983

2

						XtokensPCall::transfer {

1984

2

							currency_address: Address(asset_precompile_address.into()),

1985

2

							amount: 500_000_000_000_000u128.into(),

1986

2

							destination,

1987

2

							weight: 4_000_000,

1988

2

},

1989

2

1990

2

					.expect_cost(if evm_native { 178506 } else { 26906 })

1991

2

					.expect_no_logs()

1992

2

					// We expect an evm subcall ERC20.burnFrom

1993

2

					.with_subcall_handle(move |subcall| {

1994

1

						let Subcall {

1995

1

							address,

1996

1

							transfer,

1997

1

							input,

1998

1

							target_gas: _,

1999

1

							is_static,

2000

1

							context,

2001

1

						} = subcall;

2002

1

2003

1

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

2004

1

2005

1

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

2006

1

						let expected_address: H160 = Runtime::asset_id_to_account(

2007

1

							FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

2008

1

							asset_id,

2009

1

2010

1

						.into();

2011

1

						assert_eq!(address, expected_address);

2012

1

						assert_eq!(is_static, false);

2013

1

2014

1

						assert!(transfer.is_none());

2015

1

2016

1

						assert_eq!(context.address, expected_address);

2017

1

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

2018

1

2019

1

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

2020

1

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

2021

1

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

2022

1

2023

1

						inside2.set(true);

2024

1

2025

1

						SubcallOutput {

2026

1

							output: Default::default(),

2027

1

							cost: 149_000,

2028

1

							logs: vec![],

2029

1

							..SubcallOutput::succeed()

2030

1

2031

2

})

2032

2

					.execute_returns(())

2033

2

})

2034

2

2035

1

2036

1

	run_test_variant(false);

2037

1

	run_test_variant(true);

2038

1

2039

2040

#[test]

2041

1

fn xtokens_precompiles_transfer_multiasset() {

2042

1

	ExtBuilder::default()

2043

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2044

1

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

2045

1

			metadata: AssetRegistrarMetadata {

2046

1

				name: b"RelayToken".to_vec(),

2047

1

				symbol: b"Relay".to_vec(),

2048

1

				decimals: 12,

2049

1

				is_frozen: false,

2050

1

},

2051

1

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

2052

1

			is_sufficient: true,

2053

1

}])

2054

1

		.with_balances(vec![

2055

1

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

2056

1

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

2057

1

])

2058

1

		.with_safe_xcm_version(3)

2059

1

		.build()

2060

1

		.execute_with(|| {

2061

1

			let xtokens_precompile_address = H160::from_low_u64_be(2052);

2062

1

2063

1

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

2064

1

			let destination = Location::new(

2065

1

1,

2066

1

				[Junction::AccountId32 {

2067

1

					network: None,

2068

1

					id: [1u8; 32],

2069

1

}],

2070

1

);

2071

1

2072

1

			// This time we transfer it through TransferMultiAsset

2073

1

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

2074

1

			Precompiles::new()

2075

1

				.prepare_test(

2076

1

					ALICE,

2077

1

					xtokens_precompile_address,

2078

1

					XtokensPCall::transfer_multiasset {

2079

1

						// We want to transfer the relay token

2080

1

						asset: Location::parent(),

2081

1

						amount: 500_000_000_000_000u128.into(),

2082

1

						destination,

2083

1

						weight: 4_000_000,

2084

1

},

2085

1

2086

1

				.expect_cost(26906)

2087

1

				.expect_no_logs()

2088

1

				.execute_returns(());

2089

1

})

2090

1

2091

2092

#[test]

2093

1

fn make_sure_polkadot_xcm_cannot_be_called() {

2094

1

	ExtBuilder::default()

2095

1

		.with_balances(vec![

2096

1

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

2097

1

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

2098

1

])

2099

1

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

2100

1

		.with_mappings(vec![(

2101

1

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

2102

1

			AccountId::from(ALICE),

2103

1

)])

2104

1

		.build()

2105

1

		.execute_with(|| {

2106

1

			let dest = Location {

2107

1

				parents: 1,

2108

1

				interior: [AccountId32 {

2109

1

					network: None,

2110

1

					id: [1u8; 32],

2111

1

}]

2112

1

				.into(),

2113

1

};

2114

1

			let assets: Assets = [Asset {

2115

1

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

2116

1

				fun: Fungible(1000),

2117

1

}]

2118

1

			.to_vec()

2119

1

			.into();

2120

1

			assert_noop!(

2121

1

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

2122

1

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

2123

1

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

2124

1

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

2125

1

					fee_asset_item: 0,

2126

1

})

2127

1

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

2128

1

					AccountId::from(ALICE)

2129

1

)),

2130

1

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

2131

1

);

2132

1

});

2133

1

2134

2135

#[test]

2136

1

fn transactor_cannot_use_more_than_max_weight() {

2137

1

	ExtBuilder::default()

2138

1

		.with_balances(vec![

2139

1

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

2140

1

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

2141

1

])

2142

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2143

1

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

2144

1

			metadata: AssetRegistrarMetadata {

2145

1

				name: b"RelayToken".to_vec(),

2146

1

				symbol: b"Relay".to_vec(),

2147

1

				decimals: 12,

2148

1

				is_frozen: false,

2149

1

},

2150

1

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

2151

1

			is_sufficient: true,

2152

1

}])

2153

1

		.build()

2154

1

		.execute_with(|| {

2155

1

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

2156

1

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

2157

1

			assert_ok!(XcmTransactor::register(

2158

1

				root_origin(),

2159

1

				AccountId::from(ALICE),

2160

1

0,

2161

1

));

2162

2163

			// Root can set transact info

2164

1

			assert_ok!(XcmTransactor::set_transact_info(

2165

1

				root_origin(),

2166

1

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

2167

1

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

2168

1

				3000.into(),

2169

1

				20000.into(),

2170

1

				None

2171

1

));

2172

2173

			// Root can set transact info

2174

1

			assert_ok!(XcmTransactor::set_fee_per_second(

2175

1

				root_origin(),

2176

1

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

2177

1

2178

1

));

2179

2180

1

			assert_noop!(

2181

1

				XcmTransactor::transact_through_derivative(

2182

1

					origin_of(AccountId::from(ALICE)),

2183

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2184

1

0,

2185

1

					CurrencyPayment {

2186

1

						currency: Currency::AsMultiLocation(Box::new(xcm::VersionedLocation::V4(

2187

1

							Location::parent()

2188

1

						))),

2189

1

						fee_amount: None

2190

1

},

2191

1

					vec![],

2192

1

					// 2000 is the max

2193

1

					TransactWeights {

2194

1

						transact_required_weight_at_most: 17001.into(),

2195

1

						overall_weight: None

2196

1

},

2197

1

					false

2198

1

),

2199

1

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

2200

1

);

2201

1

			assert_noop!(

2202

1

				XcmTransactor::transact_through_derivative(

2203

1

					origin_of(AccountId::from(ALICE)),

2204

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2205

1

0,

2206

1

					CurrencyPayment {

2207

1

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

2208

1

						fee_amount: None

2209

1

},

2210

1

					vec![],

2211

1

					// 20000 is the max

2212

1

					TransactWeights {

2213

1

						transact_required_weight_at_most: 17001.into(),

2214

1

						overall_weight: None

2215

1

},

2216

1

					false

2217

1

),

2218

1

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

2219

1

);

2220

1

})

2221

1

2222

2223

#[test]

2224

1

fn transact_through_signed_precompile_works_v2() {

2225

1

	ExtBuilder::default()

2226

1

		.with_balances(vec![

2227

1

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

2228

1

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

2229

1

])

2230

1

		.with_safe_xcm_version(3)

2231

1

		.build()

2232

1

		.execute_with(|| {

2233

1

			// Destination

2234

1

			let dest = Location::parent();

2235

1

2236

1

			let fee_payer_asset = Location::parent();

2237

1

2238

1

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

2239

1

2240

1

			let total_weight = 1_000_000_000u64;

2241

1

2242

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2243

1

2244

1

			Precompiles::new()

2245

1

				.prepare_test(

2246

1

					ALICE,

2247

1

					xcm_transactor_v2_precompile_address,

2248

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2249

1

						dest,

2250

1

						fee_asset: fee_payer_asset,

2251

1

						weight: 4_000_000,

2252

1

						call: bytes.into(),

2253

1

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

2254

1

						overall_weight: total_weight,

2255

1

},

2256

1

2257

1

				.expect_cost(25411)

2258

1

				.expect_no_logs()

2259

1

				.execute_returns(());

2260

1

});

2261

1

2262

2263

#[test]

2264

1

fn transact_through_signed_cannot_send_to_local_chain() {

2265

1

	ExtBuilder::default()

2266

1

		.with_balances(vec![

2267

1

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

2268

1

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

2269

1

])

2270

1

		.with_safe_xcm_version(3)

2271

1

		.build()

2272

1

		.execute_with(|| {

2273

1

			// Destination

2274

1

			let dest = Location::here();

2275

1

2276

1

			let fee_payer_asset = Location::parent();

2277

1

2278

1

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

2279

1

2280

1

			let total_weight = 1_000_000_000u64;

2281

1

2282

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2283

1

2284

1

			Precompiles::new()

2285

1

				.prepare_test(

2286

1

					ALICE,

2287

1

					xcm_transactor_v2_precompile_address,

2288

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2289

1

						dest,

2290

1

						fee_asset: fee_payer_asset,

2291

1

						weight: 4_000_000,

2292

1

						call: bytes.into(),

2293

1

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

2294

1

						overall_weight: total_weight,

2295

1

},

2296

1

2297

1

				.execute_reverts(|output| {

2298

1

					from_utf8(&output)

2299

1

						.unwrap()

2300

1

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

2301

1

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

2302

1

});

2303

1

});

2304

1

2305

2306

#[test]

2307

1

fn call_xtokens_with_fee() {

2308

1

	ExtBuilder::default()

2309

1

		.with_balances(vec![

2310

1

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

2311

1

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

2312

1

])

2313

1

		.with_safe_xcm_version(3)

2314

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2315

1

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

2316

1

			metadata: AssetRegistrarMetadata {

2317

1

				name: b"RelayToken".to_vec(),

2318

1

				symbol: b"Relay".to_vec(),

2319

1

				decimals: 12,

2320

1

				is_frozen: false,

2321

1

},

2322

1

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

2323

1

			is_sufficient: true,

2324

1

}])

2325

1

		.build()

2326

1

		.execute_with(|| {

2327

1

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

2328

1

			let dest = Location {

2329

1

				parents: 1,

2330

1

				interior: [AccountId32 {

2331

1

					network: None,

2332

1

					id: [1u8; 32],

2333

1

}]

2334

1

				.into(),

2335

1

};

2336

1

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

2337

1

2338

1

			let before_balance =

2339

1

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

2340

1

2341

1

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

2342

1

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

2343

1

			let (chain_part, beneficiary) =

2344

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

2345

1

2346

1

			// We are able to transfer with fee

2347

1

			assert_ok!(PolkadotXcm::transfer_assets(

2348

1

				origin_of(AccountId::from(ALICE)),

2349

1

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

2350

1

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

2351

1

				Box::new(VersionedAssets::V4(vec![asset_fee, asset].into())),

2352

1

0,

2353

1

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

2354

1

			),);

2355

2356

1

			let after_balance =

2357

1

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

2358

1

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

2359

1

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

2360

1

});

2361

1

2362

2363

#[test]

2364

1

fn test_xcm_utils_ml_tp_account() {

2365

1

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

2366

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2367

1

		let expected_address_parent: H160 =

2368

1

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

2369

1

				.unwrap()

2370

1

				.into();

2371

1

2372

1

		Precompiles::new()

2373

1

			.prepare_test(

2374

1

				ALICE,

2375

1

				xcm_utils_precompile_address,

2376

1

				XcmUtilsPCall::multilocation_to_address {

2377

1

					location: Location::parent(),

2378

1

},

2379

1

2380

1

			.expect_cost(3338)

2381

1

			.expect_no_logs()

2382

1

			.execute_returns(Address(expected_address_parent));

2383

1

2384

1

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

2385

1

		let expected_address_parachain: H160 =

2386

1

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

2387

1

				&parachain_2000_multilocation,

2388

1

2389

1

			.unwrap()

2390

1

			.into();

2391

1

2392

1

		Precompiles::new()

2393

1

			.prepare_test(

2394

1

				ALICE,

2395

1

				xcm_utils_precompile_address,

2396

1

				XcmUtilsPCall::multilocation_to_address {

2397

1

					location: parachain_2000_multilocation,

2398

1

},

2399

1

2400

1

			.expect_cost(3338)

2401

1

			.expect_no_logs()

2402

1

			.execute_returns(Address(expected_address_parachain));

2403

1

2404

1

		let alice_in_parachain_2000_location = Location::new(

2405

1

1,

2406

1

2407

1

				Parachain(2000),

2408

1

				AccountKey20 {

2409

1

					network: None,

2410

1

					key: ALICE,

2411

1

},

2412

1

],

2413

1

);

2414

1

		let expected_address_alice_in_parachain_2000 =

2415

1

			xcm_builder::HashedDescription::<

2416

1

				AccountId,

2417

1

				xcm_builder::DescribeFamily<xcm_builder::DescribeAllTerminal>,

2418

1

			>::convert_location(&alice_in_parachain_2000_location)

2419

1

			.unwrap()

2420

1

			.into();

2421

1

2422

1

		Precompiles::new()

2423

1

			.prepare_test(

2424

1

				ALICE,

2425

1

				xcm_utils_precompile_address,

2426

1

				XcmUtilsPCall::multilocation_to_address {

2427

1

					location: alice_in_parachain_2000_location,

2428

1

},

2429

1

2430

1

			.expect_cost(3338)

2431

1

			.expect_no_logs()

2432

1

			.execute_returns(Address(expected_address_alice_in_parachain_2000));

2433

1

});

2434

1

2435

2436

#[test]

2437

1

fn test_xcm_utils_weight_message() {

2438

1

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

2439

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2440

1

		let expected_weight =

2441

1

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

2442

1

2443

1

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

2444

1

2445

1

		let input = XcmUtilsPCall::weight_message {

2446

1

			message: message.into(),

2447

1

};

2448

1

2449

1

		Precompiles::new()

2450

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2451

1

			.expect_cost(1669)

2452

1

			.expect_no_logs()

2453

1

			.execute_returns(expected_weight);

2454

1

});

2455

1

2456

2457

#[test]

2458

1

fn test_xcm_utils_get_units_per_second() {

2459

1

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

2460

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2461

1

		let location = SelfReserve::get();

2462

1

2463

1

		let input = XcmUtilsPCall::get_units_per_second { location };

2464

1

2465

1

		let expected_units =

2466

1

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

2467

1

2468

1

		Precompiles::new()

2469

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2470

1

			.expect_cost(3338)

2471

1

			.expect_no_logs()

2472

1

			.execute_returns(expected_units);

2473

1

});

2474

1

2475

2476

#[test]

2477

1

fn precompile_existence() {

2478

1

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

2479

1

		let precompiles = Precompiles::new();

2480

1

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

2481

1

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

2482

1

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

2483

1

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

2484

1

2485

1

		.into_iter()

2486

1

		.map(H160::from_low_u64_be)

2487

1

		.collect();

2488

2489

3001

		for i in 0..3000 {

2490

3000

			let address = H160::from_low_u64_be(i);

2491

3000

2492

3000

			if precompile_addresses.contains(&address) {

2493

40

				assert!(

2494

40

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

2495

					"is_precompile({}) should return true",

2496

2497

);

2498

2499

40

				assert!(

2500

40

					precompiles

2501

40

						.execute(&mut MockHandle::new(

2502

40

							address,

2503

40

							Context {

2504

40

								address,

2505

40

								caller: H160::zero(),

2506

40

								apparent_value: U256::zero()

2507

40

2508

40

),)

2509

40

						.is_some(),

2510

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

2511

2512

);

2513

			} else {

2514

2960

				assert!(

2515

2960

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

2516

					"is_precompile({}) should return false",

2517

2518

);

2519

2520

2960

				assert!(

2521

2960

					precompiles

2522

2960

						.execute(&mut MockHandle::new(

2523

2960

							address,

2524

2960

							Context {

2525

2960

								address,

2526

2960

								caller: H160::zero(),

2527

2960

								apparent_value: U256::zero()

2528

2960

2529

2960

),)

2530

2960

						.is_none(),

2531

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

2532

2533

);

2534

2535

2536

1

});

2537

1

2538

2539

#[test]

2540

1

fn removed_precompiles() {

2541

1

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

2542

1

		let precompiles = Precompiles::new();

2543

1

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

2544

2545

3000

		for i in 1..3000 {

2546

2999

			let address = H160::from_low_u64_be(i);

2547

2999

2548

2999

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

2549

2959

				continue;

2550

40

2551

40

2552

40

			if !removed_precompiles.contains(&i) {

2553

36

				assert!(

2554

36

					match precompiles.is_active_precompile(address, 100_000u64) {

2555

36

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

2556

						_ => false,

2557

},

2558

					"{i} should be an active precompile"

2559

);

2560

36

				continue;

2561

4

2562

4

2563

4

			assert!(

2564

4

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

2565

4

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

2566

					_ => false,

2567

},

2568

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

2569

);

2570

2571

4

			precompiles

2572

4

				.prepare_test(Alice, address, [])

2573

4

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

2574

2575

1

})

2576

1

2577

2578

#[test]

2579

1

fn deal_with_fees_handles_tip() {

2580

1

	use frame_support::traits::OnUnbalanced;

2581

1

	use moonbeam_runtime_common::deal_with_fees::DealWithSubstrateFeesAndTip;

2582

1

	use moonriver_runtime::Treasury;

2583

1

2584

1

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

2585

1

		set_parachain_inherent_data();

2586

1

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

2587

1

		// in the Moonriver runtime. It verifies that:

2588

1

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

2589

1

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

2590

1

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

2591

1

2592

1

		// The test details:

2593

1

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

2594

1

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

2595

1

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

2596

1

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

2597

1

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

2598

1

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

2599

1

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

2600

1

2601

1

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

2602

1

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

2603

1

			AccountId,

2604

1

		>>::issue(100);

2605

1

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

2606

1

			AccountId,

2607

1

		>>::issue(1000);

2608

1

2609

1

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

2610

1

		let total_supply_before = Balances::total_issuance();

2611

1

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

2612

1

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

2613

1

		assert_eq!(total_supply_before, 1_100);

2614

1

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

2615

2616

		// Step 3: Execute the fees handling logic.

2617

1

		DealWithSubstrateFeesAndTip::<

2618

1

			Runtime,

2619

1

			dynamic_params::runtime_config::FeesTreasuryProportion,

2620

1

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

2621

1

2622

1

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

2623

1

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

2624

1

2625

1

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

2626

1

		let burnt_fee_part: Balance = 100 - treasury_fee_part;

2627

1

2628

1

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

2629

1

		assert_eq!(

2630

1

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

2631

1

			treasury_fee_part,

2632

1

);

2633

2634

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

2635

1

		let total_supply_after = Balances::total_issuance();

2636

1

		assert_eq!(total_supply_before - total_supply_after, burnt_fee_part,);

2637

2638

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

2639

1

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

2640

1

		assert_eq!(

2641

1

			block_author_balance_after - block_author_balance_before,

2642

1

			1000,

2643

1

);

2644

1

});

2645

1

2646

2647

#[test]

2648

1

fn evm_revert_substrate_events() {

2649

1

	ExtBuilder::default()

2650

1

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

2651

1

		.build()

2652

1

		.execute_with(|| {

2653

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2654

1

2655

1

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

2656

1

			// Thus BatchAll will revert the transfer.

2657

1

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

2658

1

				source: ALICE.into(),

2659

1

				target: batch_precompile_address,

2660

1

				input: BatchPCall::batch_all {

2661

1

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

2662

1

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

2663

1

					call_data: vec![].into(),

2664

1

					gas_limit: vec![].into()

2665

1

2666

1

				.into(),

2667

1

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

2668

1

				gas_limit: 500_000,

2669

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2670

1

				max_priority_fee_per_gas: None,

2671

1

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

2672

1

				access_list: Vec::new(),

2673

1

})

2674

1

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

2675

2676

1

			let transfer_count = System::events()

2677

1

				.iter()

2678

6

				.filter(|r| match r.event {

2679

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

2680

6

					_ => false,

2681

6

})

2682

1

				.count();

2683

1

2684

1

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

2685

1

});

2686

1

2687

2688

#[test]

2689

1

fn evm_success_keeps_substrate_events() {

2690

1

	ExtBuilder::default()

2691

1

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

2692

1

		.build()

2693

1

		.execute_with(|| {

2694

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2695

1

2696

1

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

2697

1

				source: ALICE.into(),

2698

1

				target: batch_precompile_address,

2699

1

				input: BatchPCall::batch_all {

2700

1

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

2701

1

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

2702

1

					call_data: vec![].into(),

2703

1

					gas_limit: vec![].into()

2704

1

2705

1

				.into(),

2706

1

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

2707

1

				gas_limit: 500_000,

2708

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2709

1

				max_priority_fee_per_gas: None,

2710

1

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

2711

1

				access_list: Vec::new(),

2712

1

})

2713

1

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

2714

2715

1

			let transfer_count = System::events()

2716

1

				.iter()

2717

10

				.filter(|r| match r.event {

2718

1

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

2719

9

					_ => false,

2720

10

})

2721

1

				.count();

2722

1

2723

1

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

2724

1

});

2725

1

2726

2727

#[cfg(test)]

2728

mod treasury_tests {

2729

	use super::*;

2730

	use sp_runtime::traits::Hash;

2731

2732

2

	fn expect_events(events: Vec<RuntimeEvent>) {

2733

2

		let block_events: Vec<RuntimeEvent> =

2734

6

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

2735

2

2736

4

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

2737

2

2738

2739

4

	fn next_block() {

2740

4

		System::reset_events();

2741

4

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

2742

4

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

2743

4

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

2744

4

2745

2746

	#[test]

2747

1

	fn test_treasury_spend_local_with_council_origin() {

2748

1

		let initial_treasury_balance = 1_000 * MOVR;

2749

1

		ExtBuilder::default()

2750

1

			.with_balances(vec![

2751

1

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

2752

1

				(Treasury::account_id(), initial_treasury_balance),

2753

1

])

2754

1

			.build()

2755

1

			.execute_with(|| {

2756

1

				let spend_amount = 100u128 * MOVR;

2757

1

				let spend_beneficiary = AccountId::from(BOB);

2758

1

2759

1

				next_block();

2760

1

2761

1

				// TreasuryCouncilCollective

2762

1

				assert_ok!(TreasuryCouncilCollective::set_members(

2763

1

					root_origin(),

2764

1

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

2765

1

					Some(AccountId::from(ALICE)),

2766

1

2767

1

));

2768

2769

1

				next_block();

2770

1

2771

1

				// Perform treasury spending

2772

1

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

2773

1

					amount: spend_amount,

2774

1

					asset_kind: Box::new(()),

2775

1

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

2776

1

					valid_from: Some(5u32),

2777

1

});

2778

1

				assert_ok!(TreasuryCouncilCollective::propose(

2779

1

					origin_of(AccountId::from(ALICE)),

2780

1

1,

2781

1

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

2782

1

					1_000

2783

1

));

2784

2785

1

				let payout_period =

2786

1

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

2787

1

				let expected_events = [

2788

1

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

2789

1

						index: 0,

2790

1

						asset_kind: (),

2791

1

						amount: spend_amount,

2792

1

						beneficiary: spend_beneficiary,

2793

1

						valid_from: 5u32,

2794

1

						expire_at: payout_period + 5u32,

2795

1

}),

2796

1

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

2797

1

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

2798

1

						result: Ok(()),

2799

1

}),

2800

1

2801

1

				.to_vec();

2802

1

				expect_events(expected_events);

2803

2804

3

				while System::block_number() < 5u32 {

2805

2

					next_block();

2806

2

2807

2808

1

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

2809

2810

1

				let expected_events = [

2811

1

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

2812

1

						index: 0,

2813

1

						payment_id: (),

2814

1

}),

2815

1

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

2816

1

						from: Treasury::account_id(),

2817

1

						to: spend_beneficiary,

2818

1

						amount: spend_amount,

2819

1

}),

2820

1

2821

1

				.to_vec();

2822

1

				expect_events(expected_events);

2823

1

});

2824

1

2825

2826

2827

#[cfg(test)]

2828

mod fee_tests {

2829

	use super::*;

2830

	use fp_evm::FeeCalculator;

2831

	use frame_support::{

2832

		traits::{ConstU128, OnFinalize},

2833

		weights::{ConstantMultiplier, WeightToFee},

2834

};

2835

	use moonriver_runtime::{

2836

		currency, LengthToFee, MinimumMultiplier, RuntimeBlockWeights, SlowAdjustingFeeUpdate,

2837

		TargetBlockFullness, TransactionPaymentAsGasPrice, NORMAL_WEIGHT, WEIGHT_PER_GAS,

2838

};

2839

	use sp_core::Get;

2840

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

2841

2842

1

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

2843

1

	where

2844

1

		F: FnMut() -> (),

2845

1

2846

1

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

2847

1

			.build_storage()

2848

1

			.unwrap()

2849

1

			.into();

2850

1

		t.execute_with(|| {

2851

1

			System::set_block_consumed_resources(w, 0);

2852

1

			assertions()

2853

1

});

2854

1

2855

2856

	#[test]

2857

1

	fn test_multiplier_can_grow_from_zero() {

2858

1

		let minimum_multiplier = MinimumMultiplier::get();

2859

1

		let target = TargetBlockFullness::get()

2860

1

			* RuntimeBlockWeights::get()

2861

1

				.get(DispatchClass::Normal)

2862

1

				.max_total

2863

1

				.unwrap();

2864

1

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

2865

1

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

2866

1

		run_with_system_weight(target * 101 / 100, || {

2867

1

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

2868

1

			assert!(

2869

1

				next > minimum_multiplier,

2870

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

2871

				next,

2872

				minimum_multiplier

2873

);

2874

1

})

2875

1

2876

2877

	#[test]

2878

1

	fn test_fee_calculation() {

2879

1

		let base_extrinsic = RuntimeBlockWeights::get()

2880

1

			.get(DispatchClass::Normal)

2881

1

			.base_extrinsic;

2882

1

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

2883

1

		let extrinsic_len = 100u32;

2884

1

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

2885

1

		let tip = 42u128;

2886

1

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

2887

1

		type LengthToFeeImpl = LengthToFee;

2888

1

2889

1

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

2890

1

		let expected_fee = WeightToFeeImpl::weight_to_fee(&base_extrinsic)

2891

1

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

2892

1

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

2893

1

			+ tip;

2894

1

2895

1

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

2896

1

			.build_storage()

2897

1

			.unwrap()

2898

1

			.into();

2899

1

		t.execute_with(|| {

2900

1

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

2901

1

			let actual_fee = TransactionPayment::compute_fee(

2902

1

				extrinsic_len,

2903

1

				&frame_support::dispatch::DispatchInfo {

2904

1

					class: DispatchClass::Normal,

2905

1

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

2906

1

					weight: extrinsic_weight,

2907

1

},

2908

1

				tip,

2909

1

);

2910

1

2911

1

			assert_eq!(

2912

				expected_fee,

2913

				actual_fee,

2914

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

2915

				actual_fee - expected_fee

2916

);

2917

1

});

2918

1

2919

2920

	#[test]

2921

1

	fn test_min_gas_price_is_deterministic() {

2922

1

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

2923

1

			.build_storage()

2924

1

			.unwrap()

2925

1

			.into();

2926

1

		t.execute_with(|| {

2927

1

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

2928

1

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

2929

1

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

2930

1

			let expected: U256 = multiplier

2931

1

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

2932

1

				.into();

2933

1

2934

1

			assert_eq!(expected, actual);

2935

1

});

2936

1

2937

2938

	#[test]

2939

1

	fn test_min_gas_price_has_no_precision_loss_from_saturating_mul_int() {

2940

1

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

2941

1

			.build_storage()

2942

1

			.unwrap()

2943

1

			.into();

2944

1

		t.execute_with(|| {

2945

1

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

2946

1

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

2947

1

2948

1

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

2949

1

			let a = TransactionPaymentAsGasPrice::min_gas_price();

2950

1

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

2951

1

			let b = TransactionPaymentAsGasPrice::min_gas_price();

2952

1

2953

1

			assert_ne!(

2954

				a, b,

2955

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

2956

);

2957

1

});

2958

1

2959

2960

	#[test]

2961

1

	fn test_fee_scenarios() {

2962

1

		use sp_runtime::FixedU128;

2963

1

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

2964

1

			.build_storage()

2965

1

			.unwrap()

2966

1

			.into();

2967

1

		t.execute_with(|| {

2968

1

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

2969

12

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

2970

12

				let start_multiplier =

2971

12

					FixedU128::from_rational(start_gas_price, weight_fee_per_gas);

2972

12

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

2973

12

2974

12

				let block_weight = NORMAL_WEIGHT * fullness;

2975

2976

60004

				for i in 0..num_blocks {

2977

60004

					System::set_block_number(i as u32);

2978

60004

					System::set_block_consumed_resources(block_weight, 0);

2979

60004

					TransactionPayment::on_finalize(i as u32);

2980

60004

2981

2982

12

				TransactionPaymentAsGasPrice::min_gas_price().0

2983

12

};

2984

2985

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

2986

			// they are expected to change when parameters that influence

2987

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

2988

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

2989

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

2990

2991

1

			assert_eq!(

2992

1

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

2993

1

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

2994

1

);

2995

1

			assert_eq!(

2996

1

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

2997

1

				U256::from(312_500_000u128),

2998

1

);

2999

1

			assert_eq!(

3000

1

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

3001

1

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

3002

1

);

3003

1

			assert_eq!(

3004

1

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

3005

1

				U256::from(313_313_556u128),

3006

1

);

3007

3008

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

3009

1

			assert_eq!(

3010

1

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

3011

1

				U256::from(312_500_000u128),

3012

1

);

3013

1

			assert_eq!(

3014

1

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

3015

1

				U256::from(312_500_000u128),

3016

1

);

3017

1

			assert_eq!(

3018

1

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

3019

1

				U256::from(447_915_432u128),

3020

1

);

3021

1

			assert_eq!(

3022

1

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

3023

1

				U256::from(1_487_129_030u128),

3024

1

);

3025

3026

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

3027

1

			assert_eq!(

3028

1

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

3029

1

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

3030

1

);

3031

1

			assert_eq!(

3032

1

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

3033

1

				U256::from(312_500_000u128),

3034

1

);

3035

1

			assert_eq!(

3036

1

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

3037

1

				U256::from(1_766_664_654_709u128),

3038

1

);

3039

1

			assert_eq!(

3040

1

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

3041

1

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

3042

1

);

3043

1

});

3044

1

3045