v5.2.0 add firehose

package.json

@@ -1,6 +1,6 @@
 {
   "name": "meshblu-server",
-  "version": "5.1.7",
+  "version": "5.2.0",
   "description": "A bundled version of meshblu-core",
   "main": "dist/meshblu-core-runner.js",
   "repository": {
@@ -24,6 +24,7 @@
     "dashdash": "^1.14.0",
     "debug": "^2.6.8",
     "meshblu-core-dispatcher": "^20.0.7",
+    "meshblu-core-firehose-socket.io": "^2.0.0",
     "meshblu-core-protocol-adapter-http": "^6.0.3",
     "meshblu-core-worker-webhook": "^4.1.4",
     "sigterm-handler": "^2.0.0",

src/meshblu-core-runner.coffee

@@ -2,13 +2,16 @@ async            = require('async')
 {EventEmitter}   = require 'events'
 DispatcherWorker = require('meshblu-core-dispatcher')
 MeshbluHttp      = require('meshblu-core-protocol-adapter-http')
+MeshbluFirehose  = require('meshblu-core-firehose-socket.io')
 WebhookWorker    = require('meshblu-core-worker-webhook')
 debug            = require('debug')('meshblu:meshblu-core-runner')
 
 class MeshbluCoreRunner extends EventEmitter
   constructor: (options) ->
     @dispatcherWorker = new DispatcherWorker options.dispatcherWorker
     @meshbluHttp      = new MeshbluHttp options.meshbluHttp
+    unless options.meshbluFirehose.disable
+      @meshbluFirehose  = new MeshbluFirehose options.meshbluFirehose
     unless options.webhookWorker.disable
       @webhookWorker    = new WebhookWorker options.webhookWorker
 
@@ -20,6 +23,7 @@ class MeshbluCoreRunner extends EventEmitter
     debug '->destroy'
     tasks = []
     tasks.push @meshbluHttp.destroy
+    tasks.push @meshbluFirehose.stop if @meshbluFirehose?
     tasks.push @dispatcherWorker.stop
     tasks.push @webhookWorker.stop if @webhookWorker?
     async.parallel tasks, callback
@@ -36,6 +40,7 @@ class MeshbluCoreRunner extends EventEmitter
     debug '->stop'
     tasks = []
     tasks.push @meshbluHttp.stop
+    tasks.push @meshbluFirehose.stop if @meshbluFirehose?
     tasks.push @dispatcherWorker.stop
     tasks.push @webhookWorker.stop if @webhookWorker?
     async.parallel tasks, callback
@@ -48,6 +53,9 @@ class MeshbluCoreRunner extends EventEmitter
     @webhookWorker?.start (error) =>
       @emit 'error', error if error?
 
+    @meshbluFirehose?.run (error) =>
+      @emit 'error', error if error?
+
     @meshbluHttp.run callback
 
 module.exports = MeshbluCoreRunner