summaryrefslogtreecommitdiff
path: root/src/api/streaming.ts
diff options
context:
space:
mode:
authorha-dai <contact@haradai.net>2017-11-27 03:41:47 +0900
committerha-dai <contact@haradai.net>2017-11-27 03:41:47 +0900
commit6c75bc6d5188cbbf80fe1086fa0e8828f4edb873 (patch)
tree3ffedcc3a06e53269e92d2990cf0b3bb247ac04a /src/api/streaming.ts
parentMerge branch 'master' of https://github.com/syuilo/misskey (diff)
parentUpdate dependencies :rocket: (diff)
downloadmisskey-6c75bc6d5188cbbf80fe1086fa0e8828f4edb873.tar.gz
misskey-6c75bc6d5188cbbf80fe1086fa0e8828f4edb873.tar.bz2
misskey-6c75bc6d5188cbbf80fe1086fa0e8828f4edb873.zip
Merge branch 'master' of github.com:syuilo/misskey
Diffstat (limited to 'src/api/streaming.ts')
-rw-r--r--src/api/streaming.ts10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/api/streaming.ts b/src/api/streaming.ts
index 0e512fb210..c06d64c245 100644
--- a/src/api/streaming.ts
+++ b/src/api/streaming.ts
@@ -7,8 +7,11 @@ import AccessToken from './models/access-token';
import isNativeToken from './common/is-native-token';
import homeStream from './stream/home';
+import driveStream from './stream/drive';
import messagingStream from './stream/messaging';
+import messagingIndexStream from './stream/messaging-index';
import serverStream from './stream/server';
+import requestsStream from './stream/requests';
import channelStream from './stream/channel';
module.exports = (server: http.Server) => {
@@ -27,6 +30,11 @@ module.exports = (server: http.Server) => {
return;
}
+ if (request.resourceURL.pathname === '/requests') {
+ requestsStream(request, connection);
+ return;
+ }
+
// Connect to Redis
const subscriber = redis.createClient(
config.redis.port, config.redis.host);
@@ -51,7 +59,9 @@ module.exports = (server: http.Server) => {
const channel =
request.resourceURL.pathname === '/' ? homeStream :
+ request.resourceURL.pathname === '/drive' ? driveStream :
request.resourceURL.pathname === '/messaging' ? messagingStream :
+ request.resourceURL.pathname === '/messaging-index' ? messagingIndexStream :
null;
if (channel !== null) {