github-jwinterm/nodejs-pool
1
0
Fork 0
mirror of https://github.com/jwinterm/nodejs-pool.git synced 2026-10-17 05:21:27 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update with more debug states

Browse Source
This commit is contained in:
Alexander Blair
2017-03-07 17:16:04 -08:00
parent b3bb5a6cdf
commit 6da367c587
3 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
debug_scripts/socket_io.html
+5 -2
View File
@@ -5,11 +5,14 @@
var socket = io.connect('https://api.xmrpool.net/');
// let's assume that the client page, once rendered, knows what room it wants to join
var room = "pool_stats";
socket.on('connect', function() {
// Connected, let's sign-up for to receive messages for this room
socket.emit('room', room);
socket.emit('room', "pool_stats");
socket.emit('room', "pool_stats_pplns");
socket.emit('room', "pool_stats_solo");
socket.emit('room', "network_block_info");
socket.emit('room', "address_stats_46XWBqE1iwsVxSDP1qDrxhE1XvsZV6eALG5LwnoMdjbT4GPdy2bZTb99kagzxp2MMjUamTYZ4WgvZdFadvMimTjvR6Gv8hL")
});
socket.on('message', function(data) {
lib/api.js
+2 -1
View File
@@ -117,7 +117,7 @@ sock.on('message', function(topic, message) {
});
break;
case 'network_block_info':
io.sockets.in('block_update').emit('message', JSON.stringify(global.database.getCache('networkBlockInfo')));
io.sockets.in('block_update').emit('message', message);
break;
case 'pool_stats':
if (message === 'global'){
@@ -145,6 +145,7 @@ sock.on('message', function(topic, message) {
case 'default':
io.sockets.in('pool_stats_' + message).emit('message', JSON.stringify({'error': 'Invalid pool type'}));
}
localCache.poolType = pool_type;
delete(localCache.minerHistory);
delete(localCache.hashHistory);
io.sockets.in('pool_stats_' + message).emit('message', JSON.stringify({pool_statistics: localCache}));
lib/worker.js
+8 -2
View File
@@ -177,7 +177,7 @@ function updateShareStats() {
if (globalMinerList.indexOf(miner) === -1) {
globalMinerList.push(miner);
}
if (miner.indexOf('-') === -1){
if (miner.indexOf('_') === -1){
activeAddresses.push(miner);
}
let cachedData = global.database.getCache(miner);
@@ -440,7 +440,13 @@ function updateBlockHeader() {
value: body.result.block_header.reward,
ts: body.result.block_header.timestamp
});
sock.send(['network_block_info', 'complete']);
sock.send(['network_block_info', JSON.stringify({
difficulty: body.result.block_header.difficulty,
hash: body.result.block_header.hash,
height: body.result.block_header.height,
value: body.result.block_header.reward,
ts: body.result.block_header.timestamp
})]);
} else {
console.error("GetLastBlockHeader Error during block header update");
}