feat: add pagination support to GetAllBlogPosts

Implement pagination in the GetAllBlogPosts repository method by
accepting
FilterPagination parameters, applying limit, offset, and orderBy to the
query,
and returning total count along with paginated data. Update related
interfaces
and usecase to support paginated responses. This enables efficient
retrieval
of blog posts with pagination metadata for API consumers.

Author: Kocannn

app/blog_post/delivery/http/http.go

@@ -93,19 +93,31 @@ func (h Handler) DeleteBlogPost(w http.ResponseWriter, r *http.Request) {
 
 // GetAllBlogPosts implements domain.BlogPostHandler.
 func (h Handler) GetAllBlogPosts(w http.ResponseWriter, r *http.Request) {
-	resp, err := h.usecase.GetAllBlogPosts(r.Context())
+	// Ambil parameter pagination dari request
+	pagination, err := domain.GetPaginationFromCtx(r)
+	if err != nil {
+		logrus.Error("failed to parse pagination parameters: ", err)
+		utils.Response(domain.HttpResponse{
+			Code:    http.StatusBadRequest,
+			Message: "Invalid pagination parameters",
+		}, w)
+		return
+	}
+
+	// Panggil usecase dengan parameter pagination
+	data, paginationResponse, err := h.usecase.GetAllBlogPosts(r.Context(), pagination)
 	if err != nil {
 		resp := utils.CustomErrorResponse(err)
 		utils.Response(resp, w)
 		return
 	}
 
 	utils.Response(domain.HttpResponse{
-		Code:    http.StatusOK,
-		Message: "Blog posts retrieved successfully",
-		Data:    resp,
+		Code:       http.StatusOK,
+		Message:    "Blog posts retrieved successfully",
+		Data:       data,
+		Pagination: paginationResponse,
 	}, w)
-
 }
 
 // GetDetailBlogPost implements domain.BlogPostHandler.

app/blog_post/repository/repository.go

@@ -182,29 +182,44 @@ func (r *repository) DeleteBlogPost(ctx context.Context, id uint) error {
 }
 
 // GetAllBlogPosts implements domain.BlogPostRepository.
-func (r *repository) GetAllBlogPosts(ctx context.Context) (data []domain.BlogPost, err error) {
-	// Mengambil data blog posts dengan author dalam satu query
-	err = r.db.DB(ctx).
-		Preload("Author").Find(&data).Error
+func (r *repository) GetAllBlogPosts(ctx context.Context, pagination domain.FilterPagination) ([]domain.BlogPost, int, error) {
+	var data []domain.BlogPost
+	var totalCount int64
+
+	if err := r.db.DB(ctx).Model(&domain.BlogPost{}).Count(&totalCount).Error; err != nil {
+		logrus.Error("failed to count blog posts: ", err)
+		return nil, 0, err
+	}
+
+	offset := pagination.GetOffset()
+	limit := pagination.GetLimit()
+	orderBy := pagination.GetOrderBy()
+
+	query := r.db.DB(ctx).Preload("Author")
+
+	if orderBy != "" {
+		query = query.Order(orderBy)
+	} else {
+		query = query.Order("id DESC")
+	}
+
+	err := query.Limit(limit).Offset(offset).Find(&data).Error
 	if err != nil {
 		logrus.Error("failed to get all blog posts: ", err)
-		return nil, err
+		return nil, 0, err
 	}
 
-	// Mengambil tags untuk setiap blog post
 	for i := range data {
 		var tags []string
 		if err := r.db.DB(ctx).Table("blog_post_tags").
 			Select("tag").
 			Where("blog_post_id = ?", data[i].Id).
-			Pluck("tag", &tags).Error; err != nil {
-			logrus.Error("failed to get tags for blog post ID ", data[i].Id, ": ", err)
-		} else {
+			Pluck("tag", &tags).Error; err == nil {
 			data[i].Tags = tags
 		}
 	}
 
-	return data, nil
+	return data, int(totalCount), nil
 }
 
 func NewRepository(db pkgDB.DatabaseTransaction) domain.BlogPostRepository {

app/blog_post/usecase/usecase.go

@@ -55,13 +55,15 @@ func (uc *usecase) DeleteBlogPost(ctx context.Context, id uint) error {
 }
 
 // GetAllBlogPosts implements domain.BlogPostUsecase.
-func (uc *usecase) GetAllBlogPosts(ctx context.Context) ([]domain.BlogPost, error) {
-	blogPosts, err := uc.repo.GetAllBlogPosts(ctx)
+func (uc *usecase) GetAllBlogPosts(ctx context.Context, pagination domain.FilterPagination) ([]domain.BlogPost, domain.Pagination, error) {
+	blogPosts, totalCount, err := uc.repo.GetAllBlogPosts(ctx, pagination)
 	if err != nil {
 		logrus.Error("failed to get all blog posts: ", err)
-		return nil, err
+		return nil, domain.Pagination{}, err
 	}
-	return blogPosts, nil
+	paginationResponse := domain.NewPagination(totalCount, pagination)
+
+	return blogPosts, paginationResponse, nil
 }
 
 // GetDetailBlogPost implements domain.BlogPostUsecase.

domain/blog_post.go

@@ -19,15 +19,15 @@ type BlogPostUsecase interface {
 	CreateBlogPost(ctx context.Context, data BlogPost, token string) (BlogPost, error)
 	UpdateBlogPost(ctx context.Context, data BlogPost, id uint) error
 	DeleteBlogPost(ctx context.Context, id uint) error
-	GetAllBlogPosts(ctx context.Context) ([]BlogPost, error)
+	GetAllBlogPosts(ctx context.Context, pagination FilterPagination) ([]BlogPost, Pagination, error)
 	GetDetailBlogPost(ctx context.Context, slug string, id uint) (BlogPost, error)
 }
 
 type BlogPostRepository interface {
 	CreateBlogPost(ctx context.Context, data BlogPost) (BlogPost, error)
 	UpdateBlogPost(ctx context.Context, data BlogPost, id uint) error
 	DeleteBlogPost(ctx context.Context, id uint) error
-	GetAllBlogPosts(ctx context.Context) ([]BlogPost, error)
+	GetAllBlogPosts(ctx context.Context, pagination FilterPagination) ([]BlogPost, int, error)
 	GetDetailBlogPost(ctx context.Context, slug, typeFind string, id uint) (BlogPost, error)
 }