2018-06-08 21:14:26 +02:00
|
|
|
import * as childProcess from 'child_process';
|
2018-08-14 01:21:25 +02:00
|
|
|
import * as Deque from 'double-ended-queue';
|
2018-06-08 21:14:26 +02:00
|
|
|
import Xev from 'xev';
|
|
|
|
|
|
|
|
const ev = new Xev();
|
|
|
|
|
2018-07-14 12:49:21 +02:00
|
|
|
export default function() {
|
2018-08-14 01:21:25 +02:00
|
|
|
const log = new Deque<any>();
|
2018-06-08 21:14:26 +02:00
|
|
|
|
|
|
|
const p = childProcess.fork(__dirname + '/notes-stats-child.js');
|
|
|
|
|
|
|
|
p.on('message', stats => {
|
|
|
|
ev.emit('notesStats', stats);
|
|
|
|
log.push(stats);
|
2018-08-15 13:20:46 +02:00
|
|
|
if (log.length > 100) log.shift();
|
2018-06-08 21:14:26 +02:00
|
|
|
});
|
|
|
|
|
|
|
|
ev.on('requestNotesStatsLog', id => {
|
2018-08-14 00:49:59 +02:00
|
|
|
ev.emit('notesStatsLog:' + id, log.toArray());
|
2018-06-08 21:14:26 +02:00
|
|
|
});
|
2018-07-13 17:39:39 +02:00
|
|
|
|
|
|
|
process.on('exit', code => {
|
|
|
|
process.kill(p.pid);
|
|
|
|
});
|
|
|
|
|
2018-06-08 21:14:26 +02:00
|
|
|
}
|