[P-TX] use Banff block time for TX

scripts/build.sh

@@ -0,0 +1,3 @@
+#!/usr/bin/env bash
+
+go build cmds/magelland/magelland.go

services/indexes/pvm/writer.go

@@ -374,6 +374,12 @@ func (w *Writer) indexBlock(ctx services.ConsumerCtx, blockBytes []byte) error {
 	ctxTime := ctx.Time()
 	pvmProposer := models.NewBlockProposal(proposerBlock, &ctxTime)
 
+	adjustCtxTime := func(tm uint64) {
+		ctxTime := time.Unix(int64(tm), 0)
+		ctx.SetTime(ctxTime)
+		pvmProposer.TimeStamp = &ctxTime
+	}
+
 	errs := wrappers.Errs{}
 	switch blk := blk.(type) {
 	case *blocks.ApricotProposalBlock:
@@ -387,20 +393,16 @@ func (w *Writer) indexBlock(ctx services.ConsumerCtx, blockBytes []byte) error {
 	case *blocks.ApricotCommitBlock:
 		errs.Add(w.indexCommonBlock(ctx, blkID, models.BlockTypeCommit, blk.CommonBlock, pvmProposer, innerBlockBytes))
 	case *blocks.BanffProposalBlock:
-		ctxTime = time.Unix(int64(blk.Time), 0)
-		pvmProposer.TimeStamp = &ctxTime
+		adjustCtxTime(blk.Time)
 		errs.Add(w.indexCommonBlock(ctx, blkID, models.BlockTypeStandard, blk.CommonBlock, pvmProposer, innerBlockBytes))
 	case *blocks.BanffStandardBlock:
-		ctxTime = time.Unix(int64(blk.Time), 0)
-		pvmProposer.TimeStamp = &ctxTime
+		adjustCtxTime(blk.Time)
 		errs.Add(w.indexCommonBlock(ctx, blkID, models.BlockTypeStandard, blk.CommonBlock, pvmProposer, innerBlockBytes))
 	case *blocks.BanffAbortBlock:
-		ctxTime = time.Unix(int64(blk.Time), 0)
-		pvmProposer.TimeStamp = &ctxTime
+		adjustCtxTime(blk.Time)
 		errs.Add(w.indexCommonBlock(ctx, blkID, models.BlockTypeAbort, blk.CommonBlock, pvmProposer, innerBlockBytes))
 	case *blocks.BanffCommitBlock:
-		ctxTime = time.Unix(int64(blk.Time), 0)
-		pvmProposer.TimeStamp = &ctxTime
+		adjustCtxTime(blk.Time)
 		errs.Add(w.indexCommonBlock(ctx, blkID, models.BlockTypeCommit, blk.CommonBlock, pvmProposer, innerBlockBytes))
 	default:
 		return fmt.Errorf("unknown type %T", blk)

services/services.go

@@ -60,3 +60,4 @@ func (ic *ConsumerCtx) DB() dbr.SessionRunner { return ic.db }
 func (ic *ConsumerCtx) Ctx() context.Context  { return ic.ctx }
 func (ic *ConsumerCtx) Persist() db.Persist   { return ic.persist }
 func (ic *ConsumerCtx) ChainID() string       { return ic.chainID }
+func (ic *ConsumerCtx) SetTime(tm time.Time)  { ic.time = tm }