anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

同步群成员状态，当群成员不存在时，返回删除状态

Browse Source
This commit is contained in:
heavyrain2012
2021-02-12 17:58:27 +08:00
parent 9fa1370219
commit ae4d8a95ba
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+7 -2
View File
@@ -1549,7 +1549,9 @@ public class MemoryMessagesStore implements IMessagesStore {
WFCMessage.GroupInfo groupInfo = mIMap.get(groupId);
if (groupInfo == null) {
return ErrorCode.ERROR_CODE_NOT_EXIST;
WFCMessage.GroupMember deletedMember = WFCMessage.GroupMember.newBuilder().setMemberId(fromUser).setType(GroupMemberType_Removed).setUpdateDt(System.currentTimeMillis()).build();
members.add(deletedMember);
return ErrorCode.ERROR_CODE_SUCCESS;
} else if (groupInfo.getMemberUpdateDt() <= maxDt) {
return ErrorCode.ERROR_CODE_NOT_MODIFIED;
}
@@ -1581,7 +1583,10 @@ public class MemoryMessagesStore implements IMessagesStore {
if (fromUser != null && notInGroup) {
members.clear();
if (self != null) {
members.add(self.toBuilder().setUpdateDt(0).setType(GroupMemberType_Removed).build());
members.add(self);
} else {
WFCMessage.GroupMember deletedMember = WFCMessage.GroupMember.newBuilder().setMemberId(fromUser).setType(GroupMemberType_Removed).setUpdateDt(System.currentTimeMillis()).build();
members.add(deletedMember);
}
}