diff --git a/src/service/product.rs b/src/service/product.rs index 443b7faf1e8128a71c7ccc36259d21e4e7e994b3..32b378aedb2550ea3c417e1d521b10002a54f598 100644 --- a/src/service/product.rs +++ b/src/service/product.rs @@ -4,6 +4,7 @@ use rocket::serde::json::Json; use bambangshop::{Result, compose_error_response}; use crate::model::product::Product; use crate::repository::product::ProductRepository; +use crate::service::notification::NotificationService; pub struct ProductService; @@ -12,6 +13,7 @@ impl ProductService { product.product_type = product.product_type.to_uppercase(); let product_result: Product = ProductRepository::add(product); + NotificationService.notify(&product_result.product_type, "CREATED", product_result.clone()); return Ok(product_result); } @@ -40,6 +42,7 @@ impl ProductService { } let product: Product = product_opt.unwrap(); + NotificationService.notify(&product.product_type, "DELETED", product.clone()); return Ok(Json::from(product)); } @@ -53,7 +56,7 @@ impl ProductService { } let product: Product = product_opt.unwrap(); - NotificationService::notify(&product.product_type, "PROMOTION", product.clone()); + NotificationService.notify(&product.product_type, "PROMOTION", product.clone()); return Ok(product); } }