feat: add retrieve post replies with pagination

Author: ainunns

dto/post_dto.go

@@ -26,6 +26,7 @@ const (
 var (
 	ErrCreatePost     = errors.New("failed to create post")
 	ErrGetPostById    = errors.New("post not found")
+	ErrGetPostReplies = errors.New("failed to get post replies")
 	ErrParseParentID  = errors.New("failed to parse parent id")
 	ErrDeletePostById = errors.New("failed to delete post")
 	ErrUpdatePostById = errors.New("failed to update post")
@@ -44,6 +45,12 @@ type (
 		User     UserResponse `json:"user"`
 	}
 
+	PostRepliesResponse struct {
+		PostResponse
+		Replies []PostResponse `json:"replies"`
+		PaginationResponse
+	}
+
 	PostUpdateRequest struct {
 		Text string `json:"text" form:"text" binding:"required"`
 	}
@@ -57,4 +64,9 @@ type (
 		Posts []entity.Post `json:"posts"`
 		PaginationResponse
 	}
+
+	GetAllRepliesRepositoryResponse struct {
+		Replies []entity.Post `json:"replies"`
+		PaginationResponse
+	}
 )

repository/post_repository.go

@@ -16,6 +16,7 @@ type (
 		DeletePostById(ctx context.Context, tx *gorm.DB, postId uuid.UUID) error
 		UpdatePostById(ctx context.Context, tx *gorm.DB, postId uuid.UUID, post entity.Post) (entity.Post, error)
 		GetAllPostsWithPagination(ctx context.Context, tx *gorm.DB, req dto.PaginationRequest) (dto.GetAllPostsRepositoryResponse, error)
+		GetAllPostRepliesWithPagination(ctx context.Context, tx *gorm.DB, postId uuid.UUID, req dto.PaginationRequest) (dto.GetAllRepliesRepositoryResponse, error)
 	}
 
 	postRepository struct {
@@ -124,3 +125,39 @@ func (r *postRepository) GetAllPostsWithPagination(ctx context.Context, tx *gorm
 		},
 	}, err
 }
+
+func (r *postRepository) GetAllPostRepliesWithPagination(ctx context.Context, tx *gorm.DB, postId uuid.UUID, req dto.PaginationRequest) (dto.GetAllRepliesRepositoryResponse, error) {
+	if tx == nil {
+		tx = r.db
+	}
+
+	var replies []entity.Post
+	var err error
+	var count int64
+
+	req.Default()
+
+	query := tx.WithContext(ctx).Model(&entity.Post{}).Joins("User").Where("posts.parent_id = ?", postId).Order("created_at DESC")
+	if req.Search != "" {
+		query = query.Where("text LIKE ?", "%"+req.Search+"%")
+	}
+
+	if err := query.Count(&count).Error; err != nil {
+		return dto.GetAllRepliesRepositoryResponse{}, err
+	}
+
+	if err := query.Scopes(Paginate(req)).Find(&replies).Error; err != nil {
+		return dto.GetAllRepliesRepositoryResponse{}, err
+	}
+
+	totalPage := TotalPage(count, int64(req.PerPage))
+	return dto.GetAllRepliesRepositoryResponse{
+		Replies: replies,
+		PaginationResponse: dto.PaginationResponse{
+			Page:    req.Page,
+			PerPage: req.PerPage,
+			Count:   count,
+			MaxPage: totalPage,
+		},
+	}, err
+}

service/post_service.go

@@ -12,7 +12,7 @@ import (
 type (
 	PostService interface {
 		CreatePost(ctx context.Context, userId string, req dto.PostCreateRequest) (dto.PostResponse, error)
-		GetPostById(ctx context.Context, postId uuid.UUID) (dto.PostResponse, error)
+		GetPostById(ctx context.Context, postId uuid.UUID) (dto.PostRepliesResponse, error)
 		DeletePostById(ctx context.Context, postId uuid.UUID) error
 		UpdatePostById(ctx context.Context, userId string, postId uuid.UUID, req dto.PostUpdateRequest) (dto.PostResponse, error)
 		GetAllPosts(ctx context.Context, req dto.PaginationRequest) (dto.PostPaginationResponse, error)
@@ -71,24 +71,57 @@ func (s *postService) CreatePost(ctx context.Context, userId string, req dto.Pos
 	}, nil
 }
 
-func (s *postService) GetPostById(ctx context.Context, postId uuid.UUID) (dto.PostResponse, error) {
+func (s *postService) GetPostById(ctx context.Context, postId uuid.UUID) (dto.PostRepliesResponse, error) {
 	post, err := s.postRepo.GetPostById(ctx, nil, postId)
 	if err != nil {
-		return dto.PostResponse{}, dto.ErrGetPostById
+		return dto.PostRepliesResponse{}, dto.ErrGetPostById
 	}
 
-	return dto.PostResponse{
-		ID:       post.ID.String(),
-		Text:     post.Text,
-		ParentID: post.ParentID,
-		User: dto.UserResponse{
-			ID:       post.UserID.String(),
-			Name:     post.User.Name,
-			Bio:      post.User.Bio,
-			UserName: post.User.Username,
-			ImageUrl: post.User.ImageUrl,
+	replies, err := s.postRepo.GetAllPostRepliesWithPagination(ctx, nil, postId, dto.PaginationRequest{})
+	if err != nil {
+		return dto.PostRepliesResponse{}, dto.ErrGetPostReplies
+	}
+
+	var data []dto.PostResponse
+	for _, reply := range replies.Replies {
+		datum := dto.PostResponse{
+			ID:       reply.ID.String(),
+			Text:     reply.Text,
+			ParentID: reply.ParentID,
+			User: dto.UserResponse{
+				ID:       reply.UserID.String(),
+				Name:     reply.User.Name,
+				Bio:      reply.User.Bio,
+				UserName: reply.User.Username,
+				ImageUrl: reply.User.ImageUrl,
+			},
+		}
+
+		data = append(data, datum)
+	}
+
+	return dto.PostRepliesResponse{
+			PostResponse: dto.PostResponse{
+				ID:       post.ID.String(),
+				Text:     post.Text,
+				ParentID: post.ParentID,
+				User: dto.UserResponse{
+					ID:       post.UserID.String(),
+					Name:     post.User.Name,
+					Bio:      post.User.Bio,
+					UserName: post.User.Username,
+					ImageUrl: post.User.ImageUrl,
+				},
+			},
+			Replies: data,
+			PaginationResponse: dto.PaginationResponse{
+				Page:    replies.Page,
+				PerPage: replies.PerPage,
+				MaxPage: replies.MaxPage,
+				Count:   replies.Count,
+			},
 		},
-	}, nil
+		nil
 }
 
 func (s *postService) DeletePostById(ctx context.Context, postId uuid.UUID) error {