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