diff options
| author | fuyu <54523771+mfmfuyu@users.noreply.github.com> | 2020-07-04 10:45:36 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-07-04 10:45:36 +0900 |
| commit | 37c16e5b4536ea2db72b7853a8515df6ceb490a3 (patch) | |
| tree | c3633b4892121dd01fa2cf9523ed5ee071f8a1d5 /src/server/api | |
| parent | 投稿詳細でTwitterウィジェットが表示されなくなっている... (diff) | |
| download | sharkey-37c16e5b4536ea2db72b7853a8515df6ceb490a3.tar.gz sharkey-37c16e5b4536ea2db72b7853a8515df6ceb490a3.tar.bz2 sharkey-37c16e5b4536ea2db72b7853a8515df6ceb490a3.zip | |
「すべて既読にする」でグループメッセージが既読にならない問題を修正 (#6476)
Diffstat (limited to 'src/server/api')
| -rw-r--r-- | src/server/api/endpoints/i/read-all-messaging-messages.ts | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/src/server/api/endpoints/i/read-all-messaging-messages.ts b/src/server/api/endpoints/i/read-all-messaging-messages.ts index 036ec02d6b..e47ef16bd9 100644 --- a/src/server/api/endpoints/i/read-all-messaging-messages.ts +++ b/src/server/api/endpoints/i/read-all-messaging-messages.ts @@ -1,6 +1,6 @@ import { publishMainStream } from '../../../../services/stream'; import define from '../../define'; -import { MessagingMessages } from '../../../../models'; +import { MessagingMessages, UserGroupJoinings } from '../../../../models'; export const meta = { desc: { @@ -27,5 +27,16 @@ export default define(meta, async (ps, user) => { isRead: true }); + const joinings = await UserGroupJoinings.find({ userId: user.id }); + + await Promise.all(joinings.map(j => MessagingMessages.createQueryBuilder().update() + .set({ + reads: (() => `array_append("reads", '${user.id}')`) as any + }) + .where(`groupId = :groupId`, { groupId: j.userGroupId }) + .andWhere('userId != :userId', { userId: user.id }) + .andWhere('NOT (:userId = ANY(reads))', { userId: user.id }) + .execute())); + publishMainStream(user.id, 'readAllMessagingMessages'); }); |