index.js

const MQTT = require("mqtt")
const Livolo = require("./modules/livolo")
const IR = require("./modules/ir")
const IRMapping = require("./params/ir").default

const TOPICS = ["home/office/light", "home/living/tv"]

let client = MQTT.connect("mqtt://localhost")
let started = false

client.on("connect", function() {
  client.subscribe(TOPICS)
})

client.on("message", function(topic, message) {
  // avoid actions on connect
  if (!started) {
    started = true
    return
  }

  const receivedMessage = message.toString()
  console.log("Received message on " + topic + ": " + receivedMessage)

  switch (topic) {
    case "home/office/light":
      Livolo.switch(receivedMessage)
      break
    case "home/living/tv":
      IR.send(IRMapping.living.tv[receivedMessage])
      break
    default:
      throw "Unknown topic"
  }
})