summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-06-09 01:45:25 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-06-09 01:45:25 +0900
commit6eff8fde74e01fa3527585ec1fbd3629d51bc97a (patch)
tree55c39e88edb7e68f1928554b85bd036c96bc7ed8 /src/server
parentMerge pull request #1685 from 2vg/patch-1 (diff)
downloadsharkey-6eff8fde74e01fa3527585ec1fbd3629d51bc97a.tar.gz
sharkey-6eff8fde74e01fa3527585ec1fbd3629d51bc97a.tar.bz2
sharkey-6eff8fde74e01fa3527585ec1fbd3629d51bc97a.zip
サーバーの統計情報をメモリに記憶するようにするなど
Diffstat (limited to 'src/server')
-rw-r--r--src/server/api/stream/server.ts20
1 files changed, 18 insertions, 2 deletions
diff --git a/src/server/api/stream/server.ts b/src/server/api/stream/server.ts
index 4ca2ad1b10..342170a21e 100644
--- a/src/server/api/stream/server.ts
+++ b/src/server/api/stream/server.ts
@@ -11,9 +11,25 @@ export default function(request: websocket.request, connection: websocket.connec
}));
};
- ev.addListener('stats', onStats);
+ 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', msg.id);
+ break;
+ }
+ });
+
+ ev.addListener('serverStats', onStats);
connection.on('close', () => {
- ev.removeListener('stats', onStats);
+ ev.removeListener('serverStats', onStats);
});
}