39 lines
814 B
TypeScript
39 lines
814 B
TypeScript
import * as websocket from 'websocket';
|
|
import Xev from 'xev';
|
|
|
|
const ev = new Xev();
|
|
|
|
export default function(request: websocket.request, connection: websocket.connection): void {
|
|
const onStats = (stats: any) => {
|
|
connection.send(JSON.stringify({
|
|
type: 'stats',
|
|
body: stats
|
|
}));
|
|
};
|
|
|
|
connection.on('message', async data => {
|
|
const msg = JSON.parse(data.utf8Data);
|
|
|
|
switch (msg.type) {
|
|
case 'requestLog':
|
|
ev.once(`serverStatsLog:${msg.id}`, statsLog => {
|
|
connection.send(JSON.stringify({
|
|
type: 'statsLog',
|
|
body: statsLog
|
|
}));
|
|
});
|
|
ev.emit('requestServerStatsLog', {
|
|
id: msg.id,
|
|
length: msg.length
|
|
});
|
|
break;
|
|
}
|
|
});
|
|
|
|
ev.addListener('serverStats', onStats);
|
|
|
|
connection.on('close', () => {
|
|
ev.removeListener('serverStats', onStats);
|
|
});
|
|
}
|