feat: add get all posts endpoint

Author: ainunns

controller/post_controller.go

@@ -17,6 +17,7 @@ type (
 		GetPostById(ctx *gin.Context)
 		DeletePostById(ctx *gin.Context)
 		UpdatePostById(ctx *gin.Context)
+		GetAllPosts(ctx *gin.Context)
 	}
 
 	postController struct {
@@ -113,3 +114,28 @@ func (c *postController) UpdatePostById(ctx *gin.Context) {
 	res := utils.BuildResponseSuccess(dto.MESSAGE_SUCCESS_UPDATE_POST, result)
 	ctx.JSON(http.StatusOK, res)
 }
+
+func (c *postController) GetAllPosts(ctx *gin.Context) {
+	var req dto.PaginationRequest
+	if err := ctx.ShouldBind(&req); err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_POST_DATA_FROM_BODY, err.Error(), nil)
+		ctx.AbortWithStatusJSON(http.StatusBadRequest, res)
+		return
+	}
+
+	posts, err := c.postService.GetAllPosts(ctx.Request.Context(), req)
+	if err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_ALL_POSTS, err.Error(), nil)
+		ctx.JSON(http.StatusBadRequest, res)
+		return
+	}
+
+	res := utils.Response{
+		Status:  true,
+		Message: dto.MESSAGE_SUCCESS_GET_ALL_POSTS,
+		Data:    posts.Data,
+		Meta:    posts.PaginationResponse,
+	}
+
+	ctx.JSON(http.StatusOK, res)
+}

dto/post_dto.go

@@ -3,6 +3,7 @@ package dto
 import (
 	"errors"
 
+	"github.com/Lab-RPL-ITS/twitter-clone-api/entity"
 	"github.com/google/uuid"
 )
 
@@ -12,12 +13,14 @@ const (
 	MESSAGE_FAILED_CREATE_POST             = "failed create post"
 	MESSAGE_FAILED_GET_POST_ID             = "failed get post id"
 	MESSAGE_FAILED_UPDATE_POST             = "failed update post"
+	MESSAGE_FAILED_GET_ALL_POSTS           = "failed get all posts"
 
 	// Succcess
 	MESSAGE_SUCCESS_CREATE_POST    = "success create post"
 	MESSAGE_SUCCESS_GET_POST_BY_ID = "success get post by id"
 	MESSAGE_SUCCESS_DELETE_POST    = "success delete post"
 	MESSAGE_SUCCESS_UPDATE_POST    = "success update post"
+	MESSAGE_SUCCESS_GET_ALL_POSTS  = "success get all posts"
 )
 
 var (
@@ -44,4 +47,14 @@ type (
 	PostUpdateRequest struct {
 		Text string `json:"text" form:"text" binding:"required"`
 	}
+
+	PostPaginationResponse struct {
+		Data []PostResponse `json:"data"`
+		PaginationResponse
+	}
+
+	GetAllPostsRepositoryResponse struct {
+		Posts []entity.Post `json:"posts"`
+		PaginationResponse
+	}
 )

repository/post_repository.go

@@ -3,6 +3,7 @@ package repository
 import (
 	"context"
 
+	"github.com/Lab-RPL-ITS/twitter-clone-api/dto"
 	"github.com/Lab-RPL-ITS/twitter-clone-api/entity"
 	"github.com/google/uuid"
 	"gorm.io/gorm"
@@ -14,6 +15,7 @@ type (
 		GetPostById(ctx context.Context, tx *gorm.DB, postId uuid.UUID) (entity.Post, error)
 		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)
 	}
 
 	postRepository struct {
@@ -86,3 +88,39 @@ func (r *postRepository) UpdatePostById(ctx context.Context, tx *gorm.DB, postId
 
 	return post, nil
 }
+
+func (r *postRepository) GetAllPostsWithPagination(ctx context.Context, tx *gorm.DB, req dto.PaginationRequest) (dto.GetAllPostsRepositoryResponse, error) {
+	if tx == nil {
+		tx = r.db
+	}
+
+	var posts []entity.Post
+	var err error
+	var count int64
+
+	req.Default()
+
+	query := tx.WithContext(ctx).Model(&entity.Post{}).Joins("User")
+	if req.Search != "" {
+		query = query.Where("text LIKE ?", "%"+req.Search+"%")
+	}
+
+	if err := query.Count(&count).Error; err != nil {
+		return dto.GetAllPostsRepositoryResponse{}, err
+	}
+
+	if err := query.Scopes(Paginate(req)).Find(&posts).Error; err != nil {
+		return dto.GetAllPostsRepositoryResponse{}, err
+	}
+
+	totalPage := TotalPage(count, int64(req.PerPage))
+	return dto.GetAllPostsRepositoryResponse{
+		Posts: posts,
+		PaginationResponse: dto.PaginationResponse{
+			Page:    req.Page,
+			PerPage: req.PerPage,
+			Count:   count,
+			MaxPage: totalPage,
+		},
+	}, err
+}

routes/post_route.go

@@ -16,9 +16,10 @@ func Post(route *gin.Engine, injector *do.Injector) {
 	routes := route.Group("/api/post")
 	{
 		// Post
-		routes.POST("/", middleware.Authenticate(jwtService), postController.CreatePost)
+		routes.POST("", middleware.Authenticate(jwtService), postController.CreatePost)
 		routes.GET("/:post_id", postController.GetPostById)
 		routes.DELETE("/:post_id", middleware.Authenticate(jwtService), postController.DeletePostById)
 		routes.PATCH("/:post_id", middleware.Authenticate(jwtService), postController.UpdatePostById)
+		routes.GET("", postController.GetAllPosts)
 	}
 }

service/post_service.go

@@ -15,6 +15,7 @@ type (
 		GetPostById(ctx context.Context, postId uuid.UUID) (dto.PostResponse, 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)
 	}
 
 	postService struct {
@@ -133,3 +134,38 @@ func (s *postService) UpdatePostById(ctx context.Context, userId string, postId
 		},
 	}, nil
 }
+
+func (s *postService) GetAllPosts(ctx context.Context, req dto.PaginationRequest) (dto.PostPaginationResponse, error) {
+	dataWithPaginate, err := s.postRepo.GetAllPostsWithPagination(ctx, nil, req)
+	if err != nil {
+		return dto.PostPaginationResponse{}, err
+	}
+
+	var data []dto.PostResponse
+	for _, post := range dataWithPaginate.Posts {
+		datum := 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,
+			},
+		}
+
+		data = append(data, datum)
+	}
+
+	return dto.PostPaginationResponse{
+		Data: data,
+		PaginationResponse: dto.PaginationResponse{
+			Page:    dataWithPaginate.Page,
+			PerPage: dataWithPaginate.PerPage,
+			MaxPage: dataWithPaginate.MaxPage,
+			Count:   dataWithPaginate.Count,
+		},
+	}, nil
+}