summaryrefslogtreecommitdiff
path: root/src/server/api/stream
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-06-11 09:11:32 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-06-11 09:11:32 +0900
commit2ec25a7729e8d2fa6734bdf25ffb5a1b35ca2d5b (patch)
tree8e50814af7140caf4c8ad9ec2f69a59b8bb88a23 /src/server/api/stream
parentwip (diff)
downloadsharkey-2ec25a7729e8d2fa6734bdf25ffb5a1b35ca2d5b.tar.gz
sharkey-2ec25a7729e8d2fa6734bdf25ffb5a1b35ca2d5b.tar.bz2
sharkey-2ec25a7729e8d2fa6734bdf25ffb5a1b35ca2d5b.zip
wip
Diffstat (limited to 'src/server/api/stream')
-rw-r--r--src/server/api/stream/hashtags-stats.ts35
1 files changed, 0 insertions, 35 deletions
diff --git a/src/server/api/stream/hashtags-stats.ts b/src/server/api/stream/hashtags-stats.ts
deleted file mode 100644
index 47183467f5..0000000000
--- a/src/server/api/stream/hashtags-stats.ts
+++ /dev/null
@@ -1,35 +0,0 @@
-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 => {
- 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('hashtagsStatsLog:' + msg.id, statsLog => {
- connection.send(JSON.stringify({
- type: 'statsLog',
- body: statsLog
- }));
- });
- ev.emit('requestHashtagsStatsLog', msg.id);
- break;
- }
- });
-
- ev.addListener('hashtagsStats', onStats);
-
- connection.on('close', () => {
- ev.removeListener('hashtagsStats', onStats);
- });
-}