sc_consensus_epochs/
migration.rs1use crate::{Epoch, EpochChanges, PersistedEpoch, PersistedEpochHeader};
22use codec::{Decode, Encode};
23use fork_tree::ForkTree;
24use sp_runtime::traits::{Block as BlockT, NumberFor};
25use std::collections::BTreeMap;
26
27#[derive(Clone, Encode, Decode)]
29pub struct EpochChangesV0<Hash, Number, E: Epoch> {
30 inner: ForkTree<Hash, Number, PersistedEpoch<E>>,
31}
32
33#[derive(Clone, Encode, Decode)]
35pub struct EpochChangesV1<Hash, Number, E: Epoch> {
36 inner: ForkTree<Hash, Number, PersistedEpochHeader<E>>,
37 epochs: BTreeMap<(Hash, Number), PersistedEpoch<E>>,
38}
39
40pub type EpochChangesV0For<Block, Epoch> =
42 EpochChangesV0<<Block as BlockT>::Hash, NumberFor<Block>, Epoch>;
43pub type EpochChangesV1For<Block, Epoch> =
45 EpochChangesV1<<Block as BlockT>::Hash, NumberFor<Block>, Epoch>;
46
47impl<Hash, Number, E: Epoch> EpochChangesV0<Hash, Number, E>
48where
49 Hash: PartialEq + Ord + Copy,
50 Number: Ord + Copy,
51{
52 pub fn from_raw(inner: ForkTree<Hash, Number, PersistedEpoch<E>>) -> Self {
54 Self { inner }
55 }
56
57 pub fn migrate(self) -> EpochChanges<Hash, Number, E> {
59 let mut epochs = BTreeMap::new();
60
61 let inner = self.inner.map(&mut |hash, number, data| {
62 let header = PersistedEpochHeader::from(&data);
63 epochs.insert((*hash, *number), data);
64 header
65 });
66
67 EpochChanges { inner, epochs }
68 }
69}
70
71impl<Hash, Number, E: Epoch> EpochChangesV1<Hash, Number, E>
72where
73 Hash: PartialEq + Ord + Copy,
74 Number: Ord + Copy,
75{
76 pub fn migrate(self) -> EpochChanges<Hash, Number, E> {
78 EpochChanges { inner: self.inner, epochs: self.epochs }
79 }
80}