feat: implement user profile update functionality

Author: ainunns

controller/user_controller.go

@@ -15,6 +15,7 @@ type (
 		Login(ctx *gin.Context)
 		Me(ctx *gin.Context)
 		GetUserByUsername(ctx *gin.Context)
+		UpdateUser(ctx *gin.Context)
 	}
 
 	userController struct {
@@ -98,3 +99,23 @@ func (c *userController) GetUserByUsername(ctx *gin.Context) {
 	res := utils.BuildResponseSuccess(dto.MESSAGE_SUCCESS_GET_USER, result)
 	ctx.JSON(http.StatusOK, res)
 }
+
+func (c *userController) UpdateUser(ctx *gin.Context) {
+	userId := ctx.MustGet("user_id").(string)
+	var user dto.UserProfileUpdateRequest
+	if err := ctx.ShouldBind(&user); err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_GET_USER_DATA_FROM_BODY, err.Error(), nil)
+		ctx.AbortWithStatusJSON(http.StatusBadRequest, res)
+		return
+	}
+
+	result, err := c.userService.UpdateUser(ctx.Request.Context(), userId, user)
+	if err != nil {
+		res := utils.BuildResponseFailed(dto.MESSAGE_FAILED_UPDATE_USER, err.Error(), nil)
+		ctx.JSON(http.StatusBadRequest, res)
+		return
+	}
+
+	res := utils.BuildResponseSuccess(dto.MESSAGE_SUCCESS_UPDATE_USER, result)
+	ctx.JSON(http.StatusOK, res)
+}

dto/user_dto.go

@@ -15,11 +15,13 @@ const (
 	MESSAGE_FAILED_LOGIN                   = "failed login"
 	MESSAGE_FAILED_PROSES_REQUEST          = "failed proses request"
 	MESSAGE_FAILED_DENIED_ACCESS           = "denied access"
+	MESSAGE_FAILED_UPDATE_USER             = "failed update user"
 
 	// 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"
 )
 
 var (
@@ -40,6 +42,12 @@ type (
 		Password string                `json:"password" form:"password" binding:"required"`
 	}
 
+	UserProfileUpdateRequest struct {
+		Name  string                `json:"name" form:"name"`
+		Bio   string                `json:"bio" form:"bio"`
+		Image *multipart.FileHeader `json:"image" form:"image"`
+	}
+
 	UserResponse struct {
 		ID       string  `json:"id"`
 		Name     string  `json:"name"`

repository/user_repository.go

@@ -12,6 +12,7 @@ type (
 		RegisterUser(ctx context.Context, tx *gorm.DB, user entity.User) (entity.User, error)
 		GetUserById(ctx context.Context, tx *gorm.DB, userId string) (entity.User, error)
 		CheckUsername(ctx context.Context, tx *gorm.DB, email string) (entity.User, bool, error)
+		UpdateUser(ctx context.Context, tx *gorm.DB, userId string, user entity.User) (entity.User, error)
 	}
 
 	userRepository struct {
@@ -62,3 +63,20 @@ func (r *userRepository) CheckUsername(ctx context.Context, tx *gorm.DB, usernam
 
 	return user, true, nil
 }
+
+func (r *userRepository) UpdateUser(ctx context.Context, tx *gorm.DB, userId string, user entity.User) (entity.User, error) {
+	if tx == nil {
+		tx = r.db
+	}
+
+	if err := tx.WithContext(ctx).Model(&user).Where("id = ?", userId).Updates(user).Error; err != nil {
+		return entity.User{}, err
+	}
+
+	var updatedUser entity.User
+	if err := tx.WithContext(ctx).Where("id = ?", userId).Take(&updatedUser).Error; err != nil {
+		return entity.User{}, err
+	}
+
+	return updatedUser, nil
+}

routes/user_route.go

@@ -20,5 +20,6 @@ func User(route *gin.Engine, injector *do.Injector) {
 		routes.POST("/login", userController.Login)
 		routes.GET("/me", middleware.Authenticate(jwtService), userController.Me)
 		routes.GET("/:username", userController.GetUserByUsername)
+		routes.PATCH("/update", middleware.Authenticate(jwtService), userController.UpdateUser)
 	}
 }

service/user_service.go

@@ -18,6 +18,7 @@ type (
 		GetUserById(ctx context.Context, userId string) (dto.UserResponse, error)
 		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)
 	}
 
 	userService struct {
@@ -127,3 +128,55 @@ func (s *userService) GetUserByUsername(ctx context.Context, username string) (d
 		ImageUrl: user.ImageUrl,
 	}, nil
 }
+
+func (s *userService) UpdateUser(ctx context.Context, userId string, req dto.UserProfileUpdateRequest) (dto.UserResponse, error) {
+	user, err := s.userRepo.GetUserById(ctx, nil, userId)
+	if err != nil {
+		return dto.UserResponse{}, dto.ErrGetUserById
+	}
+
+	if req.Name != "" {
+		user.Name = req.Name
+	}
+
+	previousImage := user.ImageUrl
+
+	if req.Image != nil {
+		var filenamePtr *string
+		imageId := uuid.New()
+		ext := utils.GetExtensions(req.Image.Filename)
+
+		filename := fmt.Sprintf("profile/%s.%s", imageId, ext)
+		if err := utils.UploadFile(req.Image, filename); err != nil {
+			return dto.UserResponse{}, err
+		}
+		filenamePtr = &filename
+		user.ImageUrl = filenamePtr
+	}
+
+	if req.Bio != "" {
+		var bioPtr *string
+		bio := req.Bio
+		bioPtr = &bio
+		user.Bio = bioPtr
+	}
+
+	userUpdate, err := s.userRepo.UpdateUser(ctx, nil, userId, user)
+	if err != nil {
+		return dto.UserResponse{}, dto.ErrCreateUser
+	}
+
+	if previousImage != nil {
+		if err := utils.DeleteFile(*previousImage); err != nil {
+			return dto.UserResponse{}, err
+		}
+	}
+
+	return dto.UserResponse{
+		ID:       userUpdate.ID.String(),
+		Name:     userUpdate.Name,
+		UserName: userUpdate.Username,
+		Bio:      userUpdate.Bio,
+		ImageUrl: userUpdate.ImageUrl,
+	}, nil
+}

utils/file.go

@@ -47,4 +47,12 @@ func UploadFile(file *multipart.FileHeader, path string) error {
 
 func GetExtensions(filename string) string {
 	return strings.Split(filename, ".")[len(strings.Split(filename, "."))-1]
-}
+}
+
+func DeleteFile(path string) error {
+	filePath := fmt.Sprintf("%s/%s", PATH, path)
+	if err := os.Remove(filePath); err != nil {
+		return err
+	}
+	return nil
+}