Added the $SYS/<brokerId>/version stat data.

moscajs · Feb 18, 2014 · 9be1a9c · 9be1a9c
1 parent 6460c5a
commit 9be1a9c
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 6 deletions.
diff --git a/lib/stats.js b/lib/stats.js
@@ -26,6 +26,7 @@ OTHER DEALINGS IN THE SOFTWARE.
 "use strict";
 
 var moment = require("moment");
+var version = "mosca " + require("../package").version;
 
 /**
  * Create a new load object.
@@ -145,6 +146,7 @@ Stats.prototype.wire = function wire(server) {
       count = 0;
     }
 
+    doPublish("version", version);
     doPublish("uptime", mom.from(Date.now(), true));
     doPublish("connectedClients", stats.connectedClients);
     doPublish("publishedMessages", stats.publishedMessages);

diff --git a/test/stats_spec.js b/test/stats_spec.js
@@ -200,6 +200,18 @@ describe("mosca.Stats", function() {
     });
   });
 
+  it("should publish the version", function(done) {
+    var version = require("../package").version;
+    server.on("testPublished", function(packet) {
+      if (packet.topic === "$SYS/42/version") {
+        expect(packet.payload).to.eql("mosca " + version);
+        done();
+      }
+    });
+
+    clock.tick(60 * 1000);
+  });
+
   it("should publish the uptime", function(done) {
     server.on("testPublished", function(packet) {
       if (packet.topic === "$SYS/42/uptime") {
@@ -213,13 +225,10 @@ describe("mosca.Stats", function() {
 
   it("should publish the uptime (bis)", function(done) {
     var count = 0;
-    server.on("testPublished", function(packet) {
-      count++;
-      if (count < 3) {
-        clock.tick(60 * 1000);
-        return;
-      }
 
+    clock.tick(60 * 1000 * 2);
+
+    server.on("testPublished", function(packet) {
       if (packet.topic === "$SYS/42/uptime") {
         expect(packet.payload).to.eql("3 minutes");
         done();