From 14232ebccd27945bfb9342dd703e85f2aed11c8d Mon Sep 17 00:00:00 2001 From: Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Thu, 12 Dec 2024 17:56:03 +0800 Subject: [PATCH] fix: server can return isEnd to control fetch messages when sdk pull messages end normally. --- internal/rpc/msg/sync_msg.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rpc/msg/sync_msg.go b/internal/rpc/msg/sync_msg.go index 13e3cfd33..7d4ffa3e6 100644 --- a/internal/rpc/msg/sync_msg.go +++ b/internal/rpc/msg/sync_msg.go @@ -97,8 +97,6 @@ func (m *msgServer) GetSeqMessage(ctx context.Context, req *msg.GetSeqMessageReq return nil, err } var pullMsgs *sdkws.PullMsgs - pullMsgs.IsEnd = isEnd - pullMsgs.EndSeq = endSeq if ok := false; conversationutil.IsNotificationConversationID(conv.ConversationID) { pullMsgs, ok = resp.NotificationMsgs[conv.ConversationID] if !ok { @@ -113,6 +111,8 @@ func (m *msgServer) GetSeqMessage(ctx context.Context, req *msg.GetSeqMessageReq } } pullMsgs.Msgs = append(pullMsgs.Msgs, msgs...) + pullMsgs.IsEnd = isEnd + pullMsgs.EndSeq = endSeq } return resp, nil }