added processing initial tick to cfg that override node initial tick

Author: 0xluk

main.go

@@ -59,6 +59,7 @@ func run() error {
 			ProcessTickTimeout            time.Duration `conf:"default:5s"`
 			DisableTransactionStatusAddon bool          `conf:"default:false"`
 			ArbitratorIdentity            string        `conf:"default:AFZPUAIYVPNUYGJRQVLUKOPPVLHAZQTGLYAAUUNBXFTVTAMSBKQBLEIEPCVJ"`
+			InitialTick                   uint32        `conf:"default:0"` // Initial tick to start processing from, 0 means disabled
 		}
 		Store struct {
 			ResetEmptyTickKeys bool `conf:"default:false"`
@@ -195,7 +196,7 @@ func run() error {
 		return errors.Wrapf(err, "getting arbitrator public key from [%s]", cfg.Qubic.ArbitratorIdentity)
 	}
 
-	proc := processor.NewProcessor(p, ps, cfg.Qubic.ProcessTickTimeout, arbitratorPubKey, cfg.Qubic.DisableTransactionStatusAddon)
+	proc := processor.NewProcessor(p, ps, cfg.Qubic.ProcessTickTimeout, arbitratorPubKey, cfg.Qubic.DisableTransactionStatusAddon, cfg.Qubic.InitialTick)
 	procErrors := make(chan error, 1)
 
 	// Start the service listening for requests.

processor/processor.go

@@ -30,16 +30,18 @@ type Processor struct {
 	ps                 *store.PebbleStore
 	arbitratorPubKey   [32]byte
 	processTickTimeout time.Duration
+	initialTick        uint32
 	disableStatusAddon bool
 }
 
-func NewProcessor(p *qubic.Pool, ps *store.PebbleStore, processTickTimeout time.Duration, arbitratorPubKey [32]byte, disableStatusAddon bool) *Processor {
+func NewProcessor(p *qubic.Pool, ps *store.PebbleStore, processTickTimeout time.Duration, arbitratorPubKey [32]byte, disableStatusAddon bool, initialTick uint32) *Processor {
 	return &Processor{
 		pool:               p,
 		ps:                 ps,
 		processTickTimeout: processTickTimeout,
 		arbitratorPubKey:   arbitratorPubKey,
 		disableStatusAddon: disableStatusAddon,
+		initialTick:        initialTick,
 	}
 }
 
@@ -82,6 +84,9 @@ func (p *Processor) processOneByOne() error {
 	if err != nil {
 		return errors.Wrap(err, "getting tick info")
 	}
+	if p.initialTick != 0 {
+		tickInfo.InitialTick = p.initialTick
+	}
 
 	lastTick, err := p.getLastProcessedTick(ctx, tickInfo)
 	if err != nil {