Update mqtt so we can remove the async-mqtt wrapper

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change log
 
+## future release
+
+* Upgrade `mqtt` to get rid of `async-mqtt` (https://github.com/Jalle19/eda-modbus-bridge/issues/95)
+
 ## 2.7.1
 
 * Fix reading from unit type from wrong register (https://github.com/Jalle19/eda-modbus-bridge/issues/100)

app/mqtt.mjs

@@ -113,7 +113,7 @@ const publishTopics = async (mqttClient, topicMap, publishOptions = {}) => {
     const publishPromises = []
 
     for (const [topic, value] of Object.entries(topicMap)) {
-        publishPromises.push(mqttClient.publish(topic, value, publishOptions))
+        publishPromises.push(mqttClient.publishAsync(topic, value, publishOptions))
     }
 
     await Promise.all(publishPromises)
@@ -126,7 +126,7 @@ export const subscribeToChanges = async (modbusClient, mqttClient) => {
     for (const topicName of topicNames) {
         logger.info(`Subscribing to topic(s) ${topicName}`)
 
-        await mqttClient.subscribe(topicName)
+        await mqttClient.subscribeAsync(topicName)
     }
 }
 

eda-modbus-bridge.mjs

@@ -1,6 +1,6 @@
 import express from 'express'
 import expressWinston from 'express-winston'
-import MQTT from 'async-mqtt'
+import mqtt from 'mqtt'
 import yargs from 'yargs'
 import ModbusRTU from 'modbus-serial'
 import { getFlagStatus, root, setFlagStatus, setSetting, summary } from './app/http.mjs'
@@ -168,7 +168,7 @@ const argv = yargs(process.argv.slice(2))
 
                 do {
                     try {
-                        mqttClient = await MQTT.connectAsync(argv.mqttBrokerUrl, clientOptions)
+                        mqttClient = await mqtt.connectAsync(argv.mqttBrokerUrl, clientOptions)
                         connectedOnce = true
                         logger.info(`Successfully connected to MQTT broker at ${argv.mqttBrokerUrl}`)
                     } catch (e) {