var mqtt = require('mqtt');

var settings = {
    clientId: "", //<ambito utente>-<token dispositivo>
    username: "", //<username Databoom>
    password: "" //<oAuth Databoom>
};

var client = mqtt.connect("mqtt://mqtt.databoom.com:1883", settings);

var post_data = {
    type: "data",
    message: {
        device: "", //<token dispositivo>
        signals: [{
            name: "", //<token segnale>
            value:  //<valote segnale>
        }]
    }
};


client.on('connect', function () {
    console.log(new Date().toISOString(), "\tCLIENT CONNECTED TO DATABOOM BROKER")
    client.subscribe(''); //<topic sottoscrizione info> nel formato d'esempio MQTT/<token dispositivo>/info
});

client.on('message', function (topic, message) {
    console.log(new Date().toISOString(), "\tDATA PUBLISHED ON", "MQTT/<token dispositivo>/info");
    console.log(message.toString());
})

client.publish("", JSON.stringify(post_data), function (err) { //<topic pubblicazione data> nel formato d'esempio MQTT/<token dispositivo>/data
    console.log(new Date().toISOString(), "\tDATA PUBLISHED ON", "MQTT/<token dispositivo>/data");
    console.log(JSON.stringify(post_data));
});