blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-06-14 22:59:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

cron

Browse Source
This commit is contained in:
wangchuxiao 2022-12-28 17:49:41 +08:00
parent 235be5da0c
commit ee9c3cbde3
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/cron_task/clear_msg_test.go
View File

@ -164,4 +164,24 @@ func TestDeleteMongoMsgAndResetRedisSeq(t *testing.T) {
if minSeq != 11001 { if minSeq != 11001 {
t.Error("test3 is not the same", "minSeq:", minSeq, "targetSeq", 11001) t.Error("test3 is not the same", "minSeq:", minSeq, "targetSeq", 11001)
} }
testUID5 := "test_del_id5"
err = SetUserMaxSeq(testUID4, 9999)
userChat = GenUserChat(1, 4999, 5000, 0, testUID5)
userChat2 = GenUserChat(5000, 9999, 10000, 1, testUID5)
err = CreateChat(userChat)
err = CreateChat(userChat2)
if err := DeleteMongoMsgAndResetRedisSeq(operationID, testUID5); err != nil {
t.Error("checkMaxSeqWithMongo failed", testUID4)
}
if err := checkMaxSeqWithMongo(operationID, testUID5, constant.WriteDiffusion); err != nil {
t.Error("checkMaxSeqWithMongo failed", testUID5)
}
minSeq, err = GetUserMinSeq(testUID5)
if err != nil {
t.Error("err is not nil", testUID5, err.Error())
}
if minSeq != 10000 {
t.Error("test3 is not the same", "minSeq:", minSeq, "targetSeq", 10000)
}
} }