app.js

/** Module dependencies **/

var express = require('express')
, http      = require('http')
, path      = require('path')
, faye      = require('faye')
, fs 		= require('fs')
, OsomTalk  = require('./models/osomtalk.js').OsomTalk
, MemStore = express.session.MemoryStore;

/** Configurations **/
global.frontEndConfig 	= require('./public/js/frontend_config.js').FrontEndConfig;
global.appConfig 		= require('./app_config.js').AppConfig;

/** Global Libraries **/
global.crypto 			= require('crypto');
global.OAuth 			= require('oauth').OAuth;
global.MongoClient 		= require('mongodb').MongoClient;


/* Toogle use of Redis */
if (appConfig.use_redis) {
	var RedisStore = require('connect-redis')(express), redis = require('redis');

	global.redisclient = redis.createClient(appConfig.osomtalk_session.port, appConfig.osomtalk_session.host);
	global.redisclient.on("error", function(err) {
	  console.error("Error connecting to redis ", err);
	  process.exit(1);
	});

	global.redisclient.auth(appConfig.osomtalk_session.pass, function() {console.log("Connected!");});
	global.redisStore 		= new RedisStore({client: global.redisclient});
}

/** Global OsomTalk Classes **/
global.User 			= require('./public/js/user.js').User;
global.Room 			= require('./models/room_model.js').Room;
global.utils 			= require('./public/js/utils.js').utils;

global.osomtalk 		= new OsomTalk();

/** Add the analytics code if the file is present **/
fs.readFile('analytics.html', 'utf8', function (err,data) {
	if (err) {
		console.log("Couldn't find analytics code, if you wish to use one create the file 'analytics.html'");
		global.ANALYTICS = "";
	} else {
		global.ANALYTICS = data;
	}
});

var app = express();
app.configure ( function(){
	app.set('port', process.env.PORT || 3000);
	
	/** Jqtpl **/
	app.set('views', __dirname + '/views');
	app.set('view engine', 'html');
	app.set('layout', false);
	app.engine('html', require('jqtpl').__express);


	app.use(express.bodyParser());
	
	app.use(require('less-middleware')({ src: __dirname + '/public' }));
	app.use(express.static(path.join(__dirname, 'public')));

	if(appConfig.use_redis) {
		console.log("Using Redis for Session");
		app.use(express.cookieParser());
		app.use(
			express.session({
				store: global.redisStore,
				secret: appConfig.cookie_secret
			})
		);
	} else {
		console.log("Using Memory for Session");
		
		app.use(express.cookieParser(appConfig.cookie_secret));
		app.use(
			express.session({
				cookie: {maxAge: appConfig.session_expire * 1000},
				store: MemStore({reapInterval: appConfig.session_expire * 1000})
			})
		);
	}
});

app.configure('development', function(){
	app.use(express.errorHandler());
});


app.get('/', function(req, res) {
	res.render('index', {ANALYTICS: global.ANALYTICS});
});

app.get('/logout', function(req, res) {
	if (req.session) {
		req.session.auth = null;
		res.clearCookie('auth');
		req.session.destroy(function() {});
	}
	res.redirect('/');
});

app.get('/about', function(req, res) {
	res.render('about', {ANALYTICS: global.ANALYTICS});
});

app.get('/room/:room_id', function(req, res) {
	var room_id = req.params.room_id;
	
	if(room_id.length != 24 && room_id.length != 10) {
		res.redirect('/');
	}
	
	osomtalk.getRoom(room_id, function (room) {
		if ( room !== false ) {
			var ua = req.headers['user-agent'];
			
			var data = {
				user: false,
				room: room,
				ANALYTICS: global.ANALYTICS,
				is_mobile: utils.isMobile(ua)
			};
			//In case of logged in user, add it to the template
			if (req.session.user !== undefined) {
				osomtalk.verifyPermission(req.session.user._id,	req.session.user.token, null,
					function(has_permission) {
						if (has_permission ) {
							data.user = req.session.user;
							osomtalk.addUserToRoom(data.user._id, room_id);
						} else {
							req.session.destroy();	
						}
						res.render('room', data);
					});	
			} else {
				res.render('room', data);
			}
		} else {
			//Chat room doesn't exists
			res.redirect('/');
		}
	});
});

/** Get all the room data **/
app.get('/rooms/get/:room_id', function(req, res){
	var room_id = req.params.room_id;
	osomtalk.getRoom(room_id, function (room) {
		if ( typeof room !== "undefined" ) {
			res.send(room.getData());
		}
	});
});

/** Get all the room data **/
app.get('/rooms/get_messages/:room_id/:last_microtimestamp', function(req, res){
	var room_id = req.params.room_id;
	var last_microtimestamp = req.params.last_microtimestamp;
	
	osomtalk.getMessages(room_id, last_microtimestamp, function (messages) {
		if ( typeof messages !== "undefined" ) {
			res.send(messages);
		}
	});

});

/** Get all the room data **/
app.get('/rooms/get_messages/:room_id', function(req, res){
	var room_id = req.params.room_id;
	osomtalk.getMessages(room_id, null, function (messages) {
		if ( typeof messages !== "undefined" ) {
			res.send(messages);
		}
	});

});

/** Get all the users from room **/
app.get('/rooms/get_users/:room_id', function(req, res){
	var room_id = req.params.room_id;
	osomtalk.getUsersFromRoom(room_id, function(users){
		if ( typeof users !== "undefined" ) {
			res.send(users);
		}
	});
});


/** Ping to a room**/
app.get('/user/ping/:room_id', function(req, res){
	var room_id = req.params.room_id;
	if(req.session.user!==undefined) {
		osomtalk.pingUser(room_id, req.session.user._id);
		res.send({response: 'success'});
	}
});

/** Delete Message **/
app.post('/delete_message/:room_id/:message_id', function(req, res){
	var room_id = req.params.room_id;
	var message_id = req.params.message_id;
	var user_id = req.body.user_id;
	var token = req.body.token;
	
	osomtalk.verifyPermission(user_id, token, room_id, function (has_permission) {
		if(has_permission) {
			if (user_id === req.session.user._id) {	
				osomtalk.deleteMessage(room_id, message_id);
				res.send();
			} else {
				res.send({error: 'NO_PERMISSION'});	
			}
		} else {
			res.send({error: 'NO_PERMISSION'});
		}
	});
});

/** Reply Message **/
app.post('/reply_message/:room_id/:message_id', function(req, res){
	var room_id = req.params.room_id;
	var message_id = req.params.message_id;
	var user_id = req.body.user_id;
	var token = req.body.token;
	var text = req.body.text;
	
	osomtalk.verifyPermission(user_id, token, room_id, function (has_permission) {
		if(has_permission) {
			osomtalk.replyMessage(room_id, message_id, user_id, text);
			res.send();
		}else {
			res.send({error: 'NO_PERMISSION'});
		}
	}); 
});

/** creates a new room and then returns the generated id. **/
app.post('/rooms/create', function(req, res){
	if(req.body.name.length > 20) {
		res.send({error:'TOO_LONG'});	
		return false;
	}
	
	var room_id = osomtalk.addRoom({name:req.body.name});
	var welcomeMessage = 
	['#Welcome to OsomTalk',
	'OsomTalk isn\'t like any other chat out there, here you can.',
	'',
	'* Use MarkDown Syntax -> http://daringfireball.net/projects/markdown/syntax',
	'* Have youtube videos inserted by just pasting the link-> http://youtu.be/vbrII7frHV0',
	'* Even images (gifs included) are inserted without any fuzz -> http://i0.kym-cdn.com/photos/images/original/000/090/603/258witx.gif',
	'',
	'Have fun using with **OsomTalk!**',
	'',
	'PD: This Message was written directly in OsomTalk, isn\'t that OSOM.'
	].join('\n');
	
	osomtalk.addMessageToRoom(room_id, {
		text: welcomeMessage,
		type: 'OFFICIAL',
	});

	console.log('Room Created: ' + room_id + '(' + req.body.name + ')');
	res.send({id:room_id});
});

/** Start's the oAuth Dance (is much more natural in node by the way) **/
app.get('/auth/twitter', function(req, res){
	req.session.oauth = {};
	req.session.oauth.referer = req.header('Referer');
	if ( req.session.user===undefined ) {
		osomtalk.oa.getOAuthRequestToken(function(error, oauth_token, oauth_token_secret, results) {
			if (error) {
				console.log(error);
				res.send("yeah no. didn't work.")
			} else {
				req.session.oauth.token = oauth_token;
				req.session.oauth.token_secret = oauth_token_secret;
				res.redirect('https://twitter.com/oauth/authenticate?oauth_token='+oauth_token)
			}
		});
	} else {
		res.redirect(req.session.oauth.referer);    
	}
});

/** Coming back from twitter **/
app.get('/auth/twitter/callback', function(req, res, next){
	if (req.session.oauth) {
		req.session.oauth.verifier = req.query.oauth_verifier;
		var oauth = req.session.oauth;

		osomtalk.oa.getOAuthAccessToken(oauth.token,oauth.token_secret,oauth.verifier, 
			function(error, oauth_access_token, oauth_access_token_secret, results){
				if (error){
					console.log(error);
					res.send("yeah something broke.");
				} else {
					osomtalk.addUser({
						type: 'TWITTER',
						username: results.screen_name,
						twitter_id: results.user_id,
						access_token:  oauth_access_token,
						access_token_secret: oauth_access_token_secret
					}, function(user) {
						req.session.user = user;
						res.redirect(req.session.oauth.referer);
					});
					
				}
			});
	} else {
		next(new Error("you're not supposed to be here."));
	}
});

/** Checks for username and take it in case is valid. **/
app.get('/user/take/', function(req, res){
	var response = osomtalk.validateUserName(req.query.username);
	if (  response !== true) {
		res.send({error: response.error });
		return false;
	} else {
		osomtalk.addUser({username: req.query.username, type:'ANONYMOUS'}, function(user){
			if ( user == false) {
				res.send({error: 'NAME_TAKEN'});
				return false;
			}
			req.session.user = user;
			res.send(user);
		});
	}
});

var server = http.createServer(app);
var faye_server = new faye.NodeAdapter({mount: '/faye'});

var extension = {
	incoming : function(message, callback) {
		if(message.channel.substring(0,10) === '/messages_') {
			var message_text = message.data.text;
			var user_id   = message.data.user_id;
			var token 		 = message.data.token;
			var room_id      = message.channel.substring(10);
			
			var block='';
			/*if ( !osomtalk.roomExists(room_id) && !osomtalk.userExists(user_id) ) {
				block = 'NOT_EXIST';
			} else {
				if ( !osomtalk.verifyPermission(user_id, token, room_id) ) {
					block = "NO_PERMISSION";
				} else {*/
					result = osomtalk.validateMessage(message_text);
					if (result.error !==undefined) {
						block = result.error; //EMPTY & TOO_LONG
					} else {
						result = osomtalk.validateSpam(user_id, room_id)
						if (result.error !== undefined) {
							block = result.error; //TYPING & FLOODING
						}
					}
				/*}
			}*/
			if (!block) {
				var data = {
					text: message_text,
					user_id: user_id,
					type: 'USER'
				}
				osomtalk.addMessageToRoom(room_id, data);    
			} else {
				message.error = block;
			}
		}
		callback(message);
	}
};
faye_server.addExtension(extension);

server.listen(appConfig.port);
faye_server.attach(server);

console.log("Express server listening on port " + osomtalk.port);

client = new faye.Client(osomtalk.url + '/faye');