var express = require('express'), fs = require('fs'), sqlite3 = require('sqlite3').verbose();
var router = express.Router();

var temp_db;
var file = process.env.DB_HOME + '/' + "temp.db";
var exists;
/* GET users listing. */

function createDB() {
  console.log('Creating Temp db...');

  if (!fs.existsSync(file)) {
    console.log('creating db file');
    fs.openSync(file,'w');

    temp_db = new sqlite3.Database(file, createTable);

    temp_db.close();
  }



}

function connectDB() {
  "use strict";
  console.log('Connect db.');
  temp_db = new sqlite3.Database(file);
	console.log(temp_db);
}

function createTable() {
  console.log('Creating temp table...');
  temp_db.run('CREATE TABLE IF NOT EXISTS temp (date text, reading real);');
}


function closeDB() {
  "use strict";
  console.log('Closing db.');
  temp_db.close();
}

function insertTempReading(time, reading) {
 console.log('Inserting reading:' + reading);

 // var sql = db.prepare('INSERT into temperature(date, reading) VALUES
  // (?,?)',[time],[reading]);

  temp_db.run('BEGIN TRANSACTION');
  temp_db.run('INSERT into temp(date, reading) VALUES (?,?)',[time, reading]);

  temp_db.run('END');

}

router.get('/', function(req, res, next) {
  var now = new Date();

  var t = req.query;

  console.log('t:');
  console.log(JSON.stringify(t));
  if (req.query != {} && req.query.temp != null)
  {
   // createDB();
    console.log(req.query);
    connectDB();

    insertTempReading(now.toJSON(),parseFloat(req.query.temp) );

    closeDB();
    res.writeHead(200, {"ContentType": "text/html"});
    //res.send(JSON.stringify(t));
    res.end('ok');
  } else
  {
    res.writeHead(200, {"ContentType": "text/html"});
    //res.send(JSON.stringify(t));
    res.end('error?');
  }






});

router.get('/:id', function(req, res, next) {
  var id = req.params.id;

  console.log('id: ' + id);
  res.writeHead(200, {"ContentType": "text/html"});
  //res.send(JSON.stringify(t));
  res.end('ok');
});

router.get('/reading', function(req, res, next) {
  var now = new Date();

  var t = req.query;

  console.log('t:');
  console.log(JSON.stringify(t));

  res.writeHead(200, {"ContentType": "application/json"});
        //res.send(JSON.stringify(t));
  res.end(JSON.stringify({}));
});


router.post('/', function(req, res, next) {
  "use strict";
    console.log('POST');
  var t = req.body;
  var now = new Date();
  console.log('t:');
    console.log(JSON.stringify(t));
  if (t != {} && t.temp != null)
    {
     // createDB();
      console.log(t.temp);
console.log('A');
      connectDB();
console.log('B');

      insertTempReading(now.toJSON(),parseFloat(t.temp) );
console.log('C');
      closeDB();

    }

  res.writeHead(200, {"ContentType": "text/html"});
          //res.send(JSON.stringify(t));
    res.end('ok');
});


router.get('/all', function(req, res, next) {
  "use strict";
  console.log('Selecint all..');
  connectDB();

    temp_db.all('SELECT * from temp', function(err, rows) {

      var out = [];
      console.log(err);
        console.log(rows);
        rows.forEach(function (row) {
          console.log(row.date + ', ' + row.reading);
        //  var t = ;
        //  out.push({"date": Date(row.date), "reading":row.reading});
          out.push({"date":  row.date, "reading":row.reading});
        });

      res.writeHead(200, {"ContentType": "application/json"});
          //res.send(JSON.stringify(t));
          res.end(JSON.stringify(out));

      closeDB();
    });



});

module.exports = router;

//createDB();