From b3ee2d9edbef82405e20e0ab6d53005c8e7979c2 Mon Sep 17 00:00:00 2001 From: Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Fri, 31 May 2024 19:06:33 +0800 Subject: [PATCH] refactor: delete message and message batch use lua. --- pkg/common/storage/cache/redis/msg_test.go | 71 +++++++++++++++++++++- 1 file changed, 70 insertions(+), 1 deletion(-) diff --git a/pkg/common/storage/cache/redis/msg_test.go b/pkg/common/storage/cache/redis/msg_test.go index 2beade88f..f2ec4f93f 100644 --- a/pkg/common/storage/cache/redis/msg_test.go +++ b/pkg/common/storage/cache/redis/msg_test.go @@ -39,7 +39,76 @@ func Test_msgCache_SetMessagesToCache(t *testing.T) { wantErr assert.ErrorAssertionFunc }{ {"test1", fields{rdb: redis.NewClient(&redis.Options{Addr: "localhost:16379", Username: "", Password: "openIM123", DB: 0})}, args{context.Background(), - "cid", []*sdkws.MsgData{{Seq: 1}, {Seq: 2}, {Seq: 3}}}, 3, assert.NoError}, + "cid", []*sdkws.MsgData{{ + SendID: "1", + RecvID: "2", + GroupID: "3", + ClientMsgID: "sdfsdf", + ServerMsgID: "234234", + SenderPlatformID: 0, + SenderNickname: "", + SenderFaceURL: "", + SessionType: 0, + MsgFrom: 0, + ContentType: 0, + Content: nil, + Seq: 1, + SendTime: 0, + CreateTime: 0, + Status: 0, + IsRead: false, + Options: nil, + OfflinePushInfo: nil, + AtUserIDList: nil, + AttachedInfo: "", + Ex: "", + }, { + SendID: "2", + RecvID: "3", + GroupID: "4", + ClientMsgID: "sdfsdfsd", + ServerMsgID: "sdfsdf", + SenderPlatformID: 0, + SenderNickname: "", + SenderFaceURL: "", + SessionType: 0, + MsgFrom: 0, + ContentType: 0, + Content: nil, + Seq: 2, + SendTime: 0, + CreateTime: 0, + Status: 0, + IsRead: false, + Options: nil, + OfflinePushInfo: nil, + AtUserIDList: nil, + AttachedInfo: "", + Ex: "", + }, { + SendID: "5", + RecvID: "6", + GroupID: "7", + ClientMsgID: "sdfd", + ServerMsgID: "sdfsdf", + SenderPlatformID: 0, + SenderNickname: "", + SenderFaceURL: "", + SessionType: 0, + MsgFrom: 0, + ContentType: 0, + Content: nil, + Seq: 3, + SendTime: 0, + CreateTime: 0, + Status: 0, + IsRead: false, + Options: nil, + OfflinePushInfo: nil, + AtUserIDList: nil, + AttachedInfo: "", + Ex: "", + }}}, 3, assert.NoError}, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) {