import { Inject, Injectable } from '@nestjs/common'; import type { NotesRepository, NoteThreadMutingsRepository, NoteFavoritesRepository } from '@/models/index.js'; import { Endpoint } from '@/server/api/endpoint-base.js'; import { DI } from '@/di-symbols.js'; export const meta = { tags: ['notes'], requireCredential: true, res: { type: 'object', optional: false, nullable: false, properties: { isFavorited: { type: 'boolean', optional: false, nullable: false, }, isMutedThread: { type: 'boolean', optional: false, nullable: false, }, }, }, } as const; export const paramDef = { type: 'object', properties: { noteId: { type: 'string', format: 'misskey:id' }, }, required: ['noteId'], } as const; // eslint-disable-next-line import/no-default-export @Injectable() export default class extends Endpoint { constructor( @Inject(DI.notesRepository) private notesRepository: NotesRepository, @Inject(DI.noteThreadMutingsRepository) private noteThreadMutingsRepository: NoteThreadMutingsRepository, @Inject(DI.noteFavoritesRepository) private noteFavoritesRepository: NoteFavoritesRepository, ) { super(meta, paramDef, async (ps, me) => { const note = await this.notesRepository.findOneByOrFail({ id: ps.noteId }); const [favorite, threadMuting] = await Promise.all([ this.noteFavoritesRepository.count({ where: { userId: me.id, noteId: note.id, }, take: 1, }), this.noteThreadMutingsRepository.count({ where: { userId: me.id, threadId: note.threadId || note.id, }, take: 1, }), ]); return { isFavorited: favorite !== 0, isMutedThread: threadMuting !== 0, }; }); } }