summaryrefslogtreecommitdiff
path: root/packages/backend/src/services/note/unread.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-09-18 03:27:08 +0900
committerGitHub <noreply@github.com>2022-09-18 03:27:08 +0900
commitb75184ec8e3436200bacdcd832e3324702553d20 (patch)
tree8b7e316f29e95df921db57289c8b8da476d18f07 /packages/backend/src/services/note/unread.ts
parentUpdate ROADMAP.md (diff)
downloadmisskey-b75184ec8e3436200bacdcd832e3324702553d20.tar.gz
misskey-b75184ec8e3436200bacdcd832e3324702553d20.tar.bz2
misskey-b75184ec8e3436200bacdcd832e3324702553d20.zip
なんかもうめっちゃ変えた
Diffstat (limited to 'packages/backend/src/services/note/unread.ts')
-rw-r--r--packages/backend/src/services/note/unread.ts55
1 files changed, 0 insertions, 55 deletions
diff --git a/packages/backend/src/services/note/unread.ts b/packages/backend/src/services/note/unread.ts
deleted file mode 100644
index d9ed711e03..0000000000
--- a/packages/backend/src/services/note/unread.ts
+++ /dev/null
@@ -1,55 +0,0 @@
-import { Note } from '@/models/entities/note.js';
-import { publishMainStream } from '@/services/stream.js';
-import { User } from '@/models/entities/user.js';
-import { Mutings, NoteThreadMutings, NoteUnreads } from '@/models/index.js';
-import { genId } from '@/misc/gen-id.js';
-
-export async function insertNoteUnread(userId: User['id'], note: Note, params: {
- // NOTE: isSpecifiedがtrueならisMentionedは必ずfalse
- isSpecified: boolean;
- isMentioned: boolean;
-}) {
- //#region ミュートしているなら無視
- // TODO: 現在の仕様ではChannelにミュートは適用されないのでよしなにケアする
- const mute = await Mutings.findBy({
- muterId: userId,
- });
- if (mute.map(m => m.muteeId).includes(note.userId)) return;
- //#endregion
-
- // スレッドミュート
- const threadMute = await NoteThreadMutings.findOneBy({
- userId: userId,
- threadId: note.threadId || note.id,
- });
- if (threadMute) return;
-
- const unread = {
- id: genId(),
- noteId: note.id,
- userId: userId,
- isSpecified: params.isSpecified,
- isMentioned: params.isMentioned,
- noteChannelId: note.channelId,
- noteUserId: note.userId,
- };
-
- await NoteUnreads.insert(unread);
-
- // 2秒経っても既読にならなかったら「未読の投稿がありますよ」イベントを発行する
- setTimeout(async () => {
- const exist = await NoteUnreads.findOneBy({ id: unread.id });
-
- if (exist == null) return;
-
- if (params.isMentioned) {
- publishMainStream(userId, 'unreadMention', note.id);
- }
- if (params.isSpecified) {
- publishMainStream(userId, 'unreadSpecifiedNote', note.id);
- }
- if (note.channelId) {
- publishMainStream(userId, 'unreadChannel', note.id);
- }
- }, 2000);
-}