diff --git a/src/service/product.rs b/src/service/product.rs index a7cd27ecd5005652f2a89ca69c5313e3db856520..854ea957e08a8990d093fcc757f0e0afa1cf59a8 100644 --- a/src/service/product.rs +++ b/src/service/product.rs @@ -13,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); } @@ -41,6 +43,7 @@ impl ProductService { } let product: Product = product_opt.unwrap(); + NotificationService.notify(&product.product_type, "DELETED", product.clone()); return Ok(Json::from(product)); }