Authorization Zetta stream topics in multiplexed event stream.

server.js

var zetta = require('zetta');
var Photocell = require('zetta-photocell-mock-driver');

zetta()
  .name('kevin-mbp')
  .use(Photocell)
  .use(function(runtime) {
    var broker = runtime.httpServer.eventBroker;

    var saved = broker._publishStreamEnabledClient;
    broker._publishStreamEnabledClient = function() {
      var args = Array.prototype.slice.call(arguments);
      var client = args[0];
      var data = args[2];

      if (client && client.ws && client.ws._isServer
          && client.ws.upgradeReq.url === '/events') {
        var headers = client.ws.upgradeReq.headers;
        if (headers && headers.authorization && headers.authorization === 'test') {
          // check data.topic for topic authorization
          saved.apply(broker, args);
        } else {
          return;
        }
      } else {
        saved.apply(broker, args);
      }
    };
  })
  .listen(process.env.PORT || 3004);