From 0f42b330edfc9ef8b20d8e3c75b878bef5c82547 Mon Sep 17 00:00:00 2001 From: Monet Lee Date: Thu, 1 Aug 2024 15:51:17 +0800 Subject: [PATCH] remove unnecessary contents. --- internal/rpc/msg/clear.go | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/internal/rpc/msg/clear.go b/internal/rpc/msg/clear.go index 7864dbe21..09b38a139 100644 --- a/internal/rpc/msg/clear.go +++ b/internal/rpc/msg/clear.go @@ -7,7 +7,6 @@ import ( "github.com/openimsdk/open-im-server/v3/pkg/authverify" "github.com/openimsdk/open-im-server/v3/pkg/common/convert" - "github.com/openimsdk/protocol/conversation" pbconversation "github.com/openimsdk/protocol/conversation" "github.com/openimsdk/protocol/msg" "github.com/openimsdk/protocol/wrapperspb" @@ -35,19 +34,6 @@ func (m *msgServer) ClearMsg(ctx context.Context, req *msg.ClearMsgReq) (_ *msg. clearMsg := func(ctx context.Context) (bool, error) { conversationSeqs := make(map[string]struct{}) - // update latest msg destruct time in conversation DB. - defer func() { - req := &conversation.UpdateConversationReq{ - LatestMsgDestructTime: wrapperspb.Int64(time.Now().UnixMilli()), - } - for conversationID := range conversationSeqs { - req.ConversationID = conversationID - if err := m.Conversation.UpdateConversation(ctx, req); err != nil { - log.ZError(ctx, "update conversation max seq failed", err, "conversationID", conversationID, "msgDestructTime", req.MsgDestructTime) - } - } - }() - msgs, err := m.MsgDatabase.GetBeforeMsg(ctx, req.Timestamp, 100) if err != nil { return false, err