feat: add edit post endpoint

Author: ainunns

controller/post_controller.go

@@ -1,6 +1,7 @@
 package controller
 
 import (
+	"fmt"
 	"net/http"
 
 	"github.com/Lab-RPL-ITS/twitter-clone-api/dto"
@@ -15,6 +16,7 @@ type (
 		CreatePost(ctx *gin.Context)
 		GetPostById(ctx *gin.Context)
 		DeletePostById(ctx *gin.Context)
+		UpdatePostById(ctx *gin.Context)
 	}
 
 	postController struct {
@@ -38,6 +40,8 @@ func (c *postController) CreatePost(ctx *gin.Context) {
 		return
 	}
 
+	fmt.Println("userId", userId)
+
 	result, err := c.postService.CreatePost(ctx.Request.Context(), userId, post)
 	if err != nil {
 		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_CREATE_POST, err.Error(), nil)
@@ -81,3 +85,31 @@ func (c *postController) DeletePostById(ctx *gin.Context) {
 	res := utils.BuildResponseSuccess(dto.MESSAGE_SUCCESS_DELETE_POST, nil)
 	ctx.JSON(http.StatusOK, res)
 }
+
+func (c *postController) UpdatePostById(ctx *gin.Context) {
+	var post dto.PostUpdateRequest
+	userId := ctx.GetString("user_id")
+
+	if err := ctx.ShouldBind(&post); err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_POST_DATA_FROM_BODY, err.Error(), nil)
+		ctx.AbortWithStatusJSON(http.StatusBadRequest, res)
+		return
+	}
+
+	postId, err := uuid.Parse(ctx.Param("post_id"))
+	if err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_POST_ID, err.Error(), nil)
+		ctx.AbortWithStatusJSON(http.StatusBadRequest, res)
+		return
+	}
+
+	result, err := c.postService.UpdatePostById(ctx.Request.Context(), userId, postId, post)
+	if err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_UPDATE_POST, err.Error(), nil)
+		ctx.JSON(http.StatusBadRequest, res)
+		return
+	}
+
+	res := utils.BuildResponseSuccess(dto.MESSAGE_SUCCESS_UPDATE_POST, result)
+	ctx.JSON(http.StatusOK, res)
+}

dto/post_dto.go

@@ -11,18 +11,21 @@ const (
 	MESSAGE_FAILED_GET_POST_DATA_FROM_BODY = "failed get data from body"
 	MESSAGE_FAILED_CREATE_POST             = "failed create post"
 	MESSAGE_FAILED_GET_POST_ID             = "failed get post id"
+	MESSAGE_FAILED_UPDATE_POST             = "failed update post"
 
 	// 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"
 )
 
 var (
 	ErrCreatePost     = errors.New("failed to create post")
 	ErrGetPostById    = errors.New("post not found")
 	ErrParseParentID  = errors.New("failed to parse parent id")
 	ErrDeletePostById = errors.New("failed to delete post")
+	ErrUpdatePostById = errors.New("failed to update post")
 )
 
 type (
@@ -37,4 +40,8 @@ type (
 		ParentID *uuid.UUID   `json:"parent_id"`
 		User     UserResponse `json:"user"`
 	}
+
+	PostUpdateRequest struct {
+		Text string `json:"text" form:"text" binding:"required"`
+	}
 )

dto/user_dto.go

@@ -28,6 +28,7 @@ var (
 	ErrUsernameAlreadyExists = errors.New("username already exist")
 	ErrUsernameNotFound      = errors.New("username not found")
 	ErrPasswordNotMatch      = errors.New("password not match")
+	ErrUnauthorized          = errors.New("unauthorized")
 )
 
 type (

repository/post_repository.go

@@ -13,6 +13,7 @@ type (
 		CreatePost(ctx context.Context, tx *gorm.DB, post entity.Post) (entity.Post, error)
 		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)
 	}
 
 	postRepository struct {
@@ -73,3 +74,15 @@ func (r *postRepository) DeletePostById(ctx context.Context, tx *gorm.DB, postId
 
 	return nil
 }
+
+func (r *postRepository) UpdatePostById(ctx context.Context, tx *gorm.DB, postId uuid.UUID, post entity.Post) (entity.Post, error) {
+	if tx == nil {
+		tx = r.db
+	}
+
+	if err := tx.WithContext(ctx).Model(&entity.Post{}).Where("id = ?", postId).Updates(post).Error; err != nil {
+		return entity.Post{}, err
+	}
+
+	return post, nil
+}

routes/post_route.go

@@ -19,5 +19,6 @@ func Post(route *gin.Engine, injector *do.Injector) {
 		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)
 	}
 }

service/post_service.go

@@ -14,6 +14,7 @@ type (
 		CreatePost(ctx context.Context, userId string, req dto.PostCreateRequest) (dto.PostResponse, error)
 		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)
 	}
 
 	postService struct {
@@ -100,3 +101,34 @@ func (s *postService) DeletePostById(ctx context.Context, postId uuid.UUID) erro
 
 	return nil
 }
+
+func (s *postService) UpdatePostById(ctx context.Context, userId string, postId uuid.UUID, req dto.PostUpdateRequest) (dto.PostResponse, error) {
+	post, err := s.postRepo.GetPostById(ctx, nil, postId)
+	if err != nil {
+		return dto.PostResponse{}, dto.ErrGetPostById
+	}
+
+	if post.UserID.String() != userId {
+		return dto.PostResponse{}, dto.ErrUnauthorized
+	}
+
+	post.Text = req.Text
+
+	result, err := s.postRepo.UpdatePostById(ctx, nil, postId, post)
+	if err != nil {
+		return dto.PostResponse{}, dto.ErrUpdatePostById
+	}
+
+	return dto.PostResponse{
+		ID:       result.ID.String(),
+		Text:     result.Text,
+		ParentID: result.ParentID,
+		User: dto.UserResponse{
+			ID:       result.UserID.String(),
+			Name:     result.User.Name,
+			Bio:      result.User.Bio,
+			UserName: result.User.Username,
+			ImageUrl: result.User.ImageUrl,
+		},
+	}, nil
+}