Add warp sync provider

dot/state/block.go

@@ -51,17 +51,18 @@ var (
 // BlockState contains the historical block data of the blockchain, including block headers and bodies.
 // It wraps the blocktree (which contains unfinalised blocks) and the database (which contains finalised blocks).
 type BlockState struct {
-	bt                *blocktree.BlockTree
-	baseState         *BaseState
-	dbPath            string
-	db                BlockStateDatabase
-	lock              sync.RWMutex
-	genesisHash       common.Hash
-	lastFinalised     common.Hash
-	lastRound         uint64
-	lastSetID         uint64
-	unfinalisedBlocks *hashToBlockMap
-	tries             *Tries
+	bt                 *blocktree.BlockTree
+	baseState          *BaseState
+	dbPath             string
+	db                 BlockStateDatabase
+	lock               sync.RWMutex
+	genesisHash        common.Hash
+	lastFinalised      common.Hash
+	lastRound          uint64
+	lastSetID          uint64
+	unfinalisedBlocks  *hashToBlockMap
+	tries              *Tries
+	authoritiesChanges types.AuthoritySetChange
 
 	// State variables
 	pausedLock sync.RWMutex
@@ -960,3 +961,7 @@ func (bs *BlockState) StoreRuntime(hash common.Hash, rt runtime.Instance) {
 func (bs *BlockState) GetNonFinalisedBlocks() []common.Hash {
 	return bs.bt.GetAllBlocks()
 }
+
+func (bs *BlockState) GetAuthoritesChanges() types.AuthoritySetChange {
+	return bs.authoritiesChanges
+}

dot/types/grandpa.go

@@ -281,3 +281,39 @@ type GrandpaEquivocationProof struct {
 	SetID        uint64
 	Equivocation GrandpaEquivocationEnum
 }
+
+type AuthoritySetChangeEvent struct {
+	SetID  uint64
+	Number uint
+}
+
+type AuthoritySetChange struct {
+	//changes maps block numbers to set ids
+	changesAt []uint
+	changes   map[uint]uint64
+}
+
+func NewAuthoritySetChange() *AuthoritySetChange {
+	return &AuthoritySetChange{
+		changesAt: make([]uint, 0),
+		changes:   make(map[uint]uint64),
+	}
+}
+
+func (asc *AuthoritySetChange) Insert(setID uint64, number uint) {
+	asc.changesAt = append(asc.changesAt, number)
+	asc.changes[number] = setID
+}
+
+func (asc *AuthoritySetChange) From(blockNumber uint) []AuthoritySetChangeEvent {
+	changes := make([]AuthoritySetChangeEvent, 0)
+	for _, blockNumber := range asc.changesAt {
+		changes = append(changes,
+			AuthoritySetChangeEvent{
+				setID:  asc.changes[blockNumber],
+				number: blockNumber,
+			},
+		)
+	}
+	return changes
+}