summaryrefslogtreecommitdiff
path: root/src/server/api/stream/messaging.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2018-10-07 11:06:17 +0900
committerGitHub <noreply@github.com>2018-10-07 11:06:17 +0900
commitd0570d7fe3a3bf3c6b0312dece74bacc04c3534a (patch)
tree698218279a38f9c78b0350e81b8ac77ae52e4a0d /src/server/api/stream/messaging.ts
parentFix お知らせが確認中...のままになる(Announcement Fetching...) (... (diff)
downloadsharkey-d0570d7fe3a3bf3c6b0312dece74bacc04c3534a.tar.gz
sharkey-d0570d7fe3a3bf3c6b0312dece74bacc04c3534a.tar.bz2
sharkey-d0570d7fe3a3bf3c6b0312dece74bacc04c3534a.zip
V10 (#2826)
* wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * Update CHANGELOG.md * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * Update CHANGELOG.md * Update CHANGELOG.md * wip * Update CHANGELOG.md * wip * wip * wip * wip
Diffstat (limited to 'src/server/api/stream/messaging.ts')
-rw-r--r--src/server/api/stream/messaging.ts25
1 files changed, 0 insertions, 25 deletions
diff --git a/src/server/api/stream/messaging.ts b/src/server/api/stream/messaging.ts
deleted file mode 100644
index 8b352cea3c..0000000000
--- a/src/server/api/stream/messaging.ts
+++ /dev/null
@@ -1,25 +0,0 @@
-import * as websocket from 'websocket';
-import Xev from 'xev';
-import read from '../common/read-messaging-message';
-import { ParsedUrlQuery } from 'querystring';
-
-export default function(request: websocket.request, connection: websocket.connection, subscriber: Xev, user: any): void {
- const q = request.resourceURL.query as ParsedUrlQuery;
- const otherparty = q.otherparty as string;
-
- // Subscribe messaging stream
- subscriber.on(`messaging-stream:${user._id}-${otherparty}`, data => {
- connection.send(JSON.stringify(data));
- });
-
- connection.on('message', async (data) => {
- const msg = JSON.parse(data.utf8Data);
-
- switch (msg.type) {
- case 'read':
- if (!msg.id) return;
- read(user._id, otherparty, msg.id);
- break;
- }
- });
-}