27 lines
544 B
TypeScript
27 lines
544 B
TypeScript
import * as childProcess from 'child_process';
|
|
import * as Deque from 'double-ended-queue';
|
|
import Xev from 'xev';
|
|
|
|
const ev = new Xev();
|
|
|
|
export default function() {
|
|
const log = new Deque<any>();
|
|
|
|
const p = childProcess.fork(__dirname + '/notes-stats-child.js');
|
|
|
|
p.on('message', stats => {
|
|
ev.emit('notesStats', stats);
|
|
log.push(stats);
|
|
if (log.length > 100) log.shift();
|
|
});
|
|
|
|
ev.on('requestNotesStatsLog', id => {
|
|
ev.emit(`notesStatsLog:${id}`, log.toArray());
|
|
});
|
|
|
|
process.on('exit', code => {
|
|
process.kill(p.pid);
|
|
});
|
|
|
|
}
|