Merge branch 'main' into add-feature-mqttsupport

lib/consts.dart

@@ -133,20 +133,8 @@ const kRandMax = 100000;
 const kDataTableScrollbarTheme = ScrollbarThemeData(
   crossAxisMargin: -4,
 );
-const kMQTTTableThemeData = DaviThemeData(
-  columnDividerColor: kColorTransparent,
-  row: RowThemeData(
-    dividerColor: kColorTransparent,
-  ),
-  decoration: BoxDecoration(
-    border: Border(),
-  ),
-  header: HeaderThemeData(
-    columnDividerColor: kColorTransparent,
-    bottomBorderColor: kColorTransparent,
-    visible: true,
-  ),
-);
+const kDataTableBottomPadding = 12.0;
+const kDataTableRowHeight = 36.0;
 
 const kIconRemoveDark = Icon(
   Icons.remove_circle,

lib/models/request_model.dart

@@ -105,7 +105,7 @@ class RequestModel {
       id: id,
       method: method,
       url: url,
-      name: "$name (copy)",
+      name: name ?? "${this.name} (copy)",
       protocol: protocol,
       description: description,
       requestTabIndex: requestTabIndex ?? 0,

lib/providers/collection_providers.dart

@@ -5,6 +5,9 @@ import 'package:mqtt_client/mqtt_client.dart';
 import 'package:mqtt_client/mqtt_server_client.dart';
 import 'settings_providers.dart';
 import 'ui_providers.dart';
+import 'package:http/http.dart' as http;
+
+import '../consts.dart';
 import '../models/models.dart';
 import '../services/services.dart'
     show HiveHandler, connectToMqttServer, hiveHandler, request;
@@ -325,6 +328,139 @@ class CollectionStateNotifier
     ref.read(sentRequestIdStateProvider.notifier).state = null;
   }
 
+  Future<void> connectToBroker(String id) async {
+    RequestModel requestModel = state![id]!;
+    late final RequestModel newRequestModel;
+    ref.read(realtimeConnectionStateProvider.notifier).state =
+        RealtimeConnectionState.connecting;
+    ref.read(subscribedTopicsStateProvider.notifier).state = [];
+    ref.read(selectedIdStateProvider.notifier).state = id;
+    ref.read(realtimeHistoryStateProvider.notifier).state = [];
+    ref.read(sentRequestIdStateProvider.notifier).state = id;
+    ref.read(codePaneVisibleStateProvider.notifier).state = false;
+    String? clientId = ref.read(clientIdStateProvider.notifier).state;
+
+    try {
+      RequestModel requestModel = state![id]!;
+      mqttClient = await connectToMqttServer(
+          broker: requestModel.url, clientId: clientId!);
+
+      var map = {...state!};
+      state = map;
+    } catch (e) {
+      newRequestModel = requestModel.copyWith(
+        responseStatus: -1,
+        message: e.toString(),
+      );
+      var map = {...state!};
+      map[id] = newRequestModel;
+      state = map;
+      ref.read(sentRequestIdStateProvider.notifier).state = null;
+      ref.read(realtimeConnectionStateProvider.notifier).state =
+          RealtimeConnectionState.disconnected;
+    }
+    if (mqttClient.connectionStatus?.state == MqttConnectionState.connected) {
+      ref.read(realtimeHistoryStateProvider.notifier).state = [
+        {
+          "direction": 'info',
+          "message": 'Connected to broker',
+        },
+        ...ref.read(realtimeHistoryStateProvider)
+      ];
+      mqttClient.onDisconnected = () {
+        ref.read(realtimeHistoryStateProvider.notifier).state = [
+          {
+            "direction": 'info',
+            "message": 'Disconnected from broker',
+          },
+          ...ref.read(realtimeHistoryStateProvider)
+        ];
+        ref.read(realtimeConnectionStateProvider.notifier).state =
+            RealtimeConnectionState.disconnected;
+      };
+      mqttClient.updates?.listen(
+        (List<MqttReceivedMessage<MqttMessage>> c) {
+          final MqttPublishMessage recMess = c[0].payload as MqttPublishMessage;
+          final String pt =
+              MqttPublishPayload.bytesToStringAsString(recMess.payload.message);
+
+          // Update the history
+          ref.read(realtimeHistoryStateProvider.notifier).state = [
+            {
+              "direction": 'receive',
+              "message": "${c[0].topic}: $pt",
+            },
+            ...ref.read(realtimeHistoryStateProvider),
+          ];
+        },
+      );
+      newRequestModel = requestModel.copyWith(
+        responseStatus: 1, // 1 is for connected
+        message: 'Connected',
+      );
+      var map = {...state!};
+      map[id] = newRequestModel;
+      state = map;
+      ref.read(realtimeConnectionStateProvider.notifier).state =
+          RealtimeConnectionState.connected;
+    }
+  }
+
+  Future<void> sendMessage(String id) async {
+    ref.read(subscribedTopicsStateProvider.notifier).state = [];
+    ref.read(codePaneVisibleStateProvider.notifier).state = false;
+    String? topic = ref.watch(messageTopicStateProvider.notifier).state;
+    RequestModel requestModel = state![id]!;
+    publishMessage(
+        client: mqttClient,
+        topic: topic!,
+        message: requestModel.requestBody!,
+        qos: MqttQos.atLeastOnce);
+    // Update the history
+    ref.read(realtimeHistoryStateProvider.notifier).state = [
+      {
+        "direction": 'send',
+        "message": '$topic: ${requestModel.requestBody!}',
+      },
+      ...ref.read(realtimeHistoryStateProvider),
+    ];
+  }
+
+  Future<void> subscribeTopic(String topic, MqttQos qosLevel) async {
+    subscribeToTopic(mqttClient, topic, qosLevel);
+    ref.read(realtimeHistoryStateProvider.notifier).state = [
+      {
+        "direction": 'info',
+        "message": 'Subscribed to the topic $topic from broker',
+      },
+      ...ref.read(realtimeHistoryStateProvider)
+    ];
+  }
+
+  Future<void> unsubscribeTopic(String topic) async {
+    mqttClient.unsubscribe(topic);
+    ref.read(realtimeHistoryStateProvider.notifier).state = [
+      {
+        "direction": 'info',
+        "message": 'Unsubscribed to the topic $topic from broker',
+      },
+      ...ref.read(realtimeHistoryStateProvider)
+    ];
+  }
+
+  Future<void> disconnectFromBroker(String id) async {
+    ref.read(realtimeConnectionStateProvider.notifier).state =
+        RealtimeConnectionState.disconnecting;
+    ref.read(subscribedTopicsStateProvider.notifier).state = [];
+    ref.read(selectedIdStateProvider.notifier).state = id;
+    ref.read(codePaneVisibleStateProvider.notifier).state = false;
+    await disconnectFromMqttServer(mqttClient);
+
+    ref.read(realtimeConnectionStateProvider.notifier).state =
+        RealtimeConnectionState.disconnected;
+    ref.read(sentRequestIdStateProvider.notifier).state = null;
+  }
+
   Future<void> sendRequest(String id) async {
     ref.read(codePaneVisibleStateProvider.notifier).state = false;
     final defaultUriScheme = ref.read(