Simple (& dumb) insert in ES

insert_in_es.js

const mqtt = require('mqtt');
const ES = require('esta');

const INDEX = 'mqtt',
    TYPE = 'eclipse';

ES.CONNECT(INDEX, function(response) {
    // When DB is on => connect to mqtt
    const client = mqtt.connect('mqtt://iot.eclipse.org');

    client.on('connect', () => {
        client.subscribe('#');
    });

    client.on('message', (topic, message) => {
        addARecord(message.toString(), topic);
    });
});

function addARecord(message, topic) {
    var record = {
        index: INDEX,
        type: TYPE,
        date: new Date().toISOString(),
        message: message,
        topic: topic
    };
    ES.CREATE(record, function(response) {
        console.log(response.created);
    });
}

process.on('uncaughtException', function(err) {
    console.log('ERROR: ' + err);
});