MQTT input stream

MQTT input stream provides an easy wrapper around MQTT.js for mutator-io.

Installation

npm i mutator-io-plugin-in-mqtt

The configuration required is exactly the same, with the except of a new keyword called topics that will indicate which topics this instance should subscribe to.

import { IClientOptions } from 'mqtt/types'

interface Config extends IClientOptions {
  topics: string[]
}

TLS support

This kind of security is supported just like it is in MQTT.js (though there aren't many examples around)

import * as MqttInputStream from 'mutator-io-plugin-in-mqtt'

const myInputStream = new MqttInputStream({
  protocol: 'mqtts',
  host: 'my-endpoint.iot.eu-central-1.amazonaws.com',
  port: 8883,
  key: fs.readFileSync('./certs/mqtt.key'),
  cert: fs.readFileSync('./certs/mqtt.pem'),
  ca: fs.readFileSync('./certs/mqtt_ca.pem'),
  requestCert: true,
  rejectUnauthorized: true,
  topics: ['something/+/+/+/status/+/+/+']
} as MqttInputStream.Config)

Typescript documentation