var port = 1337;
var io = require("socket.io").listen( port );
var colors = require('colors');
var Sequelize = require("sequelize");
var sequelize = new Sequelize('authentication', 'root', 'papatool2001', {
    host: "localhost",
    port: 3306,
    dialect: 'mysql'
});

var seqConnection = sequelize.authenticate()
    .then(function () {
        console.log("Connected successfully to the database! ".green);
    })
    .catch(function (err) {
        console.log("Connected failed to the database".red);
    })
    .done();

var users = 0;

io.on("connection", function(socket) {
    // sequelize
    var User = sequelize.define('User', {
    id      : Sequelize.INTEGER,
    username: Sequelize.STRING,
    password: Sequelize.STRING
    }, {
    tableName: 'accounts', // this will define the table's name
    timestamps: false           // this will deactivate the timestamp columns
    })
    // sequelize end
    users++;
    console.log( 'Client verbunden');

    io.emit("userChange", users);

    socket.on("_ping", function() {
        socket.emit("_pong");
    });

    socket.on("disconnect", function() {
        users--;
        io.emit("userChange", users);
    });

    socket.on("authentication", function(data){
        var username = data.username;
        var password = data.password;
        User
          .find({ where: { username: username } })
          .then(function(err, username) {
            if (!username) {
              console.log('No user with the username has been found.');
            } else {
              console.log('Hello ' + username + '!');
            }
          });
    });

});

console.log( "Server erfolgreich gestartet".green );