summaryrefslogtreecommitdiff
path: root/src/server/api/stream
diff options
context:
space:
mode:
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);
- });
-}