summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/following/create.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/api/endpoints/following/create.ts')
-rw-r--r--src/server/api/endpoints/following/create.ts11
1 files changed, 2 insertions, 9 deletions
diff --git a/src/server/api/endpoints/following/create.ts b/src/server/api/endpoints/following/create.ts
index 9ccbe20171..0ccac8d83d 100644
--- a/src/server/api/endpoints/following/create.ts
+++ b/src/server/api/endpoints/following/create.ts
@@ -4,7 +4,7 @@
import $ from 'cafy';
import User from '../../../../models/user';
import Following from '../../../../models/following';
-import { createHttp } from '../../../../queue';
+import create from '../../../../services/following/create';
/**
* Follow a user
@@ -50,15 +50,8 @@ module.exports = (params, user) => new Promise(async (res, rej) => {
}
// Create following
- const { _id } = await Following.insert({
- createdAt: new Date(),
- followerId: follower._id,
- followeeId: followee._id
- });
-
- createHttp({ type: 'follow', following: _id }).save();
+ create(follower, followee);
// Send response
res();
-
});