index.js

/**
 * Created by Dieter Beelaert on 16/07/2014.
 */
var express = require('express');
var server = new express();
var SerialPort = require('serialport').SerialPort;
var Context = require('./models/Context.js');
var bodyParser = require('body-parser');
var io = require('socket.io');
var http = require('http');
var DMXHandler = require('./modules/DMXHandler.js');
server.use(bodyParser.urlencoded());
server.use(bodyParser.json())
//serve static files
server.use("/public", express.static(__dirname + '/public'));

//DMX variables
var master = 255;
var cues = ['','','','','','','','','','']; //cues is a list of values strings

var serialPort = new SerialPort('/dev/ttyACM0',{ baudrate: 9600,dataBits: 8,parity: 'none',stopBits: 1,flowControl: false});
serialPort.on("open", function () {
    console.log('serial port is open');
    //only startup the node server when the serialport is opened ...
    initServer();
});


function initServer(){
    var httpServer = http.createServer(server);
    var socket = io.listen(httpServer);
    httpServer.listen(8080);
    server.get("/",function(req,res){
        res.render('../views/index.ejs');
    });

    /*DMX keypad*/
    server.get("/console",function(req,res){
        res.render('../views/console.ejs');
    });

    /*support for old webclient*/
    server.post('/console/cmd',function(req,res){
        var ctx = new Context(req);
        var channel = ctx.getParam('channel');
        var value = ctx.getParam('value');
        //channel, value
        console.log(ctx);
        serialPort.write(channel +'c'+value+'w');
        res.end();
    });

    /*better way*/
    server.post('/cmd',function(req,res){
       var ctx = new Context(req);
       var command = ctx.getParam('cmd');
       var handler = new DMXHandler();
       handler.sendValue(command,master,serialPort);
       res.end();
    });


    /*DMX Raw desk*/
    server.get("/raw",function(req,res){
       res.render('../views/raw_desk.ejs');
    });

    /*Socket listeners*/
    socket.on('connection',function(socket){
       console.log('socket connection');

        socket.on('record',function(data){
           //data.cue, data.data
		console.log('on record: ' + data);
           if(data.cue != -1){
               cues[data.cue] = data.data;
		console.log(cues);
           }
        });

        socket.on('fade',function(data){
            console.log(data);
          if(parseInt(data.cue) === -1){
              master = parseInt(data.value);
              updateValues(serialPort);
          }else{
              //todo: use updateCue so that the master fader has an effect ...
	       new DMXHandler().sendValue(cues[data.cue],data.value,serialPort);
              //updateCue(data.cue,data.value,function(){
                // new DMXHandler().sendValue(cues[data.cue],master,serialPort);
             // });
          }
        });

        socket.on('set',function(data){
            console.log('set received ...');
            new DMXHandler().sendValue(data.data,master,serialPort);
        });
    });
}

function updateValues(serialPort){
    var handler = new DMXHandler();
    for(var i = 0; i < cues.length; i++){
       handler.sendValue(cues[i],master,serialPort);
    }
}

function updateCue(index,value,callback){
    var cue = cues[index];
    if(typeof cue !== undefined) {
        var splitted = cue.split(',');
        var toUpdate = '';
        for (var i = 0; i < splitted.length; i++) {
            var curCue = splitted[i].split('@');
            toUpdate = curCue[0] + '@' + Math.round((parseInt(curCue[1]) * (value / 255)));
        }
        cues[i] = toUpdate;
	console.log(toUpdate);
	console.log(cues[i]);
        callback();
    }
}