diff --git a/src/service/product.rs b/src/service/product.rs index 87a55ac91fd730e4934ad543777d10d1366b00a7..9d761aa912d8d87fce965393204046e5c5d7a463 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,8 @@ 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 +43,7 @@ impl ProductService { } let product: Product = product_opt.unwrap(); + NotificationService.notify(&product.product_type, "DELETED", product.clone()); return Ok(Json::from(product)); }