mqtt-async

A simple way to convert the MQTT.js library to use async/await. No dependecies. Just a simple function. This is a different approach than the async-mqtt library which encapsulates MQTT.

Create an MQTT instance as normal. Then just call MqttAsync().

1const Mqtt = require('mqtt');
2const MqttAsync = require('mqtt-async');
3
4let mqtt = MqttAsync(Mqtt.connect(...));
5
6await mqtt.subscribe('topic');
7await mqtt.publish('topic', 'Hello');
8

This is the complete source code. Nothing more. Just copy it into your project or use this module.

1
2module.exports = function MqttAsync(client) {
3
4    let subscribe = client.subscribe;
5    let publish = client.publish;
6    let unsubscribe = client.unsubscribe;
7    let end = client.end;
8
9    client.publish = (...args) => {
10        return new Promise((resolve, reject) => {
11            publish.call(client, ...args, (error) => {
12                error ? reject(error) : resolve();
13            });
14        });
15    }
16
17    client.subscribe = (...args) => {
18        return new Promise((resolve, reject) => {
19            subscribe.call(client, ...args, (error) => {
20                error ? reject(error) : resolve();
21            });
22        });
23
24    }
25
26    client.unsubscribe = (...args) => {
27        return new Promise((resolve, reject) => {
28            unsubscribe.call(client, ...args, (error) => {
29                error ? reject(error) : resolve();
30            });
31        });
32
33    }
34
35    client.end = (...args) => {
36        return new Promise((resolve, reject) => {
37            end.call(client, ...args, (error) => {
38                error ? reject(error) : resolve();
39            });
40        });
41
42    }
43
44    return client;
45}
46