server.js

/**
* Pluto - Websocket Remote for Node.js
* Eugen Pirogoff
* web: http://www.eugenpirogoff.de
* mail: eugenpirogoff@me.com
**/

// Loading express
express = require('express.io');
app = express().http().io();


app.configure(function() {
	app.use(express["static"](__dirname + '/public'));
    app.set('rootDir', __dirname);
});

app.enable('browser client minification');  // send minified client
app.enable('browser client gzip');          // gzip the file
app.enable('browser client etag');          // apply etag caching logic based on version number
app.disable('hearbeats');

//WebSocket Sessions JSON
//Connect Controller only to a running Pluto Game Session and Route
var sessions = {}

// routes with parameters passing
app.get('/game/:pluto_pin', function(req, res){
	sessions[req.params.pluto_pin] = false;
	res.sendfile(__dirname + '/public/game/index.html')
});

// router for pluto controller and the assigned pin
app.get('/controller/:pluto_pin', function(req, res){
	if (sessions[req.params.pluto_pin] == false){
		res.sendfile(__dirname + '/public/controller/index.html')
		sessions[req.params.pluto_pin] = true;
	}
	else {
		//res.sendfile(__dirname + '/public/error.html');
		res.send("there is no game awaiting connection to that controller : " + req.params.pluto_pin + "<br>" + "please load a game first and then the controller");
	}
});

// listenening for pluto_data event on socket.io and routing the data to the session
app.io.route('pluto_data', function(req){
	if (sessions[req.data['controller_session']] == true){
		req.io.room(req.data['controller_session']).broadcast('pluto_relay', req.data);
	}
})

// pluto connection joins socket.io
app.io.route('pluto_join', function(req){
	req.io.join(req.data);
	console.log( new Date() + " - Session : " + req.data);
	console.log( req.handshake.address);
})

// pluto is leaving socket.io
app.io.route('pluto_leave', function(req){
	req.io.leave(req.data);
})

// log current websocket sessions on server
// setInterval(function(){
// 	console.log("Pluto: concurrent WebSocket connections : " + Object.keys(sessions).length);
// },5000);

app.listen(process.env.VCAP_APP_PORT || 3000);