Allow to remove threads

src/config/roles.js

@@ -10,6 +10,7 @@ const allRoles = {
     'getThread',
     'publicTopics',
     'publicThreads',
+    'deleteThread',
   ],
   admin: ['getUsers', 'manageUsers'],
 };

src/controllers/thread.controller.js

@@ -32,11 +32,22 @@ const allPublic = catchAsync(async (req, res) => {
   res.status(httpStatus.OK).send(threads);
 });
 
+const deleteThread = catchAsync(async (req, res) => {
+  const thread = await threadService.deleteThread(req.params.threadId, req.user, res);
+
+  if (thread.errorCode) {
+    return res.status(thread.errorCode).send(thread.message);
+  }
+
+  res.status(httpStatus.OK).send(thread);
+});
+
 module.exports = {
   createThread,
   userThreads,
   getThread,
   getTopicThreads,
   follow,
   allPublic,
+  deleteThread,
 };

src/routes/v1/threads.route.js

@@ -10,5 +10,6 @@ router.route('/userThreads').get(auth('userThreads'), threadsController.userThre
 router.route('/:threadId').get(auth('getThread'), threadsController.getThread);
 router.route('/topic/:topicId').get(threadsController.getTopicThreads);
 router.route('/follow').post(auth('followThread'), threadsController.follow);
+router.route('/deleteThread/:threadId').delete(auth('deleteThread'), threadsController.deleteThread);
 
 module.exports = router;

src/services/thread.service.js

@@ -1,5 +1,6 @@
 const mongoose = require('mongoose');
-const { Thread, Topic, Follower } = require('../models');
+const { Thread, Topic, Follower, Message } = require('../models');
+const httpStatus = require('http-status');
 
 /**
  * Create a thread
@@ -62,6 +63,23 @@ const allPublic = async () => {
   return threads;
 };
 
+const deleteThread = async (id, user) => {
+  const thread = await Thread.findOne({ _id: id }).select('name slug owner').exec();
+
+  if (user._id.toString() !== thread.owner.toString()) {
+    return {
+      errorCode: httpStatus.UNAUTHORIZED,
+      message: "You're not the owner of this thread",
+    };
+  }
+
+  await Thread.deleteOne({ _id: id });
+  await Follower.deleteMany({ thread });
+  await Message.deleteMany({ thread });
+
+  return thread;
+};
+
 module.exports = {
   createThread,
   userThreads,
@@ -70,4 +88,5 @@ module.exports = {
   follow,
   findByIdFull,
   allPublic,
+  deleteThread,
 };