feat: add get user posts by username endpoint

Author: ainunns

controller/user_controller.go

@@ -17,6 +17,7 @@ type (
 		GetUserByUsername(ctx *gin.Context)
 		UpdateUser(ctx *gin.Context)
 		CheckUsername(ctx *gin.Context)
+		GetUserPosts(ctx *gin.Context)
 	}
 
 	userController struct {
@@ -139,3 +140,35 @@ func (c *userController) CheckUsername(ctx *gin.Context) {
 	res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_USERNAME_EXISTS, dto.ErrUsernameAlreadyExists.Error(), nil)
 	ctx.JSON(http.StatusBadRequest, res)
 }
+
+func (c *userController) GetUserPosts(ctx *gin.Context) {
+	username := ctx.Param("username")
+	if username == "" {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_USER, dto.ErrUsernameNotFound.Error(), nil)
+		ctx.JSON(http.StatusBadRequest, res)
+		return
+	}
+
+	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
+	}
+
+	result, err := c.userService.GetUserPosts(ctx.Request.Context(), username, req)
+	if err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_USER_POSTS, err.Error(), nil)
+		ctx.JSON(http.StatusBadRequest, res)
+		return
+	}
+
+	res := utils.Response{
+		Status:  true,
+		Message: dto.MESSAGE_SUCCESS_GET_ALL_POSTS,
+		Data:    result.Data,
+		Meta:    result.PaginationResponse,
+	}
+
+	ctx.JSON(http.StatusOK, res)
+}

dto/user_dto.go

@@ -17,13 +17,15 @@ const (
 	MESSAGE_FAILED_DENIED_ACCESS           = "denied access"
 	MESSAGE_FAILED_UPDATE_USER             = "failed update user"
 	MESSAGE_FAILED_USERNAME_EXISTS         = "failed get username"
+	MESSAGE_FAILED_GET_USER_POSTS          = "failed get user posts"
 
 	// Success
 	MESSAGE_SUCCESS_REGISTER_USER      = "success create user"
 	MESSAGE_SUCCESS_GET_USER           = "success get user"
 	MESSAGE_SUCCESS_LOGIN              = "success login"
 	MESSAGE_SUCCESS_UPDATE_USER        = "success update user"
 	MESSAGE_SUCCESS_USERNAME_AVAILABLE = "username available"
+	MESSAGE_SUCCESS_GET_USER_POSTS     = "success get user posts"
 )
 
 var (

provider/user_provider.go

@@ -15,9 +15,10 @@ func ProvideUserDependencies(injector *do.Injector) {
 
 	// Repository
 	userRepository := repository.NewUserRepository(db)
+	postRepository := repository.NewPostRepository(db)
 
 	// Service
-	userService := service.NewUserService(userRepository, jwtService)
+	userService := service.NewUserService(userRepository, postRepository, jwtService)
 
 	// Controller
 	do.Provide(injector, func(i *do.Injector) (controller.UserController, error) {

repository/post_repository.go

@@ -15,6 +15,7 @@ type (
 		DeletePostById(ctx context.Context, tx *gorm.DB, postId uint64) error
 		UpdatePostById(ctx context.Context, tx *gorm.DB, postId uint64, post entity.Post) (entity.Post, error)
 		GetAllPostsWithPagination(ctx context.Context, tx *gorm.DB, req dto.PaginationRequest) (dto.GetAllPostsRepositoryResponse, error)
+		GetAllPostsWithPaginationByUsername(ctx context.Context, tx *gorm.DB, username string, 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
 	}
@@ -173,3 +174,39 @@ func (r *postRepository) UpdateLikesCount(ctx context.Context, tx *gorm.DB, post
 
 	return nil
 }
+
+func (r *postRepository) GetAllPostsWithPaginationByUsername(ctx context.Context, tx *gorm.DB, username 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.parent_id IS NULL").Where("\"User\".username = ?", username).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/user_route.go

@@ -21,6 +21,7 @@ func User(route *gin.Engine, injector *do.Injector) {
 		routes.POST("/check-username", userController.CheckUsername)
 		routes.GET("/me", middleware.Authenticate(jwtService), userController.Me)
 		routes.GET("/:username", userController.GetUserByUsername)
+		routes.GET("/:username/posts", userController.GetUserPosts)
 		routes.PATCH("/update", middleware.Authenticate(jwtService), userController.UpdateUser)
 	}
 }

service/user_service.go

@@ -19,17 +19,20 @@ type (
 		Verify(ctx context.Context, req dto.UserLoginRequest) (dto.UserLoginResponse, error)
 		GetUserByUsername(ctx context.Context, username string) (dto.UserResponse, error)
 		UpdateUser(ctx context.Context, userId string, req dto.UserProfileUpdateRequest) (dto.UserResponse, error)
+		GetUserPosts(ctx context.Context, username string, req dto.PaginationRequest) (dto.PostPaginationResponse, error)
 	}
 
 	userService struct {
 		userRepo   repository.UserRepository
+		postRepo   repository.PostRepository
 		jwtService JWTService
 	}
 )
 
-func NewUserService(userRepo repository.UserRepository, jwtService JWTService) UserService {
+func NewUserService(userRepo repository.UserRepository, postRepo repository.PostRepository, jwtService JWTService) UserService {
 	return &userService{
 		userRepo:   userRepo,
+		postRepo:   postRepo,
 		jwtService: jwtService,
 	}
 }
@@ -161,3 +164,39 @@ func (s *userService) UpdateUser(ctx context.Context, userId string, req dto.Use
 		ImageUrl: userUpdate.ImageUrl,
 	}, nil
 }
+
+func (s *userService) GetUserPosts(ctx context.Context, username string, req dto.PaginationRequest) (dto.PostPaginationResponse, error) {
+	dataWithPaginate, err := s.postRepo.GetAllPostsWithPaginationByUsername(ctx, nil, username, req)
+	if err != nil {
+		return dto.PostPaginationResponse{}, err
+	}
+
+	var data []dto.PostResponse
+	for _, post := range dataWithPaginate.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:    dataWithPaginate.Page,
+			PerPage: dataWithPaginate.PerPage,
+			MaxPage: dataWithPaginate.MaxPage,
+			Count:   dataWithPaginate.Count,
+		},
+	}, nil
+}