summaryrefslogtreecommitdiff
path: root/src/api/endpoints/following/delete.ts
diff options
context:
space:
mode:
authorAkihiko Odaki <nekomanma@pixiv.co.jp>2018-03-29 01:20:40 +0900
committerAkihiko Odaki <nekomanma@pixiv.co.jp>2018-03-29 01:54:41 +0900
commit90f8fe7e538bb7e52d2558152a0390e693f39b11 (patch)
tree0f830887053c8f352b1cd0c13ca715fd14c1f030 /src/api/endpoints/following/delete.ts
parentImplement remote account resolution (diff)
downloadsharkey-90f8fe7e538bb7e52d2558152a0390e693f39b11.tar.gz
sharkey-90f8fe7e538bb7e52d2558152a0390e693f39b11.tar.bz2
sharkey-90f8fe7e538bb7e52d2558152a0390e693f39b11.zip
Introduce processor
Diffstat (limited to 'src/api/endpoints/following/delete.ts')
-rw-r--r--src/api/endpoints/following/delete.ts81
1 files changed, 0 insertions, 81 deletions
diff --git a/src/api/endpoints/following/delete.ts b/src/api/endpoints/following/delete.ts
deleted file mode 100644
index 64b9a8cecb..0000000000
--- a/src/api/endpoints/following/delete.ts
+++ /dev/null
@@ -1,81 +0,0 @@
-/**
- * Module dependencies
- */
-import $ from 'cafy';
-import User, { pack as packUser } from '../../models/user';
-import Following from '../../models/following';
-import event from '../../event';
-
-/**
- * Unfollow a user
- *
- * @param {any} params
- * @param {any} user
- * @return {Promise<any>}
- */
-module.exports = (params, user) => new Promise(async (res, rej) => {
- const follower = user;
-
- // Get 'user_id' parameter
- const [userId, userIdErr] = $(params.user_id).id().$;
- if (userIdErr) return rej('invalid user_id param');
-
- // Check if the followee is yourself
- if (user._id.equals(userId)) {
- return rej('followee is yourself');
- }
-
- // Get followee
- const followee = await User.findOne({
- _id: userId
- }, {
- fields: {
- data: false,
- 'account.profile': false
- }
- });
-
- if (followee === null) {
- return rej('user not found');
- }
-
- // Check not following
- const exist = await Following.findOne({
- follower_id: follower._id,
- followee_id: followee._id,
- deleted_at: { $exists: false }
- });
-
- if (exist === null) {
- return rej('already not following');
- }
-
- // Delete following
- await Following.update({
- _id: exist._id
- }, {
- $set: {
- deleted_at: new Date()
- }
- });
-
- // Send response
- res();
-
- // Decrement following count
- User.update({ _id: follower._id }, {
- $inc: {
- following_count: -1
- }
- });
-
- // Decrement followers count
- User.update({ _id: followee._id }, {
- $inc: {
- followers_count: -1
- }
- });
-
- // Publish follow event
- event(follower._id, 'unfollow', await packUser(followee, follower));
-});