index.js

import * as config from "./config.js";

import * as mqtt from "mqtt";
import axios from "./http/axios.js";

import * as mqttUtils from "./mqtt/utils.js";
import * as mqttLogger from "./mqtt/logger.js";
import chalk from "chalk";

const topics = mqttUtils.parseTopicsDirectory();

const client = mqtt.connect(mqttUtils.formatConnectionOpts(config.mqtt));

console.log(client.options);

client.on("connect", () => {
    mqttLogger.connect();

    client.subscribe(topics, (err, grant) => {
        if (err) {
            mqttLogger.subscriptionError(err);
        }

        mqttLogger.subscribed(grant);
    });
});

client.on("message", function (topic, message) {
    message = message.toString();

    mqttLogger.message(topic, message);

    axios
        .post("/iot/messages", {
            "real_topic": topic,
            "iot_message_value": message
        })
        .then(function (response) {
            console.log(response.data);
        })
        .catch(function (error) {
            // TODO: handle error + log + cache + retry
            mqttLogger.log(chalk.bgRed.bold(mqttLogger.dateStr() + "AJAX ERROR"));

            console.log(error.response.data);
        });
});

// client.on("packetsend", mqttLogger.packetsend);
// client.on("packetreceive", mqttLogger.packetreceive);
client.on("reconnect", mqttLogger.reconnect);
client.on("close", mqttLogger.close);
client.on("offline", mqttLogger.offline);
client.on("end", mqttLogger.end);
client.on("error", mqttLogger.error);