fastify-mqtt-async

Wrapper for async-mqtt with TS support.

Install

npm i @eduardoroth/fastify-mqtt-async

Using it

Add it to your fastify project with the register method.

1import fastify from "fastify";
2import { fastifyMqttAsync } from "@eduardoroth/fastify-mqtt-async";
3
4const host = process.env.HOST ?? "localhost";
5const port = process.env.PORT ? Number(process.env.PORT) : 3000;
6
7const server = fastify();
8
9// register plugin
10server.register(fastifyMqttAsync, { url: "mqtt://localhost:1883" });
11
12server.listen({ port, host }, (err) => {
13  if (err) throw err;
14});

Then you can use it in your methods

1import { FastifyInstance } from "fastify";
2
3export default async function (fastify: FastifyInstance) {
4  fastify.get("/mqtt/ping", async function (req, reply) {
5    await this.mqttClient.publish("your/topic/#", "Async Hi Mosquitto!");
6    reply.send({ mqtt: "message sent!" });
7  });
8}

License

Licensed under MIT.