HoovesSocial/hippofish
2
0
Fork 0
Code Issues 3 Pull requests 1 Projects Releases Packages Wiki Activity Actions

fix read-notification.ts

Browse source
This commit is contained in:
tamaina 2021-09-04 21:20:47 +09:00
parent 42d82ab379
commit 0ae98b4a07
1 changed files with 11 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/server/api/common/read-notification.ts
View file

@ -17,7 +17,8 @@ export async function readNotification(
isRead: true isRead: true
}); });
post(userId); if (!await Users.getHasUnreadNotification(userId)) return postReadAllNotifications(userId);
else return postReadNotifications(userId, notificationIds)
} }
export async function readNotificationByQuery( export async function readNotificationByQuery(
@ -33,18 +34,15 @@ export async function readNotificationByQuery(
isRead: true isRead: true
}); });
post(userId); if (!await Users.getHasUnreadNotification(userId)) return postReadAllNotifications(userId);
} }
async function post(userId: User['id']) { function postReadAllNotifications(userId: User['id']) {
if (!await Users.getHasUnreadNotification(userId)) { publishMainStream(userId, 'readAllNotifications');
// ユーザーのすべての通知が既読だったら、 return pushNotification(userId, 'readAllNotifications', undefined);
// 全ての(いままで未読だった)通知を(これで)読みましたよというイベントを発行 }
publishMainStream(userId, 'readAllNotifications');
pushNotification(userId, 'readAllNotifications', undefined); function postReadNotifications(userId: User['id'], notificationIds: Notification['id'][]) {
} else { publishMainStream(userId, 'readNotifications', notificationIds);
// まだすべて既読になっていなければ、各クライアントにnotificationIdsを伝達 return pushNotification(userId, 'readNotifications', { notificationIds });
publishMainStream(userId, 'readNotifications', notificationIds);
pushNotification(userId, 'readNotifications', { notificationIds });
}
} }