var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var mysql = require('mysql');
var _ = require('underscore');

var connection = mysql.createConnection({
    host     : 'locahost',
    user     : 'root',
    password : 'root',
    database : 'dj8'
});

connection.connect(function(err){
    console.log("Error in establishing connection." + err);
});

app.get('/', function(req, res){
  res.sendFile(__dirname + '/index.html');
});

http.listen(3000, function(){
  console.log('listening on *:3000');
});

io.on('connection', function(socket){
  socket.on('connect', function(id) {
    var currentUser;
    console.log("A User connected");
    connection.query("SELECT * FROM users WHERE id=?",id, function(error, result) {
        if(error) {
            console.log(error);
            return;
        }
        currentUser = result[0];
        connection.query("SELECT * FROM users WHERE gender=? AND timezone=? AND status = ? AND age BETWEEN ? AND ?",1-currentUser.gender,currentUser.timezone,0,currentUser.age-2,currentUser.age+2,function(error, result) {
            if(error) {
                console.log(error);
                return;
            }
            var matches = _.pluck(result, "id");
            _.each(matches, function(match) {
                connection.query("SELECT count(*) FROM matchings WHERE user1=? AND user2=? OR user1=? AND user2=?",currentUser.id,match,match,currentUser.id, function(error, result){
                    if(error) {
                        console.log(error);
                        return;
                    }
                    if(result.value == 0) {
                        connection.query("INSERT INTO matchings VALUES(?,?)",currentUser.id,match,function(error, result){
                            console.log(error);
                        });
                    }
                    return !result.value;
                });
            });
        });
    });
  });
  socket.on('disconnect', function(){
    console.log('user disconnected');
  });
});