From a394444c86d1739bb20c58982cfcb7598686ef9b Mon Sep 17 00:00:00 2001
From: heavyrian2012 <heavyrain.lee@wildfirehat.cn>
Date: Thu, 21 Jul 2022 22:10:39 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=9B=E5=BB=BA=E7=BE=A4=E7=BB=84=E6=97=B6?=
 =?UTF-8?q?=EF=BC=8C=E6=A3=80=E6=9F=A5=E7=BE=A4=E7=BB=84=E7=B1=BB=E5=9E=8B?=
 =?UTF-8?q?=E7=9A=84=E6=9C=89=E6=95=88=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/io/moquette/imhandler/CreateGroupHandler.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/broker/src/main/java/io/moquette/imhandler/CreateGroupHandler.java b/broker/src/main/java/io/moquette/imhandler/CreateGroupHandler.java
index 74e99ca2..174cf391 100644
--- a/broker/src/main/java/io/moquette/imhandler/CreateGroupHandler.java
+++ b/broker/src/main/java/io/moquette/imhandler/CreateGroupHandler.java
@@ -21,6 +21,9 @@ import win.liyufan.im.IMTopic;
 public class CreateGroupHandler extends GroupHandler<WFCMessage.CreateGroupRequest> {
     @Override
     public ErrorCode action(ByteBuf ackPayload, String clientID, String fromUser, ProtoConstants.RequestSourceType requestSourceType, WFCMessage.CreateGroupRequest request, Qos1PublishHandler.IMCallback callback) {
+        if(request.getGroup().getGroupInfo().getType() < 0 || request.getGroup().getGroupInfo().getType() > 2) {
+            return ErrorCode.ERROR_CODE_INVALID_DATA;
+        }
 
         if (!StringUtil.isNullOrEmpty(request.getGroup().getGroupInfo().getTargetId())) {
             WFCMessage.GroupInfo existGroupInfo = m_messagesStore.getGroupInfo(request.getGroup().getGroupInfo().getTargetId());