diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2017-06-13 03:42:45 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2017-06-13 03:42:45 +0900 |
| commit | fb20197d6eba271f99c5e1eecba171311df83461 (patch) | |
| tree | c98f73452a16f34087c550b7ec3333b497f0dc9f /src/api/endpoints | |
| parent | #271 (diff) | |
| download | sharkey-fb20197d6eba271f99c5e1eecba171311df83461.tar.gz sharkey-fb20197d6eba271f99c5e1eecba171311df83461.tar.bz2 sharkey-fb20197d6eba271f99c5e1eecba171311df83461.zip | |
:v:
Diffstat (limited to 'src/api/endpoints')
| -rw-r--r-- | src/api/endpoints/messaging/messages/create.ts | 4 |
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 05f9cda4cb..8af55d850c 100644 --- a/src/api/endpoints/messaging/messages/create.ts +++ b/src/api/endpoints/messaging/messages/create.ts @@ -93,13 +93,13 @@ module.exports = (params, user) => new Promise(async (res, rej) => { publishMessagingStream(message.recipient_id, message.user_id, 'message', messageObj); publishUserStream(message.recipient_id, 'messaging_message', messageObj); - // 5秒経っても(今回作成した)メッセージが既読にならなかったら「未読のメッセージがありますよ」イベントを発行する + // 3秒経っても(今回作成した)メッセージが既読にならなかったら「未読のメッセージがありますよ」イベントを発行する setTimeout(async () => { const freshMessage = await Message.findOne({ _id: message._id }, { is_read: true }); if (!freshMessage.is_read) { publishUserStream(message.recipient_id, 'unread_messaging_message', messageObj); } - }, 5000); + }, 3000); // Register to search database if (message.text && config.elasticsearch.enable) { |