app.js

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//  										DE-MOG
// 					Dictator Experiment through Multiplayer Online Game
//
// Date: 2014/06/18
// Version: 0.5
// Author: Olivier Allouard
// Website: http://running-panda.fr
// Contact: olivier.allouard@gmail.com
// Description:
//					The Express server handles passing the content to the browser. It's the router
//					The Socket.io server handles real time communications between clients and server
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////


////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
// Copyright © Olivier Allouard
//
//Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"),
//to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, 
//and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
//
//The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
//
//The Software is provided "as is", without warranty of any kind, express or implied, including but not limited to the warranties of merchantability, 
//fitness for a particular purpose and noninfringement. In no event shall the authors or copyright holders be liable for any claim, damages or other liability,
//whether in an action of contract, tort or otherwise, arising from, out of or in connection with the software or the use or other dealings in the Software.
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

require('./player.js');
require('./experiment');
require('./sioserver.js');

//require('newrelic');

/*
lines to comment for the app to run locally on ubuntu:
    require('newrelic');
	nodeMailer = require('nodemailer'),                     //Used to send results by mail to the admin
    smtpTransport = require('nodemailer-smtp-transport'),
    sgTransport = require('nodemailer-sendgrid-transport'),
	localTransport
*/
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//
// Variables Declaration
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

var 
	gameport 	= process.env.PORT || 8099,					// Listen port of the server (8099 or a specific port declared by the host machine)
	io          = require("socket.io"),                     //
	express 	= require('express'),						//
	UUID		= require('node-uuid'),						//
	routes 		= require('routes'),						//
	http 		= require('http'),							//
	app 		= express(),								//
    fs = require('fs'),                                     //Used to write the result json file in the log folder of the server

    /*
	nodeMailer = require('nodemailer'),                     //Used to send results by mail to the admin
    smtpTransport = require('nodemailer-smtp-transport'),
    sgTransport = require('nodemailer-sendgrid-transport'), */

    sendgrid  = require('sendgrid')(process.env.SENDGRID_USERNAME, process.env.SENDGRID_PASSWORD),
    sio         = undefined,
    wrap_server = undefined;
	
// to add a new variable to the result file:
// In core.js, record variable with this.variable and send variable to SetGameResult in function prototype.Share (4x)
// In player.js, add to function prototype.SetGameResult, prototype.addGameResult and var GameResult
// In sioserver.js, add to function addGameResults in prototype.checkEndedGames
// In experiment.js, add to prototype.addGameResults and var gameResult

var frame_time = 60;
var physic_time = 15;

var adminLogin = "demog";                                  //Login of the admin page
var adminPassw = "test";                                //password of the admin page

var resultMailAdress = 'resultsdemog@yahoo.fr';     //mail adress where the results will be send

var mailSenderLogin = 'olivier.allouard@gmail.com';         //login of the gmail account used to send results
var mailSenderPassw = 'wivyxuvo';                           //password of the gmail account used to send results


//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
// 
// Experiment Functions and Variables
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  
var 
    current_experiment = CreateExperiment('space',"web",1,"space_coop","en"),
    experimentsList = [current_experiment];

function CreateExperiment(name,type,iter,game,lang)
{
    try{
        return(new Experiment(name,type,iter,game,lang));
    }catch(err)
    {
        console.log(err);
    }
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//
// Mail sender set up
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
/*
var LocalTransport = nodeMailer.createTransport("SMTP",{
   service: "Gmail",
   auth: {
       user: mailSenderLogin,
       pass: mailSenderPassw
   }
});
*/

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//
// Express server set up
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

app.configure(function(){
    app.set('views', __dirname + '/views');
    app.use(express.favicon());
    //app.use(express.logger('dev'));
    app.use(express.static(__dirname + '/public'));
    app.use(express.bodyParser());
    app.use(express.methodOverride());
    app.use(app.router);
    app.use("/public",express.static(__dirname+"/public"));
});

var server 		= http.createServer(app);					// Creation of the Express server

server.listen(gameport);

app.get('/admin',function(req,res){
    res.render('admin.ejs',{login: adminLogin, passw: adminPassw});
})

app.get('/dictateur',function(req,res){
    res.render('dictateur.ejs', {exps: experimentsList, clientsInGameNum: wrap_server.clients.length, clientsInLobbyNum: wrap_server.clientsinLobby.length, clientsFinished: wrap_server.experiment.returnOldCLientsNum()});
});

app.post('/dictateur/add/', function(req,res){
    var xpName = req.param('xpName');
    var xpType = req.param('xpType');
    var xpGame = req.param('xpGame');
    var Iter = req.param('Iter');
    var lang = req.param('lang');
    if(xpName != '')
    {
        experimentsList.push(CreateExperiment(xpName,xpType,Iter,xpGame,lang));
    }
    res.redirect('/dictateur');
});

app.post('/dictateur/delete/:xpName', function(req, res) {
    var xpName = req.param('xpName');
    if (xpName != '') {
        for(var i =0; i < experimentsList.length; i ++)
        {
            if(experimentsList[i].xpName == xpName)
            {
                experimentsList.splice(i,1);
            }
        }
    }
    res.redirect('/dictateur');
});
app.post('/dictateur/start/:xpName', function(req, res) {
    var xpName = req.param('xpName');
    if (xpName != '') {
        for(var i =0; i < experimentsList.length; i ++)
        {
            if(experimentsList[i].xpName == xpName)
            {
                experimentsList[i].startXP();
                current_experiment = experimentsList[i];
                wrap_server.initServer(current_experiment, server);
                
            }
            else
            {
                experimentsList[i].stopXP();
            }
        }
    }
    res.redirect('/dictateur');
});
app.post('/dictateur/stop/:xpName', function(req, res) {
    var xpName = req.param('xpName');
    if (xpName != '') {
        for(var i =0; i < experimentsList.length; i ++)
        {
            if(experimentsList[i].xpName == xpName)
            { 
                wrap_server.stopServer();
                experimentsList[i].stopXP();
            }
        }
    }
    res.redirect('/dictateur');
});

app.post('/dictateur/write/:xpName', function(req, res) {
    var xpName = req.param('xpName');
    if (xpName != '') {
        for(var i =0; i < experimentsList.length; i ++)
        {
            if(experimentsList[i].xpName == xpName)
            {
                var mailOptions = {
                    from: 'DEMOG RESULTS SERVICE', // sender address
                    to: resultMailAdress, // list of receivers
                    subject: 'Results from exp', // Subject line
                    text: 'Results of the experiment : '+current_experiment.xpName, // plaintext body
                    html: 'Results of the experiment : '+current_experiment.xpName ,// html body
                    attachments : 
                        [{      filename: 'result.json',
                                contents: JSON.stringify(experimentsList[i], null, 4)

                        }]
                };

                if(gameport == 8099)
                {
                    LocalTransport.sendMail(mailOptions, function(error, info){
                        if(error){
                            console.log(error);
                        }
                    });
                }
                else
                {
                    var payload   = 
                    {
                        to      : resultMailAdress,
                        from    : mailSenderLogin,
                        subject : 'Experiment Result',
                        text    : 'Results of the experiment : '+current_experiment.xpName,
                        files : 
                        [
                            {
                                filename: 'result.json',
                                content : JSON.stringify(experimentsList[i], null, 4)
                            }
                        ]
                    }
                    sendgrid.send(
                        payload,
                        function(error, json){
                            if(error){
                                console.log(error);
                            }
                        }
                    );
                }  
            }
        }
    }
    res.redirect('/dictateur');
});



app.get('/game', function(req, res){
    res.render('client.ejs', {exp: current_experiment});
});

app.get('/end1', function(req,res){
    res.render('end1.ejs');
});

app.get('/end3', function(req,res){
    res.render('end3.ejs');
});

app.get('/end5', function(req,res){
    res.render('end5.ejs');
});

app.get('/home1', function(req,res){
    res.render('home1.ejs');
});
app.get('/home12', function(req,res){
    res.render('home12.ejs');
});
app.get('/home13', function(req,res){
    res.render('home13.ejs');
});
app.get('/home14', function(req,res){
    res.render('home14.ejs');
});
app.get('/home15', function(req,res){
    res.render('home15.ejs');
});
app.get('/home16', function(req,res){
    res.render('home16.ejs');
});
app.get('/home17', function(req,res){
    res.render('home17.ejs');
});

app.get('/home3', function(req,res){
    res.render('home3.ejs');
});
app.get('/home32', function(req,res){
    res.render('home32.ejs');
});
app.get('/home33', function(req,res){
    res.render('home33.ejs');
});
app.get('/home34', function(req,res){
    res.render('home34.ejs');
});
app.get('/home35', function(req,res){
    res.render('home35.ejs');
});
app.get('/home36', function(req,res){
    res.render('home36.ejs');
});
app.get('/home37', function(req,res){
    res.render('home37.ejs');
});
app.get('/home5', function(req,res){
    res.render('home5.ejs');
});
app.get('/home52', function(req,res){
    res.render('home52.ejs');
});
app.get('/home53', function(req,res){
    res.render('home53.ejs');
});
app.get('/home54', function(req,res){
    res.render('home54.ejs');
});
app.get('/home55', function(req,res){
    res.render('home55.ejs');
});
app.get('/home56', function(req,res){
    res.render('home56.ejs');
});
app.get('/home57', function(req,res){
    res.render('home57.ejs');
});


//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//
// Socket.IO server set up
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////


function CreateSIOServer()
{
    
    sio = io.listen(server);
    sio.configure(function (){
        sio.set('log level', 0);
        sio.set('authorization', function (handshakeData, callback){
            callback(null , true);
        });
    });

    wrap_server = new game_server();
    wrap_server.initServer(current_experiment);
}

function StopSIOServer()
{
    wrap_server = undefined;
    sio = undefined;
}

current_experiment.isRunning = true;
CreateSIOServer();

if(sio != undefined)
{
/*
	sio.on('connection', function(client){
		var client_ip_address = sio.request.connection.remoteAddress;
		console.log(client_ip_address);
	} */
    sio.sockets.on('connection', function (client){
		//var socketId = client.id;
		var clientIp = client.handshake.address;
	    clientIp = client.manager.handshaken[client.id].address;
		console.log(clientIp)
        var tmpClient = client;
		var addr = client.handshake.address;
        //console.log(sio);
		//var sHeaders = client.handshake.headers;
		//console.log(sHeaders.host);
	   
        client.userid = UUID();
        client.player = new player();
        client.player.InitResult(client.userid,undefined);
        client.player.result.updateStatus("waiting for games");
	    //client.player.result.updateIP(addr.address);
		//client.player.result.updateIP(sio.request.connection.remoteAddress);      
		wrap_server.addClient(client);
        
        client.on('playerLogin', function (m){
            client.player.result.amazonId = m;
        });
        client.on('partnerLost', function (){
            client.player.result.lostPartner = 1;
        });
        client.on('message', function (m){
            wrap_server.onMessage(client, m);
        });

        client.on('disconnect', function (){

			
            if(wrap_server.isClientInLobby(client))
            {
                wrap_server.removeClientFromLobby(client);
                wrap_server.removeClient(client); 
            }
            else if(wrap_server.isClientInGame(client))
            {
				wrap_server.findPartner(wrap_server.findGame(client),client) // asks partner to emit message "partnerLost"
                wrap_server.endGame(wrap_server.findGame(client));
                wrap_server.removeClientFromLobby(client);
                wrap_server.removeClient(client);
            }
            else
            {
               wrap_server.removeClient(client);   
            } 
        });
    }); 
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//
// Matching players routine
//
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

//Called every 5 seconds to match waiting players in the lobby
setInterval(function(){
    if(wrap_server != undefined && wrap_server.experiment.isRunning)
    {
        wrap_server.matchClients();     
    }
    else if(!wrap_server.experiment.isRunning)
    {

    }
}, 5000);
//Check ended games in wrap_server
setInterval(function(){
   wrap_server.update(frame_time);
   wrap_server.checkEndedGames();
}, frame_time);
//call update of the game server
setInterval(function(){
   wrap_server.physic_update(physic_time);
}, physic_time);