var webduino = require('webduino-js');
var mysql = require('mysql');
var board = new webduino.WebArduino('76QP');

connection = mysql.createConnection({
    host: 'localhost',
    user: 'monitor',
    password: 'Z4GigvD4UwVLXtPY',
    database: 'monitor'
});
connection.connect();

temp = [];
humi = [];

avg = function (list) {
    var sum = 0;
    for (var index in list) {
        sum += parseInt(list[index], 10);
    }

    return parseFloat(sum / list.length);
}

digit2 = function (n) {
    return n > 9 ? "" + n : "0" + n;
}

getDateTime = function () {
    var d = new Date;

    return d.getFullYear()
        + '-' + digit2(d.getMonth() + 1)
        + '-' + digit2(d.getDate())
        + ' ' + digit2(d.getHours())
        + ':' + digit2(d.getMinutes())
        + ':' + digit2(d.getSeconds());
}


saveTemparature = function (list) {
    var temp = avg(list);
    var sql = 'insert into temperature set ? ';

    connection.query(sql, {
        'temperature': temp,
        'created_at': getDateTime()
    }, function (err, result) {
        if (err) {
            throw err;
        }
    });
}

var dht;
board.on('ready', function() {
    dht = new webduino.module.Dht(board, board.getDigitalPin(10));
    dht.read(function(e) {
        temp.push(dht.temperature);
        humi.push(dht.humidity);

        if (temp.length == 10) {
            saveTemparature(temp);

            temp = [];
        }
    }, 2000);
});