Update packages, add async/await support and improve logs

Author: Bacto

authenticationServer.js

@@ -2,7 +2,8 @@ const express = require('express');
 const bodyParser = require('body-parser');
 const mqttWildcard = require('mqtt-wildcard');
 const app = express();
-app.use(bodyParser());
+app.use(bodyParser.urlencoded({ extended: true }));
+app.use(bodyParser.json());
 const port = 8080;
 
 const users = [

client.js

@@ -1,52 +1,66 @@
 require('dotenv').config();
 const mqtt = require('mqtt');
 
-if (!process.env.MOSQUITTO_SERVER) {
-  throw Error('You should first fill the .env-example file and rename it to .env');
-}
-
-// Connection to MQTT server
-const client = mqtt.connect(
-  // Note: you can replace 'mqtts' per 'wss' to connect to Mosquitto using websockets (you need to activate the option on Stackhero console and to configure "Security shield" to allow your IPs).
-  `mqtts://${process.env.MOSQUITTO_SERVER}:${process.env.MOSQUITTO_PORT}`,
-  {
-    username: process.env.MOSQUITTO_USERNAME,
-    password: process.env.MOSQUITTO_PASSWORD,
-    clean: true
+(async () => {
+  if (!process.env.MOSQUITTO_SERVER) {
+    throw Error('You should first fill the .env-example file and rename it to .env');
   }
-);
 
+  let client;
 
-// This callback will be executed when a message is received on topics you subscribed (see client.subscribe below)
-client.on('message', (topic, message) => {
-  // message is Buffer
-  console.log(`[${topic}]: ${message.toString()}`);
-});
+  // Connect to the MQTT server
+  console.log('Connecting...');
+  client = await mqtt.connectAsync(
+    // Note: you can replace 'mqtts' per 'wss' to connect to Mosquitto using websockets (you need to activate the option on Stackhero console and to configure "Security shield" to allow your IPs).
+    `mqtts://${process.env.MOSQUITTO_SERVER}:${process.env.MOSQUITTO_PORT}`,
+    {
+      username: process.env.MOSQUITTO_USERNAME,
+      password: process.env.MOSQUITTO_PASSWORD,
+      clean: true
+    }
+  );
+  console.log('Connected');
 
 
-// Fired when connection to MQTT is done
-client.on('connect', () => {
+  // This callback will be executed when a message is received on topics you subscribed (see client.subscribe below).
+  client.on(
+    'message',
+    (topic, message) => console.log(`Message received on topic "${topic}": ${message.toString()}`)
+  );
 
-  // We subscribe to the topic "global"
-  client.subscribe('global', (err, granted) => {
-    if (err) { throw err; }
 
-    if (granted.find(({ qos }) => qos === 128)) {
-      throw Error(`Permission error when subscribing: ${JSON.stringify(granted)}`);
-    }
-  });
+  // Subscribe to the topic "global"
+  console.log('Subscribing to "global" topic...');
+  const granted = await client.subscribeAsync('global');
+  if (granted.find(({ qos }) => qos === 128)) {
+    throw Error(`Permission error when subscribing: ${JSON.stringify(granted)}`);
+  }
+  console.log('Subscribed to "global" topic');
 
 
-  // We publish to the topic "global"
-  client.publish('global', 'Hello everyone!', { qos: 2 }, err => {
-    if (err) { throw err; }
-  });
+  // Publish to the topic "global"
+  console.log('Publishing to "global" topic...');
+  await client.publishAsync(
+    'global',
+    'Hello everyone!',
+    { qos: 2 }
+  );
+  console.log('Published to "global" topic');
 
 
-  // We publish to as user topic
-  client.publish('users/testUser/sensor1', '123', { qos: 2 }, err => {
-    if (err) { throw err; }
-  });
+  // Publish to a user topic
+  console.log('Publishing to "users/testUser/sensor1" topic...');
+  await client.publishAsync(
+    'users/testUser/sensor1',
+    '123',
+    { qos: 2 }
+  );
+  console.log('Published to "users/testUser/sensor1" topic');
 
   // Note: we can publish to a topic without "write" rights. MQTT will ignore the message without informing us.
+})().catch(error => {
+  console.error('');
+  console.error('🐞 An error occurred!');
+  console.error(error);
+  process.exit(1);
 });

package.json

@@ -9,9 +9,9 @@
   },
   "dependencies": {
     "body-parser": "^1.18.3",
-    "dotenv": "^6.2.0",
+    "dotenv": "^16.4.5",
     "express": "^4.16.4",
-    "mqtt": "^2.18.8",
+    "mqtt": "^5.10.1",
     "mqtt-wildcard": "^3.0.9"
   }
 }