RTECH/Roblox-Analytics
2
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Heartbeat stuff

Browse source
This commit is contained in:
Christopher Cookman 2026-01-25 15:09:32 -07:00
parent 16a16d643f
commit 70efdfd732
3 changed files with 31 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
index.js
View file

@ -73,4 +73,30 @@ loadRoutes(path.join(__dirname, 'routes'));
app.listen(port, () => { app.listen(port, () => {
console.log(`Listening on ${port}`); console.log(`Listening on ${port}`);
// Heartbeat checks
setInterval(() => {
const now = Date.now() / 1000;
global.db.run('SELECT * FROM analytics WHERE heartbeatCheck <= ?', [now], (err, rows) => {
if (err) {
return console.error('Failed to run heartbeat check', err);
}
if (!rows || 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"
global.db.run(
'UPDATE analytics SET endTime = ?, shutdownReason = ? WHERE id = ?',
[Math.floor(row.heartbeatCheck), 'missedHeartbeat', row.id],
(err) => {
if (err) {
return console.error(`Failed to mark server ${row.id} as inactive`, err);
}
console.log(`Server ${row.id} marked as inactive due to missed heartbeat.`);
}
);
});
});
}, 1000);
}); });

3
migrations/001_init.sql
View file

@ -6,5 +6,6 @@ CREATE TABLE IF NOT EXISTS analytics (
serverDuration INTEGER NOT NULL DEFAULT 0, serverDuration INTEGER NOT NULL DEFAULT 0,
endTime INTEGER DEFAULT NULL, endTime INTEGER DEFAULT NULL,
shutdownReason TEXT DEFAULT NULL, shutdownReason TEXT DEFAULT NULL,
allPlayers BLOB NOT NULL DEFAULT '{}' allPlayers BLOB NOT NULL DEFAULT '{}',
heartbeatCheck INTEGER NOT NULL
) )

5
routes/api/startup.js
View file

@ -9,9 +9,10 @@ router.post('/', global.auth, async (req, res) => {
return res.status(400).json({ error: 'Missing required fields' }); return res.status(400).json({ error: 'Missing required fields' });
} }
console.log(`Recording startup: ${serverId} at ${serverStartTime} for place ${placeId} rev ${revision}`); console.log(`Recording startup: ${serverId} at ${serverStartTime} for place ${placeId} rev ${revision}`);
const firstHeartbeat = Date.now() + ((parseInt(process.env.MAX_HEARTBEAT, 10) || 60) * 1000);
db.run( db.run(
'INSERT INTO analytics (id, placeId, revision, startupTime) VALUES (?, ?, ?, ?)', 'INSERT INTO analytics (id, placeId, revision, startupTime, heartbeatCheck) VALUES (?, ?, ?, ?, ?)',
[serverId, placeId, revision, serverStartTime], [serverId, placeId, revision, serverStartTime, firstHeartbeat / 1000],
function(err) { function(err) {
if (err) { if (err) {
console.error('Failed to record startup data', err); console.error('Failed to record startup data', err);