summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/NoteReadService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-07-13 16:16:13 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-07-13 16:16:13 +0900
commit12456b22c53d6247ffb0687d63343acaa35d61b3 (patch)
treef11ac449e3131f316f2d66e957289ea04b301c9f /packages/backend/src/core/NoteReadService.ts
parentUpdate about-misskey.vue (diff)
parentrefactor(backend): `core/activitypub` (#11247) (diff)
downloadmisskey-12456b22c53d6247ffb0687d63343acaa35d61b3.tar.gz
misskey-12456b22c53d6247ffb0687d63343acaa35d61b3.tar.bz2
misskey-12456b22c53d6247ffb0687d63343acaa35d61b3.zip
Merge branch 'develop' of https://github.com/misskey-dev/misskey into develop
Diffstat (limited to 'packages/backend/src/core/NoteReadService.ts')
-rw-r--r--packages/backend/src/core/NoteReadService.ts14
1 files changed, 8 insertions, 6 deletions
diff --git a/packages/backend/src/core/NoteReadService.ts b/packages/backend/src/core/NoteReadService.ts
index b84591e26d..52e9bd369a 100644
--- a/packages/backend/src/core/NoteReadService.ts
+++ b/packages/backend/src/core/NoteReadService.ts
@@ -43,11 +43,13 @@ export class NoteReadService implements OnApplicationShutdown {
//#endregion
// スレッドミュート
- const threadMute = await this.noteThreadMutingsRepository.findOneBy({
- userId: userId,
- threadId: note.threadId ?? note.id,
+ const isThreadMuted = await this.noteThreadMutingsRepository.exist({
+ where: {
+ userId: userId,
+ threadId: note.threadId ?? note.id,
+ },
});
- if (threadMute) return;
+ if (isThreadMuted) return;
const unread = {
id: this.idService.genId(),
@@ -62,9 +64,9 @@ export class NoteReadService implements OnApplicationShutdown {
// 2秒経っても既読にならなかったら「未読の投稿がありますよ」イベントを発行する
setTimeout(2000, 'unread note', { signal: this.#shutdownController.signal }).then(async () => {
- const exist = await this.noteUnreadsRepository.findOneBy({ id: unread.id });
+ const exist = await this.noteUnreadsRepository.exist({ where: { id: unread.id } });
- if (exist == null) return;
+ if (!exist) return;
if (params.isMentioned) {
this.globalEventService.publishMainStream(userId, 'unreadMention', note.id);