feat: 안되겠소, 쏩시다!

packages/backend/src/server/api/endpoints/admin/normalization.ts

@@ -0,0 +1,139 @@
+/*
+ * 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 { bindThis } from '@/decorators.js';
+import { Endpoint } from '@/server/api/endpoint-base.js';
+import { ApiError } from '@/server/api/error.js';
+import type { AbuseUserReportsRepository, FollowingsRepository, UsersRepository } from '@/models/_.js';
+import type { MiUser, MiLocalUser } from '@/models/User.js';
+import { ModerationLogService } from '@/core/ModerationLogService.js';
+import { UserSuspendService } from '@/core/UserSuspendService.js';
+import { RoleService } from '@/core/RoleService.js';
+import { QueueService } from '@/core/QueueService.js';
+import { DeleteAccountService } from '@/core/DeleteAccountService.js';
+import { InstanceActorService } from '@/core/InstanceActorService.js';
+import { ApRendererService } from '@/core/activitypub/ApRendererService.js';
+
+export const meta = {
+	tags: ['admin'],
+
+	requireCredential: true,
+	requireModerator: true,
+	kind: 'write:admin:suspend-user',
+
+	errors: {
+		noSuchUser: {
+			message: 'No such user.',
+			code: 'NO_SUCH_USER',
+			id: '7cc4f851-e2f1-4621-9633-ec9e1d00c01e',
+		},
+		noModerator: {
+			message: 'Can\'t normalize user with moderator permission.',
+			code: 'NO_MODERATOR_NORMALIZATION',
+			id: '5b68a1d3-8ee3-4862-8294-6c7d2d2edd63',
+		},
+	},
+} as const;
+
+export const paramDef = {
+	type: 'object',
+	properties: {
+		userId: { type: 'string', format: 'misskey:id' },
+	},
+	required: ['userId'],
+} as const;
+
+@Injectable()
+export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-disable-line import/no-default-export
+	constructor(
+		@Inject(DI.usersRepository)
+		private usersRepository: UsersRepository,
+
+		@Inject(DI.followingsRepository)
+		private followingsRepository: FollowingsRepository,
+
+		@Inject(DI.abuseUserReportsRepository)
+		private abuseUserReportsRepository: AbuseUserReportsRepository,
+
+		private userSuspendService: UserSuspendService,
+		private roleService: RoleService,
+		private moderationLogService: ModerationLogService,
+		private queueService: QueueService,
+		private deleteAccountService: DeleteAccountService,
+		private instanceActorService: InstanceActorService,
+		private apRendererService: ApRendererService,
+	) {
+		super(meta, paramDef, async (ps, me) => {
+			const user = await this.usersRepository.findOneBy({ id: ps.userId });
+
+			if (user == null) {
+				throw new ApiError(meta.errors.noSuchUser);
+			}
+
+			if (await this.roleService.isModerator(user)) {
+				throw new ApiError(meta.errors.noModerator);
+			}
+
+			await this.usersRepository.update(user.id, {
+				isSuspended: true,
+			});
+
+			await this.moderationLogService.log(me, 'normalize', {
+				userId: user.id,
+				userUsername: user.username,
+				userHost: user.host,
+			});
+
+			await this.resolveAllReports(user, me).catch(e => {});
+			await this.userSuspendService.doPostSuspend(user).catch(e => {});
+			await this.unFollowAll(user).catch(e => {});
+			await this.deleteAccountService.deleteAccount(user, true, me);
+		});
+	}
+
+	@bindThis
+	private async resolveAllReports(user: MiUser, me: MiLocalUser) {
+		const reports = await this.abuseUserReportsRepository.findBy({ targetUserId: user.id });
+
+		for (const report of reports) {
+			if (report.targetUserHost != null) {
+				const actor = await this.instanceActorService.getInstanceActor();
+				const targetUser = await this.usersRepository.findOneByOrFail({ id: report.targetUserId });
+
+				this.queueService.deliver(actor, this.apRendererService.addContext(this.apRendererService.renderFlag(actor, targetUser.uri!, report.comment)), targetUser.inbox, false);
+			}
+
+			await this.abuseUserReportsRepository.update(report.id, {
+				resolved: true,
+				assigneeId: me.id,
+				forwarded: user.host !== null,
+			});
+		}
+	}
+
+	@bindThis
+	private async unFollowAll(user: MiUser) {
+		const followings = await this.followingsRepository.findBy({
+			followerId: user.id,
+		});
+		const followers = await this.followingsRepository.findBy({
+			followeeId: user.id,
+		});
+
+		const followingPairs = await Promise.all(followings.map(f => Promise.all([
+			this.usersRepository.findOneByOrFail({ id: f.followerId }),
+			this.usersRepository.findOneByOrFail({ id: f.followeeId }),
+		]).then(([from, to]) => [{ id: from.id }, { id: to.id }])));
+		const followerPairs = await Promise.all(followers.map(f => Promise.all([
+			this.usersRepository.findOneByOrFail({ id: f.followerId }),
+			this.usersRepository.findOneByOrFail({ id: f.followeeId }),
+		]).then(([from, to]) => [{ id: from.id }, { id: to.id }])));
+
+		await this.queueService.createUnfollowJob(followingPairs.map(p => ({ from: p[0], to: p[1], silent: true })));
+		await this.queueService.createUnfollowJob(followerPairs.map(p => ({ from: p[0], to: p[1], silent: true })));
+	}
+}