WarpySyncer: store last synced block timestamp in database

src/warpy_sync/store.go

@@ -23,6 +23,7 @@ type Store struct {
 	savedLastSyncedBlockHeight uint64
 	lastSyncedBlockHeight      uint64
 	lastSyncedBlockHash        string
+	lastSyncedBlockTimestamp   uint64
 	syncedComponent            model.SyncedComponent
 }
 
@@ -61,6 +62,7 @@ func (self *Store) WithSyncedComponent(syncedComponent model.SyncedComponent) *S
 func (self *Store) process(payload *LastSyncedBlockPayload) (out []*LastSyncedBlockPayload, err error) {
 	self.lastSyncedBlockHeight = payload.Height
 	self.lastSyncedBlockHash = payload.Hash
+	self.lastSyncedBlockTimestamp = payload.Timestamp
 	return
 }
 
@@ -111,8 +113,9 @@ func (self *Store) updateLastSyncedHeight(tx *gorm.DB) (err error) {
 				Name: self.syncedComponent,
 			}).
 			Updates(model.State{
-				FinishedBlockHeight: uint64(self.lastSyncedBlockHeight),
-				FinishedBlockHash:   arweave.Base64String(self.lastSyncedBlockHash),
+				FinishedBlockHeight:    self.lastSyncedBlockHeight,
+				FinishedBlockHash:      arweave.Base64String(self.lastSyncedBlockHash),
+				FinishedBlockTimestamp: self.lastSyncedBlockTimestamp,
 			}).
 			Error
 		if err != nil {

src/warpy_sync/syncer_delta.go

@@ -79,8 +79,9 @@ func (self *SyncerDelta) run() (err error) {
 		case <-self.Ctx.Done():
 			return nil
 		case self.Output <- &LastSyncedBlockPayload{
-			Height: block.Height,
-			Hash:   block.Hash,
+			Height:    block.Height,
+			Hash:      block.Hash,
+			Timestamp: block.Timestamp,
 		}:
 		}
 

src/warpy_sync/syncer_sommelier.go

@@ -95,8 +95,9 @@ func (self *SyncerSommelier) run() (err error) {
 		case <-self.Ctx.Done():
 			return nil
 		case self.Output <- &LastSyncedBlockPayload{
-			Height: block.Height,
-			Hash:   block.Hash,
+			Height:    block.Height,
+			Hash:      block.Hash,
+			Timestamp: block.Timestamp,
 		}:
 		}
 

src/warpy_sync/types.go

@@ -36,8 +36,9 @@ type BlockInfoPayload struct {
 }
 
 type LastSyncedBlockPayload struct {
-	Height uint64
-	Hash   string
+	Height    uint64
+	Hash      string
+	Timestamp uint64
 }
 
 type InteractionPayload struct {