// var dbFile = "/usr/db/data.db";
var dbFile = "/home/pi/data.db";
// var dbFile = '/Users/patrickjmcd/data.db';
// app.get('/json/add/:tag',               fns.addTag);               // Adds a tag to the scan list
// app.get('/json/remove/:tag',            fns.removeTag);            // Removes a tag from the scan list
// app.get('/json/val/:tag',               fns.latestTagValue);       // Gets the latest value of a single tag
// app.get('/json/series/:tag/:hours',     fns.seriesTagValues);      // Gets all the values of a tag for the last X hours
// app.get('/json/tags',                   fns.allTags);              // Lists all tags in the scan list
// app.get('/json/all',                    fns.allValues);            // Gets the latest values of all tags in the scan list


var getTagID = function(tagName, cb){
	//Returns function(err, id)
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "SELECT id FROM tags WHERE tagName = ?";
		var prepQuery = db.prepare(query);
		prepQuery.all(tagName, function(err, rows){
			prepQuery.finalize();
			db.close();
			if (err){
				cb(err, null);
			} else {
				cb(null, rows[0].id);
			}
		})
	});
};

exports.getTagID = function(req, res){
	getTagID(req.params.tagName, function(err, id){
		if (err){
			console.log(err);
			res.json({status:"error", message:err});
		} else {
			res.json({status: "OK", tagName: req.params.tagName, id: id});
		}
	})
};

exports.createTag = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "INSERT INTO tags (tagName, units, minExpected, maxExpected) VALUES (?, ?, ?, ?)";
		var prepQuery = db.prepare(query);
		prepQuery.run(req.params.tagName, req.params.units, req.params.min, req.params.max, function(err){
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK"});
			}
		});
	});
};

exports.getTag = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "SELECT * FROM tags WHERE id = ?";
		var prepQuery = db.prepare(query);
		prepQuery.all(req.params.id, function(err, rows) {
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK", tags:rows});
			}
		});
	});
};

exports.updateTag = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "UPDATE tags set tagName = ?, units = ?, minExpected = ?, maxExpected = ? WHERE id = ?";
		var prepQuery = db.prepare(query);
		prepQuery.run(req.params.tagName, req.params.units, req.params.min, req.params.max, req.params.id, function(err) {
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK"});
			}
		});
	});
};

exports.deleteTag = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "UPDATE tags SET deleted = 1 WHERE id = ?";
		var prepQuery = db.prepare(query);
		prepQuery.run(req.params.tag, function(err) {
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK"});
			}
		});
	});
};



exports.latestTagValue = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "SELECT * FROM vals WHERE id = (SELECT MAX(id) FROM vals WHERE tagID = ?)";
		var prepQuery = db.prepare(query);
		prepQuery.all(req.params.tag, function(err, rows) {
			console.log(rows);
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK", tag_val:rows[0]});
			}
		});
	});
};

exports.seriesTagValues = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "SELECT * FROM vals WHERE tagID = ? AND dateAdded > DATETIME('now', '-24 HOUR')";
		var prepQuery = db.prepare(query);
		prepQuery.all(parseInt(req.params.tag), function(err, rows){
			prepQuery.finalize();
			db.close();
			if (err){
				console.log(err);
				res.json({status:"error", message:err, query:query});
			} else {
				res.json({status:"OK", tag: req.params.tag, vals:rows});
			}
		})
	});
};

exports.getAllTags = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "SELECT * FROM tags WHERE deleted = 0";
		var prepQuery = db.prepare(query);
		prepQuery.all(function(err, rows) {
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK", tags:rows});
			}
		});
	});
};



exports.allValues = function(req, res){
	var sqlite3 = require('sqlite3').verbose();
	var db = new sqlite3.Database(dbFile);

	db.serialize(function(){
		var query = "SELECT t.tagName as tagName, t.vanityName as vanityName, t.description as description, t.units as units, t.id as t_id, t.minExpected as min, t.maxExpected as max, MAX(v.id) as v_id, v.val as val, v.dateAdded as dtime FROM vals v JOIN tags t ON v.tagID = t.id WHERE t.deleted = 0 GROUP BY v.tagID";
		var prepQuery = db.prepare(query);
		prepQuery.all(req.params.id, function(err, rows) {
			prepQuery.finalize();
			db.close();
			if (err) {
			  	res.json({status:"error", message:err});
			  	console.log(err);
			} else {
				res.json({status:"OK", vals:rows});
			}
		});
	});
};