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
2019-11-21 09:36:41 +08:00
parent 724b6dddd6
commit 688ca4e31d
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/imhandler/FriendPullHandler.java
+1 -1
View File
@@ -26,7 +26,7 @@ public class FriendPullHandler extends IMHandler<WFCMessage.Version> {
WFCMessage.GetFriendsResult.Builder builder = WFCMessage.GetFriendsResult.newBuilder(); WFCMessage.GetFriendsResult.Builder builder = WFCMessage.GetFriendsResult.newBuilder();
for (FriendData data : friendDatas for (FriendData data : friendDatas
) { ) {
WFCMessage.Friend.Builder builder1 = WFCMessage.Friend.newBuilder().setState(data.getState()).setUid(data.getFriendUid()).setUpdateDt(data.getTimestamp()); WFCMessage.Friend.Builder builder1 = WFCMessage.Friend.newBuilder().setState(data.getState()).setBlacked(data.getBlacked()).setUid(data.getFriendUid()).setUpdateDt(data.getTimestamp());
if (!StringUtil.isNullOrEmpty(data.getAlias())) { if (!StringUtil.isNullOrEmpty(data.getAlias())) {
builder1.setAlias(data.getAlias()); builder1.setAlias(data.getAlias());
} }
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+1 -1
View File
@@ -1562,7 +1562,7 @@ public class MemoryMessagesStore implements IMessagesStore {
for (FriendData friendData : friendDatas) { for (FriendData friendData : friendDatas) {
if (friendData.getFriendUid().equals(userId)) { if (friendData.getFriendUid().equals(userId)) {
if (friendData.getState() == 2) { if (friendData.getBlacked() == 1) {
return true; return true;
} else { } else {
return false; return false;