Add bus to subcribe to events.

lib/bus.js

@@ -0,0 +1,43 @@
+'use strict';
+
+var events = require('events');
+var util = require('util');
+
+function Bus(params) {
+  events.EventEmitter.call(this);
+  this.db = params.db;
+}
+
+util.inherits(Bus, events.EventEmitter);
+
+Bus.prototype.subscribe = function(name) {
+  for (var i = 0; i < this.db.modules; i++) {
+    var module = this.db.modules[i];
+    var events = module.getEvents();
+    for (var j = 0; i < events.length; j++) {
+      var eventName = events[0];
+      var subscribeHandler = events[2];
+      var params = arguments.slice(1);
+      if (name === eventName) {
+        subscribeHandler.apply(events[1], params);
+      }
+    }
+  }
+};
+
+Bus.prototype.unsubscribe = function(name) {
+  for (var i = 0; i < this.db.modules; i++) {
+    var module = this.db.modules[i];
+    var events = module.getEvents();
+    for (var j = 0; i < events.length; j++) {
+      var eventName = events[0];
+      var unsubscribeHandler = events[3];
+      var params = arguments.slice(1);
+      if (name === eventName) {
+        unsubscribeHandler.apply(events[1], params);
+      }
+    }
+  }
+};
+
+module.exports = Bus;

lib/node.js

@@ -16,6 +16,7 @@ var _ = bitcore.deps._;
 var $ = bitcore.util.preconditions;
 var genesis = require('./genesis.json');
 var daemon = require('./daemon');
+var Bus = require('./bus');
 
 function Node(config) {
   BaseNode.call(this, config);
@@ -24,6 +25,10 @@ function Node(config) {
 
 util.inherits(Node, BaseNode);
 
+Node.prototype.openBus = function() {
+  return new Bus({db: this.db});
+};
+
 Node.prototype._loadConfiguration = function(config) {
   var self = this;
   this._loadBitcoinConf(config);

package.json

@@ -38,14 +38,14 @@
     "bitcoind"
   ],
   "dependencies": {
+    "async": "1.3.0",
     "bindings": "^1.2.1",
-    "mkdirp": "0.5.0",
-    "nan": "1.3.0",
-    "tiny": "0.0.10",
     "chainlib": "^0.1.1",
     "errno": "^0.1.2",
-    "async": "1.3.0",
-    "memdown": "^1.0.0"
+    "memdown": "^1.0.0",
+    "mkdirp": "0.5.0",
+    "nan": "1.3.0",
+    "tiny": "0.0.10"
   },
   "devDependencies": {
     "benchmark": "1.0.0",