mqtt.js

let Mqtt = require('mqtt');
let paramters = require('./parameters').parameters;
let logger = require('./log').logger;

function MqttHandler() {
    const self = this;
    if (!paramters.mqtt) {
        return;
    }

    if (paramters) {
        this.client = Mqtt.connect(paramters.mqtt.server, {
            clientId: paramters.mqtt.clientId,
            connectTimeout: paramters.mqtt.connectTimeout,
            keepalive: paramters.mqtt.keepalive,
            password: paramters.mqtt.password,
            username: paramters.mqtt.username,
            reconnectPeriod: paramters.mqtt.reconnectPeriod,
            port: paramters.mqtt.port

        });
        this.client.on('error', (topic, message) => {
            message = typeof message !== 'undefined' ? message : '';
            logger.error('mqtt error - ' + topic + ' : ' + message.toString());
        });
        this.client.on('close', () => {
            logger.error('mqtt close');
        });
        this.client.on('reconnect', () => {
            logger.error('mqtt reconnect');
        });
        this.client.on('connect', function () {
            logger.info('connected');
        });

    };

    this.connect = function () {
        this.client = Mqtt.connect(paramters.mqtt.server, {
            clientId: paramters.mqtt.clientId,
            connectTimeout: paramters.mqtt.connectTimeout,
            keepalive: paramters.mqtt.keepalive,
            password: paramters.mqtt.password,
            username: paramters.mqtt.username,
            reconnectPeriod: paramters.mqtt.reconnectPeriod,
            port: paramters.mqtt.port

        });
    };
    this.publish = function (part, data) {
        try {
            if (typeof data === 'undefined') {
                throw new Error('data not defined')
            }
            if (data === null) {
                return;
            }
            const topic = 'voc-to-mqtt/data/' + part;

            if (typeof data === 'boolean' && paramters.convertToOpenHab) {
                data = data ? 'ON' : 'OFF';
            }

            data = (typeof data === 'string' ? data : JSON.stringify(data));

            logger.info('mqtt - publish on topic - ' + topic + ' ' + data);
            this.client.publish(topic, data, { qos: 2, retain: false });
        } catch (e) {
            logger.error(e);
        }
    };
    this.subscribeToLockEvent = function(){
        self.client.subscribe('voc-to-mqtt/data/carLock');
    };
    this.subscribeToHeatEvent = function(){
        self.client.subscribe('voc-to-mqtt/data/heat');
    };
    this.subscribeToRefreshEvent = function (){
        self.client.subscribe('voc-to-mqtt/data/refresh');
    };

}

module.exports = {
    mqttHandler: new MqttHandler()
}