process.js

/**
* Module dependencies.
*/
var mysql		= require('mysql');
var _ 			= require('underscore');
var Twig 		= require("twig");
var express 	= require('express');
var http 		= require('http');
var path 		= require('path');
var Gamify 		= require("Gamify.io");

var options = _.extend({
	online:			true,
	env:			"dev",
	debug_mode:		false,
	port:			8080,
	mysql:			false,
	db:				"prod",
	batchsize:		50,
	mailmethod:		"smtp",
	process_emails:	false,
	race_update_interval:	5000
},processArgs());

var app = express();

// all environments
app.set('port', process.env.PORT || options.port);
app.set('env', options.env);
app.set('views', __dirname + '/api/doc/templates');
app.set('view engine', 'twig');
app.set('view cache', false);
app.disable('view cache');
app.set("twig options", {
	strict_variables: false
});
app.use(express.favicon());
app.use(express.logger('dev'));
app.use(express.cookieParser());
app.use(express.bodyParser());
app.use(express.methodOverride());
app.use(app.router);
app.use(express.static(path.join(__dirname, 'public')));

// development only
if ('dev' == app.get('env')) {
	app.use(express.errorHandler());
}


Gamify.settings.db 						= options.db;
Gamify.settings.mailmethod 				= options.mailmethod;
Gamify.settings.systoken 				= "sys540f40c9968814199ec7ca847ec45";
Gamify.settings.race_update_interval	= options.race_update_interval;		// ms - refresh rate for the races
Gamify.settings.mail_update_interval	= 5000;		// ms - refresh rate for the mail templates
Gamify.settings.default_race_time		= 5000;		// ms - countdown for the arcade races
Gamify.settings.max_min_late			= 5;		// min - How much  you can be late without being kicked out
Gamify.settings.mailstack_batchsize 	= options.batchsize;	// Mails to process per batch
Gamify.settings.mailstack_delay 		= 1000;	// Delay between mailstack batches
Gamify.settings.process_emails 			= options.process_emails;

if (options.mysql) {
	if (options.online) {
		console.log("Using MySQL with prod settings.");
		var mysql = mysql.createConnection({
			host     : 'localhost',
			user     : 'fleetwit_beta',
			password : '!80803666',
			database : 'fleetwit_beta'
		});
	} else {
		console.log("Using MySQL with local settings.");
		var mysql = mysql.createConnection({
			host     : 'localhost',
			user     : 'root',
			password : '',
			database : 'fleetwit'
		});
	}
	mysql.connect(function(err) {
		console.log("MySQL: Connected.");
		Gamify.sql = mysql;
		Gamify.api.init(function() {
			console.log("API mapped. Starting Mailstack...");
			Gamify.mailstack = new Gamify.Mailstack(Gamify.settings.db, Gamify, function() {
				console.log("Mailstack started. Starting server...");
				// Start the server
				http.createServer(app).listen(app.get('port'), function(){
					console.log('API server listening on port ' + app.get('port'));
				});
			});
		});
	});
} else {
	Gamify.api.init(function() {
		console.log("API mapped. Starting Mailstack...");
		Gamify.mailstack = new Gamify.Mailstack(Gamify.settings.db, Gamify, function() {
			console.log("Mailstack started. Starting server...");
			// Start the server
			http.createServer(app).listen(app.get('port'), function(){
				console.log('API server listening on port ' + app.get('port'));
			});
		});
	});
}


var apiRoute = function(req, res) {
	var data = {};
	if (req.route.method=='post') {
		data = _.extend({}, req.body);
	} else {
		data = _.extend({}, req.query);
		try {
			data.params = _.extend({},JSON.parse(data.params));	// get means we need to parse
		} catch(e) {}
	}
	console.log("\033[35m data(params):\033[37m",data);
	// Fix the types
	var i;
	for (i in data) {
		if (!isNaN(data[i]*1)) {
			data[i] *= 1;
		}
		if (data[i] == "true") {
			data[i] = true;
		}
		if (data[i] == "false") {
			data[i] = false;
		}
	}
	Gamify.api.execute(req.params.endpoint, req.params.method, data, function() {}, req.params.format, req, res);
}

app.get("/:endpoint/:method/:format?", function(req, res){
	apiRoute(req, res);
});
app.post("/:endpoint/:method/:format?", function(req, res){
	apiRoute(req, res);
});
app.get("/", function(req, res){
	res.set("Content-Type", "application/json");
	res.send(200, JSON.stringify({
		name:		"Gamify API Server",
		version:	Gamify.version,
		db:			Gamify.settings.db,
		options:	options,
		endpoints:	Gamify.api.endpoints
	}, null, 4));
});




function processArgs() {
	var i;
	var args 	= process.argv.slice(2);
	var output 	= {};
	for (i=0;i<args.length;i++) {
		var l1	= args[i].substr(0,1);
		if (l1 == "-") {
			if (args[i+1] == "true") {
				args[i+1] = true;
			}
			if (args[i+1] == "false") {
				args[i+1] = false;
			}
			if (!isNaN(args[i+1]*1)) {
				args[i+1] = args[i+1]*1;
			}
			output[args[i].substr(1)] = args[i+1];
			i++;
		}
	}
	return output;
};

/************************************/
/************************************/
/************************************/
// Process Monitoring
setInterval(function() {
	process.send({
		memory:		process.memoryUsage(),
		process:	process.pid
	});
}, 1000);

// Crash Management
if (!options.debug_mode) {
	process.on('uncaughtException', function(err) {
		console.log("err",methods);
		//global.monitor.log("Stats.error", err.stack);
	});
}