Merge pull request #9 from chainstack/bug/fix-sync-isses-chapel

Fix chapel sync issues

Author: avinashbo

consensus/parlia/parlia.go

@@ -256,6 +256,8 @@ type Parlia struct {
 	fakeDiff               bool     // Skip difficulty verifications
 	heightForks, timeForks []uint64 // Forks extracted from the chainConfig
 	snapshots              *snapshotsync.RoSnapshots
+	newValidators          []libcommon.Address
+	voteAddressMapmap      map[libcommon.Address]*types.BLSPublicKey
 }
 
 // New creates a Parlia consensus engine.
@@ -872,18 +874,27 @@ func (p *Parlia) Prepare(chain consensus.ChainHeaderReader, header *types.Header
 }
 
 func (p *Parlia) verifyValidators(header, parentHeader *types.Header, state *state.IntraBlockState) error {
-	if header.Number.Uint64()%p.config.Epoch != 0 {
-		return nil
-	}
+	    if (header.Number.Uint64()+1)%p.config.Epoch == 0 {
+		        newValidators, voteAddressMap, err := p.getCurrentValidators(header, state)
+		        if err != nil {
+			            return err
+				}
+				p.newValidators = newValidators
+				p.voteAddressMapmap = voteAddressMap
+				return nil
+		}
 
-	newValidators, voteAddressMap, err := p.getCurrentValidators(parentHeader, state)
-	if err != nil {
-		return err
-	}
+		if header.Number.Uint64()%p.config.Epoch != 0 {
+				return nil
+		}
+	
+
+	newValidators, voteAddressMap := p.newValidators, p.voteAddressMapmap
 	// sort validator by address
 	sort.Sort(validatorsAscending(newValidators))
 	var validatorsBytes []byte
 	validatorsNumber := len(newValidators)
+	
 	if !p.chainConfig.IsLuban(header.Number.Uint64()) {
 		validatorsBytes = make([]byte, validatorsNumber*validatorBytesLengthBeforeLuban)
 		for i, validator := range newValidators {