Non-nil timestamps on checkpoints

Signed-off-by: Peter Broadhurst <peter.broadhurst@kaleido.io>
hyperledger · Jul 11, 2023 · 3545306 · 3545306
1 parent bc77ecb
commit 3545306
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/persistence/dbmigration/migration.go b/internal/persistence/dbmigration/migration.go
@@ -96,6 +96,13 @@ func (m *dbMigration) migrateEventStream(ctx context.Context, es *apitypes.Event
 		return err
 	}
 	if cp != nil && existingCP == nil {
+		// LevelDB didn't have timestamps in checkpoints
+		if cp.FirstCheckpoint == nil {
+			cp.FirstCheckpoint = fftypes.Now()
+		}
+		if cp.Time == nil {
+			cp.Time = cp.FirstCheckpoint
+		}
 		log.L(ctx).Infof("Writing checkpoint %s to target", cp.StreamID)
 		if err := m.target.WriteCheckpoint(ctx, cp); err != nil {
 			return err