diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2018-06-09 01:45:25 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2018-06-09 01:45:25 +0900 |
| commit | 6eff8fde74e01fa3527585ec1fbd3629d51bc97a (patch) | |
| tree | 55c39e88edb7e68f1928554b85bd036c96bc7ed8 /src/server | |
| parent | Merge pull request #1685 from 2vg/patch-1 (diff) | |
| download | sharkey-6eff8fde74e01fa3527585ec1fbd3629d51bc97a.tar.gz sharkey-6eff8fde74e01fa3527585ec1fbd3629d51bc97a.tar.bz2 sharkey-6eff8fde74e01fa3527585ec1fbd3629d51bc97a.zip | |
サーバーの統計情報をメモリに記憶するようにするなど
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/api/stream/server.ts | 20 |
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); }); } |