Push server with Redis Subscriber

gistfile1.coffee

require.paths.unshift(process.cwd() + '/lib')
require.paths.unshift(process.cwd() + '/contrib')
redis = require 'redis'
settings = require('settings').stream

# DEFAULT SETTINGS
# -------------------------------------------------
settings.port = process.argv[2] if process.argv[2]?
io = require('socket.io').listen Number(settings.port)

subscriber = redis.createClient()
subscriber.subscribe 'stream'

io.sockets.on 'connection', (client) ->
  subscriber.on 'message', ( channel, raw_data ) ->
    msg = JSON.parse raw_data
    client.emit msg.channel, msg.data