From 91ea5d1fe83455995df490767d71b843f3c18aba Mon Sep 17 00:00:00 2001 From: Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Sat, 1 Jun 2024 10:19:21 +0800 Subject: [PATCH] refactor: delete message and message batch use lua. --- pkg/common/storage/cache/redis/msg_test.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/pkg/common/storage/cache/redis/msg_test.go b/pkg/common/storage/cache/redis/msg_test.go index 4b9af9677..c572c0a79 100644 --- a/pkg/common/storage/cache/redis/msg_test.go +++ b/pkg/common/storage/cache/redis/msg_test.go @@ -94,6 +94,19 @@ func Test_msgCache_GetMessagesBySeq(t *testing.T) { } } +func Test_msgCache_GetMessagesBySeq2(t *testing.T) { + c := &msgCache{ + rdb: redis.NewClient(&redis.Options{Addr: "localhost:16379", Password: "openIM123", DB: 0}), + } + gotSeqMsgs, gotFailedSeqs, err := c.GetMessagesBySeq(context.Background(), "cid", []int64{1, 2, 3}) + if err != nil { + fmt.Println("Test_msgCache_GetMessagesBySeq2 error is ", err) + return + } + fmt.Println("Test_msgCache_GetMessagesBySeq2 result is ", gotSeqMsgs, gotFailedSeqs) + +} + func Test_msgCache_DeleteMessagesFromCache(t *testing.T) { type fields struct { rdb redis.UniversalClient