Add http emitter

lib/cube/emitter-http.js

@@ -0,0 +1,51 @@
+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 event = queue.pop();
+    if (!event) return;
+
+    var body = JSON.stringify(event);
+
+    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() {});
+
+    postRequest.on('error', function (e) {
+      console.warn(e.message);
+    });
+
+    postRequest.write(body);
+    postRequest.end();
+
+    if (queue.length) process.nextTick(send);
+  }
+
+  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);
 };