From a46fae324afc47de401c8a8f6592f96e762f5188 Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Mon, 9 Sep 2024 11:45:29 +0800
Subject: [PATCH] feat: avoid pulling messages from sessions with a large
 number of max seq values of 0

---
 internal/rpc/msg/sync_msg.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/internal/rpc/msg/sync_msg.go b/internal/rpc/msg/sync_msg.go
index f13dfb31c..ea4c487b9 100644
--- a/internal/rpc/msg/sync_msg.go
+++ b/internal/rpc/msg/sync_msg.go
@@ -132,6 +132,12 @@ func (m *msgServer) GetMaxSeq(ctx context.Context, req *sdkws.GetMaxSeqReq) (*sd
 		log.ZWarn(ctx, "GetMaxSeqs error", err, "conversationIDs", conversationIDs, "maxSeqs", maxSeqs)
 		return nil, err
 	}
+	// avoid pulling messages from sessions with a large number of max seq values of 0
+	for conversationID, seq := range maxSeqs {
+		if seq == 0 {
+			delete(maxSeqs, conversationID)
+		}
+	}
 	resp := new(sdkws.GetMaxSeqResp)
 	resp.MaxSeqs = maxSeqs
 	return resp, nil