var mqtt = require('mqtt')

var mysql = require('mysql');

var mysql_login_details = {
    host:               'localhost',
    user:               'root',
    password:           '1111',
    database:           'Node_Monitoring_System'
};

var connection = mysql.createConnection(mysql_login_details);
connection.connect();

var client  = mqtt.connect('mqtt://127.0.0.1')

function extract(data) { return data.split(':'); }

function extractDataRef(e) {
    var data = e[1].split(',');
    var lat = latlng[0];
    var lng = latlng[1];
    return {
        "name": e[0],
        "lat": lat,
        "lng": lng,
        "rssi": e[2]
    }
}


function mappingPayload(raw_payload) {
    var payload = raw_payload.split('|');
    var node_id = payload[0];

    var data_ref = payload[1].split('&').map(extract).map(extractDataRef);
    var temp = payload[2];
    var humid = payload[3];
    var lat = 0; // you have to calculate latitude and put it here
    var lng = 0; // you have to calculate longitude and put it here

    return {
        "node_id": node_id,
        "data_ref": data_ref,
        "temp": temp,
        "humid": humid,
        "lat": lat,
        "lng": lng
    }
}


client.on('connect', function () {
  client.subscribe('gun/sensor/dht/out')
})

client.on('message', function(topic, msg, pkt) {
    var data = mappingPayload(msg);
    conn.query('INSERT INTO historical_location SET ?', data, function(err, res) {
        if (err) throw err;
    });
});