import { Notes } from "@/models/index.js"; import define from "../../define.js"; import { makePaginationQuery } from "../../common/make-pagination-query.js"; import { generateVisibilityQuery } from "../../common/generate-visibility-query.js"; import { generateMutedUserQuery } from "../../common/generate-muted-user-query.js"; import { generateBlockedUserQuery } from "../../common/generate-block-query.js"; export const meta = { tags: ["notes"], requireCredential: false, requireCredentialPrivateMode: true, res: { type: "array", optional: false, nullable: false, items: { type: "object", optional: false, nullable: false, ref: "Note", }, }, } as const; export const paramDef = { type: "object", properties: { noteId: { type: "string", format: "misskey:id" }, sinceId: { type: "string", format: "misskey:id" }, untilId: { type: "string", format: "misskey:id" }, limit: { type: "integer", minimum: 1, maximum: 100, default: 10 }, }, required: ["noteId"], } as const; export default define(meta, paramDef, async (ps, user) => { const query = makePaginationQuery( Notes.createQueryBuilder("note"), ps.sinceId, ps.untilId, ) .andWhere("note.replyId = :replyId", { replyId: ps.noteId }) .innerJoinAndSelect("note.user", "user") .leftJoinAndSelect("user.avatar", "avatar") .leftJoinAndSelect("user.banner", "banner") .leftJoinAndSelect("note.reply", "reply") .leftJoinAndSelect("note.renote", "renote") .leftJoinAndSelect("reply.user", "replyUser") .leftJoinAndSelect("replyUser.avatar", "replyUserAvatar") .leftJoinAndSelect("replyUser.banner", "replyUserBanner") .leftJoinAndSelect("renote.user", "renoteUser") .leftJoinAndSelect("renoteUser.avatar", "renoteUserAvatar") .leftJoinAndSelect("renoteUser.banner", "renoteUserBanner"); generateVisibilityQuery(query, user); if (user) generateMutedUserQuery(query, user); if (user) generateBlockedUserQuery(query, user); // We fetch more than requested because some may be filtered out, and if there's less than // requested, the pagination stops. const found = []; const take = Math.floor(ps.limit * 1.5); let skip = 0; while (found.length < ps.limit) { const notes = await query.take(take).skip(skip).getMany(); found.push(...(await Notes.packMany(notes, user))); skip += take; if (notes.length < take) break; } if (found.length > ps.limit) { found.length = ps.limit; } return found; });