summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/NoteReadService.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/core/NoteReadService.ts')
-rw-r--r--packages/backend/src/core/NoteReadService.ts18
1 files changed, 9 insertions, 9 deletions
diff --git a/packages/backend/src/core/NoteReadService.ts b/packages/backend/src/core/NoteReadService.ts
index f4395725d6..84983d600e 100644
--- a/packages/backend/src/core/NoteReadService.ts
+++ b/packages/backend/src/core/NoteReadService.ts
@@ -40,7 +40,7 @@ export class NoteReadService {
private userEntityService: UserEntityService,
private idService: IdService,
- private globalEventServie: GlobalEventService,
+ private globalEventService: GlobalEventService,
private notificationService: NotificationService,
private antennaService: AntennaService,
private pushNotificationService: PushNotificationService,
@@ -87,13 +87,13 @@ export class NoteReadService {
if (exist == null) return;
if (params.isMentioned) {
- this.globalEventServie.publishMainStream(userId, 'unreadMention', note.id);
+ this.globalEventService.publishMainStream(userId, 'unreadMention', note.id);
}
if (params.isSpecified) {
- this.globalEventServie.publishMainStream(userId, 'unreadSpecifiedNote', note.id);
+ this.globalEventService.publishMainStream(userId, 'unreadSpecifiedNote', note.id);
}
if (note.channelId) {
- this.globalEventServie.publishMainStream(userId, 'unreadChannel', note.id);
+ this.globalEventService.publishMainStream(userId, 'unreadChannel', note.id);
}
}, 2000);
}
@@ -155,7 +155,7 @@ export class NoteReadService {
}).then(mentionsCount => {
if (mentionsCount === 0) {
// 全て既読になったイベントを発行
- this.globalEventServie.publishMainStream(userId, 'readAllUnreadMentions');
+ this.globalEventService.publishMainStream(userId, 'readAllUnreadMentions');
}
});
@@ -165,7 +165,7 @@ export class NoteReadService {
}).then(specifiedCount => {
if (specifiedCount === 0) {
// 全て既読になったイベントを発行
- this.globalEventServie.publishMainStream(userId, 'readAllUnreadSpecifiedNotes');
+ this.globalEventService.publishMainStream(userId, 'readAllUnreadSpecifiedNotes');
}
});
@@ -175,7 +175,7 @@ export class NoteReadService {
}).then(channelNoteCount => {
if (channelNoteCount === 0) {
// 全て既読になったイベントを発行
- this.globalEventServie.publishMainStream(userId, 'readAllChannels');
+ this.globalEventService.publishMainStream(userId, 'readAllChannels');
}
});
@@ -200,14 +200,14 @@ export class NoteReadService {
});
if (count === 0) {
- this.globalEventServie.publishMainStream(userId, 'readAntenna', antenna);
+ this.globalEventService.publishMainStream(userId, 'readAntenna', antenna);
this.pushNotificationService.pushNotification(userId, 'readAntenna', { antennaId: antenna.id });
}
}
this.userEntityService.getHasUnreadAntenna(userId).then(unread => {
if (!unread) {
- this.globalEventServie.publishMainStream(userId, 'readAllAntennas');
+ this.globalEventService.publishMainStream(userId, 'readAllAntennas');
this.pushNotificationService.pushNotification(userId, 'readAllAntennas', undefined);
}
});