Implement boosted catch-up sync with cfx_getLogs

config/config.yml

@@ -129,6 +129,11 @@ sync:
   #   maxDbRows: 7500
   #   # Capacity of channel per worker to buffer queried epoch data
   #   workerChanSize: 5
+  #   # Max memory usage allowed in bytes (0 for no limit).
+  #   memoryThreshold: 0
+  #   # Whether to enable benchmark.
+  #   benchmark: false
+
 
   # # EVM space sync configurations
   # eth:
@@ -454,4 +459,4 @@ node:
 #   # Switch to turn on/off pprof
 #   enabled: false
 #   # The endpoint to start a http server for pprof
-#   httpEndpoint: ":6060"
+#   httpEndpoint: ":6060"

store/epoch_data.go

@@ -267,7 +267,7 @@ func queryEpochData(cfx sdk.ClientOperator, epochNumber uint64, useBatch bool) (
 }
 
 func validateBlock(block *types.Block, epochNumber uint64, hash types.Hash) error {
-	if block.GasUsed == nil { // block is not executed yet?
+	if epochNumber != 0 && block.GasUsed == nil { // block is not executed yet?
 		return errors.WithMessage(errBlockValidationFailed, "gas used is nil")
 	}
 

store/mysql/store_log_addr.go

@@ -8,7 +8,6 @@ import (
 	"github.com/Conflux-Chain/confura/store"
 	"github.com/Conflux-Chain/confura/util"
 	"github.com/pkg/errors"
-	"github.com/sirupsen/logrus"
 	"gorm.io/gorm"
 )
 
@@ -84,11 +83,7 @@ func (ls *AddressIndexedLogStore) convertToPartitionedLogs(
 
 			receipt, ok := data.Receipts[tx.Hash]
 			if !ok {
-				// should never occur, just to ensure code robust
-				logrus.WithFields(logrus.Fields{
-					"epoch": data.Number,
-					"tx":    tx.Hash,
-				}).Error("Cannot find transaction receipt in epoch data")
+				// This could happen if there are no event logs for this transaction.
 				continue
 			}