OpenSource/misskey
OpenSource/misskey
1
0
Fork 0
mirror of https://github.com/misskey-dev/misskey.git synced 2024-12-11 17:10:54 +01:00
Code Issues Projects Releases Packages Wiki Activity

Refactor

Browse source
This commit is contained in:
syuilo 2018-07-21 11:08:27 +09:00
parent edf2503ee5
commit ffd13accca
1 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/services/note/create.ts
View file

@ -25,17 +25,14 @@ import isQuote from '../../misc/is-quote';
import { TextElementMention } from '../../mfm/parse/elements/mention'; import { TextElementMention } from '../../mfm/parse/elements/mention';
import { TextElementHashtag } from '../../mfm/parse/elements/hashtag'; import { TextElementHashtag } from '../../mfm/parse/elements/hashtag';
type Type = 'reply' | 'renote' | 'quote' | 'mention'; type NotificationType = 'reply' | 'renote' | 'quote' | 'mention';
/**
* 通知を担当
*/
class NotificationManager { class NotificationManager {
private notifier: IUser; private notifier: IUser;
private note: INote; private note: INote;
private queue: Array<{ private queue: Array<{
target: ILocalUser['_id']; target: ILocalUser['_id'];
reason: Type; reason: NotificationType;
}>; }>;
constructor(notifier: IUser, note: INote) { constructor(notifier: IUser, note: INote) {
@ -44,7 +41,7 @@ class NotificationManager {
this.queue = []; this.queue = [];
} }
public push(notifiee: ILocalUser['_id'], reason: Type) { public push(notifiee: ILocalUser['_id'], reason: NotificationType) {
// 自分自身へは通知しない // 自分自身へは通知しない
if (this.notifier._id.equals(notifiee)) return; if (this.notifier._id.equals(notifiee)) return;
@ -361,7 +358,7 @@ function index(note: INote) {
}); });
} }
async function notifyToWatchersOfRenotee(renote: INote, user: IUser, nm: NotificationManager, type: Type) { async function notifyToWatchersOfRenotee(renote: INote, user: IUser, nm: NotificationManager, type: NotificationType) {
const watchers = await NoteWatching.find({ const watchers = await NoteWatching.find({
noteId: renote._id, noteId: renote._id,
userId: { $ne: user._id } userId: { $ne: user._id }