2017-06-08 18:03:54 +02:00
|
|
|
import * as os from 'os';
|
2018-07-27 10:58:19 +02:00
|
|
|
import * as sysUtils from 'systeminformation';
|
2017-06-08 18:03:54 +02:00
|
|
|
import * as diskusage from 'diskusage';
|
2018-08-14 01:21:25 +02:00
|
|
|
import * as Deque from 'double-ended-queue';
|
2017-06-08 18:03:54 +02:00
|
|
|
import Xev from 'xev';
|
2018-07-27 11:42:58 +02:00
|
|
|
const osUtils = require('os-utils');
|
2017-06-08 18:03:54 +02:00
|
|
|
|
|
|
|
const ev = new Xev();
|
|
|
|
|
2018-06-10 23:48:25 +02:00
|
|
|
const interval = 1000;
|
|
|
|
|
2017-06-08 18:03:54 +02:00
|
|
|
/**
|
2018-06-08 21:14:26 +02:00
|
|
|
* Report server stats regularly
|
2017-06-08 18:03:54 +02:00
|
|
|
*/
|
|
|
|
export default function() {
|
2018-08-14 01:21:25 +02:00
|
|
|
const log = new Deque<any>();
|
2018-06-08 18:45:25 +02:00
|
|
|
|
2018-08-18 20:32:01 +02:00
|
|
|
ev.on('requestServerStatsLog', x => {
|
2018-09-01 16:12:51 +02:00
|
|
|
ev.emit(`serverStatsLog:${x.id}`, log.toArray().slice(0, x.length || 50));
|
2018-06-08 18:45:25 +02:00
|
|
|
});
|
|
|
|
|
2018-06-10 23:48:25 +02:00
|
|
|
async function tick() {
|
2018-07-27 10:43:04 +02:00
|
|
|
const cpu = await cpuUsage();
|
2018-07-27 11:18:05 +02:00
|
|
|
const usedmem = await usedMem();
|
2018-07-27 10:31:19 +02:00
|
|
|
const totalmem = await totalMem();
|
2018-12-08 02:40:45 +01:00
|
|
|
const disk = await diskusage.check(os.platform() == 'win32' ? 'c:' : '/');
|
2018-07-27 10:31:19 +02:00
|
|
|
|
|
|
|
const stats = {
|
|
|
|
cpu_usage: cpu,
|
|
|
|
mem: {
|
|
|
|
total: totalmem,
|
2018-07-27 11:18:05 +02:00
|
|
|
used: usedmem
|
2018-07-27 10:31:19 +02:00
|
|
|
},
|
|
|
|
disk,
|
|
|
|
os_uptime: os.uptime(),
|
|
|
|
process_uptime: process.uptime()
|
|
|
|
};
|
|
|
|
ev.emit('serverStats', stats);
|
2018-08-18 20:32:01 +02:00
|
|
|
log.unshift(stats);
|
|
|
|
if (log.length > 200) log.pop();
|
2018-06-10 23:48:25 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
tick();
|
|
|
|
|
|
|
|
setInterval(tick, interval);
|
2017-06-08 18:03:54 +02:00
|
|
|
}
|
2018-07-27 10:31:19 +02:00
|
|
|
|
|
|
|
// CPU STAT
|
2018-07-27 11:42:58 +02:00
|
|
|
function cpuUsage() {
|
|
|
|
return new Promise((res, rej) => {
|
|
|
|
osUtils.cpuUsage((cpuUsage: number) => {
|
|
|
|
res(cpuUsage);
|
|
|
|
});
|
|
|
|
});
|
2018-07-27 10:31:19 +02:00
|
|
|
}
|
|
|
|
|
2018-07-27 10:43:04 +02:00
|
|
|
// MEMORY(excl buffer + cache) STAT
|
2018-07-27 11:18:05 +02:00
|
|
|
async function usedMem() {
|
2018-07-27 10:43:04 +02:00
|
|
|
try {
|
|
|
|
const data = await sysUtils.mem();
|
|
|
|
return data.active;
|
|
|
|
} catch (error) {
|
|
|
|
console.error(error);
|
2018-07-27 10:51:40 +02:00
|
|
|
throw error;
|
2018-07-27 10:43:04 +02:00
|
|
|
}
|
2018-07-27 10:31:19 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
// TOTAL MEMORY STAT
|
|
|
|
async function totalMem() {
|
2018-07-27 10:43:04 +02:00
|
|
|
try {
|
|
|
|
const data = await sysUtils.mem();
|
|
|
|
return data.total;
|
|
|
|
} catch (error) {
|
|
|
|
console.error(error);
|
2018-07-27 10:51:40 +02:00
|
|
|
throw error;
|
2018-07-27 10:43:04 +02:00
|
|
|
}
|
|
|
|
}
|