From 0e4a111f81cceed275d9bec2695f6e401fb654d8 Mon Sep 17 00:00:00 2001 From: syuilo Date: Fri, 12 Nov 2021 02:02:25 +0900 Subject: refactoring Resolve #7779 --- src/server/api/common/read-notification.ts | 43 ------------------------------ 1 file changed, 43 deletions(-) delete mode 100644 src/server/api/common/read-notification.ts (limited to 'src/server/api/common/read-notification.ts') diff --git a/src/server/api/common/read-notification.ts b/src/server/api/common/read-notification.ts deleted file mode 100644 index a4406c9eeb..0000000000 --- a/src/server/api/common/read-notification.ts +++ /dev/null @@ -1,43 +0,0 @@ -import { publishMainStream } from '@/services/stream'; -import { User } from '@/models/entities/user'; -import { Notification } from '@/models/entities/notification'; -import { Notifications, Users } from '@/models/index'; -import { In } from 'typeorm'; - -export async function readNotification( - userId: User['id'], - notificationIds: Notification['id'][] -) { - // Update documents - await Notifications.update({ - id: In(notificationIds), - isRead: false - }, { - isRead: true - }); - - post(userId); -} - -export async function readNotificationByQuery( - userId: User['id'], - query: Record -) { - // Update documents - await Notifications.update({ - ...query, - notifieeId: userId, - isRead: false - }, { - isRead: true - }); - - post(userId); -} - -async function post(userId: User['id']) { - if (!await Users.getHasUnreadNotification(userId)) { - // 全ての(いままで未読だった)通知を(これで)読みましたよというイベントを発行 - publishMainStream(userId, 'readAllNotifications'); - } -} -- cgit v1.2.3-freya