app.js

var socketServer = require('http').createServer(function(req,res){}),
	io = require('socket.io').listen(socketServer),
	os = require('os'),
    say = require('say'),
    play = require('play'),
	config = require('./appconfig'),
    Controller = require("./controller"),
    Webserver = require('./webServer'),
    Gpio = require('onoff').Gpio;


var rightEncoder = 20;
var leftEncoder = 26;

console.log('UI http Server Init');
var ws = new Webserver(config);
console.log('Controller Init');
var controller = new Controller(config);
console.log('Socket Server Init');
socketServer.listen(config.socketServerPort);

if (process.argv[2] != 'mock')
    say.speak('ras bought online, eye pee address is: '+ os.networkInterfaces().wlan0[0].address);


var cmdQueue = [];
var encoders;

(function setupGPIO(){
    encoders = require('events').EventEmitter;
    //var button = new Gpio(rightEncoder, 'in', 'both');
    new Gpio(rightEncoder, 'in', 'both').watch(function (err, value) {
        encoders.emit("rightChange", value);
    });
    new Gpio(leftEncoder, 'in', 'both').watch(function (err, value) {
        encoders.emit("leftChange", value);
    });
});//();





(function processQueue(){
    if (cmdQueue.length > 4){
        controller['stop']();
        cmdQueue = [];
        console.log('declared queue bankruptcy');
    }else{
        var thing = cmdQueue.shift();
        if (thing) controller[thing]();
    }
    setTimeout(processQueue, 200);
})();

io.sockets.on('connection', function (socket) {

	say.speak('player connected');

    socket.on('testEvent', function (data) {
        var count = 0;
        cmdQueue.push('right');
        encoders.on('rightChange', function(data){
            count ++;

            if (count > 4){
                cmdQueue.push('stop');
                encoders.removeAllListeners('rightChange')
            }
        });
    });

	socket.on('downEvent', function (data) {
		console.log(data);
        	cmdQueue.push(data.obj);
	});
	socket.on('upEvent', function (data) {
		console.log(data);
        	cmdQueue.push('stop');
	});

	socket.on('sayEvent', function (data) {
		console.log(data);
		say.speak(data.message,null,95);
	});
	
	socket.on('shutdownEvent', function(data) {
		setTimeout(()=>{
			console.log(data);
			say.speak('Commencing shut down.   Bite my Matte Black Metal Ass.');
			const exec = require('child_process').exec;
			exec('sudo shutdown -h now');
		},3000);
	});
    socket.on('sound', function(data){
        console.log(data);

        var childProcess = require('child_process'),
     	    proc;

        proc = childProcess.exec('mpg321 '+__dirname + '/sounds/' + data.file, function (error, stdout, stderr) {
            if (error) {
                console.log(error.stack);
                console.log('Error code: '+error.code);
                console.log('Signal received: '+error.signal);
            }
            console.log('Child Process STDOUT: '+stdout);
            console.log('Child Process STDERR: '+stderr);
        });
    });

	socket.on('disconnect', function(){
		say.speak('player disconnected');
	});

});