Node.js + Redis pubsub + Websockets for kandypot.com.

kandypot-node.js

// Really trivial. On new writes to the redis db, we push messages to a websocket channel

var sys = require("sys"), redis = require('./lib/redis-client'), ws = require("./lib/ws");
var pubsub = redis.createClient();
var clients = new Array();

ws.createServer(function (websocket) {
    websocket.addListener("connect", function (resource) { 
      sys.debug("connect: " + resource);
      client_id = resource.match(/apps\/([A-Za-z]+)\/timeline$/)[1];
			sys.debug("connecting to app: "+client_id);
			clients[client_id] = websocket;
    }).addListener("data", function (data) { 
      sys.debug(data);
    }).addListener("close", function () { 
      sys.debug("close");
    });
  }).listen(8080);


pubsub.stream.addListener('connect', function(){
	sys.debug('Connecting ..');
	pubsub.subscribeTo('apps:*:timeline', function(channel,data){
		sys.debug(data);
		var cid = channel.toString().split(':')[1];
		sys.debug("Cid: "+cid);
		if (clients[cid]) {
			clients[cid].write(data);
		}
		else {
			sys.debug("Client "+clients[cid]+" is not connected");
		}
	});
});