feat: add get my posts endpoint

Author: ainunns

controller/post_controller.go

@@ -17,6 +17,7 @@ type (
 		DeletePostById(ctx *gin.Context)
 		UpdatePostById(ctx *gin.Context)
 		GetAllPosts(ctx *gin.Context)
+		GetMyPosts(ctx *gin.Context)
 	}
 
 	postController struct {
@@ -152,3 +153,29 @@ func (c *postController) GetAllPosts(ctx *gin.Context) {
 
 	ctx.JSON(http.StatusOK, res)
 }
+
+func (c *postController) GetMyPosts(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
+	}
+
+	userId := ctx.GetString("user_id")
+	posts, err := c.postService.GetMyPosts(ctx.Request.Context(), userId, req)
+	if err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_MY_POSTS, err.Error(), nil)
+		ctx.JSON(http.StatusBadRequest, res)
+		return
+	}
+
+	res := utils.Response{
+		Status:  true,
+		Message: dto.MESSAGE_SUCCESS_GET_MY_POSTS,
+		Data:    posts.Data,
+		Meta:    posts.PaginationResponse,
+	}
+
+	ctx.JSON(http.StatusOK, res)
+}

dto/post_dto.go

@@ -13,13 +13,15 @@ const (
 	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"
+	MESSAGE_FAILED_GET_MY_POSTS            = "failed get my 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"
+	MESSAGE_SUCCESS_GET_MY_POSTS   = "success get my posts"
 )
 
 var (
@@ -29,6 +31,7 @@ var (
 	ErrParseParentID  = errors.New("failed to parse parent id")
 	ErrDeletePostById = errors.New("failed to delete post")
 	ErrUpdatePostById = errors.New("failed to update post")
+	ErrGetMyPosts     = errors.New("failed to get my posts")
 )
 
 type (

repository/post_repository.go

@@ -17,6 +17,7 @@ type (
 		GetAllPostsWithPagination(ctx context.Context, tx *gorm.DB, req dto.PaginationRequest) (dto.GetAllPostsRepositoryResponse, error)
 		GetAllPostRepliesWithPagination(ctx context.Context, tx *gorm.DB, postId uint64, req dto.PaginationRequest) (dto.GetAllRepliesRepositoryResponse, error)
 		UpdateLikesCount(ctx context.Context, tx *gorm.DB, postId uint64, count int) error
+		GetMyPosts(ctx context.Context, tx *gorm.DB, userId string, req dto.PaginationRequest) (dto.GetAllPostsRepositoryResponse, error)
 	}
 
 	postRepository struct {
@@ -173,3 +174,39 @@ func (r *postRepository) UpdateLikesCount(ctx context.Context, tx *gorm.DB, post
 
 	return nil
 }
+
+func (r *postRepository) GetMyPosts(ctx context.Context, tx *gorm.DB, userId string, 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").Where("posts.user_id = ?", userId).Order("created_at DESC")
+	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

@@ -17,6 +17,7 @@ func Post(route *gin.Engine, injector *do.Injector) {
 	{
 		// Post
 		routes.POST("", middleware.Authenticate(jwtService), postController.CreatePost)
+		routes.GET("/me", middleware.Authenticate(jwtService), postController.GetMyPosts)
 		routes.GET("/:post_id", postController.GetPostById)
 		routes.DELETE("/:post_id", middleware.Authenticate(jwtService), postController.DeletePostById)
 		routes.PATCH("/:post_id", middleware.Authenticate(jwtService), postController.UpdatePostById)

service/post_service.go

@@ -16,6 +16,7 @@ type (
 		DeletePostById(ctx context.Context, postId uint64) error
 		UpdatePostById(ctx context.Context, userId string, postId uint64, req dto.PostUpdateRequest) (dto.PostResponse, error)
 		GetAllPosts(ctx context.Context, req dto.PaginationRequest) (dto.PostPaginationResponse, error)
+		GetMyPosts(ctx context.Context, userId string, req dto.PaginationRequest) (dto.PostPaginationResponse, error)
 	}
 
 	postService struct {
@@ -206,3 +207,39 @@ func (s *postService) GetAllPosts(ctx context.Context, req dto.PaginationRequest
 		},
 	}, nil
 }
+
+func (s *postService) GetMyPosts(ctx context.Context, userId string, req dto.PaginationRequest) (dto.PostPaginationResponse, error) {
+	posts, err := s.postRepo.GetMyPosts(ctx, nil, userId, req)
+	if err != nil {
+		return dto.PostPaginationResponse{}, dto.ErrGetMyPosts
+	}
+
+	var data []dto.PostResponse
+	for _, post := range posts.Posts {
+		datum := dto.PostResponse{
+			ID:         post.ID,
+			Text:       post.Text,
+			TotalLikes: post.TotalLikes,
+			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:    posts.Page,
+			PerPage: posts.PerPage,
+			MaxPage: posts.MaxPage,
+			Count:   posts.Count,
+		},
+	}, nil
+}