From 82ebf006bd91dc336a528bd731ae711a9f257ae2 Mon Sep 17 00:00:00 2001 From: or-else Date: Thu, 29 Jul 2021 19:38:44 -0700 Subject: [PATCH] ensure a sane sequence of inserved messages --- tinode-db/gendb.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tinode-db/gendb.go b/tinode-db/gendb.go index 722c83166..5af624723 100644 --- 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,