referrerpolicy=no-referrer-when-downgrade
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

// Copyright (C) Parity Technologies (UK) Ltd.
// This file is part of Polkadot.

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

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

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

use super::*;
use frame_support::traits::{Contains, UncheckedOnRuntimeUpgrade};

#[derive(Encode, Decode)]
pub struct ParaInfoV1<Account, Balance> {
	manager: Account,
	deposit: Balance,
	locked: bool,
}

pub struct VersionUncheckedMigrateToV1<T, UnlockParaIds>(
	core::marker::PhantomData<(T, UnlockParaIds)>,
);
impl<T: Config, UnlockParaIds: Contains<ParaId>> UncheckedOnRuntimeUpgrade
	for VersionUncheckedMigrateToV1<T, UnlockParaIds>
{
	fn on_runtime_upgrade() -> Weight {
		let mut count = 0u64;
		Paras::<T>::translate::<ParaInfoV1<T::AccountId, BalanceOf<T>>, _>(|key, v1| {
			count.saturating_inc();
			Some(ParaInfo {
				manager: v1.manager,
				deposit: v1.deposit,
				locked: if UnlockParaIds::contains(&key) { None } else { Some(v1.locked) },
			})
		});

		log::info!(target: "runtime::registrar", "Upgraded {} storages to version 1", count);
		T::DbWeight::get().reads_writes(count, count)
	}

	#[cfg(feature = "try-runtime")]
	fn pre_upgrade() -> Result<Vec<u8>, sp_runtime::TryRuntimeError> {
		Ok((Paras::<T>::iter_keys().count() as u32).encode())
	}

	#[cfg(feature = "try-runtime")]
	fn post_upgrade(state: Vec<u8>) -> Result<(), sp_runtime::TryRuntimeError> {
		let old_count = u32::decode(&mut &state[..]).expect("Known good");
		let new_count = Paras::<T>::iter_values().count() as u32;

		ensure!(old_count == new_count, "Paras count should not change");
		Ok(())
	}
}

pub type MigrateToV1<T, UnlockParaIds> = frame_support::migrations::VersionedMigration<
	0,
	1,
	VersionUncheckedMigrateToV1<T, UnlockParaIds>,
	super::Pallet<T>,
	<T as frame_system::Config>::DbWeight,
>;