ensure a sane sequence of inserved messages

tinode · Jul 30, 2021 · 82ebf00 · 82ebf00
1 parent 0555399
commit 82ebf00
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tinode-db/gendb.go b/tinode-db/gendb.go
@@ -315,6 +315,10 @@ func genDb(data *Data) {
 				str := data.Messages[i%len(data.Messages)]
 				// Max time between messages is 2 hours, averate - 1 hour, time is increasing as seqId increases
 				timestamp = timestamp.Add(time.Microsecond * time.Duration(rand.Intn(increment)))
+				if timestamp.After(now) {
+					now = timestamp
+				}
+
 				if err = store.Messages.Save(&types.Message{
 					ObjHeader: types.ObjHeader{CreatedAt: timestamp},
 					SeqId:     seqId,