//
// Gauges server
//
 
var gossip = require('gossip');
 
// Nodes are the building block of gossip. You should run one node per process.
// They can send and receive messages to / from a cluster of nodes.
var node = new gossip.Node('ipc://temp-gauges');
 
// You can subscribe to messages you are interested in.
// Any node can check your temperature by sending you a `check-temp` message. Yay!
node.on('check-temp', function (message, reply) {
  var gauge = gauges[message.data.gauge];
 
  // read the temperature
  var temp = gauge.readTemp();
 
  // send a response back
  var response = {
    temp: temp,
    time: Date.now()
  };
 
  node.reply(message, response);
});
 
 
//
// Monitor server
//
 
var gossip = require('gossip');
 
var node = new gossip.Node('ipc://temp-monitor');
 
// Join the monitor to the gauges. This will allows the node to send messages to any nodes that are known
// by the node you are connecting to.
node.join('ipc://temp-gauges');
 
setInterval(function () {
  // check temperature
  node.send('check-temp', { gauge: 'main' }, function (err, response) {
    if (response.data.temp > 600) {
      // sound the alarm
    }
  }, 100);
});