Update forkIdIntervals

0xPolygonHermez · Mar 15, 2023 · f4e926c · f4e926c
1 parent 2a12876
commit f4e926c
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/synchronizer/synchronizer.go b/synchronizer/synchronizer.go
@@ -610,6 +610,19 @@ func (s *ClientSynchronizer) processForkID(forkID etherman.ForkID, blockNumber u
 		return err
 	}
 	if latestBatchNumber < forkID.BatchNumber { //If the forkID will start in a future batch
+		// Read Fork ID FROM POE SC
+		forkIDIntervals, err := s.etherMan.GetForks(s.ctx)
+		if err != nil || len(forkIDIntervals) == 0 {
+			log.Error("error getting all forkIDs: ", err)
+			rollbackErr := dbTx.Rollback(s.ctx)
+			if rollbackErr != nil {
+				log.Errorf("error rolling back state. BlockNumber: %d, rollbackErr: %s, error : %v", blockNumber, rollbackErr.Error(), err)
+				return rollbackErr
+			}
+			return err
+		}
+		// Update forkID intervals in the state
+		s.state.UpdateForkIDIntervals(forkIDIntervals)
 		return nil
 	}