add payload messages

Author: Wahid Nasri

lib/MqttImpl/MqttMucHandler.dart

@@ -0,0 +1,52 @@
+import 'dart:io';
+
+import 'package:flutter_mqtt/abstraction/ClientHandler.dart';
+import 'package:flutter_mqtt/abstraction/MucHandler.dart';
+import 'package:flutter_mqtt/abstraction/models/ChatMessage.dart';
+import 'package:flutter_mqtt/abstraction/models/enums/MessageType.dart';
+import 'package:uuid/uuid.dart';
+
+class MqttMucHandler extends MucHandler{
+  final ClientHandler clientHandler;
+
+  MqttMucHandler(this.clientHandler);
+  @override
+  void addUsersToGroup(String groupId, List<String> userIds, bool showPreviousHistory) {
+    ChatMessage msg = ChatMessage(id: groupId, type: MessageType.AddUsersToGroup, text: '', roomId: '', sendTime: 0, additionalFields: userIds);
+
+    String topic = "muc/" + groupId;
+    clientHandler.sendPayload(msg.toMap().toString(), topic);
+  }
+
+  @override
+  void createGroup(String name, List<String> membersIds, String? password) {
+    String id = Uuid().v4();
+    ChatMessage msg = ChatMessage(id: id, type: MessageType.CreateGroup, text: name, roomId: '', sendTime: 0, additionalFields: membersIds);
+
+    String topic = "muc/" + id;
+    clientHandler.sendPayload(msg.toMap().toString(), topic);
+  }
+
+  @override
+  void removeGroup(String groupId) {
+    ChatMessage msg = ChatMessage(id: groupId, type: MessageType.RemoveGroup, text: groupId, roomId: '', sendTime: 0);
+
+    String topic = "muc/" + groupId;
+    clientHandler.sendPayload(msg.toMap().toString(), topic);
+  }
+
+  @override
+  void removeUsersFromGroup(String groupId, List<String> memberIds) {
+    ChatMessage msg = ChatMessage(id: groupId, type: MessageType.RemoveGroupMembers, text: '', roomId: '', sendTime: 0, additionalFields: memberIds);
+
+    String topic = "muc/" + groupId;
+    clientHandler.sendPayload(msg.toMap().toString(), topic);
+
+  }
+
+  @override
+  void updateGroupInfo(String groupId, String newName, File avatar) {
+    // TODO: implement updateGroupInfo
+  }
+  
+}

lib/abstraction/MucHandler.dart

@@ -0,0 +1,9 @@
+import 'dart:io';
+
+abstract class MucHandler{
+  void createGroup(String name, List<String> members, String? password);
+  void removeGroup(String groupId);
+  void addUsersToGroup(String groupId, List<String> userIds, bool showPreviousHistory);
+  void removeUsersFromGroup(String groupId, List<String> memberIds);
+  void updateGroupInfo(String groupId, String newName, File avatar);
+}

lib/abstraction/models/enums/MessageType.dart

@@ -15,5 +15,10 @@ enum MessageType {
 
   ChatMarker,
 
-  Typing
+  Typing,
+
+  CreateGroup,
+  RemoveGroup,
+  AddUsersToGroup,
+  RemoveGroupMembers,
 }

lib/global/ChatApp.dart

@@ -4,13 +4,15 @@ import 'package:flutter_mqtt/MqttImpl/MqttChatEventsSender.dart';
 import 'package:flutter_mqtt/MqttImpl/MqttClient.dart';
 import 'package:flutter_mqtt/MqttImpl/MqttInvitationHandler.dart';
 import 'package:flutter_mqtt/MqttImpl/MqttMessageSender.dart';
+import 'package:flutter_mqtt/MqttImpl/MqttMucHandler.dart';
 import 'package:flutter_mqtt/MqttImpl/MqttOnlineReader.dart';
 import 'package:flutter_mqtt/abstraction/ArchiveHandler.dart';
 import 'package:flutter_mqtt/abstraction/ChatEventsSender.dart';
 import 'package:flutter_mqtt/abstraction/ClientHandler.dart';
 import 'package:flutter_mqtt/abstraction/InvitationsHandler.dart';
 import 'package:flutter_mqtt/abstraction/MessageOnlineReaderHandler.dart';
 import 'package:flutter_mqtt/abstraction/MessageSender.dart';
+import 'package:flutter_mqtt/abstraction/MucHandler.dart';
 
 class ChatApp {
   static ChatApp? _instance;
@@ -21,6 +23,7 @@ class ChatApp {
   late ChatEventsSender eventsSender;
   late ArchiveHandler archiveHandler;
   late InvitationHandler invitationHandler;
+  late MucHandler mucHandler;
 
   static ChatApp? instance() {
     if (_instance == null) {
@@ -37,6 +40,7 @@ class ChatApp {
     eventsSender = MqttChatEventsSender(clientHandler: clientHandler);
     archiveHandler = MqttArchiveHandler(clientHandler: clientHandler);
     invitationHandler = MqttInvitationHandler(clientHandler);
+    mucHandler = MqttMucHandler(clientHandler);
   }
   void disconnect() {
     clientHandler.disconnect();