var io = require('socket.io').listen(8080);
io.set('log level', 1);
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'xxx',
password : 'xxx',
database : 'xxx'
});
var user_id = "";
var user_password = "";
io.sockets.on('connection', function (socket) {
var user_connected = 0;
socket.on('message', function (token) {
token = token.split(',');
user_id = token[0];
user_password = token[1];
if (token[2] == "connect"){
connection.connect();
connection.query("SELECT COUNT(*) AS idCount FROM users WHERE user_id ='"+user_id+"' AND password = '"+user_password+"' LIMIT 1", function(err, results) {
if (err){throw err;}
if (results[0].idCount > 0){
user_connected = 1;
}
});
connection.end();
}
});
socket.json.send({'event': 'messageSent', 'quest': user_connected});
});