rm print

Author: rianhughes

core/block.go

@@ -120,6 +120,7 @@ func VerifyBlockHash(b *Block, network *utils.Network, stateDiff *StateDiff) (*B
 		if err != nil {
 			return nil, err
 		}
+
 		if hash.Equal(b.Hash) {
 			return commitments, nil
 		} else if skipVerification {

p2p/sync/sync.go

@@ -85,7 +85,6 @@ func (s *Service) Run(ctx context.Context) {
 
 		// todo change iteration to fetch several objects uint64(min(blockBehind, maxBlocks))
 		blockNumber := uint64(nextHeight)
-		fmt.Println(" blockNumber", blockNumber)
 		if err := s.processBlock(iterCtx, blockNumber); err != nil {
 			s.logError("Failed to process block", fmt.Errorf("blockNumber: %d, err: %w", blockNumber, err))
 			cancelIteration()
@@ -111,22 +110,27 @@ func (s *Service) processBlock(ctx context.Context, blockNumber uint64) error {
 	if err != nil {
 		return fmt.Errorf("failed to get block headers parts: %w", err)
 	}
+
 	txsCh, err := s.genTransactions(ctx, blockNumber)
 	if err != nil {
 		return fmt.Errorf("failed to get transactions: %w", err)
 	}
+
 	eventsCh, err := s.genEvents(ctx, blockNumber)
 	if err != nil {
 		return fmt.Errorf("failed to get events: %w", err)
 	}
+
 	classesCh, err := s.genClasses(ctx, blockNumber)
 	if err != nil {
 		return fmt.Errorf("failed to get classes: %w", err)
 	}
+
 	stateDiffsCh, err := s.genStateDiffs(ctx, blockNumber)
 	if err != nil {
 		return fmt.Errorf("failed to get state diffs: %w", err)
 	}
+
 	blocksCh := pipeline.Bridge(ctx, s.processSpecBlockParts(ctx, blockNumber, pipeline.FanIn(ctx,
 		pipeline.Stage(ctx, headersAndSigsCh, specBlockPartsFunc[specBlockHeaderAndSigs]),
 		pipeline.Stage(ctx, classesCh, specBlockPartsFunc[specClasses]),