Remove duplication of valid notifier check
This commit is contained in:
parent
ef65252148
commit
239a6952f7
|
@ -119,8 +119,6 @@ export class NotificationEntityService implements OnModuleInit {
|
||||||
|
|
||||||
let validNotifications = notifications;
|
let validNotifications = notifications;
|
||||||
|
|
||||||
validNotifications = await this.#filterValidNotifier(validNotifications, meId);
|
|
||||||
|
|
||||||
const noteIds = validNotifications.map(x => 'noteId' in x ? x.noteId : null).filter(isNotNull);
|
const noteIds = validNotifications.map(x => 'noteId' in x ? x.noteId : null).filter(isNotNull);
|
||||||
const notes = noteIds.length > 0 ? await this.notesRepository.find({
|
const notes = noteIds.length > 0 ? await this.notesRepository.find({
|
||||||
where: { id: In(noteIds) },
|
where: { id: In(noteIds) },
|
||||||
|
@ -255,8 +253,6 @@ export class NotificationEntityService implements OnModuleInit {
|
||||||
|
|
||||||
let validNotifications = notifications;
|
let validNotifications = notifications;
|
||||||
|
|
||||||
validNotifications = await this.#filterValidNotifier(validNotifications, meId);
|
|
||||||
|
|
||||||
const noteIds = validNotifications.map(x => 'noteId' in x ? x.noteId : null).filter(isNotNull);
|
const noteIds = validNotifications.map(x => 'noteId' in x ? x.noteId : null).filter(isNotNull);
|
||||||
const notes = noteIds.length > 0 ? await this.notesRepository.find({
|
const notes = noteIds.length > 0 ? await this.notesRepository.find({
|
||||||
where: { id: In(noteIds) },
|
where: { id: In(noteIds) },
|
||||||
|
@ -322,35 +318,4 @@ export class NotificationEntityService implements OnModuleInit {
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* notifierが存在するか、ミュートされていないか、サスペンドされていないかを複数確認する
|
|
||||||
*/
|
|
||||||
async #filterValidNotifier <T extends MiNotification | MiGroupedNotification> (
|
|
||||||
notifications: T[],
|
|
||||||
meId: MiUser['id'],
|
|
||||||
) : Promise<T[]> {
|
|
||||||
const [
|
|
||||||
userIdsWhoMeMuting,
|
|
||||||
userMutedInstances,
|
|
||||||
] = await Promise.all([
|
|
||||||
this.cacheService.userMutingsCache.fetch(meId),
|
|
||||||
this.cacheService.userProfileCache.fetch(meId).then(p => new Set(p.mutedInstances)),
|
|
||||||
]);
|
|
||||||
|
|
||||||
const filteredNotifications = ((await Promise.all(notifications.map(async (notification) => {
|
|
||||||
if (!('notifierId' in notification)) return notification;
|
|
||||||
if (userIdsWhoMeMuting.has(notification.notifierId)) return null;
|
|
||||||
|
|
||||||
const notifier = await this.usersRepository.findOneBy({ id: notification.notifierId });
|
|
||||||
if (notifier === null) return null;
|
|
||||||
if (notifier.host && userMutedInstances.has(notifier.host)) return null;
|
|
||||||
|
|
||||||
if (notifier.isSuspended) return null;
|
|
||||||
|
|
||||||
return notification;
|
|
||||||
}))) as [T|null] ).filter((notification): notification is T => notification !== null);
|
|
||||||
|
|
||||||
return filteredNotifications;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue