validate blocks before committing

Author: iuwqyir

internal/orchestrator/committer.go

@@ -29,6 +29,7 @@ type Committer struct {
 	publisher          *publisher.Publisher
 	workMode           WorkMode
 	workModeChan       chan WorkMode
+	validator          *Validator
 }
 
 type CommitterOption func(*Committer)
@@ -59,6 +60,7 @@ func NewCommitter(rpc rpc.IRPCClient, storage storage.IStorage, opts ...Committe
 		lastCommittedBlock: commitFromBlock,
 		publisher:          publisher.GetInstance(),
 		workMode:           "",
+		validator:          NewValidator(rpc, storage),
 	}
 
 	for _, opt := range opts {
@@ -210,6 +212,15 @@ func (c *Committer) getSequentialBlockDataToCommit(ctx context.Context) ([]commo
 		return nil, nil
 	}
 
+	validBlocks, invalidBlocks, err := c.validator.ValidateBlocks(blocksData)
+	if err != nil {
+		return nil, err
+	}
+	if len(invalidBlocks) > 0 {
+		// continue with valid blocks only
+		blocksData = validBlocks
+	}
+
 	// Sort blocks by block number
 	sort.Slice(blocksData, func(i, j int) bool {
 		return blocksData[i].Block.Number.Cmp(blocksData[j].Block.Number) < 0