/*---------------------packages nescessários--------------------------------*/
var express=require('express'),
app=express(),
http=require('http').createServer(app),
io=require('socket.io')(http),
path=require('path'),
bodyParser=require('body-parser'),
mysql=require('mysql'),
sharedsession=require("express-socket.io-session");
/*----------------------------------------------------------------------*/

const PORT=process.env.PORT || 5000;

var session=require('express-session')({
	secret: "my-secret",
    resave: false,
    saveUninitialized: false,
    cookie: { maxAge: 3600000}
});

app.use([
	bodyParser.urlencoded({ extended: false }),
	bodyParser.json(),
	session
]);

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

/*----------------------POSTS-------------------------------------------------------------*/

app.post('/dataPost', function(req, res){

	console.log(req.body);
	io.volatile.emit('data', req.body);
	res.sendStatus(200);
});

/*-----------------------------------------------------------------------------------*/
var pool = mysql.createPool({
	connectionLimit : 100,
	host : 'banco_whatsapp.mysql.dbaas.com.br',
	user : 'banco_whatsapp',
	password : 'rodrigo123',
	database : 'banco_whatsapp',
	debug : false
});


io.on('connection', function(socket){
	var session = socket.handshake.session;

	if(!session.autorizado){// tire esse ! para habilitar a session
		socket.on('insertIntoDb', function(data, callback){

			var numero = data.numero;
			var mensagem = data.mensagem;

			pool.query("INSERT INTO MESSAGE_SENDED (NUMBR, BODY, DATE_INPUT) VALUES ("+numero+", '"+mensagem+"', sysdate())", (err, rows)=>{

				if(!err){
					var callbackDataError = {error: false, data:rows}
				}else{
					var callbackDataError = {error: err, data:rows}
				};
				callback(callbackDataError);
			});
		});
	}
});
http.listen(PORT,function(){
console.log('listening on *:'+PORT);
});