graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-12-25 08:23:07 +02:00
Code Issues Projects Releases Packages Wiki Activity

「すべて既読にする」でグループメッセージが既読にならない問題を修正 (#6476)

Browse source
This commit is contained in:
fuyu 2020-07-04 10:45:36 +09:00 committed by GitHub
parent ca25b9acc1
commit 37c16e5b45
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/server/api/endpoints/i/read-all-messaging-messages.ts
View file

@ -1,6 +1,6 @@
import { publishMainStream } from '../../../../services/stream'; import { publishMainStream } from '../../../../services/stream';
import define from '../../define'; import define from '../../define';
import { MessagingMessages } from '../../../../models'; import { MessagingMessages, UserGroupJoinings } from '../../../../models';
export const meta = { export const meta = {
desc: { desc: {
@ -27,5 +27,16 @@ export default define(meta, async (ps, user) => {
isRead: true 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'); publishMainStream(user.id, 'readAllMessagingMessages');
}); });