added pending as a separate call

app.js

@@ -127,8 +127,6 @@ api.on('connection', function(spark) {
 	{
 		if( !_.isUndefined(data.id) && !_.isUndefined(data.stats) )
 		{
-			data.stats.latency = spark.latency;
-
 			var stats = Nodes.update(data.id, data.stats);
 
 			if(stats !== false)
@@ -146,6 +144,22 @@ api.on('connection', function(spark) {
 		}
 	});
 
+	spark.on('pending', function(data)
+	{
+		if( !_.isUndefined(data.id) && !_.isUndefined(data.stats) )
+		{
+			var stats = Nodes.updatePending(data.id, data.stats);
+
+			if(stats !== false)
+			{
+				client.write({
+					action: 'pending',
+					data: stats
+				});
+			}
+		}
+	});
+
 	spark.on('history', function(data)
 	{
 		console.log("got history from " + data.id);
@@ -167,11 +181,11 @@ api.on('connection', function(spark) {
 	{
 		if( !_.isUndefined(data.id) )
 		{
-			var stats = Nodes.updateLatency(data.id, data.latency);
+			var latency = Nodes.updateLatency(data.id, data.latency);
 
 			client.write({
 				action: 'latency',
-				data: stats
+				data: latency
 			});
 
 			if( Nodes.requiresUpdate(data.id) && (!askedForHistory || _.now() - askedForHistoryTime > 200000) )

models/collection.js

@@ -39,6 +39,16 @@ Collection.prototype.update = function(id, stats)
 	return node.setStats(stats, propagationHistory);
 }
 
+Collection.prototype.updatePending = function(id, stats)
+{
+	var node = this.getNode({ id: id });
+
+	if (!node)
+		return false;
+
+	return node.setPending(stats);
+}
+
 Collection.prototype.addHistory = function(id, blocks)
 {
 	var node = this.getNode({ id: id });

models/node.js

@@ -130,6 +130,9 @@ Node.prototype.setStats = function(stats, history)
 		else
 			stats.propagationAvg = 0;
 
+		if( !_.isUndefined(this.stats.latency) )
+			stats.latency = this.stats.latency;
+
 		this.stats = stats;
 
 		return this.getStats();
@@ -138,6 +141,21 @@ Node.prototype.setStats = function(stats, history)
 	return false;
 }
 
+Node.prototype.setPending = function(stats)
+{
+	if( !_.isUndefined(stats) && !_.isUndefined(stats.pending) )
+	{
+		this.stats.pending = stats.pending;
+
+		return {
+			id: this.id,
+			pending: this.stats.pending
+		};
+	}
+
+	return false;
+}
+
 Node.prototype.setLatency = function(latency)
 {
 	if( !_.isUndefined(latency) )

src/js/controllers.js

@@ -155,6 +155,9 @@ netStatsApp.controller('StatsCtrl', function($scope, $filter, socket, _, toastr)
 
 				if( index >= 0 && !_.isUndefined($scope.nodes[index]) && !_.isUndefined($scope.nodes[index].stats) )
 				{
+					if( !_.isUndefined($scope.nodes[index].stats.latency) )
+						data.stats.latency = $scope.nodes[index].stats.latency;
+
 					if( _.isUndefined(data.stats.hashrate) )
 						data.stats.hashrate = 0;
 
@@ -178,6 +181,19 @@ netStatsApp.controller('StatsCtrl', function($scope, $filter, socket, _, toastr)
 
 				break;
 
+			case "pending":
+				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.pending) )
+						$scope.nodes[index].stats.pending = data.pending;
+				}
+
+				break;
+
 			case "info":
 				var index = findIndex({id: data.id});
 
@@ -263,6 +279,7 @@ netStatsApp.controller('StatsCtrl', function($scope, $filter, socket, _, toastr)
 					var node = $scope.nodes[index];
 
 					if( !_.isUndefined(node) && !_.isUndefined(node.stats) && !_.isUndefined(node.stats.latency) )
+						// console.log(data.latency);
 						$scope.nodes[index].stats.latency = data.latency;
 				}