server.js

var util = require('util')
var ws = require('nodejs-websocket')
var osc = require('node-osc')
var winston = require('winston')
var express = require('express')
var lib = require('./lib')
var _ = require('underscore')
var keypress = require('keypress')
var fs = require('fs')
var lazy = require('lazy')

var OSC_PORT = 4711
var OSC_HOST = 'localhost'
var WEBSOCKET_PORT = 8001
var HTTP_PORT = 80

var RECORD_FILE = 'session-small.rec'

var logger = new (winston.Logger)({
    transports: [
        new (winston.transports.Console)({ 
            level: 'info',
            timestamp: true, 
            colorize: true 
        }),
    ]
})

var parseNumbers = function(arr) {
    return _.map(arr, function(el) { return isNaN(el) ? el : +el })
}

// OSC Stuff

var movements = lib.expiringArray()

var client = new osc.Client(OSC_HOST, OSC_PORT)
logger.info('sending OSC data to ' + OSC_HOST + ' on port: ' + OSC_PORT)

var sendToMax = function(connectionId, payload) {
    payload = parseNumbers(payload)
    var movement = payload[1]
    movements.add(connectionId, movement)

    payload.unshift("/" + connectionId)
    client.send.apply(client, payload)
}

setInterval(function() {
    var mood = movements.sum()
    //logger.debug('sending global mood: ' + mood);
    numberOfClients = 0
    connections.forEach(function() { numberOfClients++ })

    client.send('/0', mood, numberOfClients)
}, 250)

var oscServer = new osc.Server(4712, '127.0.0.1')
oscServer.on("message", function(msg, rinfo) {
    if (msg[0] == '/addsim') {
        addSimulator()
    }
});

// express stuff

var app = express()
app.use(express.static('static'))
app.get('/', function(req, res) {
    ip = req.connection.remoteAddress
    ip = ip.replace(/^.*:/, '')
    logger.info('got index request from: ' + ip)
    var url = util.format('ws://%s:%s/', lib.findClosestIP(ip), WEBSOCKET_PORT)
    res.render('index.ejs', { websocket_url: url})
})
app.listen(HTTP_PORT)
logger.info ('web server started on port: ' + HTTP_PORT)

function takeFirstEmptySlot(array, itemToAdd) {
    var index = 1 // 0 is reserved for server messages
    while (index in array) {
        index++ 
    }
    array[index] = itemToAdd
    return index
}

// websocket stuff

var connections = []

var server = ws.createServer(function(conn) {

    var connectionId = takeFirstEmptySlot(connections, conn)

    logger.info("new connection, assigned id: " + connectionId)
    conn.on("text", function (str) {
        logger.debug("connection #" + connectionId + " received: " + str)
        payload = str.split("|")

        if (record) {
            var line = payload.join("|") + require('os').EOL
            fs.appendFile(RECORD_FILE, line, function(err) {
                if (err) throw err
            })
        }

        sendToMax(connectionId, payload)
    })
    conn.on("close", function(code, reason) {
        logger.info('connection #' + connectionId +' closed')
        client.send('/disconnected', connectionId)
        connections[connectionId] = null
    })
    conn.on("error", function(error) {
        logger.info('connection #' + connectionId + ' error: ' + error.code)
    })
}).listen(WEBSOCKET_PORT)

logger.info('websocket server started on port: ' + WEBSOCKET_PORT)

logger.info('open one of these on your phone:')
_.each(lib.getIPList(), function(ip) {
    if (ip == '127.0.0.1') return
    logger.info('http://' + ip + ':' + HTTP_PORT)
})


// simulator stuff

var record = false

var addSimulator = function() {
    var recording = fs.readFileSync(RECORD_FILE).toString().split("\n")
    var lineCounter = 0
    var simulatorId = takeFirstEmptySlot(connections, {}) 
    logger.info('adding simulator in slot #' + simulatorId)
    var color = Math.round(Math.random() * 255)
    var timer = setInterval(function() {
        var line = recording[lineCounter++]
        var payload = line.split('|')
        payload[0] = color
        sendToMax(simulatorId, payload)
        logger.debug('simulator #' + simulatorId + ' sending: ' + payload)

        if (lineCounter == recording.length - 1) lineCounter = 0
    }, 500)
    connections[simulatorId] = timer
}

var removeSimulator = function() {

    var lastSimulatorIndex = -1
    connections.forEach(function(item, index) {
        if (item && item._idleStart) lastSimulatorIndex = index
    })

    if (lastSimulatorIndex < 0) {
        logger.info('no running simulators')
        return
    }
    logger.info('removing simulator at slot #' + lastSimulatorIndex)
    clearInterval(connections[lastSimulatorIndex])
    connections[lastSimulatorIndex] = null
}

keypress(process.stdin);
process.stdin.on('keypress', function (ch, key) {
    if (key && key.ctrl && key.name == 'c') {
        logger.info('exiting...')
        process.exit()
    }
    else if (key && key.name == 'space') {
        addSimulator()
    }
    else if (key && key.name == 'backspace') {
        removeSimulator()
    }
    else if (key && key.ctrl && key.name == 'r') {
        if (record) {
            record = false
            logger.info('recording stopped.')
            return
        }

        logger.info('recording...')
        fs.unlink(RECORD_FILE, function(err) {
            if (err && err.code != 'ENOENT') throw err 
        })
        record = true
    }
});

process.stdin.setRawMode(true);
process.stdin.resume();

logger.info('press space to add a simulator, backspace to remove one')
_