as time.Time

tidepool-org · Dec 12, 2023 · fbeb0f8 · fbeb0f8
1 parent 1cf7e58
commit fbeb0f8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go
@@ -217,7 +217,7 @@ func (m *Migration) execute() error {
 
 func (m *Migration) getOplogDuration() (time.Duration, error) {
 	type MongoMetaData struct {
-		Wall int64 `json:"wall"`
+		Wall time.Time `json:"wall"`
 	}
 
 	log.Println("checking oplog duration ")
@@ -239,9 +239,9 @@ func (m *Migration) getOplogDuration() (time.Duration, error) {
 			log.Printf("newest walltime mongo err %v", err)
 			return 0, err
 		}
-		oldestT := time.UnixMilli(oldest.Wall)
-		newestT := time.UnixMilli(newest.Wall)
-		oplogDuration := newestT.Sub(oldestT)
+		//oldestT := time.UnixMilli(oldest.Wall)
+		//newestT := time.UnixMilli(newest.Wall)
+		oplogDuration := newest.Wall.Sub(oldest.Wall)
 		log.Printf("oplog duration is currently: %v", oplogDuration)
 		return oplogDuration, nil
 	}