var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io').listen(http);
var port = process.env.PORT || 3000;
var parseurl = require('parseurl')
var session = require('express-session');
var Sequelize = require('sequelize');
const sha256 = require('sha256');
var sharedsession = require("express-socket.io-session");

const DBConnection = new Sequelize('pokemongo', 'pokemonGo', 'u3Iys72~', {
  host: 'localhost',
  dialect: 'mysql'
});

DBConnection.authenticate()
  .then(() => {
    console.log('Connection has been established successfully.');
  })
  .catch(err => {
    console.error('Unable to connect to the database:', err);
  });

var mySession = session({
  secret: 'R1giMG39c8tF',
  resave: false,
  saveUninitialized: true
});

app.use(mySession)

app.get('/', function(req, res){
	if(!req.session.userID) {
		res.sendFile(__dirname + '/login.html');
	} else {
		res.sendFile(__dirname + '/index.html');
	}
});

app.get('/foo', function (req, res, next) {
  res.send('you viewed this page wtf times')
})



app.get('/wat', function(req, res){
  res.send(port.toString())
});

io.use(sharedsession(mySession, {
    autoSave:true
}));

io.on('connection', function(socket){
  socket.on('Login',function(msg) {
	DBConnection.query("SELECT * FROM `user` WHERE username = $username LIMIT 1", { bind: { username: msg.username },type: DBConnection.QueryTypes.SELECT})
	.then(users => {
		if(users.length == 1) {
			if(users[0].password == sha256(msg.password).toUpperCase()) {
				socket.handshake.session.userID = users[0].id;
				socket.handshake.session.save();
				io.emit('LoginStatus', 'Login Sucess');
			} else {
				io.emit('LoginStatus', 'Login Failed');
			}
		}
	})
	return false;
  });

  socket.on('Logout',function(msg) {
	delete socket.handshake.session.userID;
	socket.handshake.session.save();
  });
});

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