Added delete poll route in backend

backend/src/controllers/poll.controller.js

@@ -1,4 +1,9 @@
-import { createPollService, getAllCreatedPollsService, getPollDataService } from "../services/poll.service.js";
+import {
+  createPollService,
+  deletePollService,
+  getAllCreatedPollsService,
+  getPollDataService,
+} from "../services/poll.service.js";
 
 export async function createPollController(req, res) {
   try {
@@ -10,7 +15,6 @@ export async function createPollController(req, res) {
       message: "Poll created successfully",
       data: poll,
     });
-
   } catch (err) {
     if (err.statusCode) {
       res.status(err.statusCode).json({
@@ -26,7 +30,6 @@ export async function createPollController(req, res) {
   }
 }
 
-
 export async function getPollDataController(req, res) {
   try {
     const pollId = req.params.pollId;
@@ -36,8 +39,7 @@ export async function getPollDataController(req, res) {
       message: "Poll data fetched successfully",
       data: poll,
     });
-  }
+  } catch (err) {
-  catch(err) {
     if (err.statusCode) {
       res.status(err.statusCode).json({
         success: false,
@@ -61,6 +63,31 @@ export async function getAllCreatedPollsController(req, res) {
       message: "Polls fetched successfully",
       data: polls,
     });
+  } catch (err) {
+    console.log(err);
+    if (err.statusCode) {
+      res.status(err.statusCode).json({
+        success: false,
+        message: err.message,
+      });
+    } else {
+      res.status(500).json({
+        success: false,
+        message: err.message,
+      });
+    }
+  }
+}
+
+export async function deletePollController(req, res) {
+  try {
+    const reqPollId = req.params.pollId;
+    const deletedPoll = await deletePollService(reqPollId, req.user);
+    res.json({
+      success : true,
+      message : "Poll deleted successfully.",
+      data : deletedPoll
+    })  
   } 
   catch (err) {
     console.log(err);

backend/src/controllers/user.controller.js

@@ -84,3 +84,4 @@ export async function logOutController(req, res) {
     })
   }
 }
+

backend/src/repositories/poll.repo.js

@@ -29,3 +29,13 @@ export async function findPollsByCreatorId(id) {
         throw err;
     }
 }
+
+export async function deletePollById(id) {
+    try {
+        const poll = await PollModel.findByIdAndDelete(id);
+        return poll;
+    }
+    catch(err){
+        throw err;
+    }
+}

backend/src/routes/v1/poll.route.js

@@ -1,6 +1,6 @@
 import express from "express";
 import { verifyToken } from "../../middlwares/verifyToken.js";
-import { createPollController, getAllCreatedPollsController, getPollDataController } from "../../controllers/poll.controller.js";
+import { createPollController, deletePollController, getAllCreatedPollsController, getPollDataController } from "../../controllers/poll.controller.js";
 import pollDataSchema from "../../validations/pollDataValidation.js";
 import validator from "../../validations/validator.js";
 const pollRouter = express.Router();
@@ -99,4 +99,6 @@ pollRouter.get("/data/:pollId", verifyToken, getPollDataController);
  */
 pollRouter.get("/created", verifyToken, getAllCreatedPollsController);
 
+pollRouter.delete("/delete/:pollId", verifyToken, deletePollController);
+
 export default pollRouter;

backend/src/services/poll.service.js

@@ -49,3 +49,29 @@ export async function getAllCreatedPollsService(id) {
         throw err;
     }
 }
+
+export async function deletePollService(pollId, user) {
+    try {
+        const userId = user._id;
+        const poll = await findPollById(pollId);
+        if (!poll) {
+            throw {
+                statusCode: 404,
+                message: "Poll not found"
+            }
+        }
+        console.log(poll?.creatorId._id.toString(), userId.toString(), user);
+        if (poll.creatorId._id.toString() !== userId.toString()) {
+            throw {
+                statusCode: 401,
+                message: "Unauthorized"
+            }
+        }
+        const deletedPoll = await deletePollService(pollId);
+        return deletedPoll;
+    }
+
+    catch(err){
+        throw err;
+    }
+}