diff --git a/conversation/conversation.pb.go b/conversation/conversation.pb.go index 109da8ce..fc1a7c7b 100644 --- a/conversation/conversation.pb.go +++ b/conversation/conversation.pb.go @@ -2272,9 +2272,10 @@ func (*UpdateConversationResp) Descriptor() ([]byte, []int) { } type GetFullOwnerConversationIDsReq struct { - state protoimpl.MessageState `protogen:"open.v1"` - IdHash uint64 `protobuf:"varint,1,opt,name=idHash,proto3" json:"idHash"` - UserID string `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID"` + state protoimpl.MessageState `protogen:"open.v1"` + IdHash uint64 `protobuf:"varint,1,opt,name=idHash,proto3" json:"idHash"` + UserID string `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID"` + Pagination *sdkws.RequestPagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -2323,12 +2324,20 @@ func (x *GetFullOwnerConversationIDsReq) GetUserID() string { return "" } +func (x *GetFullOwnerConversationIDsReq) GetPagination() *sdkws.RequestPagination { + if x != nil { + return x.Pagination + } + return nil +} + type GetFullOwnerConversationIDsResp struct { state protoimpl.MessageState `protogen:"open.v1"` Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version"` VersionID string `protobuf:"bytes,2,opt,name=versionID,proto3" json:"versionID"` Equal bool `protobuf:"varint,3,opt,name=equal,proto3" json:"equal"` ConversationIDs []string `protobuf:"bytes,4,rep,name=conversationIDs,proto3" json:"conversationIDs"` + Total int64 `protobuf:"varint,5,opt,name=total,proto3" json:"total"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -2391,6 +2400,13 @@ func (x *GetFullOwnerConversationIDsResp) GetConversationIDs() []string { return nil } +func (x *GetFullOwnerConversationIDsResp) GetTotal() int64 { + if x != nil { + return x.Total + } + return 0 +} + type GetIncrementalConversationReq struct { state protoimpl.MessageState `protogen:"open.v1"` UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"` @@ -3343,15 +3359,19 @@ const file_conversation_conversation_proto_rawDesc = "" + "\x0fmsgDestructTime\x18\f \x01(\v2\x1b.openim.protobuf.Int64ValueR\x0fmsgDestructTime\x12@\n" + "\risMsgDestruct\x18\r \x01(\v2\x1a.openim.protobuf.BoolValueR\risMsgDestruct\x12Q\n" + "\x15latestMsgDestructTime\x18\x0e \x01(\v2\x1b.openim.protobuf.Int64ValueR\x15latestMsgDestructTime\"\x18\n" + - "\x16UpdateConversationResp\"P\n" + + "\x16UpdateConversationResp\"\x91\x01\n" + "\x1eGetFullOwnerConversationIDsReq\x12\x16\n" + "\x06idHash\x18\x01 \x01(\x04R\x06idHash\x12\x16\n" + - "\x06userID\x18\x02 \x01(\tR\x06userID\"\x99\x01\n" + + "\x06userID\x18\x02 \x01(\tR\x06userID\x12?\n" + + "\n" + + "pagination\x18\x03 \x01(\v2\x1f.openim.sdkws.RequestPaginationR\n" + + "pagination\"\xaf\x01\n" + "\x1fGetFullOwnerConversationIDsResp\x12\x18\n" + "\aversion\x18\x01 \x01(\x04R\aversion\x12\x1c\n" + "\tversionID\x18\x02 \x01(\tR\tversionID\x12\x14\n" + "\x05equal\x18\x03 \x01(\bR\x05equal\x12(\n" + - "\x0fconversationIDs\x18\x04 \x03(\tR\x0fconversationIDs\"o\n" + + "\x0fconversationIDs\x18\x04 \x03(\tR\x0fconversationIDs\x12\x14\n" + + "\x05total\x18\x05 \x01(\x03R\x05total\"o\n" + "\x1dGetIncrementalConversationReq\x12\x16\n" + "\x06userID\x18\x01 \x01(\tR\x06userID\x12\x1c\n" + "\tversionID\x18\x02 \x01(\tR\tversionID\x12\x18\n" + @@ -3533,69 +3553,70 @@ var file_conversation_conversation_proto_depIdxs = []int32{ 59, // 29: openim.conversation.UpdateConversationReq.msgDestructTime:type_name -> openim.protobuf.Int64Value 57, // 30: openim.conversation.UpdateConversationReq.isMsgDestruct:type_name -> openim.protobuf.BoolValue 59, // 31: openim.conversation.UpdateConversationReq.latestMsgDestructTime:type_name -> openim.protobuf.Int64Value - 0, // 32: openim.conversation.GetIncrementalConversationResp.insert:type_name -> openim.conversation.Conversation - 0, // 33: openim.conversation.GetIncrementalConversationResp.update:type_name -> openim.conversation.Conversation - 60, // 34: openim.conversation.GetOwnerConversationReq.pagination:type_name -> openim.sdkws.RequestPagination - 0, // 35: openim.conversation.GetOwnerConversationResp.conversations:type_name -> openim.conversation.Conversation - 0, // 36: openim.conversation.GetConversationsNeedClearMsgResp.conversations:type_name -> openim.conversation.Conversation - 58, // 37: openim.conversation.UpdateConversationsByUserReq.ex:type_name -> openim.protobuf.StringValue - 4, // 38: openim.conversation.conversation.GetConversation:input_type -> openim.conversation.GetConversationReq - 6, // 39: openim.conversation.conversation.GetSortedConversationList:input_type -> openim.conversation.GetSortedConversationListReq - 12, // 40: openim.conversation.conversation.GetAllConversations:input_type -> openim.conversation.GetAllConversationsReq - 10, // 41: openim.conversation.conversation.GetConversations:input_type -> openim.conversation.GetConversationsReq - 2, // 42: openim.conversation.conversation.SetConversation:input_type -> openim.conversation.SetConversationReq - 14, // 43: openim.conversation.conversation.GetRecvMsgNotNotifyUserIDs:input_type -> openim.conversation.GetRecvMsgNotNotifyUserIDsReq - 16, // 44: openim.conversation.conversation.CreateSingleChatConversations:input_type -> openim.conversation.CreateSingleChatConversationsReq - 18, // 45: openim.conversation.conversation.CreateGroupChatConversations:input_type -> openim.conversation.CreateGroupChatConversationsReq - 20, // 46: openim.conversation.conversation.SetConversationMaxSeq:input_type -> openim.conversation.SetConversationMaxSeqReq - 22, // 47: openim.conversation.conversation.SetConversationMinSeq:input_type -> openim.conversation.SetConversationMinSeqReq - 24, // 48: openim.conversation.conversation.GetConversationIDs:input_type -> openim.conversation.GetConversationIDsReq - 26, // 49: openim.conversation.conversation.SetConversations:input_type -> openim.conversation.SetConversationsReq - 28, // 50: openim.conversation.conversation.GetUserConversationIDsHash:input_type -> openim.conversation.GetUserConversationIDsHashReq - 30, // 51: openim.conversation.conversation.GetConversationsByConversationID:input_type -> openim.conversation.GetConversationsByConversationIDReq - 32, // 52: openim.conversation.conversation.GetConversationOfflinePushUserIDs:input_type -> openim.conversation.GetConversationOfflinePushUserIDsReq - 34, // 53: openim.conversation.conversation.GetConversationNotReceiveMessageUserIDs:input_type -> openim.conversation.GetConversationNotReceiveMessageUserIDsReq - 36, // 54: openim.conversation.conversation.UpdateConversation:input_type -> openim.conversation.UpdateConversationReq - 38, // 55: openim.conversation.conversation.GetFullOwnerConversationIDs:input_type -> openim.conversation.GetFullOwnerConversationIDsReq - 40, // 56: openim.conversation.conversation.GetIncrementalConversation:input_type -> openim.conversation.GetIncrementalConversationReq - 42, // 57: openim.conversation.conversation.GetOwnerConversation:input_type -> openim.conversation.GetOwnerConversationReq - 44, // 58: openim.conversation.conversation.GetConversationsNeedClearMsg:input_type -> openim.conversation.GetConversationsNeedClearMsgReq - 46, // 59: openim.conversation.conversation.GetNotNotifyConversationIDs:input_type -> openim.conversation.GetNotNotifyConversationIDsReq - 48, // 60: openim.conversation.conversation.GetPinnedConversationIDs:input_type -> openim.conversation.GetPinnedConversationIDsReq - 50, // 61: openim.conversation.conversation.ClearUserConversationMsg:input_type -> openim.conversation.ClearUserConversationMsgReq - 52, // 62: openim.conversation.conversation.UpdateConversationsByUser:input_type -> openim.conversation.UpdateConversationsByUserReq - 54, // 63: openim.conversation.conversation.DeleteConversations:input_type -> openim.conversation.DeleteConversationsReq - 5, // 64: openim.conversation.conversation.GetConversation:output_type -> openim.conversation.GetConversationResp - 7, // 65: openim.conversation.conversation.GetSortedConversationList:output_type -> openim.conversation.GetSortedConversationListResp - 13, // 66: openim.conversation.conversation.GetAllConversations:output_type -> openim.conversation.GetAllConversationsResp - 11, // 67: openim.conversation.conversation.GetConversations:output_type -> openim.conversation.GetConversationsResp - 3, // 68: openim.conversation.conversation.SetConversation:output_type -> openim.conversation.SetConversationResp - 15, // 69: openim.conversation.conversation.GetRecvMsgNotNotifyUserIDs:output_type -> openim.conversation.GetRecvMsgNotNotifyUserIDsResp - 17, // 70: openim.conversation.conversation.CreateSingleChatConversations:output_type -> openim.conversation.CreateSingleChatConversationsResp - 19, // 71: openim.conversation.conversation.CreateGroupChatConversations:output_type -> openim.conversation.CreateGroupChatConversationsResp - 21, // 72: openim.conversation.conversation.SetConversationMaxSeq:output_type -> openim.conversation.SetConversationMaxSeqResp - 23, // 73: openim.conversation.conversation.SetConversationMinSeq:output_type -> openim.conversation.SetConversationMinSeqResp - 25, // 74: openim.conversation.conversation.GetConversationIDs:output_type -> openim.conversation.GetConversationIDsResp - 27, // 75: openim.conversation.conversation.SetConversations:output_type -> openim.conversation.SetConversationsResp - 29, // 76: openim.conversation.conversation.GetUserConversationIDsHash:output_type -> openim.conversation.GetUserConversationIDsHashResp - 31, // 77: openim.conversation.conversation.GetConversationsByConversationID:output_type -> openim.conversation.GetConversationsByConversationIDResp - 33, // 78: openim.conversation.conversation.GetConversationOfflinePushUserIDs:output_type -> openim.conversation.GetConversationOfflinePushUserIDsResp - 35, // 79: openim.conversation.conversation.GetConversationNotReceiveMessageUserIDs:output_type -> openim.conversation.GetConversationNotReceiveMessageUserIDsResp - 37, // 80: openim.conversation.conversation.UpdateConversation:output_type -> openim.conversation.UpdateConversationResp - 39, // 81: openim.conversation.conversation.GetFullOwnerConversationIDs:output_type -> openim.conversation.GetFullOwnerConversationIDsResp - 41, // 82: openim.conversation.conversation.GetIncrementalConversation:output_type -> openim.conversation.GetIncrementalConversationResp - 43, // 83: openim.conversation.conversation.GetOwnerConversation:output_type -> openim.conversation.GetOwnerConversationResp - 45, // 84: openim.conversation.conversation.GetConversationsNeedClearMsg:output_type -> openim.conversation.GetConversationsNeedClearMsgResp - 47, // 85: openim.conversation.conversation.GetNotNotifyConversationIDs:output_type -> openim.conversation.GetNotNotifyConversationIDsResp - 49, // 86: openim.conversation.conversation.GetPinnedConversationIDs:output_type -> openim.conversation.GetPinnedConversationIDsResp - 51, // 87: openim.conversation.conversation.ClearUserConversationMsg:output_type -> openim.conversation.ClearUserConversationMsgResp - 53, // 88: openim.conversation.conversation.UpdateConversationsByUser:output_type -> openim.conversation.UpdateConversationsByUserResp - 55, // 89: openim.conversation.conversation.DeleteConversations:output_type -> openim.conversation.DeleteConversationsResp - 64, // [64:90] is the sub-list for method output_type - 38, // [38:64] is the sub-list for method input_type - 38, // [38:38] is the sub-list for extension type_name - 38, // [38:38] is the sub-list for extension extendee - 0, // [0:38] is the sub-list for field type_name + 60, // 32: openim.conversation.GetFullOwnerConversationIDsReq.pagination:type_name -> openim.sdkws.RequestPagination + 0, // 33: openim.conversation.GetIncrementalConversationResp.insert:type_name -> openim.conversation.Conversation + 0, // 34: openim.conversation.GetIncrementalConversationResp.update:type_name -> openim.conversation.Conversation + 60, // 35: openim.conversation.GetOwnerConversationReq.pagination:type_name -> openim.sdkws.RequestPagination + 0, // 36: openim.conversation.GetOwnerConversationResp.conversations:type_name -> openim.conversation.Conversation + 0, // 37: openim.conversation.GetConversationsNeedClearMsgResp.conversations:type_name -> openim.conversation.Conversation + 58, // 38: openim.conversation.UpdateConversationsByUserReq.ex:type_name -> openim.protobuf.StringValue + 4, // 39: openim.conversation.conversation.GetConversation:input_type -> openim.conversation.GetConversationReq + 6, // 40: openim.conversation.conversation.GetSortedConversationList:input_type -> openim.conversation.GetSortedConversationListReq + 12, // 41: openim.conversation.conversation.GetAllConversations:input_type -> openim.conversation.GetAllConversationsReq + 10, // 42: openim.conversation.conversation.GetConversations:input_type -> openim.conversation.GetConversationsReq + 2, // 43: openim.conversation.conversation.SetConversation:input_type -> openim.conversation.SetConversationReq + 14, // 44: openim.conversation.conversation.GetRecvMsgNotNotifyUserIDs:input_type -> openim.conversation.GetRecvMsgNotNotifyUserIDsReq + 16, // 45: openim.conversation.conversation.CreateSingleChatConversations:input_type -> openim.conversation.CreateSingleChatConversationsReq + 18, // 46: openim.conversation.conversation.CreateGroupChatConversations:input_type -> openim.conversation.CreateGroupChatConversationsReq + 20, // 47: openim.conversation.conversation.SetConversationMaxSeq:input_type -> openim.conversation.SetConversationMaxSeqReq + 22, // 48: openim.conversation.conversation.SetConversationMinSeq:input_type -> openim.conversation.SetConversationMinSeqReq + 24, // 49: openim.conversation.conversation.GetConversationIDs:input_type -> openim.conversation.GetConversationIDsReq + 26, // 50: openim.conversation.conversation.SetConversations:input_type -> openim.conversation.SetConversationsReq + 28, // 51: openim.conversation.conversation.GetUserConversationIDsHash:input_type -> openim.conversation.GetUserConversationIDsHashReq + 30, // 52: openim.conversation.conversation.GetConversationsByConversationID:input_type -> openim.conversation.GetConversationsByConversationIDReq + 32, // 53: openim.conversation.conversation.GetConversationOfflinePushUserIDs:input_type -> openim.conversation.GetConversationOfflinePushUserIDsReq + 34, // 54: openim.conversation.conversation.GetConversationNotReceiveMessageUserIDs:input_type -> openim.conversation.GetConversationNotReceiveMessageUserIDsReq + 36, // 55: openim.conversation.conversation.UpdateConversation:input_type -> openim.conversation.UpdateConversationReq + 38, // 56: openim.conversation.conversation.GetFullOwnerConversationIDs:input_type -> openim.conversation.GetFullOwnerConversationIDsReq + 40, // 57: openim.conversation.conversation.GetIncrementalConversation:input_type -> openim.conversation.GetIncrementalConversationReq + 42, // 58: openim.conversation.conversation.GetOwnerConversation:input_type -> openim.conversation.GetOwnerConversationReq + 44, // 59: openim.conversation.conversation.GetConversationsNeedClearMsg:input_type -> openim.conversation.GetConversationsNeedClearMsgReq + 46, // 60: openim.conversation.conversation.GetNotNotifyConversationIDs:input_type -> openim.conversation.GetNotNotifyConversationIDsReq + 48, // 61: openim.conversation.conversation.GetPinnedConversationIDs:input_type -> openim.conversation.GetPinnedConversationIDsReq + 50, // 62: openim.conversation.conversation.ClearUserConversationMsg:input_type -> openim.conversation.ClearUserConversationMsgReq + 52, // 63: openim.conversation.conversation.UpdateConversationsByUser:input_type -> openim.conversation.UpdateConversationsByUserReq + 54, // 64: openim.conversation.conversation.DeleteConversations:input_type -> openim.conversation.DeleteConversationsReq + 5, // 65: openim.conversation.conversation.GetConversation:output_type -> openim.conversation.GetConversationResp + 7, // 66: openim.conversation.conversation.GetSortedConversationList:output_type -> openim.conversation.GetSortedConversationListResp + 13, // 67: openim.conversation.conversation.GetAllConversations:output_type -> openim.conversation.GetAllConversationsResp + 11, // 68: openim.conversation.conversation.GetConversations:output_type -> openim.conversation.GetConversationsResp + 3, // 69: openim.conversation.conversation.SetConversation:output_type -> openim.conversation.SetConversationResp + 15, // 70: openim.conversation.conversation.GetRecvMsgNotNotifyUserIDs:output_type -> openim.conversation.GetRecvMsgNotNotifyUserIDsResp + 17, // 71: openim.conversation.conversation.CreateSingleChatConversations:output_type -> openim.conversation.CreateSingleChatConversationsResp + 19, // 72: openim.conversation.conversation.CreateGroupChatConversations:output_type -> openim.conversation.CreateGroupChatConversationsResp + 21, // 73: openim.conversation.conversation.SetConversationMaxSeq:output_type -> openim.conversation.SetConversationMaxSeqResp + 23, // 74: openim.conversation.conversation.SetConversationMinSeq:output_type -> openim.conversation.SetConversationMinSeqResp + 25, // 75: openim.conversation.conversation.GetConversationIDs:output_type -> openim.conversation.GetConversationIDsResp + 27, // 76: openim.conversation.conversation.SetConversations:output_type -> openim.conversation.SetConversationsResp + 29, // 77: openim.conversation.conversation.GetUserConversationIDsHash:output_type -> openim.conversation.GetUserConversationIDsHashResp + 31, // 78: openim.conversation.conversation.GetConversationsByConversationID:output_type -> openim.conversation.GetConversationsByConversationIDResp + 33, // 79: openim.conversation.conversation.GetConversationOfflinePushUserIDs:output_type -> openim.conversation.GetConversationOfflinePushUserIDsResp + 35, // 80: openim.conversation.conversation.GetConversationNotReceiveMessageUserIDs:output_type -> openim.conversation.GetConversationNotReceiveMessageUserIDsResp + 37, // 81: openim.conversation.conversation.UpdateConversation:output_type -> openim.conversation.UpdateConversationResp + 39, // 82: openim.conversation.conversation.GetFullOwnerConversationIDs:output_type -> openim.conversation.GetFullOwnerConversationIDsResp + 41, // 83: openim.conversation.conversation.GetIncrementalConversation:output_type -> openim.conversation.GetIncrementalConversationResp + 43, // 84: openim.conversation.conversation.GetOwnerConversation:output_type -> openim.conversation.GetOwnerConversationResp + 45, // 85: openim.conversation.conversation.GetConversationsNeedClearMsg:output_type -> openim.conversation.GetConversationsNeedClearMsgResp + 47, // 86: openim.conversation.conversation.GetNotNotifyConversationIDs:output_type -> openim.conversation.GetNotNotifyConversationIDsResp + 49, // 87: openim.conversation.conversation.GetPinnedConversationIDs:output_type -> openim.conversation.GetPinnedConversationIDsResp + 51, // 88: openim.conversation.conversation.ClearUserConversationMsg:output_type -> openim.conversation.ClearUserConversationMsgResp + 53, // 89: openim.conversation.conversation.UpdateConversationsByUser:output_type -> openim.conversation.UpdateConversationsByUserResp + 55, // 90: openim.conversation.conversation.DeleteConversations:output_type -> openim.conversation.DeleteConversationsResp + 65, // [65:91] is the sub-list for method output_type + 39, // [39:65] is the sub-list for method input_type + 39, // [39:39] is the sub-list for extension type_name + 39, // [39:39] is the sub-list for extension extendee + 0, // [0:39] is the sub-list for field type_name } func init() { file_conversation_conversation_proto_init() } diff --git a/conversation/conversation.proto b/conversation/conversation.proto index 2619ce07..44a4c845 100644 --- a/conversation/conversation.proto +++ b/conversation/conversation.proto @@ -226,6 +226,7 @@ message UpdateConversationResp {} message GetFullOwnerConversationIDsReq { uint64 idHash = 1; string userID = 2; + openim.sdkws.RequestPagination pagination = 3; } message GetFullOwnerConversationIDsResp { @@ -233,6 +234,7 @@ message GetFullOwnerConversationIDsResp { string versionID = 2; bool equal = 3; repeated string conversationIDs = 4; + int64 total = 5; } message GetIncrementalConversationReq { diff --git a/msg/msg.pb.go b/msg/msg.pb.go index 73399890..1ac5ac78 100644 --- a/msg/msg.pb.go +++ b/msg/msg.pb.go @@ -4235,6 +4235,170 @@ func (x *GetLastMessageResp) GetMsgs() map[string]*sdkws.MsgData { return nil } +type GetConversationsFullSyncSeqsReq struct { + state protoimpl.MessageState `protogen:"open.v1"` + UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"` + ConversationIDs []string `protobuf:"bytes,2,rep,name=conversationIDs,proto3" json:"conversationIDs"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetConversationsFullSyncSeqsReq) Reset() { + *x = GetConversationsFullSyncSeqsReq{} + mi := &file_msg_msg_proto_msgTypes[81] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetConversationsFullSyncSeqsReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetConversationsFullSyncSeqsReq) ProtoMessage() {} + +func (x *GetConversationsFullSyncSeqsReq) ProtoReflect() protoreflect.Message { + mi := &file_msg_msg_proto_msgTypes[81] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetConversationsFullSyncSeqsReq.ProtoReflect.Descriptor instead. +func (*GetConversationsFullSyncSeqsReq) Descriptor() ([]byte, []int) { + return file_msg_msg_proto_rawDescGZIP(), []int{81} +} + +func (x *GetConversationsFullSyncSeqsReq) GetUserID() string { + if x != nil { + return x.UserID + } + return "" +} + +func (x *GetConversationsFullSyncSeqsReq) GetConversationIDs() []string { + if x != nil { + return x.ConversationIDs + } + return nil +} + +type FullSyncSeqs struct { + state protoimpl.MessageState `protogen:"open.v1"` + MaxSeq int64 `protobuf:"varint,1,opt,name=maxSeq,proto3" json:"maxSeq"` + HasReadSeq int64 `protobuf:"varint,2,opt,name=hasReadSeq,proto3" json:"hasReadSeq"` + MaxSeqTime int64 `protobuf:"varint,3,opt,name=maxSeqTime,proto3" json:"maxSeqTime"` + UserMinSeq int64 `protobuf:"varint,4,opt,name=userMinSeq,proto3" json:"userMinSeq"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *FullSyncSeqs) Reset() { + *x = FullSyncSeqs{} + mi := &file_msg_msg_proto_msgTypes[82] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *FullSyncSeqs) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*FullSyncSeqs) ProtoMessage() {} + +func (x *FullSyncSeqs) ProtoReflect() protoreflect.Message { + mi := &file_msg_msg_proto_msgTypes[82] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use FullSyncSeqs.ProtoReflect.Descriptor instead. +func (*FullSyncSeqs) Descriptor() ([]byte, []int) { + return file_msg_msg_proto_rawDescGZIP(), []int{82} +} + +func (x *FullSyncSeqs) GetMaxSeq() int64 { + if x != nil { + return x.MaxSeq + } + return 0 +} + +func (x *FullSyncSeqs) GetHasReadSeq() int64 { + if x != nil { + return x.HasReadSeq + } + return 0 +} + +func (x *FullSyncSeqs) GetMaxSeqTime() int64 { + if x != nil { + return x.MaxSeqTime + } + return 0 +} + +func (x *FullSyncSeqs) GetUserMinSeq() int64 { + if x != nil { + return x.UserMinSeq + } + return 0 +} + +type GetConversationsFullSyncSeqsResp struct { + state protoimpl.MessageState `protogen:"open.v1"` + Seqs map[string]*FullSyncSeqs `protobuf:"bytes,1,rep,name=seqs,proto3" json:"seqs,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetConversationsFullSyncSeqsResp) Reset() { + *x = GetConversationsFullSyncSeqsResp{} + mi := &file_msg_msg_proto_msgTypes[83] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetConversationsFullSyncSeqsResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetConversationsFullSyncSeqsResp) ProtoMessage() {} + +func (x *GetConversationsFullSyncSeqsResp) ProtoReflect() protoreflect.Message { + mi := &file_msg_msg_proto_msgTypes[83] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetConversationsFullSyncSeqsResp.ProtoReflect.Descriptor instead. +func (*GetConversationsFullSyncSeqsResp) Descriptor() ([]byte, []int) { + return file_msg_msg_proto_rawDescGZIP(), []int{83} +} + +func (x *GetConversationsFullSyncSeqsResp) GetSeqs() map[string]*FullSyncSeqs { + if x != nil { + return x.Seqs + } + return nil +} + var File_msg_msg_proto protoreflect.FileDescriptor const file_msg_msg_proto_rawDesc = "" + @@ -4540,7 +4704,26 @@ const file_msg_msg_proto_rawDesc = "" + "\x04msgs\x18\x01 \x03(\v2(.openim.msg.GetLastMessageResp.MsgsEntryR\x04msgs\x1aN\n" + "\tMsgsEntry\x12\x10\n" + "\x03key\x18\x01 \x01(\tR\x03key\x12+\n" + - "\x05value\x18\x02 \x01(\v2\x15.openim.sdkws.MsgDataR\x05value:\x028\x012\x88\x17\n" + + "\x05value\x18\x02 \x01(\v2\x15.openim.sdkws.MsgDataR\x05value:\x028\x01\"c\n" + + "\x1fGetConversationsFullSyncSeqsReq\x12\x16\n" + + "\x06userID\x18\x01 \x01(\tR\x06userID\x12(\n" + + "\x0fconversationIDs\x18\x02 \x03(\tR\x0fconversationIDs\"\x86\x01\n" + + "\fFullSyncSeqs\x12\x16\n" + + "\x06maxSeq\x18\x01 \x01(\x03R\x06maxSeq\x12\x1e\n" + + "\n" + + "hasReadSeq\x18\x02 \x01(\x03R\n" + + "hasReadSeq\x12\x1e\n" + + "\n" + + "maxSeqTime\x18\x03 \x01(\x03R\n" + + "maxSeqTime\x12\x1e\n" + + "\n" + + "userMinSeq\x18\x04 \x01(\x03R\n" + + "userMinSeq\"\xc1\x01\n" + + " GetConversationsFullSyncSeqsResp\x12J\n" + + "\x04seqs\x18\x01 \x03(\v26.openim.msg.GetConversationsFullSyncSeqsResp.SeqsEntryR\x04seqs\x1aQ\n" + + "\tSeqsEntry\x12\x10\n" + + "\x03key\x18\x01 \x01(\tR\x03key\x12.\n" + + "\x05value\x18\x02 \x01(\v2\x18.openim.msg.FullSyncSeqsR\x05value:\x028\x012\x83\x18\n" + "\x03msg\x12D\n" + "\tGetMaxSeq\x12\x1a.openim.sdkws.GetMaxSeqReq\x1a\x1b.openim.sdkws.GetMaxSeqResp\x12A\n" + "\n" + @@ -4566,7 +4749,8 @@ const file_msg_msg_proto_rawDesc = "" + "\x0eMarkMsgsAsRead\x12\x1d.openim.msg.MarkMsgsAsReadReq\x1a\x1e.openim.msg.MarkMsgsAsReadResp\x12g\n" + "\x16MarkConversationAsRead\x12%.openim.msg.MarkConversationAsReadReq\x1a&.openim.msg.MarkConversationAsReadResp\x12p\n" + "\x19SetConversationHasReadSeq\x12(.openim.msg.SetConversationHasReadSeqReq\x1a).openim.msg.SetConversationHasReadSeqResp\x12\x85\x01\n" + - " GetConversationsHasReadAndMaxSeq\x12/.openim.msg.GetConversationsHasReadAndMaxSeqReq\x1a0.openim.msg.GetConversationsHasReadAndMaxSeqResp\x12L\n" + + " GetConversationsHasReadAndMaxSeq\x12/.openim.msg.GetConversationsHasReadAndMaxSeqReq\x1a0.openim.msg.GetConversationsHasReadAndMaxSeqResp\x12y\n" + + "\x1cGetConversationsFullSyncSeqs\x12+.openim.msg.GetConversationsFullSyncSeqsReq\x1a,.openim.msg.GetConversationsFullSyncSeqsResp\x12L\n" + "\rGetActiveUser\x12\x1c.openim.msg.GetActiveUserReq\x1a\x1d.openim.msg.GetActiveUserResp\x12O\n" + "\x0eGetActiveGroup\x12\x1d.openim.msg.GetActiveGroupReq\x1a\x1e.openim.msg.GetActiveGroupResp\x12L\n" + "\rGetServerTime\x12\x1c.openim.msg.GetServerTimeReq\x1a\x1d.openim.msg.GetServerTimeResp\x12=\n" + @@ -4590,7 +4774,7 @@ func file_msg_msg_proto_rawDescGZIP() []byte { return file_msg_msg_proto_rawDescData } -var file_msg_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 90) +var file_msg_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 94) var file_msg_msg_proto_goTypes = []any{ (*MsgDataToMQ)(nil), // 0: openim.msg.MsgDataToMQ (*MsgDataToDB)(nil), // 1: openim.msg.MsgDataToDB @@ -4673,140 +4857,148 @@ var file_msg_msg_proto_goTypes = []any{ (*GetLastMessageSeqByTimeResp)(nil), // 78: openim.msg.GetLastMessageSeqByTimeResp (*GetLastMessageReq)(nil), // 79: openim.msg.GetLastMessageReq (*GetLastMessageResp)(nil), // 80: openim.msg.GetLastMessageResp - nil, // 81: openim.msg.SeqsInfoResp.MaxSeqsEntry - nil, // 82: openim.msg.GetMsgByConversationIDsReq.MaxSeqsEntry - nil, // 83: openim.msg.GetMsgByConversationIDsResp.MsgDatasEntry - nil, // 84: openim.msg.GetConversationsHasReadAndMaxSeqResp.SeqsEntry - nil, // 85: openim.msg.GetActiveUserResp.DateCountEntry - nil, // 86: openim.msg.GetActiveGroupResp.DateCountEntry - nil, // 87: openim.msg.GetSeqMessageResp.MsgsEntry - nil, // 88: openim.msg.GetSeqMessageResp.NotificationMsgsEntry - nil, // 89: openim.msg.GetLastMessageResp.MsgsEntry - (*sdkws.MsgData)(nil), // 90: openim.sdkws.MsgData - (*sdkws.RequestPagination)(nil), // 91: openim.sdkws.RequestPagination - (*sdkws.UserInfo)(nil), // 92: openim.sdkws.UserInfo - (*sdkws.GroupInfo)(nil), // 93: openim.sdkws.GroupInfo - (*conversation.Conversation)(nil), // 94: openim.conversation.Conversation - (sdkws.PullOrder)(0), // 95: openim.sdkws.PullOrder - (*sdkws.PullMsgs)(nil), // 96: openim.sdkws.PullMsgs - (*sdkws.GetMaxSeqReq)(nil), // 97: openim.sdkws.GetMaxSeqReq - (*sdkws.PullMessageBySeqsReq)(nil), // 98: openim.sdkws.PullMessageBySeqsReq - (*sdkws.GetMaxSeqResp)(nil), // 99: openim.sdkws.GetMaxSeqResp - (*sdkws.PullMessageBySeqsResp)(nil), // 100: openim.sdkws.PullMessageBySeqsResp + (*GetConversationsFullSyncSeqsReq)(nil), // 81: openim.msg.GetConversationsFullSyncSeqsReq + (*FullSyncSeqs)(nil), // 82: openim.msg.FullSyncSeqs + (*GetConversationsFullSyncSeqsResp)(nil), // 83: openim.msg.GetConversationsFullSyncSeqsResp + nil, // 84: openim.msg.SeqsInfoResp.MaxSeqsEntry + nil, // 85: openim.msg.GetMsgByConversationIDsReq.MaxSeqsEntry + nil, // 86: openim.msg.GetMsgByConversationIDsResp.MsgDatasEntry + nil, // 87: openim.msg.GetConversationsHasReadAndMaxSeqResp.SeqsEntry + nil, // 88: openim.msg.GetActiveUserResp.DateCountEntry + nil, // 89: openim.msg.GetActiveGroupResp.DateCountEntry + nil, // 90: openim.msg.GetSeqMessageResp.MsgsEntry + nil, // 91: openim.msg.GetSeqMessageResp.NotificationMsgsEntry + nil, // 92: openim.msg.GetLastMessageResp.MsgsEntry + nil, // 93: openim.msg.GetConversationsFullSyncSeqsResp.SeqsEntry + (*sdkws.MsgData)(nil), // 94: openim.sdkws.MsgData + (*sdkws.RequestPagination)(nil), // 95: openim.sdkws.RequestPagination + (*sdkws.UserInfo)(nil), // 96: openim.sdkws.UserInfo + (*sdkws.GroupInfo)(nil), // 97: openim.sdkws.GroupInfo + (*conversation.Conversation)(nil), // 98: openim.conversation.Conversation + (sdkws.PullOrder)(0), // 99: openim.sdkws.PullOrder + (*sdkws.PullMsgs)(nil), // 100: openim.sdkws.PullMsgs + (*sdkws.GetMaxSeqReq)(nil), // 101: openim.sdkws.GetMaxSeqReq + (*sdkws.PullMessageBySeqsReq)(nil), // 102: openim.sdkws.PullMessageBySeqsReq + (*sdkws.GetMaxSeqResp)(nil), // 103: openim.sdkws.GetMaxSeqResp + (*sdkws.PullMessageBySeqsResp)(nil), // 104: openim.sdkws.PullMessageBySeqsResp } var file_msg_msg_proto_depIdxs = []int32{ - 90, // 0: openim.msg.MsgDataToMQ.msgData:type_name -> openim.sdkws.MsgData - 90, // 1: openim.msg.MsgDataToDB.msgData:type_name -> openim.sdkws.MsgData - 90, // 2: openim.msg.PushMsgDataToMQ.msgData:type_name -> openim.sdkws.MsgData - 90, // 3: openim.msg.MsgDataToMongoByMQ.msgData:type_name -> openim.sdkws.MsgData - 90, // 4: openim.msg.SendMsgReq.msgData:type_name -> openim.sdkws.MsgData - 90, // 5: openim.msg.SendMsgResp.modify:type_name -> openim.sdkws.MsgData - 90, // 6: openim.msg.SendSimpleMsgReq.msgData:type_name -> openim.sdkws.MsgData - 90, // 7: openim.msg.SendSimpleMsgResp.modify:type_name -> openim.sdkws.MsgData - 90, // 8: openim.msg.MsgDataToModifyByMQ.messages:type_name -> openim.sdkws.MsgData + 94, // 0: openim.msg.MsgDataToMQ.msgData:type_name -> openim.sdkws.MsgData + 94, // 1: openim.msg.MsgDataToDB.msgData:type_name -> openim.sdkws.MsgData + 94, // 2: openim.msg.PushMsgDataToMQ.msgData:type_name -> openim.sdkws.MsgData + 94, // 3: openim.msg.MsgDataToMongoByMQ.msgData:type_name -> openim.sdkws.MsgData + 94, // 4: openim.msg.SendMsgReq.msgData:type_name -> openim.sdkws.MsgData + 94, // 5: openim.msg.SendMsgResp.modify:type_name -> openim.sdkws.MsgData + 94, // 6: openim.msg.SendSimpleMsgReq.msgData:type_name -> openim.sdkws.MsgData + 94, // 7: openim.msg.SendSimpleMsgResp.modify:type_name -> openim.sdkws.MsgData + 94, // 8: openim.msg.MsgDataToModifyByMQ.messages:type_name -> openim.sdkws.MsgData 25, // 9: openim.msg.ClearConversationsMsgReq.deleteSyncOpt:type_name -> openim.msg.DeleteSyncOpt 25, // 10: openim.msg.UserClearAllMsgReq.deleteSyncOpt:type_name -> openim.msg.DeleteSyncOpt 25, // 11: openim.msg.DeleteMsgsReq.deleteSyncOpt:type_name -> openim.msg.DeleteSyncOpt - 81, // 12: openim.msg.SeqsInfoResp.maxSeqs:type_name -> openim.msg.SeqsInfoResp.MaxSeqsEntry - 82, // 13: openim.msg.GetMsgByConversationIDsReq.maxSeqs:type_name -> openim.msg.GetMsgByConversationIDsReq.MaxSeqsEntry - 83, // 14: openim.msg.GetMsgByConversationIDsResp.msgDatas:type_name -> openim.msg.GetMsgByConversationIDsResp.MsgDatasEntry - 84, // 15: openim.msg.GetConversationsHasReadAndMaxSeqResp.seqs:type_name -> openim.msg.GetConversationsHasReadAndMaxSeqResp.SeqsEntry - 91, // 16: openim.msg.GetActiveUserReq.pagination:type_name -> openim.sdkws.RequestPagination - 92, // 17: openim.msg.ActiveUser.user:type_name -> openim.sdkws.UserInfo - 85, // 18: openim.msg.GetActiveUserResp.dateCount:type_name -> openim.msg.GetActiveUserResp.DateCountEntry + 84, // 12: openim.msg.SeqsInfoResp.maxSeqs:type_name -> openim.msg.SeqsInfoResp.MaxSeqsEntry + 85, // 13: openim.msg.GetMsgByConversationIDsReq.maxSeqs:type_name -> openim.msg.GetMsgByConversationIDsReq.MaxSeqsEntry + 86, // 14: openim.msg.GetMsgByConversationIDsResp.msgDatas:type_name -> openim.msg.GetMsgByConversationIDsResp.MsgDatasEntry + 87, // 15: openim.msg.GetConversationsHasReadAndMaxSeqResp.seqs:type_name -> openim.msg.GetConversationsHasReadAndMaxSeqResp.SeqsEntry + 95, // 16: openim.msg.GetActiveUserReq.pagination:type_name -> openim.sdkws.RequestPagination + 96, // 17: openim.msg.ActiveUser.user:type_name -> openim.sdkws.UserInfo + 88, // 18: openim.msg.GetActiveUserResp.dateCount:type_name -> openim.msg.GetActiveUserResp.DateCountEntry 47, // 19: openim.msg.GetActiveUserResp.users:type_name -> openim.msg.ActiveUser - 91, // 20: openim.msg.GetActiveGroupReq.pagination:type_name -> openim.sdkws.RequestPagination - 93, // 21: openim.msg.ActiveGroup.group:type_name -> openim.sdkws.GroupInfo - 86, // 22: openim.msg.GetActiveGroupResp.dateCount:type_name -> openim.msg.GetActiveGroupResp.DateCountEntry + 95, // 20: openim.msg.GetActiveGroupReq.pagination:type_name -> openim.sdkws.RequestPagination + 97, // 21: openim.msg.ActiveGroup.group:type_name -> openim.sdkws.GroupInfo + 89, // 22: openim.msg.GetActiveGroupResp.dateCount:type_name -> openim.msg.GetActiveGroupResp.DateCountEntry 50, // 23: openim.msg.GetActiveGroupResp.groups:type_name -> openim.msg.ActiveGroup - 91, // 24: openim.msg.SearchMessageReq.pagination:type_name -> openim.sdkws.RequestPagination + 95, // 24: openim.msg.SearchMessageReq.pagination:type_name -> openim.sdkws.RequestPagination 56, // 25: openim.msg.SearchChatLog.chatLog:type_name -> openim.msg.ChatLog - 90, // 26: openim.msg.SearchedMsgData.msgData:type_name -> openim.sdkws.MsgData + 94, // 26: openim.msg.SearchedMsgData.msgData:type_name -> openim.sdkws.MsgData 53, // 27: openim.msg.SearchMessageResp.chatLogs:type_name -> openim.msg.SearchChatLog - 90, // 28: openim.msg.batchSendMessageReq.msgData:type_name -> openim.sdkws.MsgData - 94, // 29: openim.msg.ClearMsgReq.conversations:type_name -> openim.conversation.Conversation + 94, // 28: openim.msg.batchSendMessageReq.msgData:type_name -> openim.sdkws.MsgData + 98, // 29: openim.msg.ClearMsgReq.conversations:type_name -> openim.conversation.Conversation 67, // 30: openim.msg.GetSeqMessageReq.conversations:type_name -> openim.msg.ConversationSeqs - 95, // 31: openim.msg.GetSeqMessageReq.order:type_name -> openim.sdkws.PullOrder - 87, // 32: openim.msg.GetSeqMessageResp.msgs:type_name -> openim.msg.GetSeqMessageResp.MsgsEntry - 88, // 33: openim.msg.GetSeqMessageResp.notificationMsgs:type_name -> openim.msg.GetSeqMessageResp.NotificationMsgsEntry + 99, // 31: openim.msg.GetSeqMessageReq.order:type_name -> openim.sdkws.PullOrder + 90, // 32: openim.msg.GetSeqMessageResp.msgs:type_name -> openim.msg.GetSeqMessageResp.MsgsEntry + 91, // 33: openim.msg.GetSeqMessageResp.notificationMsgs:type_name -> openim.msg.GetSeqMessageResp.NotificationMsgsEntry 71, // 34: openim.msg.GetActiveConversationResp.conversations:type_name -> openim.msg.ActiveConversation - 89, // 35: openim.msg.GetLastMessageResp.msgs:type_name -> openim.msg.GetLastMessageResp.MsgsEntry - 90, // 36: openim.msg.GetMsgByConversationIDsResp.MsgDatasEntry.value:type_name -> openim.sdkws.MsgData - 44, // 37: openim.msg.GetConversationsHasReadAndMaxSeqResp.SeqsEntry.value:type_name -> openim.msg.Seqs - 96, // 38: openim.msg.GetSeqMessageResp.MsgsEntry.value:type_name -> openim.sdkws.PullMsgs - 96, // 39: openim.msg.GetSeqMessageResp.NotificationMsgsEntry.value:type_name -> openim.sdkws.PullMsgs - 90, // 40: openim.msg.GetLastMessageResp.MsgsEntry.value:type_name -> openim.sdkws.MsgData - 97, // 41: openim.msg.msg.GetMaxSeq:input_type -> openim.sdkws.GetMaxSeqReq - 36, // 42: openim.msg.msg.GetMaxSeqs:input_type -> openim.msg.GetMaxSeqsReq - 37, // 43: openim.msg.msg.GetHasReadSeqs:input_type -> openim.msg.GetHasReadSeqsReq - 39, // 44: openim.msg.msg.GetMsgByConversationIDs:input_type -> openim.msg.GetMsgByConversationIDsReq - 41, // 45: openim.msg.msg.GetConversationMaxSeq:input_type -> openim.msg.GetConversationMaxSeqReq - 98, // 46: openim.msg.msg.PullMessageBySeqs:input_type -> openim.sdkws.PullMessageBySeqsReq - 68, // 47: openim.msg.msg.GetSeqMessage:input_type -> openim.msg.GetSeqMessageReq - 52, // 48: openim.msg.msg.SearchMessage:input_type -> openim.msg.SearchMessageReq - 6, // 49: openim.msg.msg.SendMsg:input_type -> openim.msg.SendMsgReq - 8, // 50: openim.msg.msg.SendSimpleMsg:input_type -> openim.msg.SendSimpleMsgReq - 65, // 51: openim.msg.msg.SetUserConversationsMinSeq:input_type -> openim.msg.SetUserConversationsMinSeqReq - 26, // 52: openim.msg.msg.ClearConversationsMsg:input_type -> openim.msg.ClearConversationsMsgReq - 28, // 53: openim.msg.msg.UserClearAllMsg:input_type -> openim.msg.UserClearAllMsgReq - 30, // 54: openim.msg.msg.DeleteMsgs:input_type -> openim.msg.DeleteMsgsReq - 34, // 55: openim.msg.msg.DeleteMsgPhysicalBySeq:input_type -> openim.msg.DeleteMsgPhysicalBySeqReq - 32, // 56: openim.msg.msg.DeleteMsgPhysical:input_type -> openim.msg.DeleteMsgPhysicalReq - 10, // 57: openim.msg.msg.SetSendMsgStatus:input_type -> openim.msg.SetSendMsgStatusReq - 12, // 58: openim.msg.msg.GetSendMsgStatus:input_type -> openim.msg.GetSendMsgStatusReq - 17, // 59: openim.msg.msg.RevokeMsg:input_type -> openim.msg.RevokeMsgReq - 19, // 60: openim.msg.msg.MarkMsgsAsRead:input_type -> openim.msg.MarkMsgsAsReadReq - 21, // 61: openim.msg.msg.MarkConversationAsRead:input_type -> openim.msg.MarkConversationAsReadReq - 23, // 62: openim.msg.msg.SetConversationHasReadSeq:input_type -> openim.msg.SetConversationHasReadSeqReq - 43, // 63: openim.msg.msg.GetConversationsHasReadAndMaxSeq:input_type -> openim.msg.GetConversationsHasReadAndMaxSeqReq - 46, // 64: openim.msg.msg.GetActiveUser:input_type -> openim.msg.GetActiveUserReq - 49, // 65: openim.msg.msg.GetActiveGroup:input_type -> openim.msg.GetActiveGroupReq - 59, // 66: openim.msg.msg.GetServerTime:input_type -> openim.msg.GetServerTimeReq - 61, // 67: openim.msg.msg.ClearMsg:input_type -> openim.msg.ClearMsgReq - 63, // 68: openim.msg.msg.DestructMsgs:input_type -> openim.msg.DestructMsgsReq - 70, // 69: openim.msg.msg.GetActiveConversation:input_type -> openim.msg.GetActiveConversationReq - 73, // 70: openim.msg.msg.SetUserConversationMaxSeq:input_type -> openim.msg.SetUserConversationMaxSeqReq - 75, // 71: openim.msg.msg.SetUserConversationMinSeq:input_type -> openim.msg.SetUserConversationMinSeqReq - 77, // 72: openim.msg.msg.GetLastMessageSeqByTime:input_type -> openim.msg.GetLastMessageSeqByTimeReq - 79, // 73: openim.msg.msg.GetLastMessage:input_type -> openim.msg.GetLastMessageReq - 99, // 74: openim.msg.msg.GetMaxSeq:output_type -> openim.sdkws.GetMaxSeqResp - 38, // 75: openim.msg.msg.GetMaxSeqs:output_type -> openim.msg.SeqsInfoResp - 38, // 76: openim.msg.msg.GetHasReadSeqs:output_type -> openim.msg.SeqsInfoResp - 40, // 77: openim.msg.msg.GetMsgByConversationIDs:output_type -> openim.msg.GetMsgByConversationIDsResp - 42, // 78: openim.msg.msg.GetConversationMaxSeq:output_type -> openim.msg.GetConversationMaxSeqResp - 100, // 79: openim.msg.msg.PullMessageBySeqs:output_type -> openim.sdkws.PullMessageBySeqsResp - 69, // 80: openim.msg.msg.GetSeqMessage:output_type -> openim.msg.GetSeqMessageResp - 55, // 81: openim.msg.msg.SearchMessage:output_type -> openim.msg.SearchMessageResp - 7, // 82: openim.msg.msg.SendMsg:output_type -> openim.msg.SendMsgResp - 9, // 83: openim.msg.msg.SendSimpleMsg:output_type -> openim.msg.SendSimpleMsgResp - 66, // 84: openim.msg.msg.SetUserConversationsMinSeq:output_type -> openim.msg.SetUserConversationsMinSeqResp - 27, // 85: openim.msg.msg.ClearConversationsMsg:output_type -> openim.msg.ClearConversationsMsgResp - 29, // 86: openim.msg.msg.UserClearAllMsg:output_type -> openim.msg.UserClearAllMsgResp - 31, // 87: openim.msg.msg.DeleteMsgs:output_type -> openim.msg.DeleteMsgsResp - 35, // 88: openim.msg.msg.DeleteMsgPhysicalBySeq:output_type -> openim.msg.DeleteMsgPhysicalBySeqResp - 33, // 89: openim.msg.msg.DeleteMsgPhysical:output_type -> openim.msg.DeleteMsgPhysicalResp - 11, // 90: openim.msg.msg.SetSendMsgStatus:output_type -> openim.msg.SetSendMsgStatusResp - 13, // 91: openim.msg.msg.GetSendMsgStatus:output_type -> openim.msg.GetSendMsgStatusResp - 18, // 92: openim.msg.msg.RevokeMsg:output_type -> openim.msg.RevokeMsgResp - 20, // 93: openim.msg.msg.MarkMsgsAsRead:output_type -> openim.msg.MarkMsgsAsReadResp - 22, // 94: openim.msg.msg.MarkConversationAsRead:output_type -> openim.msg.MarkConversationAsReadResp - 24, // 95: openim.msg.msg.SetConversationHasReadSeq:output_type -> openim.msg.SetConversationHasReadSeqResp - 45, // 96: openim.msg.msg.GetConversationsHasReadAndMaxSeq:output_type -> openim.msg.GetConversationsHasReadAndMaxSeqResp - 48, // 97: openim.msg.msg.GetActiveUser:output_type -> openim.msg.GetActiveUserResp - 51, // 98: openim.msg.msg.GetActiveGroup:output_type -> openim.msg.GetActiveGroupResp - 60, // 99: openim.msg.msg.GetServerTime:output_type -> openim.msg.GetServerTimeResp - 62, // 100: openim.msg.msg.ClearMsg:output_type -> openim.msg.ClearMsgResp - 64, // 101: openim.msg.msg.DestructMsgs:output_type -> openim.msg.DestructMsgsResp - 72, // 102: openim.msg.msg.GetActiveConversation:output_type -> openim.msg.GetActiveConversationResp - 74, // 103: openim.msg.msg.SetUserConversationMaxSeq:output_type -> openim.msg.SetUserConversationMaxSeqResp - 76, // 104: openim.msg.msg.SetUserConversationMinSeq:output_type -> openim.msg.SetUserConversationMinSeqResp - 78, // 105: openim.msg.msg.GetLastMessageSeqByTime:output_type -> openim.msg.GetLastMessageSeqByTimeResp - 80, // 106: openim.msg.msg.GetLastMessage:output_type -> openim.msg.GetLastMessageResp - 74, // [74:107] is the sub-list for method output_type - 41, // [41:74] is the sub-list for method input_type - 41, // [41:41] is the sub-list for extension type_name - 41, // [41:41] is the sub-list for extension extendee - 0, // [0:41] is the sub-list for field type_name + 92, // 35: openim.msg.GetLastMessageResp.msgs:type_name -> openim.msg.GetLastMessageResp.MsgsEntry + 93, // 36: openim.msg.GetConversationsFullSyncSeqsResp.seqs:type_name -> openim.msg.GetConversationsFullSyncSeqsResp.SeqsEntry + 94, // 37: openim.msg.GetMsgByConversationIDsResp.MsgDatasEntry.value:type_name -> openim.sdkws.MsgData + 44, // 38: openim.msg.GetConversationsHasReadAndMaxSeqResp.SeqsEntry.value:type_name -> openim.msg.Seqs + 100, // 39: openim.msg.GetSeqMessageResp.MsgsEntry.value:type_name -> openim.sdkws.PullMsgs + 100, // 40: openim.msg.GetSeqMessageResp.NotificationMsgsEntry.value:type_name -> openim.sdkws.PullMsgs + 94, // 41: openim.msg.GetLastMessageResp.MsgsEntry.value:type_name -> openim.sdkws.MsgData + 82, // 42: openim.msg.GetConversationsFullSyncSeqsResp.SeqsEntry.value:type_name -> openim.msg.FullSyncSeqs + 101, // 43: openim.msg.msg.GetMaxSeq:input_type -> openim.sdkws.GetMaxSeqReq + 36, // 44: openim.msg.msg.GetMaxSeqs:input_type -> openim.msg.GetMaxSeqsReq + 37, // 45: openim.msg.msg.GetHasReadSeqs:input_type -> openim.msg.GetHasReadSeqsReq + 39, // 46: openim.msg.msg.GetMsgByConversationIDs:input_type -> openim.msg.GetMsgByConversationIDsReq + 41, // 47: openim.msg.msg.GetConversationMaxSeq:input_type -> openim.msg.GetConversationMaxSeqReq + 102, // 48: openim.msg.msg.PullMessageBySeqs:input_type -> openim.sdkws.PullMessageBySeqsReq + 68, // 49: openim.msg.msg.GetSeqMessage:input_type -> openim.msg.GetSeqMessageReq + 52, // 50: openim.msg.msg.SearchMessage:input_type -> openim.msg.SearchMessageReq + 6, // 51: openim.msg.msg.SendMsg:input_type -> openim.msg.SendMsgReq + 8, // 52: openim.msg.msg.SendSimpleMsg:input_type -> openim.msg.SendSimpleMsgReq + 65, // 53: openim.msg.msg.SetUserConversationsMinSeq:input_type -> openim.msg.SetUserConversationsMinSeqReq + 26, // 54: openim.msg.msg.ClearConversationsMsg:input_type -> openim.msg.ClearConversationsMsgReq + 28, // 55: openim.msg.msg.UserClearAllMsg:input_type -> openim.msg.UserClearAllMsgReq + 30, // 56: openim.msg.msg.DeleteMsgs:input_type -> openim.msg.DeleteMsgsReq + 34, // 57: openim.msg.msg.DeleteMsgPhysicalBySeq:input_type -> openim.msg.DeleteMsgPhysicalBySeqReq + 32, // 58: openim.msg.msg.DeleteMsgPhysical:input_type -> openim.msg.DeleteMsgPhysicalReq + 10, // 59: openim.msg.msg.SetSendMsgStatus:input_type -> openim.msg.SetSendMsgStatusReq + 12, // 60: openim.msg.msg.GetSendMsgStatus:input_type -> openim.msg.GetSendMsgStatusReq + 17, // 61: openim.msg.msg.RevokeMsg:input_type -> openim.msg.RevokeMsgReq + 19, // 62: openim.msg.msg.MarkMsgsAsRead:input_type -> openim.msg.MarkMsgsAsReadReq + 21, // 63: openim.msg.msg.MarkConversationAsRead:input_type -> openim.msg.MarkConversationAsReadReq + 23, // 64: openim.msg.msg.SetConversationHasReadSeq:input_type -> openim.msg.SetConversationHasReadSeqReq + 43, // 65: openim.msg.msg.GetConversationsHasReadAndMaxSeq:input_type -> openim.msg.GetConversationsHasReadAndMaxSeqReq + 81, // 66: openim.msg.msg.GetConversationsFullSyncSeqs:input_type -> openim.msg.GetConversationsFullSyncSeqsReq + 46, // 67: openim.msg.msg.GetActiveUser:input_type -> openim.msg.GetActiveUserReq + 49, // 68: openim.msg.msg.GetActiveGroup:input_type -> openim.msg.GetActiveGroupReq + 59, // 69: openim.msg.msg.GetServerTime:input_type -> openim.msg.GetServerTimeReq + 61, // 70: openim.msg.msg.ClearMsg:input_type -> openim.msg.ClearMsgReq + 63, // 71: openim.msg.msg.DestructMsgs:input_type -> openim.msg.DestructMsgsReq + 70, // 72: openim.msg.msg.GetActiveConversation:input_type -> openim.msg.GetActiveConversationReq + 73, // 73: openim.msg.msg.SetUserConversationMaxSeq:input_type -> openim.msg.SetUserConversationMaxSeqReq + 75, // 74: openim.msg.msg.SetUserConversationMinSeq:input_type -> openim.msg.SetUserConversationMinSeqReq + 77, // 75: openim.msg.msg.GetLastMessageSeqByTime:input_type -> openim.msg.GetLastMessageSeqByTimeReq + 79, // 76: openim.msg.msg.GetLastMessage:input_type -> openim.msg.GetLastMessageReq + 103, // 77: openim.msg.msg.GetMaxSeq:output_type -> openim.sdkws.GetMaxSeqResp + 38, // 78: openim.msg.msg.GetMaxSeqs:output_type -> openim.msg.SeqsInfoResp + 38, // 79: openim.msg.msg.GetHasReadSeqs:output_type -> openim.msg.SeqsInfoResp + 40, // 80: openim.msg.msg.GetMsgByConversationIDs:output_type -> openim.msg.GetMsgByConversationIDsResp + 42, // 81: openim.msg.msg.GetConversationMaxSeq:output_type -> openim.msg.GetConversationMaxSeqResp + 104, // 82: openim.msg.msg.PullMessageBySeqs:output_type -> openim.sdkws.PullMessageBySeqsResp + 69, // 83: openim.msg.msg.GetSeqMessage:output_type -> openim.msg.GetSeqMessageResp + 55, // 84: openim.msg.msg.SearchMessage:output_type -> openim.msg.SearchMessageResp + 7, // 85: openim.msg.msg.SendMsg:output_type -> openim.msg.SendMsgResp + 9, // 86: openim.msg.msg.SendSimpleMsg:output_type -> openim.msg.SendSimpleMsgResp + 66, // 87: openim.msg.msg.SetUserConversationsMinSeq:output_type -> openim.msg.SetUserConversationsMinSeqResp + 27, // 88: openim.msg.msg.ClearConversationsMsg:output_type -> openim.msg.ClearConversationsMsgResp + 29, // 89: openim.msg.msg.UserClearAllMsg:output_type -> openim.msg.UserClearAllMsgResp + 31, // 90: openim.msg.msg.DeleteMsgs:output_type -> openim.msg.DeleteMsgsResp + 35, // 91: openim.msg.msg.DeleteMsgPhysicalBySeq:output_type -> openim.msg.DeleteMsgPhysicalBySeqResp + 33, // 92: openim.msg.msg.DeleteMsgPhysical:output_type -> openim.msg.DeleteMsgPhysicalResp + 11, // 93: openim.msg.msg.SetSendMsgStatus:output_type -> openim.msg.SetSendMsgStatusResp + 13, // 94: openim.msg.msg.GetSendMsgStatus:output_type -> openim.msg.GetSendMsgStatusResp + 18, // 95: openim.msg.msg.RevokeMsg:output_type -> openim.msg.RevokeMsgResp + 20, // 96: openim.msg.msg.MarkMsgsAsRead:output_type -> openim.msg.MarkMsgsAsReadResp + 22, // 97: openim.msg.msg.MarkConversationAsRead:output_type -> openim.msg.MarkConversationAsReadResp + 24, // 98: openim.msg.msg.SetConversationHasReadSeq:output_type -> openim.msg.SetConversationHasReadSeqResp + 45, // 99: openim.msg.msg.GetConversationsHasReadAndMaxSeq:output_type -> openim.msg.GetConversationsHasReadAndMaxSeqResp + 83, // 100: openim.msg.msg.GetConversationsFullSyncSeqs:output_type -> openim.msg.GetConversationsFullSyncSeqsResp + 48, // 101: openim.msg.msg.GetActiveUser:output_type -> openim.msg.GetActiveUserResp + 51, // 102: openim.msg.msg.GetActiveGroup:output_type -> openim.msg.GetActiveGroupResp + 60, // 103: openim.msg.msg.GetServerTime:output_type -> openim.msg.GetServerTimeResp + 62, // 104: openim.msg.msg.ClearMsg:output_type -> openim.msg.ClearMsgResp + 64, // 105: openim.msg.msg.DestructMsgs:output_type -> openim.msg.DestructMsgsResp + 72, // 106: openim.msg.msg.GetActiveConversation:output_type -> openim.msg.GetActiveConversationResp + 74, // 107: openim.msg.msg.SetUserConversationMaxSeq:output_type -> openim.msg.SetUserConversationMaxSeqResp + 76, // 108: openim.msg.msg.SetUserConversationMinSeq:output_type -> openim.msg.SetUserConversationMinSeqResp + 78, // 109: openim.msg.msg.GetLastMessageSeqByTime:output_type -> openim.msg.GetLastMessageSeqByTimeResp + 80, // 110: openim.msg.msg.GetLastMessage:output_type -> openim.msg.GetLastMessageResp + 77, // [77:111] is the sub-list for method output_type + 43, // [43:77] is the sub-list for method input_type + 43, // [43:43] is the sub-list for extension type_name + 43, // [43:43] is the sub-list for extension extendee + 0, // [0:43] is the sub-list for field type_name } func init() { file_msg_msg_proto_init() } @@ -4820,7 +5012,7 @@ func file_msg_msg_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_msg_msg_proto_rawDesc), len(file_msg_msg_proto_rawDesc)), NumEnums: 0, - NumMessages: 90, + NumMessages: 94, NumExtensions: 0, NumServices: 1, }, diff --git a/msg/msg.proto b/msg/msg.proto index 0e91d979..086c8da5 100644 --- a/msg/msg.proto +++ b/msg/msg.proto @@ -387,6 +387,22 @@ message GetLastMessageResp { map msgs = 1; } +message GetConversationsFullSyncSeqsReq { + string userID = 1; + repeated string conversationIDs = 2; +} + +message FullSyncSeqs { + int64 maxSeq = 1; + int64 hasReadSeq = 2; + int64 maxSeqTime = 3; + int64 userMinSeq = 4; +} + +message GetConversationsFullSyncSeqsResp { + map seqs = 1; +} + service msg { // Get min and max seq (including the user and specified groups) rpc GetMaxSeq(sdkws.GetMaxSeqReq) returns (sdkws.GetMaxSeqResp); @@ -430,6 +446,7 @@ service msg { rpc SetConversationHasReadSeq(SetConversationHasReadSeqReq) returns (SetConversationHasReadSeqResp); rpc GetConversationsHasReadAndMaxSeq(GetConversationsHasReadAndMaxSeqReq) returns (GetConversationsHasReadAndMaxSeqResp); + rpc GetConversationsFullSyncSeqs(GetConversationsFullSyncSeqsReq) returns (GetConversationsFullSyncSeqsResp); rpc GetActiveUser(GetActiveUserReq) returns (GetActiveUserResp); rpc GetActiveGroup(GetActiveGroupReq) returns (GetActiveGroupResp); rpc GetServerTime(GetServerTimeReq) returns (GetServerTimeResp); diff --git a/msg/msg_grpc.pb.go b/msg/msg_grpc.pb.go index 84c466aa..540d4aeb 100644 --- a/msg/msg_grpc.pb.go +++ b/msg/msg_grpc.pb.go @@ -43,6 +43,7 @@ const ( Msg_MarkConversationAsRead_FullMethodName = "/openim.msg.msg/MarkConversationAsRead" Msg_SetConversationHasReadSeq_FullMethodName = "/openim.msg.msg/SetConversationHasReadSeq" Msg_GetConversationsHasReadAndMaxSeq_FullMethodName = "/openim.msg.msg/GetConversationsHasReadAndMaxSeq" + Msg_GetConversationsFullSyncSeqs_FullMethodName = "/openim.msg.msg/GetConversationsFullSyncSeqs" Msg_GetActiveUser_FullMethodName = "/openim.msg.msg/GetActiveUser" Msg_GetActiveGroup_FullMethodName = "/openim.msg.msg/GetActiveGroup" Msg_GetServerTime_FullMethodName = "/openim.msg.msg/GetServerTime" @@ -97,6 +98,7 @@ type MsgClient interface { MarkConversationAsRead(ctx context.Context, in *MarkConversationAsReadReq, opts ...grpc.CallOption) (*MarkConversationAsReadResp, error) SetConversationHasReadSeq(ctx context.Context, in *SetConversationHasReadSeqReq, opts ...grpc.CallOption) (*SetConversationHasReadSeqResp, error) GetConversationsHasReadAndMaxSeq(ctx context.Context, in *GetConversationsHasReadAndMaxSeqReq, opts ...grpc.CallOption) (*GetConversationsHasReadAndMaxSeqResp, error) + GetConversationsFullSyncSeqs(ctx context.Context, in *GetConversationsFullSyncSeqsReq, opts ...grpc.CallOption) (*GetConversationsFullSyncSeqsResp, error) GetActiveUser(ctx context.Context, in *GetActiveUserReq, opts ...grpc.CallOption) (*GetActiveUserResp, error) GetActiveGroup(ctx context.Context, in *GetActiveGroupReq, opts ...grpc.CallOption) (*GetActiveGroupResp, error) GetServerTime(ctx context.Context, in *GetServerTimeReq, opts ...grpc.CallOption) (*GetServerTimeResp, error) @@ -347,6 +349,16 @@ func (c *msgClient) GetConversationsHasReadAndMaxSeq(ctx context.Context, in *Ge return out, nil } +func (c *msgClient) GetConversationsFullSyncSeqs(ctx context.Context, in *GetConversationsFullSyncSeqsReq, opts ...grpc.CallOption) (*GetConversationsFullSyncSeqsResp, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(GetConversationsFullSyncSeqsResp) + err := c.cc.Invoke(ctx, Msg_GetConversationsFullSyncSeqs_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + func (c *msgClient) GetActiveUser(ctx context.Context, in *GetActiveUserReq, opts ...grpc.CallOption) (*GetActiveUserResp, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(GetActiveUserResp) @@ -489,6 +501,7 @@ type MsgServer interface { MarkConversationAsRead(context.Context, *MarkConversationAsReadReq) (*MarkConversationAsReadResp, error) SetConversationHasReadSeq(context.Context, *SetConversationHasReadSeqReq) (*SetConversationHasReadSeqResp, error) GetConversationsHasReadAndMaxSeq(context.Context, *GetConversationsHasReadAndMaxSeqReq) (*GetConversationsHasReadAndMaxSeqResp, error) + GetConversationsFullSyncSeqs(context.Context, *GetConversationsFullSyncSeqsReq) (*GetConversationsFullSyncSeqsResp, error) GetActiveUser(context.Context, *GetActiveUserReq) (*GetActiveUserResp, error) GetActiveGroup(context.Context, *GetActiveGroupReq) (*GetActiveGroupResp, error) GetServerTime(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error) @@ -578,6 +591,9 @@ func (UnimplementedMsgServer) SetConversationHasReadSeq(context.Context, *SetCon func (UnimplementedMsgServer) GetConversationsHasReadAndMaxSeq(context.Context, *GetConversationsHasReadAndMaxSeqReq) (*GetConversationsHasReadAndMaxSeqResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetConversationsHasReadAndMaxSeq not implemented") } +func (UnimplementedMsgServer) GetConversationsFullSyncSeqs(context.Context, *GetConversationsFullSyncSeqsReq) (*GetConversationsFullSyncSeqsResp, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetConversationsFullSyncSeqs not implemented") +} func (UnimplementedMsgServer) GetActiveUser(context.Context, *GetActiveUserReq) (*GetActiveUserResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetActiveUser not implemented") } @@ -1043,6 +1059,24 @@ func _Msg_GetConversationsHasReadAndMaxSeq_Handler(srv interface{}, ctx context. return interceptor(ctx, in, info, handler) } +func _Msg_GetConversationsFullSyncSeqs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetConversationsFullSyncSeqsReq) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(MsgServer).GetConversationsFullSyncSeqs(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Msg_GetConversationsFullSyncSeqs_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(MsgServer).GetConversationsFullSyncSeqs(ctx, req.(*GetConversationsFullSyncSeqsReq)) + } + return interceptor(ctx, in, info, handler) +} + func _Msg_GetActiveUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetActiveUserReq) if err := dec(in); err != nil { @@ -1322,6 +1356,10 @@ var Msg_ServiceDesc = grpc.ServiceDesc{ MethodName: "GetConversationsHasReadAndMaxSeq", Handler: _Msg_GetConversationsHasReadAndMaxSeq_Handler, }, + { + MethodName: "GetConversationsFullSyncSeqs", + Handler: _Msg_GetConversationsFullSyncSeqs_Handler, + }, { MethodName: "GetActiveUser", Handler: _Msg_GetActiveUser_Handler,