From e43c9c0e2181831a0b6244989355d3d7de6493f0 Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Thu, 7 Feb 2019 21:59:18 +0900
Subject: 特定インスタンスからのフォローを全解除できるように
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../admin/federation/remove-all-following.ts       | 41 ++++++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 src/server/api/endpoints/admin/federation/remove-all-following.ts

(limited to 'src/server/api/endpoints/admin/federation')

diff --git a/src/server/api/endpoints/admin/federation/remove-all-following.ts b/src/server/api/endpoints/admin/federation/remove-all-following.ts
new file mode 100644
index 0000000000..1021965b1e
--- /dev/null
+++ b/src/server/api/endpoints/admin/federation/remove-all-following.ts
@@ -0,0 +1,41 @@
+import $ from 'cafy';
+import define from '../../../define';
+import Instance from '../../../../../models/instance';
+import Following from '../../../../../models/following';
+import User from '../../../../../models/user';
+import deleteFollowing from '../../../../../services/following/delete';
+
+export const meta = {
+	requireCredential: true,
+	requireModerator: true,
+
+	params: {
+		host: {
+			validator: $.str
+		}
+	}
+};
+
+export default define(meta, (ps, me) => new Promise(async (res, rej) => {
+	const instance = await Instance
+		.findOne({ host: ps.host });
+
+	if (instance == null) {
+		return rej('instance not found');
+	}
+
+	const followings = await Following.find({
+		'_follower.host': { $ne: null }
+	});
+
+	const pairs = await Promise.all(followings.map(f => Promise.all([
+		User.findOne({ _id: f.followerId }),
+		User.findOne({ _id: f.followeeId })
+	])));
+
+	for (const pair of pairs) {
+		deleteFollowing(pair[0], pair[1]);
+	}
+
+	res();
+}));
-- 
cgit v1.2.3-freya