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::{Currency as CurrencyT, EnsureOrigin, PalletInfo, StorageInfo, StorageInfoTrait},

30

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

31

	StorageHasher, Twox128,

32

};

33

use moonbeam_xcm_benchmarks::weights::XcmWeight;

34

use moonkit_xcm_primitives::AccountIdAssetIdConversion;

35

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

36

use moonriver_runtime::runtime_params::dynamic_params;

37

use moonriver_runtime::{

38

	asset_config::ForeignAssetInstance,

39

	xcm_config::{CurrencyId, SelfReserve},

40

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

41

	Precompiles, RuntimeBlockWeights, TransactionPayment, TransactionPaymentAsGasPrice,

42

	TreasuryCouncilCollective, XcmTransactor, FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX, WEEKS,

43

};

44

use nimbus_primitives::NimbusId;

45

use pallet_evm::PrecompileSet;

46

use pallet_evm_precompileset_assets_erc20::{SELECTOR_LOG_APPROVAL, SELECTOR_LOG_TRANSFER};

47

use pallet_transaction_payment::Multiplier;

48

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

49

use parity_scale_codec::Encode;

50

use polkadot_parachain::primitives::Sibling;

51

use precompile_utils::{

52

	precompile_set::{is_precompile_or_fail, IsActivePrecompile},

53

	prelude::*,

54

	testing::*,

55

};

56

use sha3::{Digest, Keccak256};

57

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

58

use sp_runtime::{

59

	traits::{Convert, Dispatchable},

60

	BuildStorage, DispatchError, ModuleError,

61

};

62

use std::str::from_utf8;

63

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

64

use xcm::{VersionedAssets, VersionedLocation};

65

use xcm_builder::{ParentIsPreset, SiblingParachainConvertsVia};

66

use xcm_executor::traits::ConvertLocation;

67

use xcm_primitives::split_location_into_chain_part_and_beneficiary;

68

69

type BatchPCall = pallet_evm_precompile_batch::BatchPrecompileCall<Runtime>;

70

type CrowdloanRewardsPCall =

71

	pallet_evm_precompile_crowdloan_rewards::CrowdloanRewardsPrecompileCall<Runtime>;

72

type XcmUtilsPCall = pallet_evm_precompile_xcm_utils::XcmUtilsPrecompileCall<

73

	Runtime,

74

	moonriver_runtime::xcm_config::XcmExecutorConfig,

75

>;

76

type XtokensPCall = pallet_evm_precompile_xtokens::XtokensPrecompileCall<Runtime>;

77

type ForeignAssetsPCall = pallet_evm_precompileset_assets_erc20::Erc20AssetsPrecompileSetCall<

78

	Runtime,

79

	ForeignAssetInstance,

80

>;

81

type XcmTransactorV2PCall =

82

	pallet_evm_precompile_xcm_transactor::v2::XcmTransactorPrecompileV2Call<Runtime>;

83

84

const BASE_FEE_GENESIS: u128 = 100 * GIGAWEI;

85

86

3

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

87

3

	Asset {

88

3

		id: AssetId(

89

3

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

90

3

				currency_id,

91

3

92

3

			.unwrap(),

93

3

),

94

3

		fun: Fungibility::Fungible(amount),

95

3

96

3

97

98

#[test]

99

1

fn xcmp_queue_controller_origin_is_root() {

100

1

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

101

1

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

102

1

	assert_ok!(

103

1

		<moonriver_runtime::Runtime as cumulus_pallet_xcmp_queue::Config

104

1

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

105

1

);

106

1

107

108

#[test]

109

1

fn verify_pallet_prefixes() {

110

30

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

111

30

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

112

30

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

113

30

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

114

30

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

115

30

		// expand/storage.rs#L389-L401

116

30

		assert_eq!(

117

30

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

118

30

			Some(name)

119

30

);

120

30

121

1

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

122

1

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

123

1

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

124

1

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

125

1

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

126

1

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

127

1

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

128

1

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

129

1

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

130

1

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

131

1

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

132

1

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

133

1

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

134

1

	is_pallet_prefix::<moonriver_runtime::OpenTechCommitteeCollective>(

135

1

		"OpenTechCommitteeCollective",

136

1

);

137

1

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

138

1

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

139

1

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

140

1

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

141

1

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

142

1

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

143

1

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

144

1

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

145

1

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

146

1

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

147

1

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

148

1

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

149

1

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

150

1

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

151

1

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

152

1

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

153

1

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

154

1

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

155

1

156

14

	let prefix = |pallet_name, storage_name| {

157

14

		let mut res = [0u8; 32];

158

14

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

159

14

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

160

14

		res.to_vec()

161

14

};

162

1

	assert_eq!(

163

1

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

164

1

		vec![

165

1

			StorageInfo {

166

1

				pallet_name: b"Timestamp".to_vec(),

167

1

				storage_name: b"Now".to_vec(),

168

1

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

169

1

				max_values: Some(1),

170

1

				max_size: Some(8),

171

1

},

172

1

			StorageInfo {

173

1

				pallet_name: b"Timestamp".to_vec(),

174

1

				storage_name: b"DidUpdate".to_vec(),

175

1

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

176

1

				max_values: Some(1),

177

1

				max_size: Some(1),

178

1

179

1

180

1

);

181

1

	assert_eq!(

182

1

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

183

1

		vec![

184

1

			StorageInfo {

185

1

				pallet_name: b"Balances".to_vec(),

186

1

				storage_name: b"TotalIssuance".to_vec(),

187

1

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

188

1

				max_values: Some(1),

189

1

				max_size: Some(16),

190

1

},

191

1

			StorageInfo {

192

1

				pallet_name: b"Balances".to_vec(),

193

1

				storage_name: b"InactiveIssuance".to_vec(),

194

1

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

195

1

				max_values: Some(1),

196

1

				max_size: Some(16),

197

1

},

198

1

			StorageInfo {

199

1

				pallet_name: b"Balances".to_vec(),

200

1

				storage_name: b"Account".to_vec(),

201

1

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

202

1

				max_values: None,

203

1

				max_size: Some(100),

204

1

},

205

1

			StorageInfo {

206

1

				pallet_name: b"Balances".to_vec(),

207

1

				storage_name: b"Locks".to_vec(),

208

1

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

209

1

				max_values: None,

210

1

				max_size: Some(1287),

211

1

},

212

1

			StorageInfo {

213

1

				pallet_name: b"Balances".to_vec(),

214

1

				storage_name: b"Reserves".to_vec(),

215

1

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

216

1

				max_values: None,

217

1

				max_size: Some(1037),

218

1

},

219

1

			StorageInfo {

220

1

				pallet_name: b"Balances".to_vec(),

221

1

				storage_name: b"Holds".to_vec(),

222

1

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

223

1

				max_values: None,

224

1

				max_size: Some(55),

225

1

},

226

1

			StorageInfo {

227

1

				pallet_name: b"Balances".to_vec(),

228

1

				storage_name: b"Freezes".to_vec(),

229

1

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

230

1

				max_values: None,

231

1

				max_size: Some(37),

232

1

},

233

1

234

1

);

235

1

	assert_eq!(

236

1

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

237

1

		vec![

238

1

			StorageInfo {

239

1

				pallet_name: b"Proxy".to_vec(),

240

1

				storage_name: b"Proxies".to_vec(),

241

1

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

242

1

				max_values: None,

243

1

				max_size: Some(845),

244

1

},

245

1

			StorageInfo {

246

1

				pallet_name: b"Proxy".to_vec(),

247

1

				storage_name: b"Announcements".to_vec(),

248

1

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

249

1

				max_values: None,

250

1

				max_size: Some(1837),

251

1

252

1

253

1

);

254

1

	assert_eq!(

255

1

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

256

1

		vec![StorageInfo {

257

1

			pallet_name: b"MaintenanceMode".to_vec(),

258

1

			storage_name: b"MaintenanceMode".to_vec(),

259

1

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

260

1

			max_values: Some(1),

261

1

			max_size: None,

262

1

},]

263

1

);

264

1

	assert_eq!(

265

1

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

266

1

		vec![

267

1

			StorageInfo {

268

1

				pallet_name: b"RelayStorageRoots".to_vec(),

269

1

				storage_name: b"RelayStorageRoot".to_vec(),

270

1

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

271

1

				max_values: None,

272

1

				max_size: Some(44),

273

1

},

274

1

			StorageInfo {

275

1

				pallet_name: b"RelayStorageRoots".to_vec(),

276

1

				storage_name: b"RelayStorageRootKeys".to_vec(),

277

1

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

278

1

				max_values: Some(1),

279

1

				max_size: Some(121),

280

1

},

281

1

282

1

);

283

1

284

285

#[test]

286

1

fn test_collectives_storage_item_prefixes() {

287

6

	for StorageInfo { pallet_name, .. } in

288

7

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

289

290

6

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

291

292

293

6

	for StorageInfo { pallet_name, .. } in

294

7

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

295

296

6

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

297

298

1

299

300

#[test]

301

1

fn collective_set_members_root_origin_works() {

302

1

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

303

1

		// TreasuryCouncilCollective

304

1

		assert_ok!(TreasuryCouncilCollective::set_members(

305

1

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

306

1

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

307

1

			Some(AccountId::from(ALICE)),

308

1

309

1

));

310

		// OpenTechCommitteeCollective

311

1

		assert_ok!(OpenTechCommitteeCollective::set_members(

312

1

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

313

1

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

314

1

			Some(AccountId::from(ALICE)),

315

1

316

1

));

317

1

});

318

1

319

320

#[test]

321

1

fn collective_set_members_general_admin_origin_works() {

322

1

	use moonriver_runtime::{

323

1

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

324

1

};

325

1

326

1

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

327

1

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

328

1

		let alice = AccountId::from(ALICE);

329

1

330

1

		// TreasuryCouncilCollective

331

1

		let _ = Utility::dispatch_as(

332

1

			root_caller.clone(),

333

1

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

334

1

			Box::new(

335

1

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

336

1

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

337

1

					prime: Some(alice),

338

1

					old_count: 2,

339

1

340

1

				.into(),

341

1

),

342

1

);

343

1

		// OpenTechCommitteeCollective

344

1

		let _ = Utility::dispatch_as(

345

1

			root_caller,

346

1

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

347

1

			Box::new(

348

1

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

349

1

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

350

1

					prime: Some(alice),

351

1

					old_count: 2,

352

1

353

1

				.into(),

354

1

),

355

1

);

356

1

357

1

		assert_eq!(

358

1

			System::events()

359

1

				.into_iter()

360

2

				.filter_map(|r| {

361

2

					match r.event {

362

2

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

363

2

							if result.is_ok() =>

364

2

365

2

							Some(true)

366

367

						_ => None,

368

369

2

})

370

1

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

371

1

				.len(),

372

1

373

1

374

1

});

375

1

376

377

#[test]

378

1

fn collective_set_members_signed_origin_does_not_work() {

379

1

	let alice = AccountId::from(ALICE);

380

1

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

381

1

		// TreasuryCouncilCollective

382

1

		assert!(TreasuryCouncilCollective::set_members(

383

1

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

384

1

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

385

1

			Some(AccountId::from(ALICE)),

386

1

387

1

388

1

		.is_err());

389

		// OpenTechCommitteeCollective

390

1

		assert!(OpenTechCommitteeCollective::set_members(

391

1

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

392

1

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

393

1

			Some(AccountId::from(ALICE)),

394

1

395

1

396

1

		.is_err());

397

1

});

398

1

399

400

#[test]

401

1

fn verify_pallet_indices() {

402

32

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

403

32

		assert_eq!(

404

32

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

405

32

			Some(index)

406

32

);

407

32

408

1

	// System support

409

1

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

410

1

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

411

1

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

412

1

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

413

1

	// Monetary

414

1

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

415

1

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

416

1

	// Consensus support

417

1

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

418

1

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

419

1

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

420

1

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

421

1

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

422

1

	// Handy utilities

423

1

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

424

1

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

425

1

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

426

1

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

427

1

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

428

1

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

429

1

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

430

1

	// Ethereum compatibility

431

1

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

432

1

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

433

1

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

434

1

	// Governance

435

1

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

436

1

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

437

1

	// Council

438

1

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

439

1

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

440

1

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

441

1

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

442

1

	// Treasury

443

1

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

444

1

	// Crowdloan

445

1

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

446

1

	// XCM Stuff

447

1

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

448

1

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

449

1

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

450

1

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

451

1

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

452

1

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

453

1

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

454

1

455

456

#[test]

457

1

fn verify_reserved_indices() {

458

1

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

459

1

		.build_storage()

460

1

		.unwrap()

461

1

		.into();

462

1

463

1

	t.execute_with(|| {

464

1

		use frame_metadata::*;

465

1

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

466

1

		let metadata = match metadata.1 {

467

1

			RuntimeMetadata::V14(metadata) => metadata,

468

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

469

};

470

		// 40: Sudo

471

		// 53: BaseFee

472

		// 108: pallet_assets::<Instance1>

473

1

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

474

1

		let existing = metadata

475

1

			.pallets

476

1

			.iter()

477

49

			.map(|p| p.index)

478

1

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

479

3

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

480

1

});

481

1

482

483

#[test]

484

1

fn verify_proxy_type_indices() {

485

1

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

486

1

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

487

1

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

488

1

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

489

1

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

490

1

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

491

1

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

492

1

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

493

1

494

495

#[test]

496

1

fn join_collator_candidates() {

497

1

	ExtBuilder::default()

498

1

		.with_balances(vec![

499

1

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

500

1

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

501

1

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

502

1

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

503

1

])

504

1

		.with_collators(vec![

505

1

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

506

1

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

507

1

])

508

1

		.with_delegations(vec![

509

1

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

510

1

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

511

1

])

512

1

		.build()

513

1

		.execute_with(|| {

514

1

			assert_noop!(

515

1

				ParachainStaking::join_candidates(

516

1

					origin_of(AccountId::from(ALICE)),

517

1

					10_000 * MOVR,

518

1

					2u32

519

1

),

520

1

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

521

1

);

522

1

			assert_noop!(

523

1

				ParachainStaking::join_candidates(

524

1

					origin_of(AccountId::from(CHARLIE)),

525

1

					10_000 * MOVR,

526

1

					2u32

527

1

),

528

1

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

529

1

);

530

1

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

531

1

			assert_ok!(ParachainStaking::join_candidates(

532

1

				origin_of(AccountId::from(DAVE)),

533

1

				10_000 * MOVR,

534

1

				2u32

535

1

));

536

1

			assert_eq!(

537

1

				last_event(),

538

1

				RuntimeEvent::ParachainStaking(

539

1

					pallet_parachain_staking::Event::JoinedCollatorCandidates {

540

1

						account: AccountId::from(DAVE),

541

1

						amount_locked: 10_000 * MOVR,

542

1

						new_total_amt_locked: 30_100 * MOVR

543

1

544

1

545

1

);

546

1

			let candidates = ParachainStaking::candidate_pool();

547

1

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

548

1

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

549

1

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

550

1

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

551

1

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

552

1

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

553

1

});

554

1

555

556

#[test]

557

1

fn transfer_through_evm_to_stake() {

558

1

	ExtBuilder::default()

559

1

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

560

1

		.build()

561

1

		.execute_with(|| {

562

1

			// Charlie has no balance => fails to stake

563

1

			assert_noop!(

564

1

				ParachainStaking::join_candidates(

565

1

					origin_of(AccountId::from(CHARLIE)),

566

1

					10_000 * MOVR,

567

1

					2u32

568

1

),

569

1

				DispatchError::Module(ModuleError {

570

1

					index: 20,

571

1

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

572

1

					message: Some("InsufficientBalance")

573

1

})

574

1

);

575

			// Alice transfer from free balance 20000 MOVR to Bob

576

1

			assert_ok!(Balances::transfer_allow_death(

577

1

				origin_of(AccountId::from(ALICE)),

578

1

				AccountId::from(BOB),

579

1

				20_000 * MOVR,

580

1

));

581

1

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

582

583

1

			let gas_limit = 100000u64;

584

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

585

1

			// Bob transfers 10000 MOVR to Charlie via EVM

586

1

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

587

1

				source: H160::from(BOB),

588

1

				target: H160::from(CHARLIE),

589

1

				input: vec![],

590

1

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

591

1

				gas_limit,

592

1

				max_fee_per_gas: gas_price,

593

1

				max_priority_fee_per_gas: None,

594

1

				nonce: None,

595

1

				access_list: Vec::new(),

596

1

})

597

1

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

598

1

			assert_eq!(

599

1

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

600

1

				10_000 * MOVR,

601

1

);

602

603

			// Charlie can stake now

604

1

			assert_ok!(ParachainStaking::join_candidates(

605

1

				origin_of(AccountId::from(CHARLIE)),

606

1

				10_000 * MOVR,

607

1

				2u32,

608

1

			),);

609

1

			let candidates = ParachainStaking::candidate_pool();

610

1

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

611

1

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

612

1

});

613

1

614

615

#[test]

616

1

fn reward_block_authors() {

617

1

	ExtBuilder::default()

618

1

		.with_balances(vec![

619

1

			// Alice gets 100 extra tokens for her mapping deposit

620

1

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

621

1

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

622

1

])

623

1

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

624

1

		.with_delegations(vec![(

625

1

			AccountId::from(BOB),

626

1

			AccountId::from(ALICE),

627

1

			500 * MOVR,

628

1

)])

629

1

		.with_mappings(vec![(

630

1

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

631

1

			AccountId::from(ALICE),

632

1

)])

633

1

		.build()

634

1

		.execute_with(|| {

635

1

			increase_last_relay_slot_number(1);

636

1

637

1

			// Just before round 3

638

1

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

639

1

640

1

			// no rewards doled out yet

641

1

			assert_eq!(

642

1

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

643

1

				10_100 * MOVR,

644

1

);

645

1

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

646

1

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

647

1

648

1

			// rewards minted and distributed

649

1

			assert_eq!(

650

1

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

651

1

				11547666666208000000000,

652

1

);

653

1

			assert_eq!(

654

1

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

655

1

				9557333332588000000000,

656

1

);

657

1

});

658

1

659

660

#[test]

661

1

fn reward_block_authors_with_parachain_bond_reserved() {

662

1

	ExtBuilder::default()

663

1

		.with_balances(vec![

664

1

			// Alice gets 100 extra tokens for her mapping deposit

665

1

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

666

1

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

667

1

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

668

1

])

669

1

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

670

1

		.with_delegations(vec![(

671

1

			AccountId::from(BOB),

672

1

			AccountId::from(ALICE),

673

1

			500 * MOVR,

674

1

)])

675

1

		.with_mappings(vec![(

676

1

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

677

1

			AccountId::from(ALICE),

678

1

)])

679

1

		.build()

680

1

		.execute_with(|| {

681

1

			increase_last_relay_slot_number(1);

682

1

			assert_ok!(ParachainStaking::set_parachain_bond_account(

683

1

				root_origin(),

684

1

				AccountId::from(CHARLIE),

685

1

			),);

686

687

			// Stop just before round 2

688

1

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

689

1

690

1

			// no collator rewards doled out yet

691

1

			assert_eq!(

692

1

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

693

1

				10_100 * MOVR,

694

1

);

695

1

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

696

697

			// Go to round 2

698

1

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

699

1

700

1

			// 30% reserved for parachain bond

701

1

			assert_eq!(

702

1

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

703

1

				452515000000000000000,

704

1

);

705

706

			// Go to round 3

707

1

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

708

1

709

1

			// rewards minted and distributed

710

1

			assert_eq!(

711

1

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

712

1

				11117700475903800000000,

713

1

);

714

1

			assert_eq!(

715

1

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

716

1

				9535834523343675000000,

717

1

);

718

			// 30% reserved for parachain bond again

719

1

			assert_eq!(

720

1

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

721

1

				910802725000000000000,

722

1

);

723

1

});

724

1

725

726

#[test]

727

1

fn initialize_crowdloan_addresses_with_batch_and_pay() {

728

1

	ExtBuilder::default()

729

1

		.with_balances(vec![

730

1

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

731

1

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

732

1

])

733

1

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

734

1

		.with_mappings(vec![(

735

1

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

736

1

			AccountId::from(ALICE),

737

1

)])

738

1

		.with_crowdloan_fund(3_000_000 * MOVR)

739

1

		.build()

740

1

		.execute_with(|| {

741

1

			// set parachain inherent data

742

1

			set_parachain_inherent_data();

743

1

			let init_block = CrowdloanRewards::init_vesting_block();

744

1

			// This matches the previous vesting

745

1

			let end_block = init_block + 48 * WEEKS;

746

1

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

747

1

			assert_ok!(

748

1

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

749

1

					calls: vec![

750

1

						RuntimeCall::CrowdloanRewards(

751

1

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

752

1

								rewards: vec![(

753

1

									[4u8; 32].into(),

754

1

									Some(AccountId::from(CHARLIE)),

755

1

									1_500_000 * MOVR

756

1

)]

757

1

758

1

),

759

1

						RuntimeCall::CrowdloanRewards(

760

1

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

761

1

								rewards: vec![(

762

1

									[5u8; 32].into(),

763

1

									Some(AccountId::from(DAVE)),

764

1

									1_500_000 * MOVR

765

1

)]

766

1

767

1

),

768

1

						RuntimeCall::CrowdloanRewards(

769

1

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

770

1

								lease_ending_block: end_block

771

1

772

1

773

1

774

1

})

775

1

				.dispatch(root_origin())

776

1

);

777

			// 30 percent initial payout

778

1

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

779

			// 30 percent initial payout

780

1

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

781

1

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

782

1

			assert_eq!(last_event(), expected);

783

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

784

1

			assert_ok!(

785

1

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

786

1

					calls: vec![RuntimeCall::CrowdloanRewards(

787

1

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

788

1

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

789

1

790

1

)]

791

1

})

792

1

				.dispatch(root_origin())

793

1

);

794

1

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

795

1

				index: 0,

796

1

				error: DispatchError::Module(ModuleError {

797

1

					index: 90,

798

1

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

799

1

					message: None,

800

1

}),

801

1

});

802

1

			assert_eq!(last_event(), expected_fail);

803

			// Claim 1 block.

804

1

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

805

1

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

806

807

1

			let vesting_period = 48 * WEEKS as u128;

808

1

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

809

1

810

1

			assert_eq!(

811

1

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

812

1

					.unwrap()

813

1

					.claimed_reward,

814

1

				(450_000 * MOVR) + per_block

815

1

);

816

1

			assert_eq!(

817

1

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

818

1

					.unwrap()

819

1

					.claimed_reward,

820

1

				(450_000 * MOVR) + per_block

821

1

);

822

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

823

1

			assert_eq!(

824

1

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

825

1

				(450_000 * MOVR) + per_block

826

1

);

827

1

			assert_eq!(

828

1

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

829

1

				(450_000 * MOVR) + per_block

830

1

);

831

1

			assert_noop!(

832

1

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

833

1

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

834

1

);

835

1

});

836

1

837

838

#[test]

839

1

fn initialize_crowdloan_address_and_change_with_relay_key_sig() {

840

1

	ExtBuilder::default()

841

1

		.with_balances(vec![

842

1

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

843

1

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

844

1

])

845

1

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

846

1

		.with_mappings(vec![(

847

1

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

848

1

			AccountId::from(ALICE),

849

1

)])

850

1

		.with_crowdloan_fund(3_000_000 * MOVR)

851

1

		.build()

852

1

		.execute_with(|| {

853

1

			// set parachain inherent data

854

1

			set_parachain_inherent_data();

855

1

			let init_block = CrowdloanRewards::init_vesting_block();

856

1

			// This matches the previous vesting

857

1

			let end_block = init_block + 4 * WEEKS;

858

1

859

1

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

860

1

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

861

1

862

1

			let public1 = pair1.public();

863

1

			let public2 = pair2.public();

864

1

865

1

			// signature:

866

1

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

867

1

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

868

1

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

869

1

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

870

1

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

871

1

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

872

1

			let signature1 = pair1.sign(&message);

873

1

			let signature2 = pair2.sign(&message);

874

1

875

1

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

876

1

			assert_ok!(

877

1

				// two relay accounts pointing at the same reward account

878

1

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

879

1

					calls: vec![

880

1

						RuntimeCall::CrowdloanRewards(

881

1

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

882

1

								rewards: vec![(

883

1

									public1.into(),

884

1

									Some(AccountId::from(CHARLIE)),

885

1

									1_500_000 * MOVR

886

1

)]

887

1

888

1

),

889

1

						RuntimeCall::CrowdloanRewards(

890

1

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

891

1

								rewards: vec![(

892

1

									public2.into(),

893

1

									Some(AccountId::from(CHARLIE)),

894

1

									1_500_000 * MOVR

895

1

)]

896

1

897

1

),

898

1

						RuntimeCall::CrowdloanRewards(

899

1

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

900

1

								lease_ending_block: end_block

901

1

902

1

903

1

904

1

})

905

1

				.dispatch(root_origin())

906

1

);

907

			// 30 percent initial payout

908

1

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

909

910

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

911

1

			assert_noop!(

912

1

				CrowdloanRewards::change_association_with_relay_keys(

913

1

					origin_of(AccountId::from(CHARLIE)),

914

1

					AccountId::from(DAVE),

915

1

					AccountId::from(CHARLIE),

916

1

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

917

1

),

918

1

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

919

1

);

920

921

			// this should be valid

922

1

			assert_ok!(CrowdloanRewards::change_association_with_relay_keys(

923

1

				origin_of(AccountId::from(CHARLIE)),

924

1

				AccountId::from(DAVE),

925

1

				AccountId::from(CHARLIE),

926

1

				vec![

927

1

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

928

1

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

929

1

930

1

));

931

932

1

			assert_eq!(

933

1

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

934

1

					.unwrap()

935

1

					.claimed_reward,

936

1

				(900_000 * MOVR)

937

1

);

938

1

});

939

1

940

941

#[test]

942

1

fn claim_via_precompile() {

943

1

	ExtBuilder::default()

944

1

		.with_balances(vec![

945

1

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

946

1

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

947

1

])

948

1

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

949

1

		.with_mappings(vec![(

950

1

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

951

1

			AccountId::from(ALICE),

952

1

)])

953

1

		.with_crowdloan_fund(3_000_000 * MOVR)

954

1

		.build()

955

1

		.execute_with(|| {

956

1

			// set parachain inherent data

957

1

			set_parachain_inherent_data();

958

1

			let init_block = CrowdloanRewards::init_vesting_block();

959

1

			// This matches the previous vesting

960

1

			let end_block = init_block + 4 * WEEKS;

961

1

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

962

1

			assert_ok!(

963

1

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

964

1

					calls: vec![

965

1

						RuntimeCall::CrowdloanRewards(

966

1

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

967

1

								rewards: vec![(

968

1

									[4u8; 32].into(),

969

1

									Some(AccountId::from(CHARLIE)),

970

1

									1_500_000 * MOVR

971

1

)]

972

1

973

1

),

974

1

						RuntimeCall::CrowdloanRewards(

975

1

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

976

1

								rewards: vec![(

977

1

									[5u8; 32].into(),

978

1

									Some(AccountId::from(DAVE)),

979

1

									1_500_000 * MOVR

980

1

)]

981

1

982

1

),

983

1

						RuntimeCall::CrowdloanRewards(

984

1

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

985

1

								lease_ending_block: end_block

986

1

987

1

988

1

989

1

})

990

1

				.dispatch(root_origin())

991

1

);

992

993

1

			assert!(CrowdloanRewards::initialized());

994

995

			// 30 percent initial payout

996

1

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

997

			// 30 percent initial payout

998

1

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

999

1000

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1001

1

1002

1

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

1003

1

			let gas_limit = 100000u64;

1004

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1005

1

1006

1

			// Construct the call data (selector, amount)

1007

1

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

1008

1

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

1009

1

1010

1

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

1011

1

				source: H160::from(CHARLIE),

1012

1

				target: crowdloan_precompile_address,

1013

1

				input: call_data,

1014

1

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

1015

1

				gas_limit,

1016

1

				max_fee_per_gas: gas_price,

1017

1

				max_priority_fee_per_gas: None,

1018

1

				nonce: None, // Use the next nonce

1019

1

				access_list: Vec::new(),

1020

1

})

1021

1

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

1022

1023

1

			let vesting_period = 4 * WEEKS as u128;

1024

1

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

1025

1

1026

1

			assert_eq!(

1027

1

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

1028

1

					.unwrap()

1029

1

					.claimed_reward,

1030

1

				(450_000 * MOVR) + per_block

1031

1

);

1032

1

})

1033

1

1034

1035

#[test]

1036

1

fn is_contributor_via_precompile() {

1037

1

	ExtBuilder::default()

1038

1

		.with_balances(vec![

1039

1

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

1040

1

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

1041

1

])

1042

1

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

1043

1

		.with_mappings(vec![(

1044

1

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

1045

1

			AccountId::from(ALICE),

1046

1

)])

1047

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1048

1

		.build()

1049

1

		.execute_with(|| {

1050

1

			// set parachain inherent data

1051

1

			set_parachain_inherent_data();

1052

1

			let init_block = CrowdloanRewards::init_vesting_block();

1053

1

			// This matches the previous vesting

1054

1

			let end_block = init_block + 4 * WEEKS;

1055

1

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

1056

1

			assert_ok!(

1057

1

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

1058

1

					calls: vec![

1059

1

						RuntimeCall::CrowdloanRewards(

1060

1

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

1061

1

								rewards: vec![(

1062

1

									[4u8; 32].into(),

1063

1

									Some(AccountId::from(CHARLIE)),

1064

1

									1_500_000 * MOVR

1065

1

)]

1066

1

1067

1

),

1068

1

						RuntimeCall::CrowdloanRewards(

1069

1

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

1070

1

								rewards: vec![(

1071

1

									[5u8; 32].into(),

1072

1

									Some(AccountId::from(DAVE)),

1073

1

									1_500_000 * MOVR

1074

1

)]

1075

1

1076

1

),

1077

1

						RuntimeCall::CrowdloanRewards(

1078

1

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

1079

1

								lease_ending_block: end_block

1080

1

1081

1

1082

1

1083

1

})

1084

1

				.dispatch(root_origin())

1085

1

);

1086

1087

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1088

1

1089

1

			// Assert precompile reports Bob is not a contributor

1090

1

			Precompiles::new()

1091

1

				.prepare_test(

1092

1

					ALICE,

1093

1

					crowdloan_precompile_address,

1094

1

					CrowdloanRewardsPCall::is_contributor {

1095

1

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

1096

1

},

1097

1

1098

1

				.expect_cost(1669)

1099

1

				.expect_no_logs()

1100

1

				.execute_returns(false);

1101

1

1102

1

			// Assert precompile reports Charlie is a nominator

1103

1

			Precompiles::new()

1104

1

				.prepare_test(

1105

1

					ALICE,

1106

1

					crowdloan_precompile_address,

1107

1

					CrowdloanRewardsPCall::is_contributor {

1108

1

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

1109

1

},

1110

1

1111

1

				.expect_cost(1669)

1112

1

				.expect_no_logs()

1113

1

				.execute_returns(true);

1114

1

})

1115

1

1116

1117

#[test]

1118

1

fn reward_info_via_precompile() {

1119

1

	ExtBuilder::default()

1120

1

		.with_balances(vec![

1121

1

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

1122

1

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

1123

1

])

1124

1

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

1125

1

		.with_mappings(vec![(

1126

1

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

1127

1

			AccountId::from(ALICE),

1128

1

)])

1129

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1130

1

		.build()

1131

1

		.execute_with(|| {

1132

1

			// set parachain inherent data

1133

1

			set_parachain_inherent_data();

1134

1

			let init_block = CrowdloanRewards::init_vesting_block();

1135

1

			// This matches the previous vesting

1136

1

			let end_block = init_block + 4 * WEEKS;

1137

1

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

1138

1

			assert_ok!(

1139

1

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

1140

1

					calls: vec![

1141

1

						RuntimeCall::CrowdloanRewards(

1142

1

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

1143

1

								rewards: vec![(

1144

1

									[4u8; 32].into(),

1145

1

									Some(AccountId::from(CHARLIE)),

1146

1

									1_500_000 * MOVR

1147

1

)]

1148

1

1149

1

),

1150

1

						RuntimeCall::CrowdloanRewards(

1151

1

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

1152

1

								rewards: vec![(

1153

1

									[5u8; 32].into(),

1154

1

									Some(AccountId::from(DAVE)),

1155

1

									1_500_000 * MOVR

1156

1

)]

1157

1

1158

1

),

1159

1

						RuntimeCall::CrowdloanRewards(

1160

1

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

1161

1

								lease_ending_block: end_block

1162

1

1163

1

1164

1

1165

1

})

1166

1

				.dispatch(root_origin())

1167

1

);

1168

1169

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1170

1

1171

1

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

1172

1

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

1173

1

1174

1

			// Assert precompile reports correct Charlie reward info.

1175

1

			Precompiles::new()

1176

1

				.prepare_test(

1177

1

					ALICE,

1178

1

					crowdloan_precompile_address,

1179

1

					CrowdloanRewardsPCall::reward_info {

1180

1

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

1181

1

},

1182

1

1183

1

				.expect_cost(1669)

1184

1

				.expect_no_logs()

1185

1

				.execute_returns((expected_total, expected_claimed));

1186

1

})

1187

1

1188

1189

#[test]

1190

1

fn update_reward_address_via_precompile() {

1191

1

	ExtBuilder::default()

1192

1

		.with_balances(vec![

1193

1

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

1194

1

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

1195

1

])

1196

1

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

1197

1

		.with_mappings(vec![(

1198

1

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

1199

1

			AccountId::from(ALICE),

1200

1

)])

1201

1

		.with_crowdloan_fund(3_000_000 * MOVR)

1202

1

		.build()

1203

1

		.execute_with(|| {

1204

1

			// set parachain inherent data

1205

1

			set_parachain_inherent_data();

1206

1

			let init_block = CrowdloanRewards::init_vesting_block();

1207

1

			// This matches the previous vesting

1208

1

			let end_block = init_block + 4 * WEEKS;

1209

1

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

1210

1

			assert_ok!(

1211

1

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

1212

1

					calls: vec![

1213

1

						RuntimeCall::CrowdloanRewards(

1214

1

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

1215

1

								rewards: vec![(

1216

1

									[4u8; 32].into(),

1217

1

									Some(AccountId::from(CHARLIE)),

1218

1

									1_500_000 * MOVR

1219

1

)]

1220

1

1221

1

),

1222

1

						RuntimeCall::CrowdloanRewards(

1223

1

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

1224

1

								rewards: vec![(

1225

1

									[5u8; 32].into(),

1226

1

									Some(AccountId::from(DAVE)),

1227

1

									1_500_000 * MOVR

1228

1

)]

1229

1

1230

1

),

1231

1

						RuntimeCall::CrowdloanRewards(

1232

1

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

1233

1

								lease_ending_block: end_block

1234

1

1235

1

1236

1

1237

1

})

1238

1

				.dispatch(root_origin())

1239

1

);

1240

1241

1

			let crowdloan_precompile_address = H160::from_low_u64_be(2049);

1242

1

1243

1

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

1244

1

			let gas_limit = 100000u64;

1245

1

			let gas_price: U256 = BASE_FEE_GENESIS.into();

1246

1

1247

1

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

1248

1

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

1249

1

			call_data[0..4]

1250

1

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

1251

1

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

1252

1

1253

1

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

1254

1

				source: H160::from(CHARLIE),

1255

1

				target: crowdloan_precompile_address,

1256

1

				input: call_data,

1257

1

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

1258

1

				gas_limit,

1259

1

				max_fee_per_gas: gas_price,

1260

1

				max_priority_fee_per_gas: None,

1261

1

				nonce: None, // Use the next nonce

1262

1

				access_list: Vec::new(),

1263

1

})

1264

1

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

1265

1266

1

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

1267

1

			assert_eq!(

1268

1

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

1269

1

					.unwrap()

1270

1

					.claimed_reward,

1271

1

				(450_000 * MOVR)

1272

1

);

1273

1

})

1274

1

1275

1276

1

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

1277

1

where

1278

1

	F: FnMut() -> (),

1279

1

1280

1

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

1281

1

		.build_storage()

1282

1

		.unwrap()

1283

1

		.into();

1284

1

	t.execute_with(|| {

1285

1

		System::set_block_consumed_resources(w, 0);

1286

1

		assertions()

1287

1

});

1288

1

1289

1290

#[test]

1291

#[rustfmt::skip]

1292

1

fn length_fee_is_sensible() {

1293

1

	use sp_runtime::testing::TestXt;

1294

1

1295

1

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

1296

1

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

1297

1

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

1298

1

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

1299

1

1300

9

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

1301

9

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

1302

9

				.inclusion_fee

1303

9

				.expect("fee should be calculated")

1304

9

				.len_fee

1305

9

};

1306

1307

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

1308

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

1309

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

1310

		//                             |           |

1311

1

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

1312

1

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

1313

1

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

1314

1

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

1315

1

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

1316

1

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

1317

1

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

1318

1

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

1319

1

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

1320

1

});

1321

1

1322

1323

#[test]

1324

1

fn multiplier_can_grow_from_zero() {

1325

1

	use frame_support::traits::Get;

1326

1

1327

1

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

1328

1

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

1329

1

		* RuntimeBlockWeights::get()

1330

1

			.get(DispatchClass::Normal)

1331

1

			.max_total

1332

1

			.unwrap();

1333

1

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

1334

1

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

1335

1

	run_with_system_weight(target * 101 / 100, || {

1336

1

		let next =

1337

1

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

1338

1

		assert!(

1339

1

			next > minimum_multiplier,

1340

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

1341

			next,

1342

			minimum_multiplier

1343

);

1344

1

})

1345

1

1346

1347

#[test]

1348

1

fn ethereum_invalid_transaction() {

1349

1

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

1350

1

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

1351

1

		// on chain is rejected.

1352

1

		assert_eq!(

1353

1

			Executive::apply_extrinsic(unchecked_eth_tx(INVALID_ETH_TX)),

1354

1

			Err(

1355

1

				sp_runtime::transaction_validity::TransactionValidityError::Invalid(

1356

1

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

1357

1

1358

1

1359

1

);

1360

1

});

1361

1

1362

1363

#[test]

1364

1

fn initial_gas_fee_is_correct() {

1365

1

	use fp_evm::FeeCalculator;

1366

1

1367

1

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

1368

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1369

1

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

1370

1371

1

		assert_eq!(

1372

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1373

1

1374

1

				3_125_000_000u128.into(),

1375

1

				Weight::from_parts(41_742_000u64, 0)

1376

1

1377

1

);

1378

1

});

1379

1

1380

1381

#[test]

1382

1

fn min_gas_fee_is_correct() {

1383

1

	use fp_evm::FeeCalculator;

1384

1

	use frame_support::traits::Hooks;

1385

1

1386

1

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

1387

1

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

1388

1

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

1389

1

1390

1

		let multiplier = TransactionPayment::next_fee_multiplier();

1391

1

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

1392

1393

1

		assert_eq!(

1394

1

			TransactionPaymentAsGasPrice::min_gas_price(),

1395

1

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

1396

1

);

1397

1

});

1398

1

1399

1400

#[test]

1401

1

fn transfer_ed_0_substrate() {

1402

1

	ExtBuilder::default()

1403

1

		.with_balances(vec![

1404

1

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

1405

1

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

1406

1

])

1407

1

		.build()

1408

1

		.execute_with(|| {

1409

1

			// Substrate transfer

1410

1

			assert_ok!(Balances::transfer_allow_death(

1411

1

				origin_of(AccountId::from(ALICE)),

1412

1

				AccountId::from(BOB),

1413

1

				1 * MOVR,

1414

1

));

1415

			// 1 WEI is left in the account

1416

1

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

1417

1

});

1418

1

1419

1420

#[test]

1421

1

fn transfer_ed_0_evm() {

1422

1

	ExtBuilder::default()

1423

1

		.with_balances(vec![

1424

1

1425

1

				AccountId::from(ALICE),

1426

1

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

1427

1

),

1428

1

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

1429

1

])

1430

1

		.build()

1431

1

		.execute_with(|| {

1432

1

			set_parachain_inherent_data();

1433

1

			// EVM transfer

1434

1

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

1435

1

				source: H160::from(ALICE),

1436

1

				target: H160::from(BOB),

1437

1

				input: Vec::new(),

1438

1

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

1439

1

				gas_limit: 21_000u64,

1440

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1441

1

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

1442

1

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

1443

1

				access_list: Vec::new(),

1444

1

})

1445

1

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

1446

			// 1 WEI is left in the account

1447

1

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

1448

1

});

1449

1

1450

1451

#[test]

1452

1

fn refund_ed_0_evm() {

1453

1

	ExtBuilder::default()

1454

1

		.with_balances(vec![

1455

1

1456

1

				AccountId::from(ALICE),

1457

1

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

1458

1

),

1459

1

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

1460

1

])

1461

1

		.build()

1462

1

		.execute_with(|| {

1463

1

			set_parachain_inherent_data();

1464

1

			// EVM transfer that zeroes ALICE

1465

1

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

1466

1

				source: H160::from(ALICE),

1467

1

				target: H160::from(BOB),

1468

1

				input: Vec::new(),

1469

1

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

1470

1

				gas_limit: 21_777u64,

1471

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1472

1

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

1473

1

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

1474

1

				access_list: Vec::new(),

1475

1

})

1476

1

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

1477

			// ALICE is refunded

1478

1

			assert_eq!(

1479

1

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

1480

1

				777 * BASE_FEE_GENESIS + existential_deposit(),

1481

1

);

1482

1

});

1483

1

1484

1485

#[test]

1486

1

fn author_does_receive_priority_fee() {

1487

1

	ExtBuilder::default()

1488

1

		.with_balances(vec![(

1489

1

			AccountId::from(BOB),

1490

1

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

1491

1

)])

1492

1

		.build()

1493

1

		.execute_with(|| {

1494

1

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

1495

1

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

1496

1

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

1497

1

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

1498

1

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

1499

1

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

1500

1

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

1501

1

1502

1

			// EVM transfer.

1503

1

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

1504

1

				source: H160::from(BOB),

1505

1

				target: H160::from(ALICE),

1506

1

				input: Vec::new(),

1507

1

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

1508

1

				gas_limit: 21_000u64,

1509

1

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

1510

1

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

1511

1

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

1512

1

				access_list: Vec::new(),

1513

1

})

1514

1

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

1515

1516

1

			let priority_fee = 200 * GIGAWEI * 21_000;

1517

1

			// Author free balance increased by priority fee.

1518

1

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

1519

1

});

1520

1

1521

1522

#[test]

1523

1

fn total_issuance_after_evm_transaction_with_priority_fee() {

1524

1

	use fp_evm::FeeCalculator;

1525

1

	ExtBuilder::default()

1526

1

		.with_balances(vec![

1527

1

1528

1

				AccountId::from(BOB),

1529

1

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

1530

1

),

1531

1

1532

1

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

1533

1

				existential_deposit(),

1534

1

),

1535

1

])

1536

1

		.build()

1537

1

		.execute_with(|| {

1538

1

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

1539

1

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

1540

1

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

1541

1

			// EVM transfer.

1542

1

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

1543

1

				source: H160::from(BOB),

1544

1

				target: H160::from(ALICE),

1545

1

				input: Vec::new(),

1546

1

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

1547

1

				gas_limit: 21_000u64,

1548

1

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

1549

1

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

1550

1

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

1551

1

				access_list: Vec::new(),

1552

1

})

1553

1

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

1554

1555

1

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

1556

1

1557

1

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

1558

1

1559

1

			let base_fee: Balance = base_fee * 21_000;

1560

1

1561

1

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

1562

1

1563

1

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

1564

1

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

1565

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1566

1

1567

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1568

1569

1

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

1570

1

});

1571

1

1572

1573

#[test]

1574

1

fn total_issuance_after_evm_transaction_without_priority_fee() {

1575

1

	use fp_evm::FeeCalculator;

1576

1

	ExtBuilder::default()

1577

1

		.with_balances(vec![

1578

1

1579

1

				AccountId::from(BOB),

1580

1

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

1581

1

),

1582

1

1583

1

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

1584

1

				existential_deposit(),

1585

1

),

1586

1

])

1587

1

		.build()

1588

1

		.execute_with(|| {

1589

1

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

1590

1

			// EVM transfer.

1591

1

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

1592

1

				source: H160::from(BOB),

1593

1

				target: H160::from(ALICE),

1594

1

				input: Vec::new(),

1595

1

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

1596

1

				gas_limit: 21_000u64,

1597

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

1598

1

				max_priority_fee_per_gas: None,

1599

1

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

1600

1

				access_list: Vec::new(),

1601

1

})

1602

1

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

1603

1604

1

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

1605

1

1606

1

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

1607

1

1608

1

			let base_fee: Balance = base_fee * 21_000;

1609

1

1610

1

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

1611

1

1612

1

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

1613

1

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

1614

1

			let burnt_base_fee_part: Balance = base_fee - treasury_base_fee_part;

1615

1

1616

1

			assert_eq!(issuance_after, issuance_before - burnt_base_fee_part);

1617

1618

1

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

1619

1

});

1620

1

1621

1622

#[test]

1623

1

fn root_can_change_default_xcm_vers() {

1624

1

	ExtBuilder::default()

1625

1

		.with_balances(vec![

1626

1

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

1627

1

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

1628

1

])

1629

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1630

1

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

1631

1

			metadata: AssetRegistrarMetadata {

1632

1

				name: b"RelayToken".to_vec(),

1633

1

				symbol: b"Relay".to_vec(),

1634

1

				decimals: 12,

1635

1

				is_frozen: false,

1636

1

},

1637

1

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

1638

1

			is_sufficient: true,

1639

1

}])

1640

1

		.build()

1641

1

		.execute_with(|| {

1642

1

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

1643

1

			let dest = Location {

1644

1

				parents: 1,

1645

1

				interior: [AccountId32 {

1646

1

					network: None,

1647

1

					id: [1u8; 32],

1648

1

}]

1649

1

				.into(),

1650

1

};

1651

1

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

1652

1

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

1653

1

			let (chain_part, beneficiary) =

1654

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

1655

1

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

1656

1

			// know with which version to send

1657

1

			assert_noop!(

1658

1

				PolkadotXcm::transfer_assets(

1659

1

					origin_of(AccountId::from(ALICE)),

1660

1

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

1661

1

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

1662

1

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

1663

1

0,

1664

1

					WeightLimit::Limited(4000000000.into())

1665

1

),

1666

1

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

1667

1

);

1668

1669

			// Root sets the defaultXcm

1670

1

			assert_ok!(PolkadotXcm::force_default_xcm_version(

1671

1

				root_origin(),

1672

1

				Some(2)

1673

1

));

1674

1675

			// Now transferring does not fail

1676

1

			assert_ok!(PolkadotXcm::transfer_assets(

1677

1

				origin_of(AccountId::from(ALICE)),

1678

1

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

1679

1

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

1680

1

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

1681

1

0,

1682

1

				WeightLimit::Limited(4000000000.into())

1683

1

));

1684

1

})

1685

1

1686

1687

#[test]

1688

1

fn asset_can_be_registered() {

1689

1

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

1690

1

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

1691

1

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

1692

1

		let asset_metadata = AssetRegistrarMetadata {

1693

1

			name: b"RelayToken".to_vec(),

1694

1

			symbol: b"Relay".to_vec(),

1695

1

			decimals: 12,

1696

1

			is_frozen: false,

1697

1

};

1698

1

		assert_ok!(AssetManager::register_foreign_asset(

1699

1

			moonriver_runtime::RuntimeOrigin::root(),

1700

1

			source_location,

1701

1

			asset_metadata,

1702

1

			1u128,

1703

1

			true

1704

1

));

1705

1

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

1706

1

});

1707

1

1708

1709

#[test]

1710

1

fn xcm_asset_erc20_precompiles_supply_and_balance() {

1711

1

	ExtBuilder::default()

1712

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1713

1

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

1714

1

			metadata: AssetRegistrarMetadata {

1715

1

				name: b"RelayToken".to_vec(),

1716

1

				symbol: b"Relay".to_vec(),

1717

1

				decimals: 12,

1718

1

				is_frozen: false,

1719

1

},

1720

1

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

1721

1

			is_sufficient: true,

1722

1

}])

1723

1

		.with_balances(vec![

1724

1

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

1725

1

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

1726

1

])

1727

1

		.build()

1728

1

		.execute_with(|| {

1729

1

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

1730

1

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

1731

1

1732

1

			// Its address is

1733

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1734

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1735

1

				relay_asset_id,

1736

1

);

1737

1

1738

1

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

1739

1

			assert_eq!(

1740

1

				moonriver_runtime::Assets::total_supply(relay_asset_id),

1741

1

				1_000 * MOVR

1742

1

);

1743

1744

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

1745

1

			Precompiles::new()

1746

1

				.prepare_test(

1747

1

					ALICE,

1748

1

					asset_precompile_address,

1749

1

					ForeignAssetsPCall::total_supply {},

1750

1

1751

1

				.expect_cost(3338)

1752

1

				.expect_no_logs()

1753

1

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

1754

1

1755

1

			// Access balanceOf through precompile

1756

1

			Precompiles::new()

1757

1

				.prepare_test(

1758

1

					ALICE,

1759

1

					asset_precompile_address,

1760

1

					ForeignAssetsPCall::balance_of {

1761

1

						who: Address(ALICE.into()),

1762

1

},

1763

1

1764

1

				.expect_cost(3338)

1765

1

				.expect_no_logs()

1766

1

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

1767

1

});

1768

1

1769

1770

#[test]

1771

1

fn xcm_asset_erc20_precompiles_transfer() {

1772

1

	ExtBuilder::default()

1773

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1774

1

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

1775

1

			metadata: AssetRegistrarMetadata {

1776

1

				name: b"RelayToken".to_vec(),

1777

1

				symbol: b"Relay".to_vec(),

1778

1

				decimals: 12,

1779

1

				is_frozen: false,

1780

1

},

1781

1

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

1782

1

			is_sufficient: true,

1783

1

}])

1784

1

		.with_balances(vec![

1785

1

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

1786

1

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

1787

1

])

1788

1

		.build()

1789

1

		.execute_with(|| {

1790

1

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

1791

1

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

1792

1

1793

1

			// Its address is

1794

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1795

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1796

1

				relay_asset_id,

1797

1

);

1798

1

1799

1

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

1800

1

			Precompiles::new()

1801

1

				.prepare_test(

1802

1

					ALICE,

1803

1

					asset_precompile_address,

1804

1

					ForeignAssetsPCall::transfer {

1805

1

						to: Address(BOB.into()),

1806

1

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

1807

1

},

1808

1

1809

1

				.expect_cost(24801)

1810

1

				.expect_log(log3(

1811

1

					asset_precompile_address,

1812

1

					SELECTOR_LOG_TRANSFER,

1813

1

					H160::from(ALICE),

1814

1

					H160::from(BOB),

1815

1

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

1816

1

))

1817

1

				.execute_returns(true);

1818

1

1819

1

			// Make sure BOB has 400 MOVR

1820

1

			Precompiles::new()

1821

1

				.prepare_test(

1822

1

					BOB,

1823

1

					asset_precompile_address,

1824

1

					ForeignAssetsPCall::balance_of {

1825

1

						who: Address(BOB.into()),

1826

1

},

1827

1

1828

1

				.expect_cost(3338)

1829

1

				.expect_no_logs()

1830

1

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

1831

1

});

1832

1

1833

1834

#[test]

1835

1

fn xcm_asset_erc20_precompiles_approve() {

1836

1

	ExtBuilder::default()

1837

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1838

1

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

1839

1

			metadata: AssetRegistrarMetadata {

1840

1

				name: b"RelayToken".to_vec(),

1841

1

				symbol: b"Relay".to_vec(),

1842

1

				decimals: 12,

1843

1

				is_frozen: false,

1844

1

},

1845

1

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

1846

1

			is_sufficient: true,

1847

1

}])

1848

1

		.with_balances(vec![

1849

1

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

1850

1

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

1851

1

])

1852

1

		.build()

1853

1

		.execute_with(|| {

1854

1

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

1855

1

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

1856

1

1857

1

			// Its address is

1858

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1859

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1860

1

				relay_asset_id,

1861

1

);

1862

1

1863

1

			// Aprove Bob for spending 400 MOVR from Alice

1864

1

			Precompiles::new()

1865

1

				.prepare_test(

1866

1

					ALICE,

1867

1

					asset_precompile_address,

1868

1

					ForeignAssetsPCall::approve {

1869

1

						spender: Address(BOB.into()),

1870

1

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

1871

1

},

1872

1

1873

1

				.expect_cost(15589)

1874

1

				.expect_log(log3(

1875

1

					asset_precompile_address,

1876

1

					SELECTOR_LOG_APPROVAL,

1877

1

					H160::from(ALICE),

1878

1

					H160::from(BOB),

1879

1

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

1880

1

))

1881

1

				.execute_returns(true);

1882

1

1883

1

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

1884

1

			Precompiles::new()

1885

1

				.prepare_test(

1886

1

					BOB,

1887

1

					asset_precompile_address,

1888

1

					ForeignAssetsPCall::transfer_from {

1889

1

						from: Address(ALICE.into()),

1890

1

						to: Address(CHARLIE.into()),

1891

1

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

1892

1

},

1893

1

1894

1

				.expect_cost(30061)

1895

1

				.expect_log(log3(

1896

1

					asset_precompile_address,

1897

1

					SELECTOR_LOG_TRANSFER,

1898

1

					H160::from(ALICE),

1899

1

					H160::from(CHARLIE),

1900

1

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

1901

1

))

1902

1

				.execute_returns(true);

1903

1

1904

1

			// Make sure CHARLIE has 400 MOVR

1905

1

			Precompiles::new()

1906

1

				.prepare_test(

1907

1

					CHARLIE,

1908

1

					asset_precompile_address,

1909

1

					ForeignAssetsPCall::balance_of {

1910

1

						who: Address(CHARLIE.into()),

1911

1

},

1912

1

1913

1

				.expect_cost(3338)

1914

1

				.expect_no_logs()

1915

1

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

1916

1

});

1917

1

1918

1919

#[test]

1920

1

fn xtokens_precompiles_transfer() {

1921

1

	ExtBuilder::default()

1922

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1923

1

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

1924

1

			metadata: AssetRegistrarMetadata {

1925

1

				name: b"RelayToken".to_vec(),

1926

1

				symbol: b"Relay".to_vec(),

1927

1

				decimals: 12,

1928

1

				is_frozen: false,

1929

1

},

1930

1

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

1931

1

			is_sufficient: true,

1932

1

}])

1933

1

		.with_balances(vec![

1934

1

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

1935

1

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

1936

1

])

1937

1

		.with_safe_xcm_version(2)

1938

1

		.build()

1939

1

		.execute_with(|| {

1940

1

			let xtokens_precompile_address = H160::from_low_u64_be(2052);

1941

1

1942

1

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

1943

1

			let relay_asset_id: moonriver_runtime::AssetId =

1944

1

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

1945

1

1946

1

			// Its address is

1947

1

			let asset_precompile_address = Runtime::asset_id_to_account(

1948

1

				FOREIGN_ASSET_PRECOMPILE_ADDRESS_PREFIX,

1949

1

				relay_asset_id,

1950

1

);

1951

1

1952

1

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

1953

1

			let destination = Location::new(

1954

1

1,

1955

1

				[Junction::AccountId32 {

1956

1

					network: None,

1957

1

					id: [1u8; 32],

1958

1

}],

1959

1

);

1960

1

1961

1

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

1962

1

			Precompiles::new()

1963

1

				.prepare_test(

1964

1

					ALICE,

1965

1

					xtokens_precompile_address,

1966

1

					XtokensPCall::transfer {

1967

1

						currency_address: Address(asset_precompile_address.into()),

1968

1

						amount: 500_000_000_000_000u128.into(),

1969

1

						destination,

1970

1

						weight: 4_000_000,

1971

1

},

1972

1

1973

1

				.expect_cost(24692)

1974

1

				.expect_no_logs()

1975

1

				.execute_returns(())

1976

1

})

1977

1

1978

1979

#[test]

1980

1

fn xtokens_precompiles_transfer_multiasset() {

1981

1

	ExtBuilder::default()

1982

1

		.with_xcm_assets(vec![XcmAssetInitialization {

1983

1

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

1984

1

			metadata: AssetRegistrarMetadata {

1985

1

				name: b"RelayToken".to_vec(),

1986

1

				symbol: b"Relay".to_vec(),

1987

1

				decimals: 12,

1988

1

				is_frozen: false,

1989

1

},

1990

1

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

1991

1

			is_sufficient: true,

1992

1

}])

1993

1

		.with_balances(vec![

1994

1

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

1995

1

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

1996

1

])

1997

1

		.with_safe_xcm_version(2)

1998

1

		.build()

1999

1

		.execute_with(|| {

2000

1

			let xtokens_precompile_address = H160::from_low_u64_be(2052);

2001

1

2002

1

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

2003

1

			let destination = Location::new(

2004

1

1,

2005

1

				[Junction::AccountId32 {

2006

1

					network: None,

2007

1

					id: [1u8; 32],

2008

1

}],

2009

1

);

2010

1

2011

1

			// This time we transfer it through TransferMultiAsset

2012

1

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

2013

1

			Precompiles::new()

2014

1

				.prepare_test(

2015

1

					ALICE,

2016

1

					xtokens_precompile_address,

2017

1

					XtokensPCall::transfer_multiasset {

2018

1

						// We want to transfer the relay token

2019

1

						asset: Location::parent(),

2020

1

						amount: 500_000_000_000_000u128.into(),

2021

1

						destination,

2022

1

						weight: 4_000_000,

2023

1

},

2024

1

2025

1

				.expect_cost(24692)

2026

1

				.expect_no_logs()

2027

1

				.execute_returns(());

2028

1

})

2029

1

2030

2031

#[test]

2032

1

fn make_sure_polkadot_xcm_cannot_be_called() {

2033

1

	ExtBuilder::default()

2034

1

		.with_balances(vec![

2035

1

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

2036

1

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

2037

1

])

2038

1

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

2039

1

		.with_mappings(vec![(

2040

1

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

2041

1

			AccountId::from(ALICE),

2042

1

)])

2043

1

		.build()

2044

1

		.execute_with(|| {

2045

1

			let dest = Location {

2046

1

				parents: 1,

2047

1

				interior: [AccountId32 {

2048

1

					network: None,

2049

1

					id: [1u8; 32],

2050

1

}]

2051

1

				.into(),

2052

1

};

2053

1

			let assets: Assets = [Asset {

2054

1

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

2055

1

				fun: Fungible(1000),

2056

1

}]

2057

1

			.to_vec()

2058

1

			.into();

2059

1

			assert_noop!(

2060

1

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

2061

1

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

2062

1

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

2063

1

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

2064

1

					fee_asset_item: 0,

2065

1

})

2066

1

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

2067

1

					AccountId::from(ALICE)

2068

1

)),

2069

1

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

2070

1

);

2071

1

});

2072

1

2073

2074

#[test]

2075

1

fn transactor_cannot_use_more_than_max_weight() {

2076

1

	ExtBuilder::default()

2077

1

		.with_balances(vec![

2078

1

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

2079

1

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

2080

1

])

2081

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2082

1

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

2083

1

			metadata: AssetRegistrarMetadata {

2084

1

				name: b"RelayToken".to_vec(),

2085

1

				symbol: b"Relay".to_vec(),

2086

1

				decimals: 12,

2087

1

				is_frozen: false,

2088

1

},

2089

1

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

2090

1

			is_sufficient: true,

2091

1

}])

2092

1

		.build()

2093

1

		.execute_with(|| {

2094

1

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

2095

1

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

2096

1

			assert_ok!(XcmTransactor::register(

2097

1

				root_origin(),

2098

1

				AccountId::from(ALICE),

2099

1

0,

2100

1

));

2101

2102

			// Root can set transact info

2103

1

			assert_ok!(XcmTransactor::set_transact_info(

2104

1

				root_origin(),

2105

1

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

2106

1

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

2107

1

				3000.into(),

2108

1

				20000.into(),

2109

1

				None

2110

1

));

2111

2112

			// Root can set transact info

2113

1

			assert_ok!(XcmTransactor::set_fee_per_second(

2114

1

				root_origin(),

2115

1

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

2116

1

2117

1

));

2118

2119

1

			assert_noop!(

2120

1

				XcmTransactor::transact_through_derivative(

2121

1

					origin_of(AccountId::from(ALICE)),

2122

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2123

1

0,

2124

1

					CurrencyPayment {

2125

1

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

2126

1

							Location::parent()

2127

1

						))),

2128

1

						fee_amount: None

2129

1

},

2130

1

					vec![],

2131

1

					// 2000 is the max

2132

1

					TransactWeights {

2133

1

						transact_required_weight_at_most: 17001.into(),

2134

1

						overall_weight: None

2135

1

},

2136

1

					false

2137

1

),

2138

1

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

2139

1

);

2140

1

			assert_noop!(

2141

1

				XcmTransactor::transact_through_derivative(

2142

1

					origin_of(AccountId::from(ALICE)),

2143

1

					moonriver_runtime::xcm_config::Transactors::Relay,

2144

1

0,

2145

1

					CurrencyPayment {

2146

1

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

2147

1

						fee_amount: None

2148

1

},

2149

1

					vec![],

2150

1

					// 20000 is the max

2151

1

					TransactWeights {

2152

1

						transact_required_weight_at_most: 17001.into(),

2153

1

						overall_weight: None

2154

1

},

2155

1

					false

2156

1

),

2157

1

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

2158

1

);

2159

1

})

2160

1

2161

2162

#[test]

2163

1

fn transact_through_signed_precompile_works_v2() {

2164

1

	ExtBuilder::default()

2165

1

		.with_balances(vec![

2166

1

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

2167

1

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

2168

1

])

2169

1

		.with_safe_xcm_version(2)

2170

1

		.build()

2171

1

		.execute_with(|| {

2172

1

			// Destination

2173

1

			let dest = Location::parent();

2174

1

2175

1

			let fee_payer_asset = Location::parent();

2176

1

2177

1

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

2178

1

2179

1

			let total_weight = 1_000_000_000u64;

2180

1

2181

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2182

1

2183

1

			Precompiles::new()

2184

1

				.prepare_test(

2185

1

					ALICE,

2186

1

					xcm_transactor_v2_precompile_address,

2187

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2188

1

						dest,

2189

1

						fee_asset: fee_payer_asset,

2190

1

						weight: 4_000_000,

2191

1

						call: bytes.into(),

2192

1

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

2193

1

						overall_weight: total_weight,

2194

1

},

2195

1

2196

1

				.expect_cost(21465)

2197

1

				.expect_no_logs()

2198

1

				.execute_returns(());

2199

1

});

2200

1

2201

2202

#[test]

2203

1

fn transact_through_signed_cannot_send_to_local_chain() {

2204

1

	ExtBuilder::default()

2205

1

		.with_balances(vec![

2206

1

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

2207

1

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

2208

1

])

2209

1

		.with_safe_xcm_version(2)

2210

1

		.build()

2211

1

		.execute_with(|| {

2212

1

			// Destination

2213

1

			let dest = Location::here();

2214

1

2215

1

			let fee_payer_asset = Location::parent();

2216

1

2217

1

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

2218

1

2219

1

			let total_weight = 1_000_000_000u64;

2220

1

2221

1

			let xcm_transactor_v2_precompile_address = H160::from_low_u64_be(2061);

2222

1

2223

1

			Precompiles::new()

2224

1

				.prepare_test(

2225

1

					ALICE,

2226

1

					xcm_transactor_v2_precompile_address,

2227

1

					XcmTransactorV2PCall::transact_through_signed_multilocation {

2228

1

						dest,

2229

1

						fee_asset: fee_payer_asset,

2230

1

						weight: 4_000_000,

2231

1

						call: bytes.into(),

2232

1

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

2233

1

						overall_weight: total_weight,

2234

1

},

2235

1

2236

1

				.execute_reverts(|output| {

2237

1

					from_utf8(&output)

2238

1

						.unwrap()

2239

1

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

2240

1

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

2241

1

});

2242

1

});

2243

1

2244

2245

#[test]

2246

1

fn call_xtokens_with_fee() {

2247

1

	ExtBuilder::default()

2248

1

		.with_balances(vec![

2249

1

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

2250

1

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

2251

1

])

2252

1

		.with_safe_xcm_version(2)

2253

1

		.with_xcm_assets(vec![XcmAssetInitialization {

2254

1

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

2255

1

			metadata: AssetRegistrarMetadata {

2256

1

				name: b"RelayToken".to_vec(),

2257

1

				symbol: b"Relay".to_vec(),

2258

1

				decimals: 12,

2259

1

				is_frozen: false,

2260

1

},

2261

1

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

2262

1

			is_sufficient: true,

2263

1

}])

2264

1

		.build()

2265

1

		.execute_with(|| {

2266

1

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

2267

1

			let dest = Location {

2268

1

				parents: 1,

2269

1

				interior: [AccountId32 {

2270

1

					network: None,

2271

1

					id: [1u8; 32],

2272

1

}]

2273

1

				.into(),

2274

1

};

2275

1

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

2276

1

2277

1

			let before_balance =

2278

1

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

2279

1

2280

1

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

2281

1

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

2282

1

			let (chain_part, beneficiary) =

2283

1

				split_location_into_chain_part_and_beneficiary(dest).unwrap();

2284

1

2285

1

			// We are able to transfer with fee

2286

1

			assert_ok!(PolkadotXcm::transfer_assets(

2287

1

				origin_of(AccountId::from(ALICE)),

2288

1

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

2289

1

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

2290

1

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

2291

1

0,

2292

1

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

2293

1

			),);

2294

2295

1

			let after_balance =

2296

1

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

2297

1

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

2298

1

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

2299

1

});

2300

1

2301

2302

#[test]

2303

1

fn test_xcm_utils_ml_tp_account() {

2304

1

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

2305

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2306

1

		let expected_address_parent: H160 =

2307

1

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

2308

1

				.unwrap()

2309

1

				.into();

2310

1

2311

1

		Precompiles::new()

2312

1

			.prepare_test(

2313

1

				ALICE,

2314

1

				xcm_utils_precompile_address,

2315

1

				XcmUtilsPCall::multilocation_to_address {

2316

1

					location: Location::parent(),

2317

1

},

2318

1

2319

1

			.expect_cost(1669)

2320

1

			.expect_no_logs()

2321

1

			.execute_returns(Address(expected_address_parent));

2322

1

2323

1

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

2324

1

		let expected_address_parachain: H160 =

2325

1

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

2326

1

				&parachain_2000_multilocation,

2327

1

2328

1

			.unwrap()

2329

1

			.into();

2330

1

2331

1

		Precompiles::new()

2332

1

			.prepare_test(

2333

1

				ALICE,

2334

1

				xcm_utils_precompile_address,

2335

1

				XcmUtilsPCall::multilocation_to_address {

2336

1

					location: parachain_2000_multilocation,

2337

1

},

2338

1

2339

1

			.expect_cost(1669)

2340

1

			.expect_no_logs()

2341

1

			.execute_returns(Address(expected_address_parachain));

2342

1

2343

1

		let alice_in_parachain_2000_location = Location::new(

2344

1

1,

2345

1

2346

1

				Parachain(2000),

2347

1

				AccountKey20 {

2348

1

					network: None,

2349

1

					key: ALICE,

2350

1

},

2351

1

],

2352

1

);

2353

1

		let expected_address_alice_in_parachain_2000 =

2354

1

			xcm_builder::HashedDescription::<

2355

1

				AccountId,

2356

1

				xcm_builder::DescribeFamily<xcm_builder::DescribeAllTerminal>,

2357

1

			>::convert_location(&alice_in_parachain_2000_location)

2358

1

			.unwrap()

2359

1

			.into();

2360

1

2361

1

		Precompiles::new()

2362

1

			.prepare_test(

2363

1

				ALICE,

2364

1

				xcm_utils_precompile_address,

2365

1

				XcmUtilsPCall::multilocation_to_address {

2366

1

					location: alice_in_parachain_2000_location,

2367

1

},

2368

1

2369

1

			.expect_cost(1669)

2370

1

			.expect_no_logs()

2371

1

			.execute_returns(Address(expected_address_alice_in_parachain_2000));

2372

1

});

2373

1

2374

2375

#[test]

2376

1

fn test_xcm_utils_weight_message() {

2377

1

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

2378

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2379

1

		let expected_weight =

2380

1

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

2381

1

2382

1

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

2383

1

2384

1

		let input = XcmUtilsPCall::weight_message {

2385

1

			message: message.into(),

2386

1

};

2387

1

2388

1

		Precompiles::new()

2389

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2390

1

			.expect_cost(0)

2391

1

			.expect_no_logs()

2392

1

			.execute_returns(expected_weight);

2393

1

});

2394

1

2395

2396

#[test]

2397

1

fn test_xcm_utils_get_units_per_second() {

2398

1

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

2399

1

		let xcm_utils_precompile_address = H160::from_low_u64_be(2060);

2400

1

		let location = SelfReserve::get();

2401

1

2402

1

		let input = XcmUtilsPCall::get_units_per_second { location };

2403

1

2404

1

		let expected_units =

2405

1

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

2406

1

2407

1

		Precompiles::new()

2408

1

			.prepare_test(ALICE, xcm_utils_precompile_address, input)

2409

1

			.expect_cost(1669)

2410

1

			.expect_no_logs()

2411

1

			.execute_returns(expected_units);

2412

1

});

2413

1

2414

2415

#[test]

2416

1

fn precompile_existence() {

2417

1

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

2418

1

		let precompiles = Precompiles::new();

2419

1

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

2420

1

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

2421

1

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

2422

1

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

2423

1

2424

1

		.into_iter()

2425

1

		.map(H160::from_low_u64_be)

2426

1

		.collect();

2427

2428

3001

		for i in 0..3000 {

2429

3000

			let address = H160::from_low_u64_be(i);

2430

3000

2431

3000

			if precompile_addresses.contains(&address) {

2432

40

				assert!(

2433

40

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

2434

					"is_precompile({}) should return true",

2435

2436

);

2437

2438

40

				assert!(

2439

40

					precompiles

2440

40

						.execute(&mut MockHandle::new(

2441

40

							address,

2442

40

							Context {

2443

40

								address,

2444

40

								caller: H160::zero(),

2445

40

								apparent_value: U256::zero()

2446

40

2447

40

),)

2448

40

						.is_some(),

2449

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

2450

2451

);

2452

			} else {

2453

2960

				assert!(

2454

2960

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

2455

					"is_precompile({}) should return false",

2456

2457

);

2458

2459

2960

				assert!(

2460

2960

					precompiles

2461

2960

						.execute(&mut MockHandle::new(

2462

2960

							address,

2463

2960

							Context {

2464

2960

								address,

2465

2960

								caller: H160::zero(),

2466

2960

								apparent_value: U256::zero()

2467

2960

2468

2960

),)

2469

2960

						.is_none(),

2470

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

2471

2472

);

2473

2474

2475

1

});

2476

1

2477

2478

#[test]

2479

1

fn removed_precompiles() {

2480

1

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

2481

1

		let precompiles = Precompiles::new();

2482

1

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

2483

2484

3000

		for i in 1..3000 {

2485

2999

			let address = H160::from_low_u64_be(i);

2486

2999

2487

2999

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

2488

2959

				continue;

2489

40

2490

40

2491

40

			if !removed_precompiles.contains(&i) {

2492

36

				assert!(

2493

36

					match precompiles.is_active_precompile(address, 100_000u64) {

2494

36

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

2495

						_ => false,

2496

},

2497

					"{i} should be an active precompile"

2498

);

2499

36

				continue;

2500

4

2501

4

2502

4

			assert!(

2503

4

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

2504

4

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

2505

					_ => false,

2506

},

2507

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

2508

);

2509

2510

4

			precompiles

2511

4

				.prepare_test(Alice, address, [])

2512

4

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

2513

2514

1

})

2515

1

2516

2517

#[test]

2518

1

fn deal_with_fees_handles_tip() {

2519

1

	use frame_support::traits::OnUnbalanced;

2520

1

	use moonbeam_runtime_common::deal_with_fees::DealWithSubstrateFeesAndTip;

2521

1

	use moonriver_runtime::Treasury;

2522

1

2523

1

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

2524

1

		set_parachain_inherent_data();

2525

1

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

2526

1

		// in the Moonriver runtime. It verifies that:

2527

1

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

2528

1

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

2529

1

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

2530

1

2531

1

		// The test details:

2532

1

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

2533

1

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

2534

1

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

2535

1

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

2536

1

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

2537

1

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

2538

1

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

2539

1

2540

1

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

2541

1

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

2542

1

			AccountId,

2543

1

		>>::issue(100);

2544

1

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

2545

1

			AccountId,

2546

1

		>>::issue(1000);

2547

1

2548

1

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

2549

1

		let total_supply_before = Balances::total_issuance();

2550

1

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

2551

1

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

2552

1

		assert_eq!(total_supply_before, 1_100);

2553

1

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

2554

2555

		// Step 3: Execute the fees handling logic.

2556

1

		DealWithSubstrateFeesAndTip::<

2557

1

			Runtime,

2558

1

			dynamic_params::runtime_config::FeesTreasuryProportion,

2559

1

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

2560

1

2561

1

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

2562

1

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

2563

1

2564

1

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

2565

1

		let burnt_fee_part: Balance = 100 - treasury_fee_part;

2566

1

2567

1

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

2568

1

		assert_eq!(

2569

1

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

2570

1

			treasury_fee_part,

2571

1

);

2572

2573

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

2574

1

		let total_supply_after = Balances::total_issuance();

2575

1

		assert_eq!(total_supply_before - total_supply_after, burnt_fee_part,);

2576

2577

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

2578

1

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

2579

1

		assert_eq!(

2580

1

			block_author_balance_after - block_author_balance_before,

2581

1

			1000,

2582

1

);

2583

1

});

2584

1

2585

2586

#[test]

2587

1

fn evm_revert_substrate_events() {

2588

1

	ExtBuilder::default()

2589

1

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

2590

1

		.build()

2591

1

		.execute_with(|| {

2592

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2593

1

2594

1

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

2595

1

			// Thus BatchAll will revert the transfer.

2596

1

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

2597

1

				source: ALICE.into(),

2598

1

				target: batch_precompile_address,

2599

1

				input: BatchPCall::batch_all {

2600

1

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

2601

1

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

2602

1

					call_data: vec![].into(),

2603

1

					gas_limit: vec![].into()

2604

1

2605

1

				.into(),

2606

1

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

2607

1

				gas_limit: 500_000,

2608

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2609

1

				max_priority_fee_per_gas: None,

2610

1

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

2611

1

				access_list: Vec::new(),

2612

1

})

2613

1

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

2614

2615

1

			let transfer_count = System::events()

2616

1

				.iter()

2617

6

				.filter(|r| match r.event {

2618

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

2619

6

					_ => false,

2620

6

})

2621

1

				.count();

2622

1

2623

1

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

2624

1

});

2625

1

2626

2627

#[test]

2628

1

fn evm_success_keeps_substrate_events() {

2629

1

	ExtBuilder::default()

2630

1

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

2631

1

		.build()

2632

1

		.execute_with(|| {

2633

1

			let batch_precompile_address = H160::from_low_u64_be(2056);

2634

1

2635

1

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

2636

1

				source: ALICE.into(),

2637

1

				target: batch_precompile_address,

2638

1

				input: BatchPCall::batch_all {

2639

1

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

2640

1

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

2641

1

					call_data: vec![].into(),

2642

1

					gas_limit: vec![].into()

2643

1

2644

1

				.into(),

2645

1

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

2646

1

				gas_limit: 500_000,

2647

1

				max_fee_per_gas: U256::from(BASE_FEE_GENESIS),

2648

1

				max_priority_fee_per_gas: None,

2649

1

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

2650

1

				access_list: Vec::new(),

2651

1

})

2652

1

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

2653

2654

1

			let transfer_count = System::events()

2655

1

				.iter()

2656

10

				.filter(|r| match r.event {

2657

1

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

2658

9

					_ => false,

2659

10

})

2660

1

				.count();

2661

1

2662

1

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

2663

1

});

2664

1

2665

2666

#[cfg(test)]

2667

mod fee_tests {

2668

	use super::*;

2669

	use fp_evm::FeeCalculator;

2670

	use frame_support::{

2671

		traits::{ConstU128, OnFinalize},

2672

		weights::{ConstantMultiplier, WeightToFee},

2673

};

2674

	use moonriver_runtime::{

2675

		currency, LengthToFee, MinimumMultiplier, RuntimeBlockWeights, SlowAdjustingFeeUpdate,

2676

		TargetBlockFullness, TransactionPaymentAsGasPrice, NORMAL_WEIGHT, WEIGHT_PER_GAS,

2677

};

2678

	use sp_core::Get;

2679

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

2680

2681

1

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

2682

1

	where

2683

1

		F: FnMut() -> (),

2684

1

2685

1

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

2686

1

			.build_storage()

2687

1

			.unwrap()

2688

1

			.into();

2689

1

		t.execute_with(|| {

2690

1

			System::set_block_consumed_resources(w, 0);

2691

1

			assertions()

2692

1

});

2693

1

2694

2695

	#[test]

2696

1

	fn test_multiplier_can_grow_from_zero() {

2697

1

		let minimum_multiplier = MinimumMultiplier::get();

2698

1

		let target = TargetBlockFullness::get()

2699

1

			* RuntimeBlockWeights::get()

2700

1

				.get(DispatchClass::Normal)

2701

1

				.max_total

2702

1

				.unwrap();

2703

1

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

2704

1

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

2705

1

		run_with_system_weight(target * 101 / 100, || {

2706

1

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

2707

1

			assert!(

2708

1

				next > minimum_multiplier,

2709

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

2710

				next,

2711

				minimum_multiplier

2712

);

2713

1

})

2714

1

2715

2716

	#[test]

2717

1

	fn test_fee_calculation() {

2718

1

		let base_extrinsic = RuntimeBlockWeights::get()

2719

1

			.get(DispatchClass::Normal)

2720

1

			.base_extrinsic;

2721

1

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

2722

1

		let extrinsic_len = 100u32;

2723

1

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

2724

1

		let tip = 42u128;

2725

1

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

2726

1

		type LengthToFeeImpl = LengthToFee;

2727

1

2728

1

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

2729

1

		let expected_fee = WeightToFeeImpl::weight_to_fee(&base_extrinsic)

2730

1

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

2731

1

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

2732

1

			+ tip;

2733

1

2734

1

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

2735

1

			.build_storage()

2736

1

			.unwrap()

2737

1

			.into();

2738

1

		t.execute_with(|| {

2739

1

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

2740

1

			let actual_fee = TransactionPayment::compute_fee(

2741

1

				extrinsic_len,

2742

1

				&frame_support::dispatch::DispatchInfo {

2743

1

					class: DispatchClass::Normal,

2744

1

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

2745

1

					weight: extrinsic_weight,

2746

1

},

2747

1

				tip,

2748

1

);

2749

1

2750

1

			assert_eq!(

2751

				expected_fee,

2752

				actual_fee,

2753

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

2754

				actual_fee - expected_fee

2755

);

2756

1

});

2757

1

2758

2759

	#[test]

2760

1

	fn test_min_gas_price_is_deterministic() {

2761

1

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

2762

1

			.build_storage()

2763

1

			.unwrap()

2764

1

			.into();

2765

1

		t.execute_with(|| {

2766

1

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

2767

1

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

2768

1

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

2769

1

			let expected: U256 = multiplier

2770

1

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

2771

1

				.into();

2772

1

2773

1

			assert_eq!(expected, actual);

2774

1

});

2775

1

2776

2777

	#[test]

2778

1

	fn test_min_gas_price_has_no_precision_loss_from_saturating_mul_int() {

2779

1

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

2780

1

			.build_storage()

2781

1

			.unwrap()

2782

1

			.into();

2783

1

		t.execute_with(|| {

2784

1

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

2785

1

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

2786

1

2787

1

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

2788

1

			let a = TransactionPaymentAsGasPrice::min_gas_price();

2789

1

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

2790

1

			let b = TransactionPaymentAsGasPrice::min_gas_price();

2791

1

2792

1

			assert_ne!(

2793

				a, b,

2794

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

2795

);

2796

1

});

2797

1

2798

2799

	#[test]

2800

1

	fn test_fee_scenarios() {

2801

1

		use sp_runtime::FixedU128;

2802

1

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

2803

1

			.build_storage()

2804

1

			.unwrap()

2805

1

			.into();

2806

1

		t.execute_with(|| {

2807

1

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

2808

12

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

2809

12

				let start_multiplier =

2810

12

					FixedU128::from_rational(start_gas_price, weight_fee_per_gas);

2811

12

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

2812

12

2813

12

				let block_weight = NORMAL_WEIGHT * fullness;

2814

2815

60004

				for i in 0..num_blocks {

2816

60004

					System::set_block_number(i as u32);

2817

60004

					System::set_block_consumed_resources(block_weight, 0);

2818

60004

					TransactionPayment::on_finalize(i as u32);

2819

60004

2820

2821

12

				TransactionPaymentAsGasPrice::min_gas_price().0

2822

12

};

2823

2824

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

2825

			// they are expected to change when parameters that influence

2826

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

2827

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

2828

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

2829

2830

1

			assert_eq!(

2831

1

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

2832

1

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

2833

1

);

2834

1

			assert_eq!(

2835

1

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

2836

1

				U256::from(312_500_000u128),

2837

1

);

2838

1

			assert_eq!(

2839

1

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

2840

1

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

2841

1

);

2842

1

			assert_eq!(

2843

1

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

2844

1

				U256::from(313_313_556u128),

2845

1

);

2846

2847

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

2848

1

			assert_eq!(

2849

1

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

2850

1

				U256::from(312_500_000u128),

2851

1

);

2852

1

			assert_eq!(

2853

1

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

2854

1

				U256::from(312_500_000u128),

2855

1

);

2856

1

			assert_eq!(

2857

1

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

2858

1

				U256::from(447_915_432u128),

2859

1

);

2860

1

			assert_eq!(

2861

1

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

2862

1

				U256::from(1_487_129_030u128),

2863

1

);

2864

2865

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

2866

1

			assert_eq!(

2867

1

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

2868

1

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

2869

1

);

2870

1

			assert_eq!(

2871

1

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

2872

1

				U256::from(312_500_000u128),

2873

1

);

2874

1

			assert_eq!(

2875

1

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

2876

1

				U256::from(1_766_664_654_709u128),

2877

1

);

2878

1

			assert_eq!(

2879

1

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

2880

1

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

2881

1

);

2882

1

});

2883

1

2884