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

Merge pull request #322 from keyhash/feature/send-email-on-rpc-error

Browse Source 
Send an email when the worker cannot get the last block header
This commit is contained in:
Snipa22
2018-02-25 10:19:05 -08:00
committed by GitHub
parent 43ed5842d0 774a5254cc
commit c8d07c9913
1 changed files with 32 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/worker.js
+32 -10
View File
@@ -504,20 +504,42 @@ function updateWalletStats() {
}
let lastBlockCheckIsOk = true;
function monitorNodes() {
global.mysql.query("SELECT blockID, hostname, ip FROM pools WHERE last_checkin > date_sub(now(), interval 30 minute)").then(function (rows) {
global.coinFuncs.getLastBlockHeader(function (err, block) {
if (err !== null){
console.error("Issue in getting block header. Skipping node monitor");
return;
global.coinFuncs.getLastBlockHeader((err, block) => {
if (err !== null) {
if (lastBlockCheckIsOk) {
lastBlockCheckIsOk = false;
global.support.sendEmail(
global.config.general.adminEmail,
'Failed to query daemon for last block header',
`The worker failed to return last block header. Please verify if the daemon is running properly.`
);
}
rows.forEach(function (row) {
if (row.blockID < block.height - 3) {
global.support.sendEmail(global.config.general.adminEmail, "Pool server behind in blocks", "The pool server: "+row.hostname+" with IP: "+row.ip+" is "+(block.height - row.blockID)+ " blocks behind");
}
}
return
}
if (!lastBlockCheckIsOk) {
lastBlockCheckIsOk = true;
global.support.sendEmail(
global.config.general.adminEmail,
'Quering daemon for last block header is back to normal',
`An warning was sent to you indicating that the the worker failed to return the last block header.
The issue seems to be solved now.`
);
}
const sql = 'SELECT blockID, hostname, ip FROM pools WHERE last_checkin > DATE_SUB(NOW(), INTERVAL 30 MINUTE)';
global.mysql.query(sql).then(pools => {
pools.forEach(({ blockID, hostname, ip }) => {
if (blockID < block.height - 3) {
global.support.sendEmail(
global.config.general.adminEmail,
'Pool server is behind in blocks',
`The pool server: ${hostname} with IP: ${ip} is ${(block.height - blockID)} blocks behind.`
);
}
})
});
});
}