From 12685615676e31385b7c7d8b88ac7ffc1b53f803 Mon Sep 17 00:00:00 2001 From: cubedro Date: Wed, 27 May 2015 10:15:22 +0300 Subject: [PATCH] refactoring --- lib/node.js | 42 +++++++++++++----------------------------- 1 file changed, 13 insertions(+), 29 deletions(-) diff --git a/lib/node.js b/lib/node.js index d6cdc5e..6133112 100644 --- a/lib/node.js +++ b/lib/node.js @@ -199,8 +199,8 @@ Node.prototype.setupSockets = function() self._socket = true; console.success('wsc', 'The socket connection has been established.'); - self.updateBlock(); - self.update(true); + self.getLatestBlock(); + self.getStats(true); }) .on('data', function incoming(data) { @@ -342,7 +342,7 @@ Node.prototype.formatBlock = function (block) return false; } -Node.prototype.getStatsBlock = function () +Node.prototype.getLatestBlock = function () { var self = this; @@ -353,12 +353,12 @@ Node.prototype.getStatsBlock = function () { this._startBlockFetch = _.now(); web3.eth.getBlock('latest', false, function(error, result) { - self.sendStatsBlock(error, result); + self.validateLatestBlock(error, result); }); } } -Node.prototype.sendStatsBlock = function (error, result) +Node.prototype.validateLatestBlock = function (error, result) { if( !error ) { @@ -369,9 +369,7 @@ Node.prototype.sendStatsBlock = function (error, result) if( this.stats.block.number !== block.number ) { this.stats.block = block; - console.success("==>", "Got block:", chalk.reset.cyan(block.number), 'in', chalk.reset.cyan(_.now() - this._startBlockFetch, 'ms')); - this.sendUpdate(); } else @@ -386,7 +384,7 @@ Node.prototype.sendStatsBlock = function (error, result) } else { - console.error("xx>", "getStatsBlock couldn't fetch block..."); + console.error("xx>", "getLatestBlock couldn't fetch block..."); console.error("xx>", error); } } @@ -489,8 +487,6 @@ Node.prototype.getHistory = function (range) }, function (err, results) { - console.timeEnd('=H=', 'his', 'Got history in'); - if (err) { console.error('his', 'history fetch failed:', err); @@ -508,23 +504,11 @@ Node.prototype.getHistory = function (range) id: self.id, history: results.reverse() }); + + console.timeEnd('=H=', 'his', 'Got history in'); }); } -Node.prototype.updateBlock = function() -{ - this.getStatsBlock(); - - return this; -}; - -Node.prototype.update = function(forced) -{ - this.getStats(forced); - - return this; -}; - Node.prototype.changed = function () { var changed = ! _.isEqual( this._lastStats, JSON.stringify(this.stats) ); @@ -570,12 +554,12 @@ Node.prototype.setWatches = function() if(time > 50) { - self.updateBlock(); + self.getLatestBlock(); } else { debounce(function() { - self.updateBlock(); + self.getLatestBlock(); }, 50); } }); @@ -598,12 +582,12 @@ Node.prototype.setWatches = function() if(time > 50) { - self.update(true); + self.getStats(true); } else { debounce(function() { - self.update(true); + self.getStats(true); }, 50); } }); @@ -615,7 +599,7 @@ Node.prototype.setWatches = function() } this.updateInterval = setInterval( function(){ - self.update(); + self.getStats(); }, UPDATE_INTERVAL); this.pingInterval = setInterval( function(){