iceshrimp/src/daemons/notes-stats.ts
2018-09-01 23:12:51 +09:00

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);
});
}