Merge branch 'http-emitter' of https://github.com/trotter/cube into 0.2.2

Author: mbostock

lib/cube/emitter-http.js

@@ -0,0 +1,53 @@
+var util = require("util"),
+    http = require("http");
+
+module.exports = function(protocol, host, port) {
+  var emitter = {},
+      queue = [],
+      closing;
+
+  if (protocol != "http:") throw new Error("invalid HTTP protocol");
+
+  function send() {
+    var events = queue.splice(0, 500);
+    if (events.length === 0) return;
+
+    var body = JSON.stringify(events);
+
+    var postOptions = {
+      host: host,
+      port: port,
+      path: "/1.0/event/put",
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+        'Content-Length': body.length
+      }
+    };
+
+    var postRequest = http.request(postOptions, function(res) {
+      if (res.statusCode !== 200) queue.unshift.apply(queue, events);
+      if (queue.length) setTimeout(send, 500);
+    });
+
+    postRequest.on('error', function (e) {
+      console.warn(e.message);
+      queue.unshift.apply(queue, events);
+    });
+
+    postRequest.write(body);
+    postRequest.end();
+  }
+
+  emitter.send = function(event) {
+    if (!closing && queue.push(event) == 1) process.nextTick(send);
+    return emitter;
+  };
+
+  emitter.close = function () {
+    if (queue.length) closing = 1;
+    return emitter;
+  };
+
+  return emitter;
+};

lib/cube/emitter.js

@@ -1,5 +1,6 @@
 var util = require("util"),
     url = require("url"),
+    http = require("./emitter-http"),
     udp = require("./emitter-udp"),
     ws = require("./emitter-ws");
 
@@ -9,6 +10,7 @@ module.exports = function(u) {
   switch (u.protocol) {
     case "udp:": emitter = udp; break;
     case "ws:": case "wss:": emitter = ws; break;
+    case "http:": emitter = http; break;
   }
   return emitter(u.protocol, u.hostname, u.port);
 };