diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2017-11-14 00:54:16 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2017-11-14 00:54:16 +0900 |
| commit | ab2293aa4c0832f9e57d64aa22d2fce319fbfcb1 (patch) | |
| tree | 0060da35ac7fcb525ba2df2d9ac02d71c10d7b29 /src/api/endpoints/messaging/messages/create.ts | |
| parent | Add access log widget (diff) | |
| download | sharkey-ab2293aa4c0832f9e57d64aa22d2fce319fbfcb1.tar.gz sharkey-ab2293aa4c0832f9e57d64aa22d2fce319fbfcb1.tar.bz2 sharkey-ab2293aa4c0832f9e57d64aa22d2fce319fbfcb1.zip | |
Add messaging widget
Diffstat (limited to 'src/api/endpoints/messaging/messages/create.ts')
| -rw-r--r-- | src/api/endpoints/messaging/messages/create.ts | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/api/endpoints/messaging/messages/create.ts b/src/api/endpoints/messaging/messages/create.ts index 149852c093..29a4671f84 100644 --- a/src/api/endpoints/messaging/messages/create.ts +++ b/src/api/endpoints/messaging/messages/create.ts @@ -10,6 +10,7 @@ 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 config from '../../../../conf'; /** @@ -85,10 +86,12 @@ module.exports = (params, user) => new Promise(async (res, rej) => { // 自分のストリーム publishMessagingStream(message.user_id, message.recipient_id, 'message', messageObj); + publishMessagingIndexStream(message.user_id, 'message', messageObj); publishUserStream(message.user_id, 'messaging_message', messageObj); // 相手のストリーム publishMessagingStream(message.recipient_id, message.user_id, 'message', messageObj); + publishMessagingIndexStream(message.recipient_id, 'message', messageObj); publishUserStream(message.recipient_id, 'messaging_message', messageObj); // 3秒経っても(今回作成した)メッセージが既読にならなかったら「未読のメッセージがありますよ」イベントを発行する |