get comments by task id

Author: hilu03

backend/app/controllers/CommentController.scala

@@ -58,20 +58,20 @@ class CommentController @Inject()(
       }
     }
 
-//  def getCommentsByTaskId(taskId: Int): Action[AnyContent] =
-//    authenticatedActionWithUser.async { request =>
-//      val userId = request.userToken.userId
-//      commentService.getCommentsByTaskId(taskId, userId).map { comments =>
-//        Ok(
-//          Json.toJson(
-//            ApiResponse(
-//              s"Comments retrieved successfully for task ID: $taskId",
-//              comments
-//            )
-//          )
-//        )
-//      }
-//    }
+  def getCommentsByTaskId(taskId: Int): Action[AnyContent] =
+    authenticatedActionWithUser.async { request =>
+      val userId = request.userToken.userId
+      commentService.getCommentsByTaskId(taskId, userId).map { comments =>
+        Ok(
+          Json.toJson(
+            ApiResponse.success(
+              s"Comments retrieved successfully for task ID: $taskId",
+              comments
+            )
+          )
+        )
+      }
+    }
 
   def delete(commentId: Int): Action[AnyContent] =
     authenticatedActionWithUser.async { request =>

backend/app/dto/response/comment/CommentResponse.scala

@@ -0,0 +1,18 @@
+package dto.response.comment
+
+import dto.request.comment.CommentChunk
+import play.api.libs.json.{JsValue, Json, OFormat}
+
+import java.time.Instant
+
+case class CommentResponse(commentId: Int,
+                           userId: Int,
+                           name: String,
+                           taskId: Int,
+                           content: JsValue,
+                           createdAt: Instant,
+                           updatedAt: Instant)
+
+object CommentResponse {
+  implicit val format: OFormat[CommentResponse] = Json.format[CommentResponse]
+}

backend/app/repositories/CommentRepository.scala

@@ -1,7 +1,9 @@
 package repositories
 
+import dto.request.comment.CommentChunk
+import dto.response.comment.CommentResponse
 import models.entities.TaskComment
-import models.tables.TableRegistry.taskComments
+import models.tables.TableRegistry.{taskComments, users}
 import play.api.db.slick.{DatabaseConfigProvider, HasDatabaseConfigProvider}
 import slick.jdbc.JdbcProfile
 
@@ -28,4 +30,26 @@ class CommentRepository @Inject()(
   def deleteById(commentId: Int): DBIO[Int] = {
     taskComments.filter(_.id === commentId).delete
   }
+
+  def findByTaskId(taskId: Int): DBIO[Seq[CommentResponse]] = {
+    val query = taskComments
+      .filter(_.taskId === taskId)
+      .join(users).on(_.userId === _.id)
+      .sortBy { case (c, _) => c.updatedAt.desc }
+
+    query.result.map { rows =>
+      rows.map { case (c, u) =>
+        CommentResponse(
+          commentId = c.id.get,
+          userId = c.userId,
+          name = u.name,
+          taskId = taskId,
+          content = c.content,
+          createdAt = c.createdAt,
+          updatedAt = c.updatedAt
+        )
+      }
+    }
+  }
+
 }

backend/app/services/CommentService.scala

@@ -1,6 +1,7 @@
 package services
 
 import dto.request.comment.CreateUpdateCommentRequest
+import dto.response.comment.CommentResponse
 import exception.AppException
 import models.entities.TaskComment
 import play.api.db.slick.{DatabaseConfigProvider, HasDatabaseConfigProvider}
@@ -9,6 +10,7 @@ import play.api.libs.json.Json
 import repositories.{CommentRepository, TaskRepository}
 import slick.jdbc.JdbcProfile
 
+import java.time.Instant
 import javax.inject.{Inject, Singleton}
 import scala.concurrent.{ExecutionContext, Future}
 
@@ -78,35 +80,37 @@ class CommentService @Inject()(
         DBIO.successful(())
       }
       updatedComment = existingComment.copy(
-        content = Json.toJson(request.content)
+        content = Json.toJson(request.content),
+        updatedAt = Instant.now()
       )
       updateCount <- commentRepository.update(updatedComment)
     } yield updateCount
 
     db.run(action.transactionally)
   }
 
-//  def getCommentsByTaskId(taskId: Int, userId: Int) = {
-//    val action = for {
-//      taskOpt <- taskRepository.findTaskAndProjectIdIfUserInProject(
-//        taskId,
-//        userId
-//      )
-//      _ <- taskOpt match {
-//        case Some((_, _)) =>
-//          DBIO.successful(())
-//        case _ =>
-//          DBIO.failed(
-//            AppException(
-//              message = s"Task with ID $taskId does not exist or you do not have access.",
-//              statusCode = Status.NOT_FOUND
-//            )
-//          )
-//      }
-//
-//
-//    } yield
-//  }
+  def getCommentsByTaskId(taskId: Int, userId: Int): Future[Seq[CommentResponse]] = {
+    val action = for {
+      taskOpt <- taskRepository.findTaskAndProjectIdIfUserInProject(
+        taskId,
+        userId
+      )
+      _ <- taskOpt match {
+        case Some((_, _)) =>
+          DBIO.successful(())
+        case _ =>
+          DBIO.failed(
+            AppException(
+              message = s"Task with ID $taskId does not exist or you do not have access.",
+              statusCode = Status.NOT_FOUND
+            )
+          )
+      }
+      comments <- commentRepository.findByTaskId(taskId)
+    } yield comments
+
+    db.run(action.transactionally)
+  }
 
   def deleteComment(commentId: Int, userId: Int): Future[Int] = {
     val action = for {

backend/conf/routes

@@ -78,7 +78,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)
+GET    /api/tasks/:taskId/comments    controllers.CommentController.getCommentsByTaskId(taskId: Int)
 DELETE /api/comments/:commentId        controllers.CommentController.delete(commentId: Int)
 PUT    /api/comments/:commentId        controllers.CommentController.update(commentId: Int)