Fix issue #8

Aietes · Oct 21, 2017 · 643c249 · 643c249
1 parent 65e3162
commit 643c249
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/harmony/harmony-server.js b/harmony/harmony-server.js
@@ -1,12 +1,14 @@
 var HarmonyHubDiscover = require('harmonyhubjs-discover')
 var harmonyClient = require('harmonyhubjs-client')
+var events = require('events')
 
 module.exports = function (RED) {
   function HarmonyServerNode (n) {
     RED.nodes.createNode(this, n)
     var node = this
 
     node.ip = n.ip
+    node.harmonyEventEmitter = new events.EventEmitter()
     createClient(node)
 
     this.on('close', function () {
@@ -29,6 +31,9 @@ module.exports = function (RED) {
     }
     harmonyClient(ip).then(function (harmony) {
       node.harmony = harmony
+      harmony.on('stateDigest', function(digest) {
+        node.harmonyEventEmitter.emit('stateDigest', digest)
+      })
       !(function keepAlive () {
         harmony.request('getCurrentActivity').timeout(50000).then(function (response) {
           setTimeout(keepAlive, 50000)

diff --git a/harmony/harmony.js b/harmony/harmony.js
@@ -89,8 +89,8 @@ module.exports = function (RED) {
 
     setTimeout(function () {
       try {
-        node.server.harmony.on('stateDigest', function (digest) {
-          // console.log(JSON.stringify(digest));
+        node.server.harmonyEventEmitter.on('stateDigest', function (digest) {
+		  // console.log(JSON.stringify(digest));
           try {
             node.send({
               payload: {