import mqtt from 'mqtt';


function createConsumerMqttClient({ ssl = true }) {

    const host = '<host>';
    const path = '/ws';
    const protocolVersion = 5;
    let port = 15675;
    let protocol = 'ws';

    if (ssl) {
        port = 15676;
        protocol = 'wss';
    }

    return mqtt.connect(`${protocol}://${host}${path}`, {
        port,
        protocolVersion,
        clientId: 'mqtt_11111',
        username: '<username>',
        password: '<password>',
        reconnectPeriod: 5000,
        queueQoSZero: true,
        resubscribe: true,
        clean: true,
        keepalive: 30,
        properties: {
            sessionExpiryInterval: 600
        }
    });

}

createConsumerMqttClient({ ssl: true })
.on('connect', function () {
    console.log('\n\nMQTT Client connected\n\n');
})
.on('error', function (error) {
    console.log('\n\nMQTT Client error\n\n', error);
})
.on('message', function (topic, message, packet) {
    console.log('\n\nMQTT Client message\n\n', { topic });
})
.subscribe('<topic>', { qos: 1 }, function (error) {
    console.log('\n\nMQTT Client subscribe\n\n', error);
});