diff --git a/lib/node.js b/lib/node.js index 0a5ac60..d6cdc5e 100644 --- a/lib/node.js +++ b/lib/node.js @@ -277,6 +277,8 @@ Node.prototype.emit = function(message, payload) { try { socket.emit(message, payload); + console.success('wsc', 'Socket emited message:', chalk.reset.cyan(message)); + console.success('wsc', payload); } catch (err) { console.error('wsc', 'Socket emit error:', err); @@ -502,7 +504,7 @@ Node.prototype.getHistory = function (range) } } - socket.emit('history', { + self.emit('history', { id: self.id, history: results.reverse() }); @@ -540,14 +542,16 @@ Node.prototype.prepareStats = function () Node.prototype.sendUpdate = function (force) { - if( this.changed() || force ) + if( this.changed() || force ) { + console.info("wsc", "Sending", chalk.reset.blue((force ? "forced" : "changed")), chalk.bold.white("update")); this.emit('update', this.prepareStats()); + } } Node.prototype.ping = function() { this._latency = _.now(); - this.emit('node-ping', { id: this.id }); + socket.emit('node-ping', { id: this.id }); }; Node.prototype.setWatches = function()