Added ZeroMQ and updating web page

To make it run one have to: 1. Start sensor (simple broker) $ cd cpp-app # compile app $ gcc -lstdc++ -lczmq -lzmq -o test test.cpp # Run app $ ./test 2. Start server npm start 3. Visit web page at http://localhost:3000

Added ZeroMQ and updating web page
b3ce23ae · Martin Vala · 6da0d997 · b3ce23ae · b3ce23ae · b3ce23ae
Commit b3ce23ae authored 9 years ago by Martin Vala
--- a/package.json
+++ b/package.json
@@ -8,6 +8,7 @@
  },
  "dependencies": {
    "bower": "*",
-    "express.io": "*"
+    "express.io": "*",
+    "zmq": "*"
  }
 }
--- a/public/index.html
+++ b/public/index.html
@@ -13,9 +13,9 @@

 <body ng-controller="MyController">
 <h1>Hello {{name}} and we have {{nUsers}} users connected</h1>
-<button type="button" class="btn btn-lg btn-danger">Style Success</button>
+<button type="button" class="btn btn-lg btn-danger">Num : {{zmqmsg.num}}</button>
 <div class="progress">
-  <div class="progress-bar" role="progressbar" aria-valuenow="60" aria-valuemin="0" aria-valuemax="100" style="width: 60%;"><span class="sr-only">60% Complete</span></div>
+  <div class="progress-bar" role="progressbar" aria-valuenow="{{zmqmsg.num}}" aria-valuemin="0" aria-valuemax="100" style="width: {{zmqmsg.num}}%;"><span class="sr-only">{{zmqmsg.num}}% Complete</span></div>
 </div>
 <input ng-model="name"></input>
 </body>

--- a/public/main.js
+++ b/public/main.js
@@ -7,10 +7,15 @@ app.controller("MyController", ["$scope", function($scope) {
    $scope.socket=socket;
    $scope.nUsers = 0;
    $scope.name = "Jozko";
+    $scope.zmqmsg;

    //Listen to users_changed event
    $scope.socket.on('users_changed', function(data) {
        $scope.nUsers = data.nUsers;
        $scope.$digest();
    })
+    $scope.socket.on('my_zmq_signal', function(data) {
+      $scope.zmqmsg  = JSON.parse(data);
+      $scope.$digest();
+    })
 }]);
--- a/server.js
+++ b/server.js
@@ -3,6 +3,13 @@ var express = require('express.io'),
    app = express(),
    path = require('path')

+var zmq = require('zmq'),
+    sock = zmq.socket('sub');
+var data_sub;
+sock.connect('tcp://localhost:5000');
+sock.subscribe("");
+console.log('Subscriber connected to port 5000');
+
 app.http().io();
 app.set('port', process.env.PORT || 3000);
 app.use(express.static(path.join(__dirname, 'public')));
@@ -33,6 +40,11 @@ app.io.on('connection', function(socket) {
 	})
        console.log('User ' + socket.id + ' disconnected');
    });
+
+    sock.on('message', function(topic, message) {
+        console.log("topic=" + topic + " msg=" + message.toString());
+        socket.emit("my_zmq_signal", message.toString());
+    });
 });

 app.listen(app.get('port'), function() {