BrainBlast/src/services/mqttService.js

import mqtt from 'mqtt';
import config from '@/config.js';

const mqttBrokerUrl = config.mqttBrokerUrl;
// Créer une instance de client MQTT
const client = mqtt.connect(mqttBrokerUrl);

// 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());
  });
}