delete

Author: hilu03

backend/app/controllers/CommentController.scala

@@ -73,5 +73,15 @@ class CommentController @Inject()(
 //      }
 //    }
 
+  def delete(commentId: Int): Action[AnyContent] =
+    authenticatedActionWithUser.async { request =>
+      val deletedBy = request.userToken.userId
+      commentService
+        .deleteComment(commentId, deletedBy)
+        .map { _ =>
+          Ok(Json.toJson(ApiResponse[Unit](s"Comment deleted successfully")))
+        }
+    }
+
 
 }

backend/app/repositories/CommentRepository.scala

@@ -25,4 +25,7 @@ class CommentRepository @Inject()(
     taskComments.filter(_.id === commentId).result.headOption
   }
 
+  def deleteById(commentId: Int): DBIO[Int] = {
+    taskComments.filter(_.id === commentId).delete
+  }
 }

backend/app/services/CommentService.scala

@@ -108,6 +108,35 @@ class CommentService @Inject()(
 //    } yield
 //  }
 
+  def deleteComment(commentId: Int, userId: Int): Future[Int] = {
+    val action = for {
+      existingCommentOpt <- commentRepository.findById(commentId)
+      existingComment <- existingCommentOpt match {
+        case Some(comment) =>
+          DBIO.successful(comment)
+        case None =>
+          DBIO.failed(
+            AppException(
+              message = s"Comment with ID $commentId does not exist.",
+              statusCode = Status.NOT_FOUND
+            )
+          )
+      }
+      _ <- if (existingComment.userId != userId) {
+        DBIO.failed(
+          AppException(
+            message = s"You do not have permission to delete this comment.",
+            statusCode = Status.FORBIDDEN
+          )
+        )
+      } else {
+        DBIO.successful(())
+      }
+      deletedCount <- commentRepository.deleteById(commentId)
+    } yield deletedCount
+    db.run(action.transactionally)
+  }
+
 
 
 }

backend/conf/routes

@@ -79,7 +79,7 @@ PUT     /api/user/profile              controllers.UserProfileController.updateP
 # Task Comment routes
 POST   /api/tasks/:taskId/comments    controllers.CommentController.create(taskId: Int)
 # GET    /api/tasks/:taskId/comments    controllers.CommentController.getCommentsByTaskId(taskId: Int)
-# DELETE /api/comments/:commentId        controllers.CommentController.deleteComment(commentId: Int)
+DELETE /api/comments/:commentId        controllers.CommentController.delete(commentId: Int)
 PUT    /api/comments/:commentId        controllers.CommentController.update(commentId: Int)
 
 #Web socket