75 lines
1.4 KiB
TypeScript
75 lines
1.4 KiB
TypeScript
import * as os from 'os';
|
|
import * as sysUtils from 'systeminformation';
|
|
import * as diskusage from 'diskusage';
|
|
import * as Deque from 'double-ended-queue';
|
|
import Xev from 'xev';
|
|
const osUtils = require('os-utils');
|
|
|
|
const ev = new Xev();
|
|
|
|
const interval = 1000;
|
|
|
|
/**
|
|
* Report server stats regularly
|
|
*/
|
|
export default function() {
|
|
const log = new Deque<any>();
|
|
|
|
ev.on('requestServerStatsLog', x => {
|
|
ev.emit(`serverStatsLog:${x.id}`, log.toArray().slice(0, x.length || 50));
|
|
});
|
|
|
|
async function tick() {
|
|
const cpu = await cpuUsage();
|
|
const usedmem = await usedMem();
|
|
const totalmem = await totalMem();
|
|
const disk = await diskusage.check(os.platform() == 'win32' ? 'c:' : '/');
|
|
|
|
const stats = {
|
|
cpu_usage: cpu,
|
|
mem: {
|
|
total: totalmem,
|
|
used: usedmem
|
|
},
|
|
disk,
|
|
os_uptime: os.uptime(),
|
|
process_uptime: process.uptime()
|
|
};
|
|
ev.emit('serverStats', stats);
|
|
log.unshift(stats);
|
|
if (log.length > 200) log.pop();
|
|
}
|
|
|
|
tick();
|
|
|
|
setInterval(tick, interval);
|
|
}
|
|
|
|
// CPU STAT
|
|
function cpuUsage() {
|
|
return new Promise((res, rej) => {
|
|
osUtils.cpuUsage((cpuUsage: number) => {
|
|
res(cpuUsage);
|
|
});
|
|
});
|
|
}
|
|
|
|
// MEMORY(excl buffer + cache) STAT
|
|
async function usedMem() {
|
|
try {
|
|
const data = await sysUtils.mem();
|
|
return data.active;
|
|
} catch (error) {
|
|
throw error;
|
|
}
|
|
}
|
|
|
|
// TOTAL MEMORY STAT
|
|
async function totalMem() {
|
|
try {
|
|
const data = await sysUtils.mem();
|
|
return data.total;
|
|
} catch (error) {
|
|
throw error;
|
|
}
|
|
}
|