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

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

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