feat: add Seqs time, GetActiveConversation

openimsdk · Sep 25, 2024 · 1018d55 · 1018d55
1 parent b5ba0f0
commit 1018d55
Show file tree

Hide file tree

Showing 14 changed files with 559 additions and 263 deletions.
diff --git a/auth/auth.pb.go b/auth/auth.pb.go
diff --git a/errinfo/errinfo.pb.go b/errinfo/errinfo.pb.go
diff --git a/group/group.pb.go b/group/group.pb.go
diff --git a/msg/msg.pb.go b/msg/msg.pb.go
diff --git a/msg/msg.proto b/msg/msg.proto
@@ -194,6 +194,7 @@ message GetConversationsHasReadAndMaxSeqReq {
 message Seqs {
   int64 maxSeq = 1;
   int64 hasReadSeq = 2;
+  int64 maxSeqTime = 3;
 }
 
 message GetConversationsHasReadAndMaxSeqResp {
@@ -335,6 +336,21 @@ message GetSeqMessageResp {
   map<string, sdkws.PullMsgs> notificationMsgs = 2;
 }
 
+message GetActiveConversationReq {
+  repeated string conversationIDs = 1;
+  int64 limit = 2;
+}
+
+message ActiveConversation {
+  string conversationID = 1;
+  int64 lastTime = 2;
+  int64 maxSeq = 3;
+}
+
+message GetActiveConversationResp {
+  repeated ActiveConversation conversations = 1;
+}
+
 service msg {
   //获取最小最大seq（包括用户的，以及指定群组的）
   rpc GetMaxSeq(sdkws.GetMaxSeqReq) returns (sdkws.GetMaxSeqResp);
@@ -382,4 +398,6 @@ service msg {
 
   rpc ClearMsg(ClearMsgReq) returns (ClearMsgResp);
   rpc DestructMsgs(DestructMsgsReq) returns (DestructMsgsResp);
+
+  rpc GetActiveConversation(GetActiveConversationReq) returns (GetActiveConversationResp);
 }
diff --git a/msggateway/msggateway.pb.go b/msggateway/msggateway.pb.go
diff --git a/push/push.pb.go b/push/push.pb.go
diff --git a/relation/relation.pb.go b/relation/relation.pb.go
diff --git a/rtc/rtc.pb.go b/rtc/rtc.pb.go
diff --git a/sdkws/sdkws.pb.go b/sdkws/sdkws.pb.go
diff --git a/statistics/statistics.pb.go b/statistics/statistics.pb.go
diff --git a/third/third.pb.go b/third/third.pb.go
diff --git a/user/user.pb.go b/user/user.pb.go
diff --git a/wrapperspb/wrapperspb.pb.go b/wrapperspb/wrapperspb.pb.go