var client = require("socket.io").listen(8001).sockets;
var mysql = require("mysql");

var config = {
	host: "localhost",
	user: "root",
	password: "",
	database: "incremental"
};

var num = 0;
var con;
function handleConnection() {
	con = mysql.createConnection(config);

	con.connect(function(err) {
		if (err) {
			console.log("Error connecting: " + err);
			setTimeout(handleConnection, 2000);
		} else {
			console.log("Connected.");
		}
	});

	con.on("error", function(err) {
		console.log("Error: " + err);
		if (err.code === "PROTOCOL_CONNECTION_LOST") {
			handleConnection();
		} else {
			throw err;
		}
	});
}

client.on("connection", function(socket) {
	handleConnection();
  socket.on("add", function(data) {
	 con.query("SELECT * FROM testing", function(err, res) {
	 	if (err) throw err;
		console.log("Returned amount: " + res[0].amount);
		num = parseInt(res[0].amount);
		num += 1;
		console.log("Number value = " + num);
	 });

	 con.query("UPDATE testing SET amount = ? WHERE id = ?", [num, 1], function (err, res) {
		 if (err) throw err;

		 con.query("SHOW WARNINGS", function (err, res) {
			 console.log(res);
		 });

		 console.log(res);

	 });


  });
});