ctx.bus

Author: jasoncalabrese

lib/bootevent.js

@@ -30,23 +30,23 @@ function boot (env) {
       store.ensureIndexes(ctx.devicestatus( ), ctx.devicestatus.indexedFields);
       store.ensureIndexes(ctx.profile( ), ctx.profile.indexedFields);
 
-      ctx.heartbeat = require('./ticker')(env, ctx);
+      ctx.bus = require('./bus')(env, ctx);
 
       ctx.data = require('./data')(env, ctx);
       ctx.notifications = require('./notifications')(env, ctx);
 
-      ctx.heartbeat.on('tick', function(tick) {
+      ctx.bus.on('tick', function(tick) {
         console.info('tick', tick.now);
         ctx.data.update(function dataUpdated () {
-          ctx.heartbeat.emit('data-loaded');
+          ctx.bus.emit('data-loaded');
         });
       });
 
-      ctx.heartbeat.on('data-loaded', function() {
+      ctx.bus.on('data-loaded', function() {
         ctx.notifications.processData(env, ctx);
       });
 
-      ctx.heartbeat.uptime( );
+      ctx.bus.uptime( );
 
       next( );
     })

lib/ticker.js lib/bus.js

@@ -1,12 +1,13 @@
-
-var es = require('event-stream');
 var Stream = require('stream');
 
-function heartbeat (env, ctx) {
+function init (env, ctx) {
   var beats = 0;
   var started = new Date( );
   var id;
   var interval = env.HEARTBEAT || 20000;
+
+  var stream = new Stream;
+
   function ictus ( ) {
     var tick = {
       now: new Date( )
@@ -18,18 +19,20 @@ function heartbeat (env, ctx) {
     };
     return tick;
   }
+
   function repeat ( ) {
     stream.emit('tick', ictus( ));
   }
+
   function ender ( ) {
     if (id) cancelInterval(id);
     stream.emit('end');
   }
-  var stream = new Stream;
+
   stream.readable = true;
   stream.uptime = repeat;
   id = setInterval(repeat, interval);
   return stream;
 }
-module.exports = heartbeat;
+module.exports = init;
 

lib/notifications.js

@@ -38,15 +38,15 @@ function init (env, ctx) {
       }
     }
     if (sendClear) {
-      ctx.heartbeat.emit('notification', {clear: true});
+      ctx.bus.emit('notification', {clear: true});
       console.info('emitted notification clear');
     }
   }
 
   function emitAlarm (type) {
     var alarm = alarms[type];
     if (ctx.data.lastUpdated > alarm.lastAckTime + alarm.silenceTime) {
-      ctx.heartbeat.emit('notification', {type: type});
+      ctx.bus.emit('notification', {type: type});
       alarm.lastEmitTime = ctx.data.lastUpdated;
       console.info('emitted notification:' + type);
     } else {

server.js

@@ -60,11 +60,11 @@ bootevent(env).boot(function booted (ctx) {
     ///////////////////////////////////////////////////
     var websocket = require('./lib/websocket')(env, ctx, server);
 
-    ctx.heartbeat.on('data-loaded', function() {
+    ctx.bus.on('data-loaded', function() {
       websocket.processData();
     });
 
-    ctx.heartbeat.on('notification', function(info) {
+    ctx.bus.on('notification', function(info) {
       websocket.emitNotification(info);
     });