mqtt-handler

Basic Usage

in case of instantiate MqttHandler

import MqttHandler from 'mqtt-handler';

const mqttHandler = new MqttHandler(
  [
    "my-mqtt-endpoint-1",
    "my-mqtt-endpoint-2",
  ],
  "my-mqtt-username",
  "my-mqtt-password",
);

in case of publish messages

await mqttHandler.connect();

await mqttHandler.publishMessage('my-topic', {
'my-key': 'my-value',
});

await mqttHandler.end();

in case of receive messages

await mqttHandler.connect({
  'my-topic-1': async (message) => {
    // do something with messages received from topic "my-topic-1"
  },
  'my-topic-2': async (message) => {
    // do something with messages received from topic "my-topic-2"
  },
});

in case of add onMessage handlers or remove onMessage handlers

await mqttHandler.addOnMessageHandler('my-topic-3', async (message) => {
    // do something with messages received from topic "my-topic-3"
});

await mqttHandler.removeOnMessageHandler('my-topic-3');

in case of publish http request and response

// client side
import ClientSideMqttHandler, { MqttRequestMessage } from 'mqtt-handler';

const clientSideMqttHandler = new ClientSideMqttHandler(
  [
    "my-mqtt-endpoint-1",
    "my-mqtt-endpoint-2",
  ],
  "my-mqtt-username",
  "my-mqtt-password",
);

await clientSideMqttHandler.connect();

const requestMessage: MqttRequestMessage = {
  url: 'my-url',
  method: 'POST',
  data: {
    message: 'message sent.'
  },
};

const response = await clientSideMqttHandler.publishRequestMessage('my-request-topic', requestMessage);

console.log(response.data);
console.log(response.status);
console.log(response.statusText);

await clientSideMqttHandler.end();

// server side
import ServerSideMqttHandler, { MqttResponseMessage } from 'mqtt-handler';

const handler = async message => {
  const { mqttRequestMessage, responseTopic } = JSON.parse(message);

  const { url, method, headers, data } = mqttRequestMessage;
  
  const responseMessage: MqttResponseMessage = {
    data: {
      message: `message received, url: ${url}, method: ${method}, headers: ${JSON.stringify(headers)}, data: ${JSON.stringify(data)}.`,
    },
    status: 200,
    statusText: 'OK',
  };
    
  await serverSideMqttHandler.publishResponseMessage(responseTopic, responseMessage);
}

await serverSideMqttHandler.connect({
  'my-request-topic': handler,
});

in case of handle request timeout

// client side
import ClientSideMqttHandler, { MqttRequestMessage } from 'mqtt-handler';

const clientSideMqttHandler = new ClientSideMqttHandler(
  [
    "my-mqtt-endpoint-1",
    "my-mqtt-endpoint-2",
  ],
  "my-mqtt-username",
  "my-mqtt-password",
);

await clientSideMqttHandler.connect();

const requestMessage: MqttRequestMessage = {
  url: 'my-url',
  method: 'POST',
  data: {
    message: 'message sent.'
  }
};

const timeout = 1000;

try {
  const response = await clientSideMqttHandler.publishRequestMessage('my-request-topic', requestMessage, timeout)
} catch (error) {
  if (error.message === 'Request Timeout') {
    // do something in case of request timeout
  }
}