diff --git a/src/server/api/endpoints/admin/suspend-user.ts b/src/server/api/endpoints/admin/suspend-user.ts index 83b39fb0b..0a2d30953 100644 --- a/src/server/api/endpoints/admin/suspend-user.ts +++ b/src/server/api/endpoints/admin/suspend-user.ts @@ -1,7 +1,9 @@ import $ from 'cafy'; import ID, { transform } from '../../../../misc/cafy-id'; import define from '../../define'; -import User from '../../../../models/user'; +import User, { IUser } from '../../../../models/user'; +import Following from '../../../../models/following'; +import deleteFollowing from '../../../../services/following/delete'; export const meta = { desc: { @@ -51,5 +53,25 @@ export default define(meta, async (ps) => { } }); + unFollowAll(user); + return; }); + +async function unFollowAll(follower: IUser) { + const followings = await Following.find({ + followerId: follower._id + }); + + for (const following of followings) { + const followee = await User.findOne({ + _id: following.followeeId + }); + + if (followee == null) { + throw `Cant find followee ${following.followeeId}`; + } + + await deleteFollowing(follower, followee, true); + } +} diff --git a/src/services/following/delete.ts b/src/services/following/delete.ts index 28268f1fd..d85c8472b 100644 --- a/src/services/following/delete.ts +++ b/src/services/following/delete.ts @@ -13,7 +13,7 @@ import instanceChart from '../../services/chart/instance'; const logger = new Logger('following/delete'); -export default async function(follower: IUser, followee: IUser) { +export default async function(follower: IUser, followee: IUser, silent = false) { const following = await Following.findOne({ followerId: follower._id, followeeId: followee._id @@ -71,7 +71,7 @@ export default async function(follower: IUser, followee: IUser) { perUserFollowingChart.update(follower, followee, false); // Publish unfollow event - if (isLocalUser(follower)) { + if (!silent && isLocalUser(follower)) { packUser(followee, follower, { detail: true }).then(packed => publishMainStream(follower._id, 'unfollow', packed));