add DeleteProduct method and endpoint for product deletion

Author: GabrielNat1

cmd/main.go

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

controller/product_controller.go

@@ -100,3 +100,34 @@ func (p *productController) UpdateProduct(ctx *gin.Context) {
 
 	ctx.JSON(http.StatusOK, product)
 }
+
+func (p *productController) DeleteProduct(ctx *gin.Context) {
+	id := ctx.Param("productId")
+	if id == "" {
+		response := model.Response{
+			Message: "Product ID cannot be null",
+		}
+		ctx.JSON(http.StatusBadRequest, response)
+		return
+	}
+
+	productId, err := strconv.Atoi(id)
+	if err != nil {
+		response := model.Response{
+			Message: "Product Id need to be number",
+		}
+		ctx.JSON(http.StatusBadRequest, response)
+		return
+	}
+
+	err = p.productUseCase.DeleteProduct(productId)
+	if err != nil {
+		ctx.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	response := model.Response{
+		Message: "Product deleted successfully",
+	}
+	ctx.JSON(http.StatusOK, response)
+}

repository/product_repository.go

@@ -111,3 +111,20 @@ func (pr *ProductRepository) UpdateProduct(product model.Product) error {
 
 	return nil
 }
+
+func (pr *ProductRepository) DeleteProduct(id int) error {
+	query, err := pr.connection.Prepare("DELETE FROM product WHERE id = $1")
+	if err != nil {
+		fmt.Println(err)
+		return err
+	}
+	defer query.Close()
+
+	_, err = query.Exec(id)
+	if err != nil {
+		fmt.Println(err)
+		return err
+	}
+
+	return nil
+}

usecase/product_usecase.go

@@ -39,3 +39,7 @@ func (pu *ProductUseCase) GetProductById(id_product int) (*model.Product, error)
 func (pu *ProductUseCase) UpdateProduct(product model.Product) error {
 	return pu.repository.UpdateProduct(product)
 }
+
+func (pu *ProductUseCase) DeleteProduct(id int) error {
+	return pu.repository.DeleteProduct(id)
+}