396 lines
9.4 KiB
JavaScript
396 lines
9.4 KiB
JavaScript
|
|
/* Controllers */
|
|
|
|
netStatsApp.controller('StatsCtrl', function($scope, $filter, socket, _, toastr) {
|
|
|
|
var MAX_BINS = 40;
|
|
|
|
// Main Stats init
|
|
// ---------------
|
|
|
|
$scope.nodesTotal = 0;
|
|
$scope.nodesActive = 0;
|
|
$scope.bestBlock = 0;
|
|
$scope.lastBlock = 0;
|
|
$scope.lastDifficulty = 0;
|
|
$scope.upTimeTotal = 0;
|
|
$scope.avgBlockTime = 0;
|
|
$scope.blockPropagationAvg = 0;
|
|
$scope.avgHashrate = 0;
|
|
$scope.uncleCount = 0;
|
|
$scope.bestStats = {};
|
|
|
|
$scope.lastBlocksTime = _.fill(Array(MAX_BINS), 2);
|
|
$scope.difficultyChart = _.fill(Array(MAX_BINS), 2);
|
|
$scope.transactionDensity = _.fill(Array(MAX_BINS), 2);
|
|
$scope.gasSpending = _.fill(Array(MAX_BINS), 2);
|
|
$scope.miners = [];
|
|
|
|
|
|
$scope.nodes = [];
|
|
$scope.map = [];
|
|
$scope.blockPropagationChart = [];
|
|
$scope.uncleCountChart = _.fill(Array(MAX_BINS), 2);
|
|
$scope.coinbases = [];
|
|
|
|
$scope.latency = 0;
|
|
|
|
$scope.currentApiVersion = "0.0.9";
|
|
|
|
$scope.predicate = ['-pinned', '-stats.active', '-stats.block.number', 'stats.block.propagation'];
|
|
$scope.reverse = false;
|
|
|
|
$scope.prefixPredicate = ['-pinned', '-stats.active'];
|
|
$scope.originalPredicate = ['-stats.block.number', 'stats.block.propagation'];
|
|
|
|
$scope.orderTable = function(predicate, reverse)
|
|
{
|
|
if(!_.isEqual(predicate, $scope.originalPredicate))
|
|
{
|
|
$scope.reverse = reverse;
|
|
$scope.originalPredicate = predicate;
|
|
$scope.predicate = _.union($scope.prefixPredicate, predicate);
|
|
}
|
|
else
|
|
{
|
|
$scope.reverse = !$scope.reverse;
|
|
|
|
if($scope.reverse === true){
|
|
_.forEach(predicate, function (value, key) {
|
|
predicate[key] = (value[0] === '-' ? value.replace('-', '') : '-' + value);
|
|
});
|
|
}
|
|
|
|
$scope.predicate = _.union($scope.prefixPredicate, predicate);
|
|
}
|
|
}
|
|
|
|
var timeout = setInterval(function ()
|
|
{
|
|
$scope.$apply();
|
|
}, 200);
|
|
|
|
$scope.getNumber = function (num) {
|
|
return new Array(num);
|
|
}
|
|
|
|
// Socket listeners
|
|
// ----------------
|
|
|
|
socket.on('open', function open() {
|
|
socket.emit('ready');
|
|
console.log('The connection has been opened.');
|
|
})
|
|
.on('end', function end() {
|
|
console.log('Socket connection ended.')
|
|
})
|
|
.on('error', function error(err) {
|
|
console.log(err);
|
|
})
|
|
.on('reconnecting', function reconnecting(opts) {
|
|
console.log('We are scheduling a reconnect operation', opts);
|
|
})
|
|
.on('data', function incoming(data) {
|
|
socketAction(data.action, data.data);
|
|
});
|
|
|
|
socket.on('init', function(data)
|
|
{
|
|
socketAction("init", data.nodes);
|
|
});
|
|
|
|
socket.on('client-latency', function(data)
|
|
{
|
|
$scope.latency = data.latency;
|
|
})
|
|
|
|
function socketAction(action, data)
|
|
{
|
|
// console.log('Action: ', action);
|
|
// console.log('Data: ', data);
|
|
|
|
switch(action) {
|
|
case "init":
|
|
var oldNodes = [];
|
|
|
|
if( $scope.nodes.length > 0 ){
|
|
oldNodes = $scope.nodes;
|
|
}
|
|
|
|
$scope.nodes = data;
|
|
|
|
_.forEach($scope.nodes, function (node, index) {
|
|
// Init hashrate
|
|
if( _.isUndefined(node.stats.hashrate) )
|
|
$scope.nodes[index].stats.hashrate = 0;
|
|
|
|
// Init history
|
|
if( _.isUndefined(data.history) )
|
|
{
|
|
data.history = new Array(40);
|
|
_.fill(data.history, -1);
|
|
}
|
|
|
|
// Init or recover pin
|
|
$scope.nodes[index].pinned = _.result(_.find(oldNodes, 'id', node.id), 'pinned', false);
|
|
});
|
|
|
|
if($scope.nodes.length > 0)
|
|
toastr['success']("Got nodes list", "Got nodes!");
|
|
|
|
break;
|
|
|
|
case "add":
|
|
var index = findIndex({id: data.id});
|
|
|
|
if( addNewNode(data) )
|
|
toastr['success']("New node "+ $scope.nodes[findIndex({id: data.id})].info.name +" connected!", "New node!");
|
|
else
|
|
toastr['info']("Node "+ $scope.nodes[index].info.name +" reconnected!", "Node is back!");
|
|
|
|
break;
|
|
|
|
case "update":
|
|
var index = findIndex({id: data.id});
|
|
|
|
if( index >= 0 && !_.isUndefined($scope.nodes[index]) && !_.isUndefined($scope.nodes[index].stats) )
|
|
{
|
|
if( _.isUndefined(data.stats.hashrate) )
|
|
data.stats.hashrate = 0;
|
|
|
|
if( $scope.nodes[index].stats.block.number < data.stats.block.number )
|
|
{
|
|
var best = _.max($scope.nodes, function (node) {
|
|
return parseInt(node.stats.block.number);
|
|
}).stats.block;
|
|
|
|
if (data.stats.block.number > best.number) {
|
|
data.stats.block.arrived = _.now();
|
|
} else {
|
|
data.stats.block.arrived = best.arrived;
|
|
}
|
|
|
|
$scope.nodes[index].history = data.history;
|
|
}
|
|
|
|
$scope.nodes[index].stats = data.stats;
|
|
}
|
|
|
|
break;
|
|
|
|
case "info":
|
|
var index = findIndex({id: data.id});
|
|
|
|
if( index >= 0 )
|
|
{
|
|
$scope.nodes[index].info = data.info;
|
|
|
|
if( _.isUndefined($scope.nodes[index].pinned) )
|
|
$scope.nodes[index].pinned = false;
|
|
}
|
|
|
|
break;
|
|
|
|
case "blockPropagationChart":
|
|
$scope.blockPropagationChart = data.histogram;
|
|
$scope.blockPropagationAvg = data.avg;
|
|
|
|
break;
|
|
|
|
case "uncleCount":
|
|
$scope.uncleCount = data[0] + data[1];
|
|
data.reverse();
|
|
$scope.uncleCountChart = data;
|
|
|
|
break;
|
|
|
|
case "charts":
|
|
if( !_.isEqual($scope.avgBlockTime, data.avgBlocktime) )
|
|
$scope.avgBlockTime = data.avgBlocktime;
|
|
|
|
if( !_.isEqual($scope.avgHashrate, data.avgHashrate) )
|
|
$scope.avgHashrate = data.avgHashrate;
|
|
|
|
if( !_.isEqual($scope.lastBlocksTime, data.blocktime) && data.blocktime.length >= MAX_BINS )
|
|
$scope.lastBlocksTime = data.blocktime;
|
|
|
|
if( !_.isEqual($scope.difficultyChart, data.difficulty) && data.difficulty.length >= MAX_BINS )
|
|
$scope.difficultyChart = data.difficulty;
|
|
|
|
if( !_.isEqual($scope.blockPropagationChart, data.propagation.histogram) ) {
|
|
$scope.blockPropagationChart = data.propagation.histogram;
|
|
$scope.blockPropagationAvg = data.propagation.avg;
|
|
}
|
|
|
|
data.uncleCount.reverse();
|
|
|
|
if( !_.isEqual($scope.uncleCountChart, data.uncleCount) && data.uncleCount.length >= MAX_BINS ) {
|
|
$scope.uncleCount = data.uncleCount[data.uncleCount.length-2] + data.uncleCount[data.uncleCount.length-1];
|
|
$scope.uncleCountChart = data.uncleCount;
|
|
}
|
|
|
|
if( !_.isEqual($scope.transactionDensity, data.transactions) && data.transactions.length >= MAX_BINS )
|
|
$scope.transactionDensity = data.transactions;
|
|
|
|
if( !_.isEqual($scope.gasSpending, data.gasSpending) && data.gasSpending.length >= MAX_BINS )
|
|
$scope.gasSpending = data.gasSpending;
|
|
|
|
if( !_.isEqual($scope.miners, data.miners) ) {
|
|
$scope.miners = data.miners;
|
|
getMinersNames();
|
|
}
|
|
|
|
break;
|
|
|
|
case "inactive":
|
|
var index = findIndex({id: data.id});
|
|
|
|
if( index >= 0 )
|
|
{
|
|
if( !_.isUndefined(data.stats) )
|
|
$scope.nodes[index].stats = data.stats;
|
|
|
|
toastr['error']("Node "+ $scope.nodes[index].info.name +" went away!", "Node connection was lost!");
|
|
}
|
|
|
|
break;
|
|
|
|
case "latency":
|
|
var index = findIndex({id: data.id});
|
|
|
|
if( !_.isUndefined(data.id) && index >= 0 )
|
|
{
|
|
var node = $scope.nodes[index];
|
|
|
|
if( !_.isUndefined(node) && !_.isUndefined(node.stats) && !_.isUndefined(node.stats.latency) )
|
|
$scope.nodes[index].stats.latency = data.latency;
|
|
}
|
|
|
|
break;
|
|
|
|
case "client-ping":
|
|
socket.emit('client-pong');
|
|
|
|
break;
|
|
}
|
|
|
|
if( action !== "latency" && action !== "client-ping" )
|
|
{
|
|
updateStats();
|
|
}
|
|
}
|
|
|
|
function findIndex(search)
|
|
{
|
|
return _.findIndex($scope.nodes, search);
|
|
}
|
|
|
|
function getMinersNames()
|
|
{
|
|
if( $scope.miners.length > 0 )
|
|
{
|
|
_.forIn($scope.miners, function (value, key)
|
|
{
|
|
if(value.name !== false)
|
|
return;
|
|
|
|
if(value.miner === "0x0000000000000000000000000000000000000000")
|
|
return;
|
|
|
|
var name = _.result(_.find(_.pluck($scope.nodes, 'info'), 'coinbase', value.miner), 'name');
|
|
|
|
if( !_.isUndefined(name) )
|
|
$scope.miners[key].name = name;
|
|
});
|
|
}
|
|
}
|
|
|
|
function addNewNode(data)
|
|
{
|
|
var index = findIndex({id: data.id});
|
|
|
|
if( _.isUndefined(data.history) )
|
|
{
|
|
data.history = new Array(40);
|
|
_.fill(data.history, -1);
|
|
}
|
|
|
|
if( index < 0 )
|
|
{
|
|
if( !_.isUndefined(data.stats) && _.isUndefined(data.stats.hashrate) )
|
|
{
|
|
data.stats.hashrate = 0;
|
|
}
|
|
|
|
data.pinned = false;
|
|
|
|
$scope.nodes.push(data);
|
|
|
|
return true;
|
|
}
|
|
|
|
data.pinned = ( !_.isUndefined($scope.nodes[index].pinned) ? $scope.nodes[index].pinned : false);
|
|
|
|
if( !_.isUndefined($scope.nodes[index].history) )
|
|
{
|
|
data.history = $scope.nodes[index].history;
|
|
}
|
|
|
|
$scope.nodes[index] = data;
|
|
|
|
return false;
|
|
}
|
|
|
|
function updateStats()
|
|
{
|
|
if( $scope.nodes.length )
|
|
{
|
|
$scope.nodesTotal = $scope.nodes.length;
|
|
|
|
$scope.nodesActive = _.filter($scope.nodes, function (node) {
|
|
return node.stats.active == true;
|
|
}).length;
|
|
|
|
var bestBlock = _.max($scope.nodes, function (node) {
|
|
return parseInt(node.stats.block.number);
|
|
}).stats.block.number;
|
|
|
|
if( bestBlock > $scope.bestBlock )
|
|
{
|
|
$scope.bestBlock = bestBlock;
|
|
$scope.bestStats = _.max($scope.nodes, function (node) {
|
|
return parseInt(node.stats.block.number);
|
|
}).stats;
|
|
|
|
$scope.lastBlock = $scope.bestStats.block.arrived;
|
|
$scope.lastDifficulty = $scope.bestStats.block.difficulty;
|
|
}
|
|
|
|
$scope.upTimeTotal = _.reduce($scope.nodes, function (total, node) {
|
|
return total + node.stats.uptime;
|
|
}, 0) / $scope.nodes.length;
|
|
|
|
$scope.map = _.map($scope.nodes, function (node) {
|
|
var fill = $filter('bubbleClass')(node.stats, $scope.bestBlock);
|
|
|
|
if(node.geo != null)
|
|
return {
|
|
radius: 3,
|
|
latitude: node.geo.ll[0],
|
|
longitude: node.geo.ll[1],
|
|
nodeName: node.info.name,
|
|
fillClass: "text-" + fill,
|
|
fillKey: fill,
|
|
};
|
|
else
|
|
return {
|
|
radius: 0,
|
|
latitude: 0,
|
|
longitude: 0
|
|
};
|
|
});
|
|
|
|
// $scope.$apply();
|
|
}
|
|
}
|
|
}); |