/* * SPDX-FileCopyrightText: syuilo and misskey-project * SPDX-License-Identifier: AGPL-3.0-only */ import { Inject, Injectable } from '@nestjs/common'; import { DI } from '@/di-symbols.js'; import type { FollowRequestsRepository } from '@/models/_.js'; import type { MiUser } from '@/models/User.js'; import type { MiFollowRequest } from '@/models/FollowRequest.js'; import { bindThis } from '@/decorators.js'; import { Packed } from '@/misc/json-schema.js'; import { UserEntityService } from './UserEntityService.js'; @Injectable() export class FollowRequestEntityService { constructor( @Inject(DI.followRequestsRepository) private followRequestsRepository: FollowRequestsRepository, private userEntityService: UserEntityService, ) { } @bindThis public async pack( src: MiFollowRequest['id'] | MiFollowRequest, me: { id: MiUser['id'] } | null | undefined, ) : Promise> { const request = typeof src === 'object' ? src : await this.followRequestsRepository.findOneByOrFail({ id: src }); return { id: request.id, follower: await this.userEntityService.pack(request.followerId, me), followee: await this.userEntityService.pack(request.followeeId, me), }; } @bindThis public async packMany( requests: (MiFollowRequest['id'] | MiFollowRequest)[], me: { id: MiUser['id'] } | null | undefined, ) : Promise[]> { return (await Promise.allSettled(requests.map(x => this.pack(x, me)))) .filter(result => result.status === 'fulfilled') .map(result => (result as PromiseFulfilledResult>).value); } }