summaryrefslogtreecommitdiff
path: root/src/api/endpoints/messaging/messages/create.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2017-11-21 05:09:45 +0900
committersyuilo <syuilotan@yahoo.co.jp>2017-11-21 05:09:45 +0900
commitc598a9cba2d4cdecf2aec3dcde1a893ee039bce3 (patch)
treeecd8d77ef22f487296b7ae0b3aba44d79eaf1506 /src/api/endpoints/messaging/messages/create.ts
parentMerge remote-tracking branch 'refs/remotes/origin/master' into sw (diff)
downloadsharkey-c598a9cba2d4cdecf2aec3dcde1a893ee039bce3.tar.gz
sharkey-c598a9cba2d4cdecf2aec3dcde1a893ee039bce3.tar.bz2
sharkey-c598a9cba2d4cdecf2aec3dcde1a893ee039bce3.zip
wip
Diffstat (limited to 'src/api/endpoints/messaging/messages/create.ts')
-rw-r--r--src/api/endpoints/messaging/messages/create.ts4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/api/endpoints/messaging/messages/create.ts b/src/api/endpoints/messaging/messages/create.ts
index 29a4671f84..3c7689f967 100644
--- a/src/api/endpoints/messaging/messages/create.ts
+++ b/src/api/endpoints/messaging/messages/create.ts
@@ -9,8 +9,7 @@ import User from '../../../models/user';
import DriveFile from '../../../models/drive-file';
import serialize from '../../../serializers/messaging-message';
import publishUserStream from '../../../event';
-import { publishMessagingStream } from '../../../event';
-import { publishMessagingIndexStream } from '../../../event';
+import { publishMessagingStream, publishMessagingIndexStream, pushSw } from '../../../event';
import config from '../../../../conf';
/**
@@ -99,6 +98,7 @@ module.exports = (params, user) => new Promise(async (res, rej) => {
const freshMessage = await Message.findOne({ _id: message._id }, { is_read: true });
if (!freshMessage.is_read) {
publishUserStream(message.recipient_id, 'unread_messaging_message', messageObj);
+ pushSw(message.recipient_id, 'unread_messaging_message', messageObj);
}
}, 3000);