grassrootseconomics/ethstats-client
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

refactoring

Browse Source
This commit is contained in:
cubedro 2015-05-27 10:15:22 +03:00
parent de187ba872
commit 1268561567
1 changed files with 13 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
lib/node.js
View File

@ -199,8 +199,8 @@ Node.prototype.setupSockets = function()
self._socket = true; self._socket = true;
console.success('wsc', 'The socket connection has been established.'); console.success('wsc', 'The socket connection has been established.');
self.updateBlock(); self.getLatestBlock();
self.update(true); self.getStats(true);
}) })
.on('data', function incoming(data) .on('data', function incoming(data)
{ {
@ -342,7 +342,7 @@ Node.prototype.formatBlock = function (block)
return false; return false;
} }
Node.prototype.getStatsBlock = function () Node.prototype.getLatestBlock = function ()
{ {
var self = this; var self = this;
@ -353,12 +353,12 @@ Node.prototype.getStatsBlock = function ()
{ {
this._startBlockFetch = _.now(); this._startBlockFetch = _.now();
web3.eth.getBlock('latest', false, function(error, result) { 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 ) if( !error )
{ {
@ -369,9 +369,7 @@ Node.prototype.sendStatsBlock = function (error, result)
if( this.stats.block.number !== block.number ) if( this.stats.block.number !== block.number )
{ {
this.stats.block = block; this.stats.block = block;
console.success("==>", "Got block:", chalk.reset.cyan(block.number), 'in', chalk.reset.cyan(_.now() - this._startBlockFetch, 'ms')); console.success("==>", "Got block:", chalk.reset.cyan(block.number), 'in', chalk.reset.cyan(_.now() - this._startBlockFetch, 'ms'));
this.sendUpdate(); this.sendUpdate();
} }
else else
@ -386,7 +384,7 @@ Node.prototype.sendStatsBlock = function (error, result)
} }
else else
{ {
console.error("xx>", "getStatsBlock couldn't fetch block..."); console.error("xx>", "getLatestBlock couldn't fetch block...");
console.error("xx>", error); console.error("xx>", error);
} }
} }
@ -489,8 +487,6 @@ Node.prototype.getHistory = function (range)
}, },
function (err, results) function (err, results)
{ {
console.timeEnd('=H=', 'his', 'Got history in');
if (err) { if (err) {
console.error('his', 'history fetch failed:', err); console.error('his', 'history fetch failed:', err);
@ -508,23 +504,11 @@ Node.prototype.getHistory = function (range)
id: self.id, id: self.id,
history: results.reverse() 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 () Node.prototype.changed = function ()
{ {
var changed = ! _.isEqual( this._lastStats, JSON.stringify(this.stats) ); var changed = ! _.isEqual( this._lastStats, JSON.stringify(this.stats) );
@ -570,12 +554,12 @@ Node.prototype.setWatches = function()
if(time > 50) if(time > 50)
{ {
self.updateBlock(); self.getLatestBlock();
} }
else else
{ {
debounce(function() { debounce(function() {
self.updateBlock(); self.getLatestBlock();
}, 50); }, 50);
} }
}); });
@ -598,12 +582,12 @@ Node.prototype.setWatches = function()
if(time > 50) if(time > 50)
{ {
self.update(true); self.getStats(true);
} }
else else
{ {
debounce(function() { debounce(function() {
self.update(true); self.getStats(true);
}, 50); }, 50);
} }
}); });
@ -615,7 +599,7 @@ Node.prototype.setWatches = function()
} }
this.updateInterval = setInterval( function(){ this.updateInterval = setInterval( function(){
self.update(); self.getStats();
}, UPDATE_INTERVAL); }, UPDATE_INTERVAL);
this.pingInterval = setInterval( function(){ this.pingInterval = setInterval( function(){