forum.js

var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var dm = require('./dm_remote.js');
var zmq= require('zmq');
var sub = zmq.socket('sub');

//Argumentos
var HOST = process.argv[2];
var PORT = process.argv[3];
var PORTSUB = process.argv[4]; 
var PORTHTTP = process.argv[5];



var viewsdir = __dirname + '/views';
// called on connection
function get_page (req, res) {
	console.log ("Serving request " + req.params.page);
	res.sendFile(viewsdir + '/' + req.params.page);
}

// Called on server startup
function on_startup () {
	console.log("Starting: server current directory:" + __dirname)
}

//Conexiones
sub.connect('tcp://'+HOST+':'+PORTSUB);
sub.subscribe('webserver');
sub.on('message', function(data){
	var str = data.toString();
	var invo = JSON.parse (str.split('webserver')[1]);

    console.log('Request is:' + invo.what + ':' + str);
	switch (invo.what) {
		case 'add private message':
		case 'add public message':
			console.log(JSON.stringify(invo.msg));
            io.emit('message', JSON.stringify(invo.msg));
        break;
        case 'add user':
            io.emit ('new user', 'add', invo.u);    
        break;
        case 'add subject':
            io.emit ('new subject', 'add', invo.s);
        break;
	}
});


dm.Start(HOST, PORT, function () {
	app.set('views', viewsdir)
	// serve static css as is
	app.use('/css', express.static(__dirname + '/css'));

	// serve static html files
	app.get('/', function(req, res){
		req.params.page = 'index.html'
		get_page (req, res);
	});

	app.get('/:page', function(req, res){
		get_page (req, res);
	});



	io.on('connection', function(sock) {
		console.log("Event: client connected");
		sock.on('disconnect', function(){
			console.log('Event: client disconnected');
		});
	
		// on messages that come from client, store them, and send them to every 
		// connected client
		// TODO: We better optimize message delivery using rooms.
		sock.on('message', function(msgStr){
			console.log("Event: message: " + msgStr);
			var msg = JSON.parse (msgStr);
			msg.ts = new Date(); // timestamp
			if (msg.isPrivate) {
				dm.addPrivateMessage (msg, function () {
					//io.emit('message', JSON.stringify(msg));
				});
			} else {
				dm.addPublicMessage (msg, function () {
					//io.emit('message', JSON.stringify(msg));
				});
			}
		});
	
		// New subject added to storage, and broadcasted
		sock.on('new subject', function (sbj) {
			dm.addSubject(sbj, function (id) {
				console.log("Event: new subject: " + sbj + '-->' + id);
				if (id == -1) {
					sock.emit ('new subject', 'err', 'El tema ya existe', sbj);
				} else {
					sock.emit ('new subject', 'ack', id, sbj);
					//io.emit ('new subject', 'add', id, sbj);
				}      
			});
		});
	
		// New subject added to storage, and broadcasted
		sock.on('new user', function (usr, pas) {
			console.log ( 'Creando usuario:' + usr + ' con pass:' + pas);
			dm.addUser(usr, pas, function (exists) {
				console.log('exists:' + exists);
				if (exists) {
					sock.emit ('new user', 'err', usr, 'El usuario ya existe');
				} else {
					sock.emit ('new user', 'ack', usr);
					//io.emit ('new user', 'add', usr);      
				}
			});
		});
	
		  // Client ask for current user list
		  sock.on ('get user list', function () {
			  dm.getUserList (function (list) {
				  console.log("Event: get user list");  		
				  sock.emit ('user list', list);
			  });
		  });
	
		   // Client ask for current subject list
		   sock.on ('get subject list', function () {
			   dm.getSubjectList (function (list) {
				   console.log("Event: get subject list");  		
				   sock.emit ('subject list', list);
			   });
		   });
	
		   // Client ask for message list
		   sock.on ('get message list', function (from, to, isPriv) {
			  console.log("Event: get message list: " + from + ':' + to + '(' + isPriv + ')');  		
			  if (isPriv) {
				  dm.getPrivateMessageList (from, to, function (list) {
					  sock.emit ('message list', from, to, isPriv, list);
				  });
			  } else {
				  dm.getPublicMessageList (to, function (list) {
					  sock.emit ('message list', from, to, isPriv, list);
				  });
			  }
		  });
	
		  // Client authenticates
		  // TODO: session management and possible single sign on
		  sock.on ('login', function (u,p) {
			  console.log("Event: user logs in");  		
			  dm.login (u, p, function (ok) {
				  if (!ok) {
					  console.log ("Wrong user credentials: " + u + '(' + p + ')');
					  sock.emit ('login', 'err', 'Credenciales incorrectas');
				  } else {
					  console.log ("User logs in: " + u + '(' + p + ')');
					  sock.emit ('login', 'ack', u);	  			
				  }
			  });
		  });
		});
		if(PORTHTTP!=null)
		http.listen (PORTHTTP, on_startup);
		else
		http.listen (10000, on_startup);
	
	});