add UpdateProduct method and endpoint for updating a product

Author: GabrielNat1

cmd/main.go

@@ -33,6 +33,7 @@ func main() {
 	server.GET("/products", ProductController.GetProducts)
 	server.POST("/product", ProductController.CreateProduct)
 	server.GET("/product/:productId", ProductController.GetProductsById)
+	server.PUT("/product", ProductController.UpdateProduct)
 
 	server.Run(":8000")
 

controller/product_controller.go

@@ -51,7 +51,7 @@ func (p *productController) GetProductsById(ctx *gin.Context) {
 
 	id := ctx.Param("productId")
 	if id == "" {
-		response := model.Reponse{
+		response := model.Response{
 			Message: "Product ID cannot be null",
 		}
 		ctx.JSON(http.StatusBadRequest, response)
@@ -60,7 +60,7 @@ func (p *productController) GetProductsById(ctx *gin.Context) {
 
 	productId, err := strconv.Atoi(id)
 	if err != nil {
-		response := model.Reponse{
+		response := model.Response{
 			Message: "Product Id need to be number",
 		}
 		ctx.JSON(http.StatusBadRequest, response)
@@ -74,7 +74,7 @@ func (p *productController) GetProductsById(ctx *gin.Context) {
 	}
 
 	if product == nil {
-		response := model.Reponse{
+		response := model.Response{
 			Message: "Product not existing in database",
 		}
 		ctx.JSON(http.StatusNotFound, response)
@@ -83,3 +83,20 @@ func (p *productController) GetProductsById(ctx *gin.Context) {
 
 	ctx.JSON(http.StatusOK, product)
 }
+
+func (p *productController) UpdateProduct(ctx *gin.Context) {
+	var product model.Product
+	err := ctx.BindJSON(&product)
+	if err != nil {
+		ctx.JSON(http.StatusBadRequest, err)
+		return
+	}
+
+	err = p.productUseCase.UpdateProduct(product)
+	if err != nil {
+		ctx.JSON(http.StatusInternalServerError, err)
+		return
+	}
+
+	ctx.JSON(http.StatusOK, product)
+}

model/response.go

@@ -1,5 +1,5 @@
 package model
 
-type Reponse struct {
+type Response struct {
 	Message string
 }

repository/product_repository.go

@@ -94,3 +94,20 @@ func (pr *ProductRepository) GetProductById(id_product int) (*model.Product, err
 	query.Close()
 	return &produto, nil
 }
+
+func (pr *ProductRepository) UpdateProduct(product model.Product) error {
+	query, err := pr.connection.Prepare("UPDATE product SET product_name = $1, price = $2 WHERE id = $3")
+	if err != nil {
+		fmt.Println(err)
+		return err
+	}
+	defer query.Close()
+
+	_, err = query.Exec(product.Name, product.Price, product.ID)
+	if err != nil {
+		fmt.Println(err)
+		return err
+	}
+
+	return nil
+}

usecase/product_usecase.go

@@ -20,23 +20,22 @@ func (pu *ProductUseCase) GetProducts() ([]model.Product, error) {
 }
 
 func (pu *ProductUseCase) CreateProduct(product model.Product) (model.Product, error) {
-
 	productId, err := pu.repository.CreateProduct(product)
 	if err != nil {
 		return model.Product{}, err
 	}
-
 	product.ID = productId
-
 	return product, nil
 }
 
 func (pu *ProductUseCase) GetProductById(id_product int) (*model.Product, error) {
-
 	product, err := pu.repository.GetProductById(id_product)
 	if err != nil {
 		return nil, err
 	}
-
 	return product, nil
 }
+
+func (pu *ProductUseCase) UpdateProduct(product model.Product) error {
+	return pu.repository.UpdateProduct(product)
+}