From 77f76ecc645571bb6359217e1395157bc31ed0ca Mon Sep 17 00:00:00 2001
From: Laurent <laurent@ollagnier.org>
Date: Sat, 17 Feb 2024 19:01:52 +0000
Subject: [PATCH] =?UTF-8?q?Module=20permettant=20g=C3=A9rer=20la=20connexi?=
 =?UTF-8?q?on=20MQTT?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Permet une seule connexion mqtt pour tous les composants de l'app
---
 src/services/mqttService.js | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)
 create mode 100644 src/services/mqttService.js

diff --git a/src/services/mqttService.js b/src/services/mqttService.js
new file mode 100644
index 0000000..08389f3
--- /dev/null
+++ b/src/services/mqttService.js
@@ -0,0 +1,17 @@
+import mqtt from 'mqtt';
+
+// Créer une instance de client MQTT
+const client = mqtt.connect('ws://localhost:9001');
+
+// Fonction pour publier un message sur un topic MQTT
+export function publishMessage(topic, message) {
+  client.publish(topic, message);
+}
+
+// Fonction pour s'abonner à un topic MQTT et écouter les messages entrants
+export function subscribeToTopic(topic, callback) {
+  client.subscribe(topic);
+  client.on('message', (receivedTopic, message) => {
+    callback(receivedTopic.toString(), message.toString());
+  });
+}