summaryrefslogtreecommitdiff
path: root/src/server/api/common/read-messaging-message.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-05-29 01:22:39 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-05-29 01:22:39 +0900
commitab16fb3a3fff96a4fa2bc1fc0e56a87c129a4625 (patch)
tree26de7290eede6b42a661f328adce965a889f9887 /src/server/api/common/read-messaging-message.ts
parenttypo (diff)
downloadsharkey-ab16fb3a3fff96a4fa2bc1fc0e56a87c129a4625.tar.gz
sharkey-ab16fb3a3fff96a4fa2bc1fc0e56a87c129a4625.tar.bz2
sharkey-ab16fb3a3fff96a4fa2bc1fc0e56a87c129a4625.zip
#1634
Diffstat (limited to 'src/server/api/common/read-messaging-message.ts')
-rw-r--r--src/server/api/common/read-messaging-message.ts8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/server/api/common/read-messaging-message.ts b/src/server/api/common/read-messaging-message.ts
index 28854e186e..fd5e9f242c 100644
--- a/src/server/api/common/read-messaging-message.ts
+++ b/src/server/api/common/read-messaging-message.ts
@@ -4,6 +4,7 @@ import { IMessagingMessage as IMessage } from '../../../models/messaging-message
import publishUserStream from '../../../publishers/stream';
import { publishMessagingStream } from '../../../publishers/stream';
import { publishMessagingIndexStream } from '../../../publishers/stream';
+import User from '../../../models/user';
/**
* Mark as read message(s)
@@ -62,6 +63,13 @@ export default (
});
if (count == 0) {
+ // Update flag
+ User.update({ _id: userId }, {
+ $set: {
+ hasUnreadMessagingMessage: false
+ }
+ });
+
// 全ての(いままで未読だった)自分宛てのメッセージを(これで)読みましたよというイベントを発行
publishUserStream(userId, 'read_all_messaging_messages');
}