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