diff --git a/index.js b/index.js index 9f39116..383cf30 100644 --- a/index.js +++ b/index.js @@ -76,11 +76,13 @@ app.listen(port, () => { // Heartbeat checks setInterval(() => { const now = Date.now() / 1000; - global.db.run('SELECT * FROM analytics WHERE heartbeatCheck <= ? AND endTime IS NULL', [now], (err, rows) => { + global.db.all('SELECT * FROM analytics WHERE heartbeatCheck <= ? AND endTime IS NULL', [now], (err, rows) => { if (err) { return console.error('Failed to run heartbeat check', err); } - console.log(rows) + if (rows.length === 0) { + return; // No missed heartbeats + } rows.forEach(row => { console.log(`Server ${row.id} missed heartbeat check. Marking as inactive.`); // Set endTime to last known heartbeatCheck time, shutdownReason "missedHeartbeat"