From e28a4c6cbfb71a092f1cbcabec672a902132561b Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Sat, 11 Feb 2023 13:51:05 +0800 Subject: [PATCH] =?UTF-8?q?server=20api=E5=8F=91=E9=80=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=A3=80=E6=9F=A5=E5=AF=B9=E8=B1=A1=E6=98=AF=E5=90=A6?= =?UTF-8?q?=E5=AD=98=E5=9C=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/imhandler/SendMessageHandler.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/broker/src/main/java/io/moquette/imhandler/SendMessageHandler.java b/broker/src/main/java/io/moquette/imhandler/SendMessageHandler.java index 463017c7..3bdf2c12 100644 --- a/broker/src/main/java/io/moquette/imhandler/SendMessageHandler.java +++ b/broker/src/main/java/io/moquette/imhandler/SendMessageHandler.java @@ -182,6 +182,15 @@ public class SendMessageHandler extends IMHandler { } } } + } else if (message.getConversation().getType() == ProtoConstants.ConversationType.ConversationType_Group) { + if(m_messagesStore.getGroupInfo(message.getConversation().getTarget()) == null) { + return ErrorCode.ERROR_CODE_NOT_EXIST; + } + } else if (message.getConversation().getType() == ProtoConstants.ConversationType.ConversationType_Channel) { + WFCMessage.ChannelInfo channelData = m_messagesStore.getChannelInfo(message.getConversation().getTarget()); + if(channelData == null || channelData.getStatus() == ProtoConstants.ChannelState.Channel_State_Mask_Deleted) { + return ErrorCode.ERROR_CODE_NOT_EXIST; + } } long timestamp = System.currentTimeMillis();