Grcov report - integration

1

// Copyright 2019-2022 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

use common::*;

23

24

use fp_evm::{Context, IsPrecompileResult};

25

use frame_support::traits::fungible::Inspect;

26

use frame_support::{

27

	assert_noop, assert_ok,

28

	dispatch::DispatchClass,

29

	traits::{

30

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

31

		StorageInfoTrait,

32

},

33

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

34

	StorageHasher, Twox128,

35

};

36

use moonbeam_xcm_benchmarks::weights::XcmWeight;

37

use moonkit_xcm_primitives::AccountIdAssetIdConversion;

38

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

39

use moonriver_runtime::runtime_params::dynamic_params;

40

use moonriver_runtime::{

41

	asset_config::ForeignAssetInstance,

42

	xcm_config::{CurrencyId, SelfReserve},

43

	AssetId, Balances, CrowdloanRewards, Executive, OpenTechCommitteeCollective, PolkadotXcm,

44

	Precompiles, RuntimeBlockWeights, TransactionPayment, TransactionPaymentAsGasPrice, Treasury,

45

	TreasuryCouncilCollective, XcmTransactor, FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX, WEEKS,

46

};

47

use nimbus_primitives::NimbusId;

48

use pallet_evm::PrecompileSet;

49

use pallet_evm_precompileset_assets_erc20::{SELECTOR_LOG_APPROVAL, SELECTOR_LOG_TRANSFER};

50

use pallet_transaction_payment::Multiplier;

51

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

52

use parity_scale_codec::Encode;

53

use polkadot_parachain::primitives::Sibling;

54

use precompile_utils::{

55

	precompile_set::{is_precompile_or_fail, IsActivePrecompile},

56

	prelude::*,

57

	testing::*,

58

};

59

use sha3::{Digest, Keccak256};

60

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

61

use sp_runtime::{

62

	traits::{Convert, Dispatchable},

63

	BuildStorage, DispatchError, ModuleError,

64

};

65

use std::str::from_utf8;

66

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

67

use xcm::{VersionedAssets, VersionedLocation};

68

use xcm_builder::{ParentIsPreset, SiblingParachainConvertsVia};

69

use xcm_executor::traits::ConvertLocation;

70

use xcm_primitives::split_location_into_chain_part_and_beneficiary;

71

72

type BatchPCall = pallet_evm_precompile_batch::BatchPrecompileCall<Runtime>;

73

type CrowdloanRewardsPCall =

74

	pallet_evm_precompile_crowdloan_rewards::CrowdloanRewardsPrecompileCall<Runtime>;

75

type XcmUtilsPCall = pallet_evm_precompile_xcm_utils::XcmUtilsPrecompileCall<

76

	Runtime,

77

	moonriver_runtime::xcm_config::XcmExecutorConfig,

78

>;

79

type XtokensPCall = pallet_evm_precompile_xtokens::XtokensPrecompileCall<Runtime>;

80

type ForeignAssetsPCall = pallet_evm_precompileset_assets_erc20::Erc20AssetsPrecompileSetCall<

81

	Runtime,

82

	ForeignAssetInstance,

83

>;

84

type XcmTransactorV2PCall =

85

	pallet_evm_precompile_xcm_transactor::v2::XcmTransactorPrecompileV2Call<Runtime>;

86

87

const BASE_FEE_GENESIS: u128 = 100 * GIGAWEI;

88

89

3

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

90

3

	Asset {

91

3

		id: AssetId(

92

3

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

93

3

				currency_id,

94

3

95

3

			.unwrap(),

96

3

),

97

3

		fun: Fungibility::Fungible(amount),

98

3

99

3

100

101

#[test]

102

1

fn xcmp_queue_controller_origin_is_root() {

103

1

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

104

1

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

105

1

	assert_ok!(

106

1

		<moonriver_runtime::Runtime as cumulus_pallet_xcmp_queue::Config

107

1

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

108

1

);

109

1

110

111

#[test]

112

1

fn verify_pallet_prefixes() {

113

30

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

114

30

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

115

30

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

116

30

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

117

30

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

118

30

		// expand/storage.rs#L389-L401

119

30

		assert_eq!(

120

30

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

121

30

			Some(name)

122

30

);

123

30

124

1

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

125

1

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

126

1

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

127

1

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

128

1

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

129

1

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

130

1

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

131

1

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

132

1

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

133

1

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

134

1

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

135

1

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

136

1

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

137

1

	is_pallet_prefix::<moonriver_runtime::OpenTechCommitteeCollective>(

138

1

		"OpenTechCommitteeCollective",

139

1

);

140

1

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

141

1

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

142

1

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

143

1

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

144

1

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

145

1

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

146

1

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

147

1

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

148

1

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

149

1

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

150

1

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

151

1

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

152

1

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

153

1

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

154

1

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

155

1

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

156

1

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

157

1

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

158

1

159

14

	let prefix = |pallet_name, storage_name| {

160

14

		let mut res = [0u8; 32];

161

14

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

162

14

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

163

14

		res.to_vec()

164

14

};

165

1

	assert_eq!(

166

1

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

167

1

		vec![

168

1

			StorageInfo {

169

1

				pallet_name: b"Timestamp".to_vec(),

170

1

				storage_name: b"Now".to_vec(),

171

1

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

172

1

				max_values: Some(1),

173

1

				max_size: Some(8),

174

1

},

175

1

			StorageInfo {

176

1

				pallet_name: b"Timestamp".to_vec(),

177

1

				storage_name: b"DidUpdate".to_vec(),

178

1

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

179

1

				max_values: Some(1),

180

1

				max_size: Some(1),

181

1

182

1

183

1

);

184

1

	assert_eq!(

185

1

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

186

1

		vec![

187

1

			StorageInfo {

188

1

				pallet_name: b"Balances".to_vec(),

189

1

				storage_name: b"TotalIssuance".to_vec(),

190

1

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

191

1

				max_values: Some(1),

192

1

				max_size: Some(16),

193

1

},

194

1

			StorageInfo {

195

1

				pallet_name: b"Balances".to_vec(),

196

1

				storage_name: b"InactiveIssuance".to_vec(),

197

1

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

198

1

				max_values: Some(1),

199

1

				max_size: Some(16),

200

1

},

201

1

			StorageInfo {

202

1

				pallet_name: b"Balances".to_vec(),

203

1

				storage_name: b"Account".to_vec(),

204

1

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

205

1

				max_values: None,

206

1

				max_size: Some(100),

207

1

},

208

1

			StorageInfo {

209

1

				pallet_name: b"Balances".to_vec(),

210

1

				storage_name: b"Locks".to_vec(),

211

1

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

212

1

				max_values: None,

213

1

				max_size: Some(1287),

214

1

},

215

1

			StorageInfo {

216

1

				pallet_name: b"Balances".to_vec(),

217

1

				storage_name: b"Reserves".to_vec(),

218

1

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

219

1

				max_values: None,

220

1

				max_size: Some(1037),

221

1

},

222

1

			StorageInfo {

223

1

				pallet_name: b"Balances".to_vec(),

224

1

				storage_name: b"Holds".to_vec(),

225

1

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

226

1

				max_values: None,

227

1

				max_size: Some(55),

228

1

},

229

1

			StorageInfo {

230

1

				pallet_name: b"Balances".to_vec(),

231

1

				storage_name: b"Freezes".to_vec(),

232

1

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

233

1

				max_values: None,

234

1

				max_size: Some(37),

235

1

},

236

1

237

1

);

238

1

	assert_eq!(

239

1

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

240

1

		vec![

241

1

			StorageInfo {

242

1

				pallet_name: b"Proxy".to_vec(),

243

1

				storage_name: b"Proxies".to_vec(),

244

1

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

245

1

				max_values: None,

246

1

				max_size: Some(845),

247

1

},

248

1

			StorageInfo {

249

1

				pallet_name: b"Proxy".to_vec(),

250

1

				storage_name: b"Announcements".to_vec(),

251

1

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

252

1

				max_values: None,

253

1

				max_size: Some(1837),

254

1

255

1

256

1

);

257

1

	assert_eq!(

258

1

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

259

1

		vec![StorageInfo {

260

1

			pallet_name: b"MaintenanceMode".to_vec(),

261

1

			storage_name: b"MaintenanceMode".to_vec(),

262

1

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

263

1

			max_values: Some(1),

264

1

			max_size: None,

265

1

},]

266

1

);

267

1

	assert_eq!(

268

1

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

269

1

		vec![

270

1

			StorageInfo {

271

1

				pallet_name: b"RelayStorageRoots".to_vec(),

272

1

				storage_name: b"RelayStorageRoot".to_vec(),

273

1

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

274

1

				max_values: None,

275

1

				max_size: Some(44),

276

1

},

277

1

			StorageInfo {

278

1

				pallet_name: b"RelayStorageRoots".to_vec(),

279

1

				storage_name: b"RelayStorageRootKeys".to_vec(),

280

1

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

281

1

				max_values: Some(1),

282

1

				max_size: Some(121),

283

1

},

284

1

285

1

);

286

1

287

288

#[test]

289

1

fn test_collectives_storage_item_prefixes() {

290

6

	for StorageInfo { pallet_name, .. } in

291

7

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

292

293

6

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

294

295

296

6

	for StorageInfo { pallet_name, .. } in

297

7

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

298

299

6

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

300

301

1

302

303

#[test]

304

1

fn collective_set_members_root_origin_works() {

305

1

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

306

1

		// TreasuryCouncilCollective

307

1

		assert_ok!(TreasuryCouncilCollective::set_members(

308

1

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

309

1

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

310

1

			Some(AccountId::from(ALICE)),

311

1

312

1

));

313

		// OpenTechCommitteeCollective

314

1

		assert_ok!(OpenTechCommitteeCollective::set_members(

315

1

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

316

1

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

317

1

			Some(AccountId::from(ALICE)),

318

1

319

1

));

320

1

});

321

1

322

323

#[test]

324

1

fn collective_set_members_general_admin_origin_works() {

325

1

	use moonriver_runtime::{

326

1

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

327

1

};

328

1

329

1

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

330

1

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

331

1

		let alice = AccountId::from(ALICE);

332

1

333

1

		// TreasuryCouncilCollective

334

1

		let _ = Utility::dispatch_as(

335

1

			root_caller.clone(),

336

1

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

337

1

			Box::new(

338

1

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

339

1

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

340

1

					prime: Some(alice),

341

1

					old_count: 2,

342

1

343

1

				.into(),

344

1

),

345

1

);

346

1

		// OpenTechCommitteeCollective

347

1

		let _ = Utility::dispatch_as(

348

1

			root_caller,

349

1

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

350

1

			Box::new(

351

1

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

352

1

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

353

1

					prime: Some(alice),

354

1

					old_count: 2,

355

1

356

1

				.into(),

357

1

),

358

1

);

359

1

360

1

		assert_eq!(

361

1

			System::events()

362

1

				.into_iter()

363

2

				.filter_map(|r| {

364

2

					match r.event {

365

2

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

366

2

							if result.is_ok() =>

367

2

368

2

							Some(true)

369

370

						_ => None,

371

372

2

})

373

1

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

374

1

				.len(),

375

1

376

1

377

1

});

378

1

379

380

#[test]

381

1

fn collective_set_members_signed_origin_does_not_work() {

382

1

	let alice = AccountId::from(ALICE);

383

1

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

384

1

		// TreasuryCouncilCollective

385

1

		assert!(TreasuryCouncilCollective::set_members(

386

1

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

387

1

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

388

1

			Some(AccountId::from(ALICE)),

389

1

390

1

391

1

		.is_err());

392

		// OpenTechCommitteeCollective

393

1

		assert!(OpenTechCommitteeCollective::set_members(

394

1

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

395

1

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

396

1

			Some(AccountId::from(ALICE)),

397

1

398

1

399

1

		.is_err());

400

1

});

401

1

402

403

#[test]

404

1

fn verify_pallet_indices() {

405

32

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

406

32

		assert_eq!(

407

32

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

408

32

			Some(index)

409

32

);

410

32

411

1

	// System support

412

1

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

413

1

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

414

1

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

415

1

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

416

1

	// Monetary

417

1

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

418

1

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

419

1

	// Consensus support

420

1

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

421

1

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

422

1

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

423

1

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

424

1

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

425

1

	// Handy utilities

426

1

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

427

1

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

428

1

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

429

1

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

430

1

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

431

1

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

432

1

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

433

1

	// Ethereum compatibility

434

1

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

435

1

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

436

1

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

437

1

	// Governance

438

1

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

439

1

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

440

1

	// Council

441

1

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

442

1

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

443

1

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

444

1

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

445

1

	// Treasury

446

1

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

447

1

	// Crowdloan

448

1

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

449

1

	// XCM Stuff

450

1

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

451

1

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

452

1

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

453

1

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

454

1

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

455

1

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

456

1

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

457

1

458

459

#[test]

460

1

fn verify_reserved_indices() {

461

1

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

462

1

		.build_storage()

463

1

		.unwrap()

464

1

		.into();

465

1

466

1

	t.execute_with(|| {

467

1

		use frame_metadata::*;

468

1

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

469

1

		let metadata = match metadata.1 {

470

1

			RuntimeMetadata::V14(metadata) => metadata,

471

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

472

};

473

		// 40: Sudo

474

		// 53: BaseFee

475

		// 108: pallet_assets::<Instance1>

476

1

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

477

1

		let existing = metadata

478

1

			.pallets

479

1

			.iter()

480

49

			.map(|p| p.index)

481

1

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

482

3

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

483

1

});

484

1

485

486

#[test]

487

1

fn verify_proxy_type_indices() {

488

1

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

489

1

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

490

1

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

491

1

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

492

1

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

493

1

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

494

1

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

495

1

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

496

1

497

498

#[test]

499

1

fn join_collator_candidates() {

500

1

	ExtBuilder::default()

501

1

		.with_balances(vec![

502

1

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

503

1

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

504

1

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

505

1

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

506

1

])

507

1

		.with_collators(vec![

508

1

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

509

1

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

510

1

])

511

1

		.with_delegations(vec![

512

1

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

513

1

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

514

1

])

515

1

		.build()

516

1

		.execute_with(|| {

517

1

			assert_noop!(

518

1

				ParachainStaking::join_candidates(

519

1

					origin_of(AccountId::from(ALICE)),

520

1

					10_000 * MOVR,

521

1

					2u32

522

1

),

523

1

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

524

1

);

525

1

			assert_noop!(

526

1

				ParachainStaking::join_candidates(

527

1

					origin_of(AccountId::from(CHARLIE)),

528

1

					10_000 * MOVR,

529

1

					2u32

530

1

),

531

1

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

532

1

);

533

1

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

534

1

			assert_ok!(ParachainStaking::join_candidates(

535

1

				origin_of(AccountId::from(DAVE)),

536

1

				10_000 * MOVR,

537

1

				2u32

538

1

));

539

1

			assert_eq!(

540

1

				last_event(),

541

1

				RuntimeEvent::ParachainStaking(

542

1

					pallet_parachain_staking::Event::JoinedCollatorCandidates {

543

1

						account: AccountId::from(DAVE),

544

1

						amount_locked: 10_000 * MOVR,

545

1

						new_total_amt_locked: 30_100 * MOVR

546

1

547

1

548

1

);

549

1

			let candidates = ParachainStaking::candidate_pool();

550

1

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

551

1

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

552

1

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

553

1

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

554

1

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

555

1

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

556

1

});

557

1

558

559

#[test]

560

1

fn transfer_through_evm_to_stake() {

561

1

	ExtBuilder::default()

562

1

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

563

1

		.build()

564

1

		.execute_with(|| {

565

1

			// Charlie has no balance => fails to stake

566

1

			assert_noop!(

567

1

				ParachainStaking::join_candidates(

568

1

					origin_of(AccountId::from(CHARLIE)),

569

1

					10_000 * MOVR,

570

1

					2u32

571

1

),

572

1

				DispatchError::Module(ModuleError {

573

1

					index: 20,

574

1

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

575

1

					message: Some("InsufficientBalance")

576

1

})

577

1

);

578

			// Alice transfer from free balance 20000 MOVR to Bob

579

1

			assert_ok!(Balances::transfer_allow_death(

580

1

				origin_of(AccountId::from(ALICE)),

581

1

				AccountId::from(BOB),

582

1

				20_000 * MOVR,

583

1

));

584

1

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

585

586

1

			let gas_limit = 100000u64;

587

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

588

1

			// Bob transfers 10000 MOVR to Charlie via EVM

589

1

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

590

1

				source: H160::from(BOB),

591

1

				target: H160::from(CHARLIE),

592

1

				input: vec![],

593

1

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

594

1

				gas_limit,

595

1

				max_fee_per_gas: gas_price,

596

1

				max_priority_fee_per_gas: None,

597

1

				nonce: None,

598

1

				access_list: Vec::new(),

599

1

})

600

1

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

601

1

			assert_eq!(

602

1

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

603

1

				10_000 * MOVR,

604

1

);

605

606

			// Charlie can stake now

607

1

			assert_ok!(ParachainStaking::join_candidates(

608

1

				origin_of(AccountId::from(CHARLIE)),

609

1

				10_000 * MOVR,

610

1

				2u32,

611

1

			),);

612

1

			let candidates = ParachainStaking::candidate_pool();

613

1

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

614

1

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

615

1

});

616

1

617

618

#[test]

619

1

fn reward_block_authors() {

620

1

	ExtBuilder::default()

621

1

		.with_balances(vec![

622

1

			// Alice gets 100 extra tokens for her mapping deposit

623

1

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

624

1

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

625

1

])

626

1

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

627

1

		.with_delegations(vec![(

628

1

			AccountId::from(BOB),

629

1

			AccountId::from(ALICE),

630

1

			500 * MOVR,

631

1

)])

632

1

		.with_mappings(vec![(

633

1

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

634

1

			AccountId::from(ALICE),

635

1

)])

636

1

		.build()

637

1

		.execute_with(|| {

638

1

			increase_last_relay_slot_number(1);

639

1

640

1

			// Just before round 3

641

1

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

642

1

643

1

			// no rewards doled out yet

644

1

			assert_eq!(

645

1

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

646

1

				10_100 * MOVR,

647

1

);

648

1

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

649

1

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

650

1

651

1

			// rewards minted and distributed

652

1

			assert_eq!(

653

1

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

654

1

				11547666666208000000000,

655

1

);

656

1

			assert_eq!(

657

1

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

658

1

				9557333332588000000000,

659

1

);

660

1

});

661

1

662

663

#[test]

664

1

fn reward_block_authors_with_parachain_bond_reserved() {

665

1

	ExtBuilder::default()

666

1

		.with_balances(vec![

667

1

			// Alice gets 100 extra tokens for her mapping deposit

668

1

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

669

1

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

670

1

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

671

1

])

672

1

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

673

1

		.with_delegations(vec![(

674

1

			AccountId::from(BOB),

675

1

			AccountId::from(ALICE),

676

1

			500 * MOVR,

677

1

)])

678

1

		.with_mappings(vec![(

679

1

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

680

1

			AccountId::from(ALICE),

681

1

)])

682

1

		.build()

683

1

		.execute_with(|| {

684

1

			increase_last_relay_slot_number(1);

685

1

			assert_ok!(ParachainStaking::set_parachain_bond_account(

686

1

				root_origin(),

687

1

				AccountId::from(CHARLIE),

688

1

			),);

689

690

			// Stop just before round 2

691

1

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

692

1

693

1

			// no collator rewards doled out yet

694

1

			assert_eq!(

695

1

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

696

1

				10_100 * MOVR,

697

1

);

698

1

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

699

700

			// Go to round 2

701

1

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

702

1

703

1

			// 30% reserved for parachain bond

704

1

			assert_eq!(

705

1

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

706

1

				452515000000000000000,

707

1

);

708

709

			// Go to round 3

710

1

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

711

1

712

1

			// rewards minted and distributed

713

1

			assert_eq!(

714

1

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

715

1

				11117700475903800000000,

716

1

);

717

1

			assert_eq!(

718

1

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

719

1

				9535834523343675000000,

720

1

);

721

			// 30% reserved for parachain bond again

722

1

			assert_eq!(

723

1

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

724

1

				910802725000000000000,

725

1

);

726

1

});

727

1

728

729

#[test]

730

1

fn initialize_crowdloan_addresses_with_batch_and_pay() {

731

1

	ExtBuilder::default()

732

1

		.with_balances(vec![

733

1

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

734

1

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

735

1

])

736

1

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

737

1

		.with_mappings(vec![(

738

1

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

739

1

			AccountId::from(ALICE),

740

1

)])

741

1

		.with_crowdloan_fund(3_000_000 * MOVR)

742

1

		.build()

743

1

		.execute_with(|| {

744

1

			// set parachain inherent data

745

1

			set_parachain_inherent_data();

746

1

			let init_block = CrowdloanRewards::init_vesting_block();

747

1

			// This matches the previous vesting

748

1

			let end_block = init_block + 48 * WEEKS;

749

1

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

750

1

			assert_ok!(

751

1

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

752

1

					calls: vec![

753

1

						RuntimeCall::CrowdloanRewards(

754

1

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

755

1

								rewards: vec![(

756

1

									[4u8; 32].into(),

757

1

									Some(AccountId::from(CHARLIE)),

758

1

									1_500_000 * MOVR

759

1

)]

760

1

761

1

),

762

1

						RuntimeCall::CrowdloanRewards(

763

1

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

764

1

								rewards: vec![(

765

1

									[5u8; 32].into(),

766

1

									Some(AccountId::from(DAVE)),

767

1

									1_500_000 * MOVR

768

1

)]

769

1

770

1

),

771

1

						RuntimeCall::CrowdloanRewards(

772

1

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

773

1

								lease_ending_block: end_block

774

1

775

1

776

1

777

1

})

778

1

				.dispatch(root_origin())

779

1

);

780

			// 30 percent initial payout

781

1

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

782

			// 30 percent initial payout

783

1

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

784

1

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

785

1

			assert_eq!(last_event(), expected);

786

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

787

1

			assert_ok!(

788

1

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

789

1

					calls: vec![RuntimeCall::CrowdloanRewards(

790

1

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

791

1

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

792

1

793

1

)]

794

1

})

795

1

				.dispatch(root_origin())

796

1

);

797

1

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

798

1

				index: 0,

799

1

				error: DispatchError::Module(ModuleError {

800

1

					index: 90,

801

1

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

802

1

					message: None,

803

1

}),

804

1

});

805

1

			assert_eq!(last_event(), expected_fail);

806

			// Claim 1 block.

807

1

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

808

1

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

809

810

1

			let vesting_period = 48 * WEEKS as u128;

811

1

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

812

1

813

1

			assert_eq!(

814

1

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

815

1

					.unwrap()

816

1

					.claimed_reward,

817

1

				(450_000 * MOVR) + per_block

818

1

);

819

1

			assert_eq!(

820

1

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

821

1

					.unwrap()

822

1

					.claimed_reward,

823

1

				(450_000 * MOVR) + per_block

824

1

);

825

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

826

1

			assert_eq!(

827

1

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

828

1

				(450_000 * MOVR) + per_block

829

1

);

830

1

			assert_eq!(

831

1

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

832

1

				(450_000 * MOVR) + per_block

833

1

);

834

1

			assert_noop!(

835

1

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

836

1

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

837

1

);

838

1

});

839

1

840

841

#[test]

842

1

fn initialize_crowdloan_address_and_change_with_relay_key_sig() {

843

1

	ExtBuilder::default()

844

1

		.with_balances(vec![

845

1

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

846

1

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

847

1

])

848

1

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

849

1

		.with_mappings(vec![(

850

1

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

851

1

			AccountId::from(ALICE),

852

1

)])

853

1

		.with_crowdloan_fund(3_000_000 * MOVR)

854

1

		.build()

855

1

		.execute_with(|| {

856

1

			// set parachain inherent data

857

1

			set_parachain_inherent_data();

858

1

			let init_block = CrowdloanRewards::init_vesting_block();

859

1

			// This matches the previous vesting

860

1

			let end_block = init_block + 4 * WEEKS;

861

1

862

1

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

863

1

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

864

1

865

1

			let public1 = pair1.public();

866

1

			let public2 = pair2.public();

867

1

868

1

			// signature:

869

1

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

870

1

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

871

1

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

872

1

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

873

1

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

874

1

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

875

1

			let signature1 = pair1.sign(&message);

876

1

			let signature2 = pair2.sign(&message);

877

1

878

1

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

879

1

			assert_ok!(

880

1

				// two relay accounts pointing at the same reward account

881

1

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

882

1

					calls: vec![

883

1

						RuntimeCall::CrowdloanRewards(

884

1

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

885

1

								rewards: vec![(

886

1

									public1.into(),

887

1

									Some(AccountId::from(CHARLIE)),

888

1

									1_500_000 * MOVR

889

1

)]

890

1

891

1

),

892

1

						RuntimeCall::CrowdloanRewards(

893

1

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

894

1

								rewards: vec![(

895

1

									public2.into(),

896

1

									Some(AccountId::from(CHARLIE)),

897

1

									1_500_000 * MOVR

898

1

)]

899

1

900

1

),

901

1

						RuntimeCall::CrowdloanRewards(

902

1

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

903

1

								lease_ending_block: end_block

904

1

905

1

906

1

907

1

})

908

1

				.dispatch(root_origin())

909

1

);

910

			// 30 percent initial payout

911

1

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

912

913

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

914

1

			assert_noop!(

915

1

				CrowdloanRewards::change_association_with_relay_keys(

916

1

					origin_of(AccountId::from(CHARLIE)),

917

1

					AccountId::from(DAVE),

918

1

					AccountId::from(CHARLIE),

919

1

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

920

1

),

921

1

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

922

1

);

923

924

			// this should be valid

925

1

			assert_ok!(CrowdloanRewards::change_association_with_relay_keys(

926

1

				origin_of(AccountId::from(CHARLIE)),

927

1

				AccountId::from(DAVE),

928

1

				AccountId::from(CHARLIE),

929

1

				vec![

930

1

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

931

1

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

932

1

933

1

));

934

935

1

			assert_eq!(

936

1

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

937

1

					.unwrap()

938

1

					.claimed_reward,

939

1

				(900_000 * MOVR)

940

1

);

941

1

});

942

1

943

944

#[test]

945

1

fn claim_via_precompile() {

946

1

	ExtBuilder::default()

947

1

		.with_balances(vec![

948

1

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

949

1

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

950

1

])

951

1

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

952

1

		.with_mappings(vec![(

953

1

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

954

1

			AccountId::from(ALICE),

955

1

)])

956

1

		.with_crowdloan_fund(3_000_000 * MOVR)

957

1

		.build()

958

1

		.execute_with(|| {

959

1

			// set parachain inherent data

960

1

			set_parachain_inherent_data();

961

1

			let init_block = CrowdloanRewards::init_vesting_block();

962

1

			// This matches the previous vesting

963

1

			let end_block = init_block + 4 * WEEKS;

964

1

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

965

1

			assert_ok!(

966

1

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

967

1

					calls: vec![

968

1

						RuntimeCall::CrowdloanRewards(

969

1

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

970

1

								rewards: vec![(

971

1

									[4u8; 32].into(),

972

1

									Some(AccountId::from(CHARLIE)),

973

1

									1_500_000 * MOVR

974

1

)]

975

1

976

1

),

977

1

						RuntimeCall::CrowdloanRewards(

978

1

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

979

1

								rewards: vec![(

980

1

									[5u8; 32].into(),

981

1

									Some(AccountId::from(DAVE)),

982

1

									1_500_000 * MOVR

983

1

)]

984

1

985

1

),

986

1

						RuntimeCall::CrowdloanRewards(

987

1

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

988

1

								lease_ending_block: end_block

989

1

990

1

991

1

992

1

})

993

1

				.dispatch(root_origin())

994

1

);

995

996

1

			assert!(CrowdloanRewards::initialized());

997

998

			// 30 percent initial payout

999

1

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

1000

			// 30 percent initial payout

1001

1

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

1002

1003

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1004

1

1005

1

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

1006

1

			let gas_limit = 100000u64;

1007

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1008

1

1009

1

			// Construct the call data (selector, amount)

1010

1

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

1011

1

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

1012

1

1013

1

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

1014

1

				source: H160::from(CHARLIE),

1015

1

				target: crowdloan_precompile_address,

1016

1

				input: call_data,

1017

1

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

1018

1

				gas_limit,

1019

1

				max_fee_per_gas: gas_price,

1020

1

				max_priority_fee_per_gas: None,

1021

1

				nonce: None, // Use the next nonce

1022

1

				access_list: Vec::new(),

1023

1

})

1024

1

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

1025

1026

1

			let vesting_period = 4 * WEEKS as u128;

1027

1

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

1028

1

1029

1

			assert_eq!(

1030

1

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

1031

1

					.unwrap()

1032

1

					.claimed_reward,

1033

1

				(450_000 * MOVR) + per_block

1034

1

);

1035

1

})

1036

1

1037

1038

#[test]

1039

1

fn is_contributor_via_precompile() {

1040

1

	ExtBuilder::default()

1041

1

		.with_balances(vec![

1042

1

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

1043

1

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

1044

1

])

1045

1

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

1046

1

		.with_mappings(vec![(

1047

1

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

1048

1

			AccountId::from(ALICE),

1049

1

)])

1050

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1051

1

		.build()

1052

1

		.execute_with(|| {

1053

1

			// set parachain inherent data

1054

1

			set_parachain_inherent_data();

1055

1

			let init_block = CrowdloanRewards::init_vesting_block();

1056

1

			// This matches the previous vesting

1057

1

			let end_block = init_block + 4 * WEEKS;

1058

1

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

1059

1

			assert_ok!(

1060

1

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

1061

1

					calls: vec![

1062

1

						RuntimeCall::CrowdloanRewards(

1063

1

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

1064

1

								rewards: vec![(

1065

1

									[4u8; 32].into(),

1066

1

									Some(AccountId::from(CHARLIE)),

1067

1

									1_500_000 * MOVR

1068

1

)]

1069

1

1070

1

),

1071

1

						RuntimeCall::CrowdloanRewards(

1072

1

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

1073

1

								rewards: vec![(

1074

1

									[5u8; 32].into(),

1075

1

									Some(AccountId::from(DAVE)),

1076

1

									1_500_000 * MOVR

1077

1

)]

1078

1

1079

1

),

1080

1

						RuntimeCall::CrowdloanRewards(

1081

1

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

1082

1

								lease_ending_block: end_block

1083

1

1084

1

1085

1

1086

1

})

1087

1

				.dispatch(root_origin())

1088

1

);

1089

1090

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1091

1

1092

1

			// Assert precompile reports Bob is not a contributor

1093

1

			Precompiles::new()

1094

1

				.prepare_test(

1095

1

					ALICE,

1096

1

					crowdloan_precompile_address,

1097

1

					CrowdloanRewardsPCall::is_contributor {

1098

1

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

1099

1

},

1100

1

1101

1

				.expect_cost(1669)

1102

1

				.expect_no_logs()

1103

1

				.execute_returns(false);

1104

1

1105

1

			// Assert precompile reports Charlie is a nominator

1106

1

			Precompiles::new()

1107

1

				.prepare_test(

1108

1

					ALICE,

1109

1

					crowdloan_precompile_address,

1110

1

					CrowdloanRewardsPCall::is_contributor {

1111

1

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

1112

1

},

1113

1

1114

1

				.expect_cost(1669)

1115

1

				.expect_no_logs()

1116

1

				.execute_returns(true);

1117

1

})

1118

1

1119

1120

#[test]

1121

1

fn reward_info_via_precompile() {

1122

1

	ExtBuilder::default()

1123

1

		.with_balances(vec![

1124

1

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

1125

1

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

1126

1

])

1127

1

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

1128

1

		.with_mappings(vec![(

1129

1

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

1130

1

			AccountId::from(ALICE),

1131

1

)])

1132

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1133

1

		.build()

1134

1

		.execute_with(|| {

1135

1

			// set parachain inherent data

1136

1

			set_parachain_inherent_data();

1137

1

			let init_block = CrowdloanRewards::init_vesting_block();

1138

1

			// This matches the previous vesting

1139

1

			let end_block = init_block + 4 * WEEKS;

1140

1

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

1141

1

			assert_ok!(

1142

1

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

1143

1

					calls: vec![

1144

1

						RuntimeCall::CrowdloanRewards(

1145

1

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

1146

1

								rewards: vec![(

1147

1

									[4u8; 32].into(),

1148

1

									Some(AccountId::from(CHARLIE)),

1149

1

									1_500_000 * MOVR

1150

1

)]

1151

1

1152

1

),

1153

1

						RuntimeCall::CrowdloanRewards(

1154

1

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

1155

1

								rewards: vec![(

1156

1

									[5u8; 32].into(),

1157

1

									Some(AccountId::from(DAVE)),

1158

1

									1_500_000 * MOVR

1159

1

)]

1160

1

1161

1

),

1162

1

						RuntimeCall::CrowdloanRewards(

1163

1

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

1164

1

								lease_ending_block: end_block

1165

1

1166

1

1167

1

1168

1

})

1169

1

				.dispatch(root_origin())

1170

1

);

1171

1172

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1173

1

1174

1

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

1175

1

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

1176

1

1177

1

			// Assert precompile reports correct Charlie reward info.

1178

1

			Precompiles::new()

1179

1

				.prepare_test(

1180

1

					ALICE,

1181

1

					crowdloan_precompile_address,

1182

1

					CrowdloanRewardsPCall::reward_info {

1183

1

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

1184

1

},

1185

1

1186

1

				.expect_cost(1669)

1187

1

				.expect_no_logs()

1188

1

				.execute_returns((expected_total, expected_claimed));

1189

1

})

1190

1

1191

1192

#[test]

1193

1

fn update_reward_address_via_precompile() {

1194

1

	ExtBuilder::default()

1195

1

		.with_balances(vec![

1196

1

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

1197

1

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

1198

1

])

1199

1

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

1200

1

		.with_mappings(vec![(

1201

1

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

1202

1

			AccountId::from(ALICE),

1203

1

)])

1204

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1205

1

		.build()

1206

1

		.execute_with(|| {

1207

1

			// set parachain inherent data

1208

1

			set_parachain_inherent_data();

1209

1

			let init_block = CrowdloanRewards::init_vesting_block();

1210

1

			// This matches the previous vesting

1211

1

			let end_block = init_block + 4 * WEEKS;

1212

1

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

1213

1

			assert_ok!(

1214

1

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

1215

1

					calls: vec![

1216

1

						RuntimeCall::CrowdloanRewards(

1217

1

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

1218

1

								rewards: vec![(

1219

1

									[4u8; 32].into(),

1220

1

									Some(AccountId::from(CHARLIE)),

1221

1

									1_500_000 * MOVR

1222

1

)]

1223

1

1224

1

),

1225

1

						RuntimeCall::CrowdloanRewards(

1226

1

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

1227

1

								rewards: vec![(

1228

1

									[5u8; 32].into(),

1229

1

									Some(AccountId::from(DAVE)),

1230

1

									1_500_000 * MOVR

1231

1

)]

1232

1

1233

1

),

1234

1

						RuntimeCall::CrowdloanRewards(

1235

1

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

1236

1

								lease_ending_block: end_block

1237

1

1238

1

1239

1

1240

1

})

1241

1

				.dispatch(root_origin())

1242

1

);

1243

1244

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1245

1

1246

1

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

1247

1

			let gas_limit = 100000u64;

1248

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1249

1

1250

1

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

1251

1

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

1252

1

			call_data[0..4]

1253

1

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

1254

1

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

1255

1

1256

1

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

1257

1

				source: H160::from(CHARLIE),

1258

1

				target: crowdloan_precompile_address,

1259

1

				input: call_data,

1260

1

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

1261

1

				gas_limit,

1262

1

				max_fee_per_gas: gas_price,

1263

1

				max_priority_fee_per_gas: None,

1264

1

				nonce: None, // Use the next nonce

1265

1

				access_list: Vec::new(),

1266

1

})

1267

1

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

1268

1269

1

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

1270

1

			assert_eq!(

1271

1

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

1272

1

					.unwrap()

1273

1

					.claimed_reward,

1274

1

				(450_000 * MOVR)

1275

1

);

1276

1

})

1277

1

1278

1279

1

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

1280

1

where

1281

1

	F: FnMut() -> (),

1282

1

1283

1

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

1284

1

		.build_storage()

1285

1

		.unwrap()

1286

1

		.into();

1287

1

	t.execute_with(|| {

1288

1

		System::set_block_consumed_resources(w, 0);

1289

1

		assertions()

1290

1

});

1291

1

1292

1293

#[test]

1294

#[rustfmt::skip]

1295

1

fn length_fee_is_sensible() {

1296

1

	use sp_runtime::testing::TestXt;

1297

1

1298

1

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

1299

1

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

1300

1

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

1301

1

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

1302

1

1303

9

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

1304

9

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

1305

9

				.inclusion_fee

1306

9

				.expect("fee should be calculated")

1307

9

				.len_fee

1308

9

};

1309

1310

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

1311

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

1312

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

1313

		//                             |           |

1314

1

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

1315

1

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

1316

1

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

1317

1

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

1318

1

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

1319

1

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

1320

1

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

1321

1

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

1322

1

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

1323

1

});

1324

1

1325

1326

#[test]

1327

1

fn multiplier_can_grow_from_zero() {

1328

1

	use frame_support::traits::Get;

1329

1

1330

1

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

1331

1

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

1332

1

		* RuntimeBlockWeights::get()

1333

1

			.get(DispatchClass::Normal)

1334

1

			.max_total

1335

1

			.unwrap();

1336

1

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

1337

1

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

1338

1

	run_with_system_weight(target * 101 / 100, || {

1339

1

		let next =

1340

1

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

1341

1

		assert!(

1342

1

			next > minimum_multiplier,

1343

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

1344

			next,

1345

			minimum_multiplier

1346

);

1347

1

})

1348

1

1349

1350

#[test]

1351

1

fn ethereum_invalid_transaction() {

1352

1

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

1353

1

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

1354

1

		// on chain is rejected.

1355

1

		assert_eq!(

1356

1

			Executive::apply_extrinsic(unchecked_eth_tx(INVALID_ETH_TX)),

1357

1

			Err(

1358

1

				sp_runtime::transaction_validity::TransactionValidityError::Invalid(

1359

1

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

1360

1

1361

1

1362

1

);

1363

1

});

1364

1

1365

1366

#[test]

1367

1

fn initial_gas_fee_is_correct() {

1368

1

	use fp_evm::FeeCalculator;

1369

1

1370

1

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

1371

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1372

1

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

1373

1374

1

		assert_eq!(

1375

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1376

1

1377

1

				3_125_000_000u128.into(),

1378

1

				Weight::from_parts(41_742_000u64, 0)

1379

1

1380

1

);

1381

1

});

1382

1

1383

1384

#[test]

1385

1

fn min_gas_fee_is_correct() {

1386

1

	use fp_evm::FeeCalculator;

1387

1

	use frame_support::traits::Hooks;

1388

1

1389

1

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

1390

1

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

1391

1

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

1392

1

1393

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1394

1

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

1395

1396

1

		assert_eq!(

1397

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1398

1

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

1399

1

);

1400

1

});

1401

1

1402

1403

#[test]

1404

1

fn transfer_ed_0_substrate() {

1405

1

	ExtBuilder::default()

1406

1

		.with_balances(vec![

1407

1

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

1408

1

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

1409

1

])

1410

1

		.build()

1411

1

		.execute_with(|| {

1412

1

			// Substrate transfer

1413

1

			assert_ok!(Balances::transfer_allow_death(

1414

1

				origin_of(AccountId::from(ALICE)),

1415

1

				AccountId::from(BOB),

1416

1

				1 * MOVR,

1417

1

));

1418

			// 1 WEI is left in the account

1419

1

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

1420

1

});

1421

1

1422

1423

#[test]

1424

1

fn transfer_ed_0_evm() {

1425

1

	ExtBuilder::default()

1426

1

		.with_balances(vec![

1427

1

1428

1

				AccountId::from(ALICE),

1429

1

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

1430

1

),

1431

1

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

1432

1

])

1433

1

		.build()

1434

1

		.execute_with(|| {

1435

1

			set_parachain_inherent_data();

1436

1

			// EVM transfer

1437

1

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

1438

1

				source: H160::from(ALICE),

1439

1

				target: H160::from(BOB),

1440

1

				input: Vec::new(),

1441

1

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

1442

1

				gas_limit: 21_000u64,

1443

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1444

1

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

1445

1

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

1446

1

				access_list: Vec::new(),

1447

1

})

1448

1

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

1449

			// 1 WEI is left in the account

1450

1

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

1451

1

});

1452

1

1453

1454

#[test]

1455

1

fn refund_ed_0_evm() {

1456

1

	ExtBuilder::default()

1457

1

		.with_balances(vec![

1458

1

1459

1

				AccountId::from(ALICE),

1460

1

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

1461

1

),

1462

1

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

1463

1

])

1464

1

		.build()

1465

1

		.execute_with(|| {

1466

1

			set_parachain_inherent_data();

1467

1

			// EVM transfer that zeroes ALICE

1468

1

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

1469

1

				source: H160::from(ALICE),

1470

1

				target: H160::from(BOB),

1471

1

				input: Vec::new(),

1472

1

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

1473

1

				gas_limit: 21_777u64,

1474

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1475

1

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

1476

1

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

1477

1

				access_list: Vec::new(),

1478

1

})

1479

1

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

1480

			// ALICE is refunded

1481

1

			assert_eq!(

1482

1

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

1483

1

				777 * BASE_FEE_GENESIS + existential_deposit(),

1484

1

);

1485

1

});

1486

1

1487

1488

#[test]

1489

1

fn author_does_receive_priority_fee() {

1490

1

	ExtBuilder::default()

1491

1

		.with_balances(vec![(

1492

1

			AccountId::from(BOB),

1493

1

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

1494

1

)])

1495

1

		.build()

1496

1

		.execute_with(|| {

1497

1

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

1498

1

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

1499

1

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

1500

1

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

1501

1

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

1502

1

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

1503

1

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

1504

1

1505

1

			// EVM transfer.

1506

1

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

1507

1

				source: H160::from(BOB),

1508

1

				target: H160::from(ALICE),

1509

1

				input: Vec::new(),

1510

1

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

1511

1

				gas_limit: 21_000u64,

1512

1

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

1513

1

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

1514

1

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

1515

1

				access_list: Vec::new(),

1516

1

})

1517

1

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

1518

1519

1

			let priority_fee = 200 * GIGAWEI * 21_000;

1520

1

			// Author free balance increased by priority fee.

1521

1

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

1522

1

});

1523

1

1524

1525

#[test]

1526

1

fn total_issuance_after_evm_transaction_with_priority_fee() {

1527

1

	use fp_evm::FeeCalculator;

1528

1

	ExtBuilder::default()

1529

1

		.with_balances(vec![

1530

1

1531

1

				AccountId::from(BOB),

1532

1

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

1533

1

),

1534

1

1535

1

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

1536

1

				existential_deposit(),

1537

1

),

1538

1

])

1539

1

		.build()

1540

1

		.execute_with(|| {

1541

1

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

1542

1

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

1543

1

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

1544

1

			// EVM transfer.

1545

1

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

1546

1

				source: H160::from(BOB),

1547

1

				target: H160::from(ALICE),

1548

1

				input: Vec::new(),

1549

1

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

1550

1

				gas_limit: 21_000u64,

1551

1

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

1552

1

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

1553

1

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

1554

1

				access_list: Vec::new(),

1555

1

})

1556

1

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

1557

1558

1

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

1559

1

1560

1

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

1561

1

1562

1

			let base_fee: Balance = base_fee * 21_000;

1563

1

1564

1

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

1565

1

1566

1

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

1567

1

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

1568

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1569

1

1570

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1571

1572

1

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

1573

1

});

1574

1

1575

1576

#[test]

1577

1

fn total_issuance_after_evm_transaction_without_priority_fee() {

1578

1

	use fp_evm::FeeCalculator;

1579

1

	ExtBuilder::default()

1580

1

		.with_balances(vec![

1581

1

1582

1

				AccountId::from(BOB),

1583

1

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

1584

1

),

1585

1

1586

1

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

1587

1

				existential_deposit(),

1588

1

),

1589

1

])

1590

1

		.build()

1591

1

		.execute_with(|| {

1592

1

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

1593

1

			// EVM transfer.

1594

1

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

1595

1

				source: H160::from(BOB),

1596

1

				target: H160::from(ALICE),

1597

1

				input: Vec::new(),

1598

1

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

1599

1

				gas_limit: 21_000u64,

1600

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1601

1

				max_priority_fee_per_gas: None,

1602

1

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

1603

1

				access_list: Vec::new(),

1604

1

})

1605

1

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

1606

1607

1

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

1608

1

1609

1

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

1610

1

1611

1

			let base_fee: Balance = base_fee * 21_000;

1612

1

1613

1

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

1614

1

1615

1

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

1616

1

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

1617

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1618

1

1619

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1620

1621

1

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

1622

1

});

1623

1

1624

1625

#[test]

1626

1

fn root_can_change_default_xcm_vers() {

1627

1

	ExtBuilder::default()

1628

1

		.with_balances(vec![

1629

1

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

1630

1

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

1631

1

])

1632

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1633

1

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

1634

1

			metadata: AssetRegistrarMetadata {

1635

1

				name: b"RelayToken".to_vec(),

1636

1

				symbol: b"Relay".to_vec(),

1637

1

				decimals: 12,

1638

1

				is_frozen: false,

1639

1

},

1640

1

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

1641

1

			is_sufficient: true,

1642

1

}])

1643

1

		.build()

1644

1

		.execute_with(|| {

1645

1

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

1646

1

			let dest = Location {

1647

1

				parents: 1,

1648

1

				interior: [AccountId32 {

1649

1

					network: None,

1650

1

					id: [1u8; 32],

1651

1

}]

1652

1

				.into(),

1653

1

};

1654

1

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

1655

1

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

1656

1

			let (chain_part, beneficiary) =

1657

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

1658

1

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

1659

1

			// know with which version to send

1660

1

			assert_noop!(

1661

1

				PolkadotXcm::transfer_assets(

1662

1

					origin_of(AccountId::from(ALICE)),

1663

1

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

1664

1

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

1665

1

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

1666

1

0,

1667

1

					WeightLimit::Limited(4000000000.into())

1668

1

),

1669

1

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

1670

1

);

1671

1672

			// Root sets the defaultXcm

1673

1

			assert_ok!(PolkadotXcm::force_default_xcm_version(

1674

1

				root_origin(),

1675

1

				Some(3)

1676

1

));

1677

1678

			// Now transferring does not fail

1679

1

			assert_ok!(PolkadotXcm::transfer_assets(

1680

1

				origin_of(AccountId::from(ALICE)),

1681

1

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

1682

1

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

1683

1

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

1684

1

0,

1685

1

				WeightLimit::Limited(4000000000.into())

1686

1

));

1687

1

})

1688

1

1689

1690

#[test]

1691

1

fn asset_can_be_registered() {

1692

1

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

1693

1

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

1694

1

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

1695

1

		let asset_metadata = AssetRegistrarMetadata {

1696

1

			name: b"RelayToken".to_vec(),

1697

1

			symbol: b"Relay".to_vec(),

1698

1

			decimals: 12,

1699

1

			is_frozen: false,

1700

1

};

1701

1

		assert_ok!(AssetManager::register_foreign_asset(

1702

1

			moonriver_runtime::RuntimeOrigin::root(),

1703

1

			source_location,

1704

1

			asset_metadata,

1705

1

			1u128,

1706

1

			true

1707

1

));

1708

1

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

1709

1

});

1710

1

1711

1712

#[test]

1713

1

fn xcm_asset_erc20_precompiles_supply_and_balance() {

1714

1

	ExtBuilder::default()

1715

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1716

1

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

1717

1

			metadata: AssetRegistrarMetadata {

1718

1

				name: b"RelayToken".to_vec(),

1719

1

				symbol: b"Relay".to_vec(),

1720

1

				decimals: 12,

1721

1

				is_frozen: false,

1722

1

},

1723

1

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

1724

1

			is_sufficient: true,

1725

1

}])

1726

1

		.with_balances(vec![

1727

1

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

1728

1

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

1729

1

])

1730

1

		.build()

1731

1

		.execute_with(|| {

1732

1

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

1733

1

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

1734

1

1735

1

			// Its address is

1736

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1737

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1738

1

				relay_asset_id,

1739

1

);

1740

1

1741

1

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

1742

1

			assert_eq!(

1743

1

				moonriver_runtime::Assets::total_supply(relay_asset_id),

1744

1

				1_000 * MOVR

1745

1

);

1746

1747

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

1748

1

			Precompiles::new()

1749

1

				.prepare_test(

1750

1

					ALICE,

1751

1

					asset_precompile_address,

1752

1

					ForeignAssetsPCall::total_supply {},

1753

1

1754

1

				.expect_cost(3338)

1755

1

				.expect_no_logs()

1756

1

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

1757

1

1758

1

			// Access balanceOf through precompile

1759

1

			Precompiles::new()

1760

1

				.prepare_test(

1761

1

					ALICE,

1762

1

					asset_precompile_address,

1763

1

					ForeignAssetsPCall::balance_of {

1764

1

						who: Address(ALICE.into()),

1765

1

},

1766

1

1767

1

				.expect_cost(3338)

1768

1

				.expect_no_logs()

1769

1

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

1770

1

});

1771

1

1772

1773

#[test]

1774

1

fn xcm_asset_erc20_precompiles_transfer() {

1775

1

	ExtBuilder::default()

1776

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1777

1

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

1778

1

			metadata: AssetRegistrarMetadata {

1779

1

				name: b"RelayToken".to_vec(),

1780

1

				symbol: b"Relay".to_vec(),

1781

1

				decimals: 12,

1782

1

				is_frozen: false,

1783

1

},

1784

1

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

1785

1

			is_sufficient: true,

1786

1

}])

1787

1

		.with_balances(vec![

1788

1

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

1789

1

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

1790

1

])

1791

1

		.build()

1792

1

		.execute_with(|| {

1793

1

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

1794

1

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

1795

1

1796

1

			// Its address is

1797

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1798

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1799

1

				relay_asset_id,

1800

1

);

1801

1

1802

1

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

1803

1

			Precompiles::new()

1804

1

				.prepare_test(

1805

1

					ALICE,

1806

1

					asset_precompile_address,

1807

1

					ForeignAssetsPCall::transfer {

1808

1

						to: Address(BOB.into()),

1809

1

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

1810

1

},

1811

1

1812

1

				.expect_cost(24956)

1813

1

				.expect_log(log3(

1814

1

					asset_precompile_address,

1815

1

					SELECTOR_LOG_TRANSFER,

1816

1

					H160::from(ALICE),

1817

1

					H160::from(BOB),

1818

1

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

1819

1

))

1820

1

				.execute_returns(true);

1821

1

1822

1

			// Make sure BOB has 400 MOVR

1823

1

			Precompiles::new()

1824

1

				.prepare_test(

1825

1

					BOB,

1826

1

					asset_precompile_address,

1827

1

					ForeignAssetsPCall::balance_of {

1828

1

						who: Address(BOB.into()),

1829

1

},

1830

1

1831

1

				.expect_cost(3338)

1832

1

				.expect_no_logs()

1833

1

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

1834

1

});

1835

1

1836

1837

#[test]

1838

1

fn xcm_asset_erc20_precompiles_approve() {

1839

1

	ExtBuilder::default()

1840

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1841

1

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

1842

1

			metadata: AssetRegistrarMetadata {

1843

1

				name: b"RelayToken".to_vec(),

1844

1

				symbol: b"Relay".to_vec(),

1845

1

				decimals: 12,

1846

1

				is_frozen: false,

1847

1

},

1848

1

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

1849

1

			is_sufficient: true,

1850

1

}])

1851

1

		.with_balances(vec![

1852

1

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

1853

1

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

1854

1

])

1855

1

		.build()

1856

1

		.execute_with(|| {

1857

1

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

1858

1

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

1859

1

1860

1

			// Its address is

1861

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1862

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1863

1

				relay_asset_id,

1864

1

);

1865

1

1866

1

			// Aprove Bob for spending 400 MOVR from Alice

1867

1

			Precompiles::new()

1868

1

				.prepare_test(

1869

1

					ALICE,

1870

1

					asset_precompile_address,

1871

1

					ForeignAssetsPCall::approve {

1872

1

						spender: Address(BOB.into()),

1873

1

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

1874

1

},

1875

1

1876

1

				.expect_cost(15652)

1877

1

				.expect_log(log3(

1878

1

					asset_precompile_address,

1879

1

					SELECTOR_LOG_APPROVAL,

1880

1

					H160::from(ALICE),

1881

1

					H160::from(BOB),

1882

1

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

1883

1

))

1884

1

				.execute_returns(true);

1885

1

1886

1

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

1887

1

			Precompiles::new()

1888

1

				.prepare_test(

1889

1

					BOB,

1890

1

					asset_precompile_address,

1891

1

					ForeignAssetsPCall::transfer_from {

1892

1

						from: Address(ALICE.into()),

1893

1

						to: Address(CHARLIE.into()),

1894

1

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

1895

1

},

1896

1

1897

1

				.expect_cost(30253)

1898

1

				.expect_log(log3(

1899

1

					asset_precompile_address,

1900

1

					SELECTOR_LOG_TRANSFER,

1901

1

					H160::from(ALICE),

1902

1

					H160::from(CHARLIE),

1903

1

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

1904

1

))

1905

1

				.execute_returns(true);

1906

1

1907

1

			// Make sure CHARLIE has 400 MOVR

1908

1

			Precompiles::new()

1909

1

				.prepare_test(

1910

1

					CHARLIE,

1911

1

					asset_precompile_address,

1912

1

					ForeignAssetsPCall::balance_of {

1913

1

						who: Address(CHARLIE.into()),

1914

1

},

1915

1

1916

1

				.expect_cost(3338)

1917

1

				.expect_no_logs()

1918

1

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

1919

1

});

1920

1

1921

1922

#[test]

1923

1

fn xtokens_precompiles_transfer() {

1924

1

	ExtBuilder::default()

1925

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1926

1

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

1927

1

			metadata: AssetRegistrarMetadata {

1928

1

				name: b"RelayToken".to_vec(),

1929

1

				symbol: b"Relay".to_vec(),

1930

1

				decimals: 12,

1931

1

				is_frozen: false,

1932

1

},

1933

1

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

1934

1

			is_sufficient: true,

1935

1

}])

1936

1

		.with_balances(vec![

1937

1

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

1938

1

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

1939

1

])

1940

1

		.with_safe_xcm_version(3)

1941

1

		.build()

1942

1

		.execute_with(|| {

1943

1

			let xtokens_precompile_address = H160::from_low_u64_be(2052);

1944

1

1945

1

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

1946

1

			let relay_asset_id: moonriver_runtime::AssetId =

1947

1

				AssetType::Xcm(xcm::v3::Location::parent()).into();

1948

1

1949

1

			// Its address is

1950

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1951

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1952

1

				relay_asset_id,

1953

1

);

1954

1

1955

1

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

1956

1

			let destination = Location::new(

1957

1

1,

1958

1

				[Junction::AccountId32 {

1959

1

					network: None,

1960

1

					id: [1u8; 32],

1961

1

}],

1962

1

);

1963

1

1964

1

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

1965

1

			Precompiles::new()

1966

1

				.prepare_test(

1967

1

					ALICE,

1968

1

					xtokens_precompile_address,

1969

1

					XtokensPCall::transfer {

1970

1

						currency_address: Address(asset_precompile_address.into()),

1971

1

						amount: 500_000_000_000_000u128.into(),

1972

1

						destination,

1973

1

						weight: 4_000_000,

1974

1

},

1975

1

1976

1

				.expect_cost(25190)

1977

1

				.expect_no_logs()

1978

1

				.execute_returns(())

1979

1

})

1980

1

1981

1982

#[test]

1983

1

fn xtokens_precompiles_transfer_multiasset() {

1984

1

	ExtBuilder::default()

1985

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1986

1

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

1987

1

			metadata: AssetRegistrarMetadata {

1988

1

				name: b"RelayToken".to_vec(),

1989

1

				symbol: b"Relay".to_vec(),

1990

1

				decimals: 12,

1991

1

				is_frozen: false,

1992

1

},

1993

1

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

1994

1

			is_sufficient: true,

1995

1

}])

1996

1

		.with_balances(vec![

1997

1

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

1998

1

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

1999

1

])

2000

1

		.with_safe_xcm_version(3)

2001

1

		.build()

2002

1

		.execute_with(|| {

2003

1

			let xtokens_precompile_address = H160::from_low_u64_be(2052);

2004

1

2005

1

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

2006

1

			let destination = Location::new(

2007

1

1,

2008

1

				[Junction::AccountId32 {

2009

1

					network: None,

2010

1

					id: [1u8; 32],

2011

1

}],

2012

1

);

2013

1

2014

1

			// This time we transfer it through TransferMultiAsset

2015

1

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

2016

1

			Precompiles::new()

2017

1

				.prepare_test(

2018

1

					ALICE,

2019

1

					xtokens_precompile_address,

2020

1

					XtokensPCall::transfer_multiasset {

2021

1

						// We want to transfer the relay token

2022

1

						asset: Location::parent(),

2023

1

						amount: 500_000_000_000_000u128.into(),

2024

1

						destination,

2025

1

						weight: 4_000_000,

2026

1

},

2027

1

2028

1

				.expect_cost(25190)

2029

1

				.expect_no_logs()

2030

1

				.execute_returns(());

2031

1

})

2032

1

2033

2034

#[test]

2035

1

fn make_sure_polkadot_xcm_cannot_be_called() {

2036

1

	ExtBuilder::default()

2037

1

		.with_balances(vec![

2038

1

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

2039

1

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

2040

1

])

2041

1

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

2042

1

		.with_mappings(vec![(

2043

1

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

2044

1

			AccountId::from(ALICE),

2045

1

)])

2046

1

		.build()

2047

1

		.execute_with(|| {

2048

1

			let dest = Location {

2049

1

				parents: 1,

2050

1

				interior: [AccountId32 {

2051

1

					network: None,

2052

1

					id: [1u8; 32],

2053

1

}]

2054

1

				.into(),

2055

1

};

2056

1

			let assets: Assets = [Asset {

2057

1

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

2058

1

				fun: Fungible(1000),

2059

1

}]

2060

1

			.to_vec()

2061

1

			.into();

2062

1

			assert_noop!(

2063

1

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

2064

1

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

2065

1

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

2066

1

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

2067

1

					fee_asset_item: 0,

2068

1

})

2069

1

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

2070

1

					AccountId::from(ALICE)

2071

1

)),

2072

1

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

2073

1

);

2074

1

});

2075

1

2076

2077

#[test]

2078

1

fn transactor_cannot_use_more_than_max_weight() {

2079

1

	ExtBuilder::default()

2080

1

		.with_balances(vec![

2081

1

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

2082

1

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

2083

1

])

2084

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2085

1

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

2086

1

			metadata: AssetRegistrarMetadata {

2087

1

				name: b"RelayToken".to_vec(),

2088

1

				symbol: b"Relay".to_vec(),

2089

1

				decimals: 12,

2090

1

				is_frozen: false,

2091

1

},

2092

1

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

2093

1

			is_sufficient: true,

2094

1

}])

2095

1

		.build()

2096

1

		.execute_with(|| {

2097

1

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

2098

1

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

2099

1

			assert_ok!(XcmTransactor::register(

2100

1

				root_origin(),

2101

1

				AccountId::from(ALICE),

2102

1

0,

2103

1

));

2104

2105

			// Root can set transact info

2106

1

			assert_ok!(XcmTransactor::set_transact_info(

2107

1

				root_origin(),

2108

1

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

2109

1

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

2110

1

				3000.into(),

2111

1

				20000.into(),

2112

1

				None

2113

1

));

2114

2115

			// Root can set transact info

2116

1

			assert_ok!(XcmTransactor::set_fee_per_second(

2117

1

				root_origin(),

2118

1

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

2119

1

2120

1

));

2121

2122

1

			assert_noop!(

2123

1

				XcmTransactor::transact_through_derivative(

2124

1

					origin_of(AccountId::from(ALICE)),

2125

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2126

1

0,

2127

1

					CurrencyPayment {

2128

1

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

2129

1

							Location::parent()

2130

1

						))),

2131

1

						fee_amount: None

2132

1

},

2133

1

					vec![],

2134

1

					// 2000 is the max

2135

1

					TransactWeights {

2136

1

						transact_required_weight_at_most: 17001.into(),

2137

1

						overall_weight: None

2138

1

},

2139

1

					false

2140

1

),

2141

1

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

2142

1

);

2143

1

			assert_noop!(

2144

1

				XcmTransactor::transact_through_derivative(

2145

1

					origin_of(AccountId::from(ALICE)),

2146

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2147

1

0,

2148

1

					CurrencyPayment {

2149

1

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

2150

1

						fee_amount: None

2151

1

},

2152

1

					vec![],

2153

1

					// 20000 is the max

2154

1

					TransactWeights {

2155

1

						transact_required_weight_at_most: 17001.into(),

2156

1

						overall_weight: None

2157

1

},

2158

1

					false

2159

1

),

2160

1

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

2161

1

);

2162

1

})

2163

1

2164

2165

#[test]

2166

1

fn transact_through_signed_precompile_works_v2() {

2167

1

	ExtBuilder::default()

2168

1

		.with_balances(vec![

2169

1

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

2170

1

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

2171

1

])

2172

1

		.with_safe_xcm_version(3)

2173

1

		.build()

2174

1

		.execute_with(|| {

2175

1

			// Destination

2176

1

			let dest = Location::parent();

2177

1

2178

1

			let fee_payer_asset = Location::parent();

2179

1

2180

1

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

2181

1

2182

1

			let total_weight = 1_000_000_000u64;

2183

1

2184

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2185

1

2186

1

			Precompiles::new()

2187

1

				.prepare_test(

2188

1

					ALICE,

2189

1

					xcm_transactor_v2_precompile_address,

2190

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2191

1

						dest,

2192

1

						fee_asset: fee_payer_asset,

2193

1

						weight: 4_000_000,

2194

1

						call: bytes.into(),

2195

1

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

2196

1

						overall_weight: total_weight,

2197

1

},

2198

1

2199

1

				.expect_cost(21890)

2200

1

				.expect_no_logs()

2201

1

				.execute_returns(());

2202

1

});

2203

1

2204

2205

#[test]

2206

1

fn transact_through_signed_cannot_send_to_local_chain() {

2207

1

	ExtBuilder::default()

2208

1

		.with_balances(vec![

2209

1

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

2210

1

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

2211

1

])

2212

1

		.with_safe_xcm_version(3)

2213

1

		.build()

2214

1

		.execute_with(|| {

2215

1

			// Destination

2216

1

			let dest = Location::here();

2217

1

2218

1

			let fee_payer_asset = Location::parent();

2219

1

2220

1

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

2221

1

2222

1

			let total_weight = 1_000_000_000u64;

2223

1

2224

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2225

1

2226

1

			Precompiles::new()

2227

1

				.prepare_test(

2228

1

					ALICE,

2229

1

					xcm_transactor_v2_precompile_address,

2230

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2231

1

						dest,

2232

1

						fee_asset: fee_payer_asset,

2233

1

						weight: 4_000_000,

2234

1

						call: bytes.into(),

2235

1

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

2236

1

						overall_weight: total_weight,

2237

1

},

2238

1

2239

1

				.execute_reverts(|output| {

2240

1

					from_utf8(&output)

2241

1

						.unwrap()

2242

1

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

2243

1

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

2244

1

});

2245

1

});

2246

1

2247

2248

#[test]

2249

1

fn call_xtokens_with_fee() {

2250

1

	ExtBuilder::default()

2251

1

		.with_balances(vec![

2252

1

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

2253

1

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

2254

1

])

2255

1

		.with_safe_xcm_version(3)

2256

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2257

1

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

2258

1

			metadata: AssetRegistrarMetadata {

2259

1

				name: b"RelayToken".to_vec(),

2260

1

				symbol: b"Relay".to_vec(),

2261

1

				decimals: 12,

2262

1

				is_frozen: false,

2263

1

},

2264

1

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

2265

1

			is_sufficient: true,

2266

1

}])

2267

1

		.build()

2268

1

		.execute_with(|| {

2269

1

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

2270

1

			let dest = Location {

2271

1

				parents: 1,

2272

1

				interior: [AccountId32 {

2273

1

					network: None,

2274

1

					id: [1u8; 32],

2275

1

}]

2276

1

				.into(),

2277

1

};

2278

1

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

2279

1

2280

1

			let before_balance =

2281

1

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

2282

1

2283

1

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

2284

1

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

2285

1

			let (chain_part, beneficiary) =

2286

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

2287

1

2288

1

			// We are able to transfer with fee

2289

1

			assert_ok!(PolkadotXcm::transfer_assets(

2290

1

				origin_of(AccountId::from(ALICE)),

2291

1

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

2292

1

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

2293

1

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

2294

1

0,

2295

1

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

2296

1

			),);

2297

2298

1

			let after_balance =

2299

1

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

2300

1

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

2301

1

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

2302

1

});

2303

1

2304

2305

#[test]

2306

1

fn test_xcm_utils_ml_tp_account() {

2307

1

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

2308

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2309

1

		let expected_address_parent: H160 =

2310

1

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

2311

1

				.unwrap()

2312

1

				.into();

2313

1

2314

1

		Precompiles::new()

2315

1

			.prepare_test(

2316

1

				ALICE,

2317

1

				xcm_utils_precompile_address,

2318

1

				XcmUtilsPCall::multilocation_to_address {

2319

1

					location: Location::parent(),

2320

1

},

2321

1

2322

1

			.expect_cost(1669)

2323

1

			.expect_no_logs()

2324

1

			.execute_returns(Address(expected_address_parent));

2325

1

2326

1

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

2327

1

		let expected_address_parachain: H160 =

2328

1

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

2329

1

				&parachain_2000_multilocation,

2330

1

2331

1

			.unwrap()

2332

1

			.into();

2333

1

2334

1

		Precompiles::new()

2335

1

			.prepare_test(

2336

1

				ALICE,

2337

1

				xcm_utils_precompile_address,

2338

1

				XcmUtilsPCall::multilocation_to_address {

2339

1

					location: parachain_2000_multilocation,

2340

1

},

2341

1

2342

1

			.expect_cost(1669)

2343

1

			.expect_no_logs()

2344

1

			.execute_returns(Address(expected_address_parachain));

2345

1

2346

1

		let alice_in_parachain_2000_location = Location::new(

2347

1

1,

2348

1

2349

1

				Parachain(2000),

2350

1

				AccountKey20 {

2351

1

					network: None,

2352

1

					key: ALICE,

2353

1

},

2354

1

],

2355

1

);

2356

1

		let expected_address_alice_in_parachain_2000 =

2357

1

			xcm_builder::HashedDescription::<

2358

1

				AccountId,

2359

1

				xcm_builder::DescribeFamily<xcm_builder::DescribeAllTerminal>,

2360

1

			>::convert_location(&alice_in_parachain_2000_location)

2361

1

			.unwrap()

2362

1

			.into();

2363

1

2364

1

		Precompiles::new()

2365

1

			.prepare_test(

2366

1

				ALICE,

2367

1

				xcm_utils_precompile_address,

2368

1

				XcmUtilsPCall::multilocation_to_address {

2369

1

					location: alice_in_parachain_2000_location,

2370

1

},

2371

1

2372

1

			.expect_cost(1669)

2373

1

			.expect_no_logs()

2374

1

			.execute_returns(Address(expected_address_alice_in_parachain_2000));

2375

1

});

2376

1

2377

2378

#[test]

2379

1

fn test_xcm_utils_weight_message() {

2380

1

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

2381

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2382

1

		let expected_weight =

2383

1

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

2384

1

2385

1

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

2386

1

2387

1

		let input = XcmUtilsPCall::weight_message {

2388

1

			message: message.into(),

2389

1

};

2390

1

2391

1

		Precompiles::new()

2392

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2393

1

			.expect_cost(0)

2394

1

			.expect_no_logs()

2395

1

			.execute_returns(expected_weight);

2396

1

});

2397

1

2398

2399

#[test]

2400

1

fn test_xcm_utils_get_units_per_second() {

2401

1

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

2402

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2403

1

		let location = SelfReserve::get();

2404

1

2405

1

		let input = XcmUtilsPCall::get_units_per_second { location };

2406

1

2407

1

		let expected_units =

2408

1

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

2409

1

2410

1

		Precompiles::new()

2411

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2412

1

			.expect_cost(1669)

2413

1

			.expect_no_logs()

2414

1

			.execute_returns(expected_units);

2415

1

});

2416

1

2417

2418

#[test]

2419

1

fn precompile_existence() {

2420

1

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

2421

1

		let precompiles = Precompiles::new();

2422

1

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

2423

1

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

2424

1

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

2425

1

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

2426

1

2427

1

		.into_iter()

2428

1

		.map(H160::from_low_u64_be)

2429

1

		.collect();

2430

2431

3001

		for i in 0..3000 {

2432

3000

			let address = H160::from_low_u64_be(i);

2433

3000

2434

3000

			if precompile_addresses.contains(&address) {

2435

40

				assert!(

2436

40

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

2437

					"is_precompile({}) should return true",

2438

2439

);

2440

2441

40

				assert!(

2442

40

					precompiles

2443

40

						.execute(&mut MockHandle::new(

2444

40

							address,

2445

40

							Context {

2446

40

								address,

2447

40

								caller: H160::zero(),

2448

40

								apparent_value: U256::zero()

2449

40

2450

40

),)

2451

40

						.is_some(),

2452

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

2453

2454

);

2455

			} else {

2456

2960

				assert!(

2457

2960

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

2458

					"is_precompile({}) should return false",

2459

2460

);

2461

2462

2960

				assert!(

2463

2960

					precompiles

2464

2960

						.execute(&mut MockHandle::new(

2465

2960

							address,

2466

2960

							Context {

2467

2960

								address,

2468

2960

								caller: H160::zero(),

2469

2960

								apparent_value: U256::zero()

2470

2960

2471

2960

),)

2472

2960

						.is_none(),

2473

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

2474

2475

);

2476

2477

2478

1

});

2479

1

2480

2481

#[test]

2482

1

fn removed_precompiles() {

2483

1

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

2484

1

		let precompiles = Precompiles::new();

2485

1

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

2486

2487

3000

		for i in 1..3000 {

2488

2999

			let address = H160::from_low_u64_be(i);

2489

2999

2490

2999

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

2491

2959

				continue;

2492

40

2493

40

2494

40

			if !removed_precompiles.contains(&i) {

2495

36

				assert!(

2496

36

					match precompiles.is_active_precompile(address, 100_000u64) {

2497

36

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

2498

						_ => false,

2499

},

2500

					"{i} should be an active precompile"

2501

);

2502

36

				continue;

2503

4

2504

4

2505

4

			assert!(

2506

4

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

2507

4

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

2508

					_ => false,

2509

},

2510

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

2511

);

2512

2513

4

			precompiles

2514

4

				.prepare_test(Alice, address, [])

2515

4

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

2516

2517

1

})

2518

1

2519

2520

#[test]

2521

1

fn deal_with_fees_handles_tip() {

2522

1

	use frame_support::traits::OnUnbalanced;

2523

1

	use moonbeam_runtime_common::deal_with_fees::DealWithSubstrateFeesAndTip;

2524

1

	use moonriver_runtime::Treasury;

2525

1

2526

1

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

2527

1

		set_parachain_inherent_data();

2528

1

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

2529

1

		// in the Moonriver runtime. It verifies that:

2530

1

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

2531

1

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

2532

1

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

2533

1

2534

1

		// The test details:

2535

1

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

2536

1

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

2537

1

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

2538

1

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

2539

1

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

2540

1

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

2541

1

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

2542

1

2543

1

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

2544

1

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

2545

1

			AccountId,

2546

1

		>>::issue(100);

2547

1

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

2548

1

			AccountId,

2549

1

		>>::issue(1000);

2550

1

2551

1

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

2552

1

		let total_supply_before = Balances::total_issuance();

2553

1

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

2554

1

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

2555

1

		assert_eq!(total_supply_before, 1_100);

2556

1

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

2557

2558

		// Step 3: Execute the fees handling logic.

2559

1

		DealWithSubstrateFeesAndTip::<

2560

1

			Runtime,

2561

1

			dynamic_params::runtime_config::FeesTreasuryProportion,

2562

1

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

2563

1

2564

1

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

2565

1

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

2566

1

2567

1

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

2568

1

		let burnt_fee_part: Balance = 100 - treasury_fee_part;

2569

1

2570

1

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

2571

1

		assert_eq!(

2572

1

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

2573

1

			treasury_fee_part,

2574

1

);

2575

2576

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

2577

1

		let total_supply_after = Balances::total_issuance();

2578

1

		assert_eq!(total_supply_before - total_supply_after, burnt_fee_part,);

2579

2580

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

2581

1

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

2582

1

		assert_eq!(

2583

1

			block_author_balance_after - block_author_balance_before,

2584

1

			1000,

2585

1

);

2586

1

});

2587

1

2588

2589

#[test]

2590

1

fn evm_revert_substrate_events() {

2591

1

	ExtBuilder::default()

2592

1

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

2593

1

		.build()

2594

1

		.execute_with(|| {

2595

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2596

1

2597

1

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

2598

1

			// Thus BatchAll will revert the transfer.

2599

1

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

2600

1

				source: ALICE.into(),

2601

1

				target: batch_precompile_address,

2602

1

				input: BatchPCall::batch_all {

2603

1

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

2604

1

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

2605

1

					call_data: vec![].into(),

2606

1

					gas_limit: vec![].into()

2607

1

2608

1

				.into(),

2609

1

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

2610

1

				gas_limit: 500_000,

2611

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2612

1

				max_priority_fee_per_gas: None,

2613

1

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

2614

1

				access_list: Vec::new(),

2615

1

})

2616

1

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

2617

2618

1

			let transfer_count = System::events()

2619

1

				.iter()

2620

6

				.filter(|r| match r.event {

2621

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

2622

6

					_ => false,

2623

6

})

2624

1

				.count();

2625

1

2626

1

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

2627

1

});

2628

1

2629

2630

#[test]

2631

1

fn evm_success_keeps_substrate_events() {

2632

1

	ExtBuilder::default()

2633

1

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

2634

1

		.build()

2635

1

		.execute_with(|| {

2636

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2637

1

2638

1

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

2639

1

				source: ALICE.into(),

2640

1

				target: batch_precompile_address,

2641

1

				input: BatchPCall::batch_all {

2642

1

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

2643

1

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

2644

1

					call_data: vec![].into(),

2645

1

					gas_limit: vec![].into()

2646

1

2647

1

				.into(),

2648

1

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

2649

1

				gas_limit: 500_000,

2650

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2651

1

				max_priority_fee_per_gas: None,

2652

1

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

2653

1

				access_list: Vec::new(),

2654

1

})

2655

1

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

2656

2657

1

			let transfer_count = System::events()

2658

1

				.iter()

2659

10

				.filter(|r| match r.event {

2660

1

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

2661

9

					_ => false,

2662

10

})

2663

1

				.count();

2664

1

2665

1

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

2666

1

});

2667

1

2668

2669

#[cfg(test)]

2670

mod treasury_tests {

2671

	use super::*;

2672

	use sp_runtime::traits::Hash;

2673

2674

2

	fn expect_events(events: Vec<RuntimeEvent>) {

2675

2

		let block_events: Vec<RuntimeEvent> =

2676

6

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

2677

2

2678

4

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

2679

2

2680

2681

4

	fn next_block() {

2682

4

		System::reset_events();

2683

4

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

2684

4

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

2685

4

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

2686

4

2687

2688

	#[test]

2689

1

	fn test_treasury_spend_local_with_council_origin() {

2690

1

		let initial_treasury_balance = 1_000 * MOVR;

2691

1

		ExtBuilder::default()

2692

1

			.with_balances(vec![

2693

1

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

2694

1

				(Treasury::account_id(), initial_treasury_balance),

2695

1

])

2696

1

			.build()

2697

1

			.execute_with(|| {

2698

1

				let spend_amount = 100u128 * MOVR;

2699

1

				let spend_beneficiary = AccountId::from(BOB);

2700

1

2701

1

				next_block();

2702

1

2703

1

				// TreasuryCouncilCollective

2704

1

				assert_ok!(TreasuryCouncilCollective::set_members(

2705

1

					root_origin(),

2706

1

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

2707

1

					Some(AccountId::from(ALICE)),

2708

1

2709

1

));

2710

2711

1

				next_block();

2712

1

2713

1

				// Perform treasury spending

2714

1

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

2715

1

					amount: spend_amount,

2716

1

					asset_kind: Box::new(()),

2717

1

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

2718

1

					valid_from: Some(5u32),

2719

1

});

2720

1

				assert_ok!(TreasuryCouncilCollective::propose(

2721

1

					origin_of(AccountId::from(ALICE)),

2722

1

1,

2723

1

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

2724

1

					1_000

2725

1

));

2726

2727

1

				let payout_period =

2728

1

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

2729

1

				let expected_events = [

2730

1

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

2731

1

						index: 0,

2732

1

						asset_kind: (),

2733

1

						amount: spend_amount,

2734

1

						beneficiary: spend_beneficiary,

2735

1

						valid_from: 5u32,

2736

1

						expire_at: payout_period + 5u32,

2737

1

}),

2738

1

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

2739

1

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

2740

1

						result: Ok(()),

2741

1

}),

2742

1

2743

1

				.to_vec();

2744

1

				expect_events(expected_events);

2745

2746

3

				while System::block_number() < 5u32 {

2747

2

					next_block();

2748

2

2749

2750

1

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

2751

2752

1

				let expected_events = [

2753

1

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

2754

1

						index: 0,

2755

1

						payment_id: (),

2756

1

}),

2757

1

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

2758

1

						from: Treasury::account_id(),

2759

1

						to: spend_beneficiary,

2760

1

						amount: spend_amount,

2761

1

}),

2762

1

2763

1

				.to_vec();

2764

1

				expect_events(expected_events);

2765

1

});

2766

1

2767

2768

2769

#[cfg(test)]

2770

mod fee_tests {

2771

	use super::*;

2772

	use fp_evm::FeeCalculator;

2773

	use frame_support::{

2774

		traits::{ConstU128, OnFinalize},

2775

		weights::{ConstantMultiplier, WeightToFee},

2776

};

2777

	use moonriver_runtime::{

2778

		currency, LengthToFee, MinimumMultiplier, RuntimeBlockWeights, SlowAdjustingFeeUpdate,

2779

		TargetBlockFullness, TransactionPaymentAsGasPrice, NORMAL_WEIGHT, WEIGHT_PER_GAS,

2780

};

2781

	use sp_core::Get;

2782

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

2783

2784

1

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

2785

1

	where

2786

1

		F: FnMut() -> (),

2787

1

2788

1

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

2789

1

			.build_storage()

2790

1

			.unwrap()

2791

1

			.into();

2792

1

		t.execute_with(|| {

2793

1

			System::set_block_consumed_resources(w, 0);

2794

1

			assertions()

2795

1

});

2796

1

2797

2798

	#[test]

2799

1

	fn test_multiplier_can_grow_from_zero() {

2800

1

		let minimum_multiplier = MinimumMultiplier::get();

2801

1

		let target = TargetBlockFullness::get()

2802

1

			* RuntimeBlockWeights::get()

2803

1

				.get(DispatchClass::Normal)

2804

1

				.max_total

2805

1

				.unwrap();

2806

1

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

2807

1

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

2808

1

		run_with_system_weight(target * 101 / 100, || {

2809

1

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

2810

1

			assert!(

2811

1

				next > minimum_multiplier,

2812

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

2813

				next,

2814

				minimum_multiplier

2815

);

2816

1

})

2817

1

2818

2819

	#[test]

2820

1

	fn test_fee_calculation() {

2821

1

		let base_extrinsic = RuntimeBlockWeights::get()

2822

1

			.get(DispatchClass::Normal)

2823

1

			.base_extrinsic;

2824

1

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

2825

1

		let extrinsic_len = 100u32;

2826

1

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

2827

1

		let tip = 42u128;

2828

1

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

2829

1

		type LengthToFeeImpl = LengthToFee;

2830

1

2831

1

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

2832

1

		let expected_fee = WeightToFeeImpl::weight_to_fee(&base_extrinsic)

2833

1

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

2834

1

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

2835

1

			+ tip;

2836

1

2837

1

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

2838

1

			.build_storage()

2839

1

			.unwrap()

2840

1

			.into();

2841

1

		t.execute_with(|| {

2842

1

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

2843

1

			let actual_fee = TransactionPayment::compute_fee(

2844

1

				extrinsic_len,

2845

1

				&frame_support::dispatch::DispatchInfo {

2846

1

					class: DispatchClass::Normal,

2847

1

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

2848

1

					weight: extrinsic_weight,

2849

1

},

2850

1

				tip,

2851

1

);

2852

1

2853

1

			assert_eq!(

2854

				expected_fee,

2855

				actual_fee,

2856

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

2857

				actual_fee - expected_fee

2858

);

2859

1

});

2860

1

2861

2862

	#[test]

2863

1

	fn test_min_gas_price_is_deterministic() {

2864

1

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

2865

1

			.build_storage()

2866

1

			.unwrap()

2867

1

			.into();

2868

1

		t.execute_with(|| {

2869

1

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

2870

1

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

2871

1

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

2872

1

			let expected: U256 = multiplier

2873

1

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

2874

1

				.into();

2875

1

2876

1

			assert_eq!(expected, actual);

2877

1

});

2878

1

2879

2880

	#[test]

2881

1

	fn test_min_gas_price_has_no_precision_loss_from_saturating_mul_int() {

2882

1

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

2883

1

			.build_storage()

2884

1

			.unwrap()

2885

1

			.into();

2886

1

		t.execute_with(|| {

2887

1

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

2888

1

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

2889

1

2890

1

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

2891

1

			let a = TransactionPaymentAsGasPrice::min_gas_price();

2892

1

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

2893

1

			let b = TransactionPaymentAsGasPrice::min_gas_price();

2894

1

2895

1

			assert_ne!(

2896

				a, b,

2897

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

2898

);

2899

1

});

2900

1

2901

2902

	#[test]

2903

1

	fn test_fee_scenarios() {

2904

1

		use sp_runtime::FixedU128;

2905

1

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

2906

1

			.build_storage()

2907

1

			.unwrap()

2908

1

			.into();

2909

1

		t.execute_with(|| {

2910

1

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

2911

12

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

2912

12

				let start_multiplier =

2913

12

					FixedU128::from_rational(start_gas_price, weight_fee_per_gas);

2914

12

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

2915

12

2916

12

				let block_weight = NORMAL_WEIGHT * fullness;

2917

2918

60004

				for i in 0..num_blocks {

2919

60004

					System::set_block_number(i as u32);

2920

60004

					System::set_block_consumed_resources(block_weight, 0);

2921

60004

					TransactionPayment::on_finalize(i as u32);

2922

60004

2923

2924

12

				TransactionPaymentAsGasPrice::min_gas_price().0

2925

12

};

2926

2927

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

2928

			// they are expected to change when parameters that influence

2929

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

2930

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

2931

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

2932

2933

1

			assert_eq!(

2934

1

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

2935

1

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

2936

1

);

2937

1

			assert_eq!(

2938

1

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

2939

1

				U256::from(312_500_000u128),

2940

1

);

2941

1

			assert_eq!(

2942

1

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

2943

1

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

2944

1

);

2945

1

			assert_eq!(

2946

1

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

2947

1

				U256::from(313_313_556u128),

2948

1

);

2949

2950

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

2951

1

			assert_eq!(

2952

1

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

2953

1

				U256::from(312_500_000u128),

2954

1

);

2955

1

			assert_eq!(

2956

1

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

2957

1

				U256::from(312_500_000u128),

2958

1

);

2959

1

			assert_eq!(

2960

1

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

2961

1

				U256::from(447_915_432u128),

2962

1

);

2963

1

			assert_eq!(

2964

1

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

2965

1

				U256::from(1_487_129_030u128),

2966

1

);

2967

2968

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

2969

1

			assert_eq!(

2970

1

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

2971

1

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

2972

1

);

2973

1

			assert_eq!(

2974

1

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

2975

1

				U256::from(312_500_000u128),

2976

1

);

2977

1

			assert_eq!(

2978

1

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

2979

1

				U256::from(1_766_664_654_709u128),

2980

1

);

2981

1

			assert_eq!(

2982

1

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

2983

1

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

2984

1

);

2985

1

});

2986

1

2987