diff --git a/src/service/product.rs b/src/service/product.rs index d4dff9aedf03e3f1d58878826eed8158fbe39f8e..2137732bf14c2b6cd9501c6a2e0cfacfc6c3e456 100644 --- a/src/service/product.rs +++ b/src/service/product.rs @@ -12,6 +12,11 @@ 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); } @@ -38,6 +43,8 @@ impl ProductService { String::from("Product not found."), )); } + + NotificationService.notify(&product.product_type, "DELETED", product.clone()); let product: Product = product_opt.unwrap(); return Ok(Json::from(product));