Edit Product service methods to call notify after create/delete.

src/service/notification.rs

@@ -27,7 +27,7 @@ impl NotificationService {
         return Ok(subscriber_result.unwrap());
     }
 
-    pub fn notify(self, product_type: &str, status: &str, product: Product) {
+    pub fn notify(&self, product_type: &str, status: &str, product: Product) {
         let mut payload: Notification = Notification {
             product_title: product.clone().title,
             product_type: String::from(product_type),

src/service/product.rs

@@ -2,8 +2,10 @@ use rocket::http::Status;
 use rocket::serde::json::Json;
 
 use bambangshop::{Result, compose_error_response};
+use crate::model::notification::Notification;
 use crate::model::product::Product;
 use crate::repository::product::ProductRepository;
+use crate::service::notification::NotificationService; // Import NotificationService
 
 pub struct ProductService;
 
@@ -12,6 +14,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 +43,7 @@ impl ProductService {
         }
         let product: Product = product_opt.unwrap();
 
+        NotificationService.notify(&product.product_type, "DELETED", product.clone());
         return Ok(Json::from(product));
     }
 
@@ -54,7 +58,6 @@ impl ProductService {
         }
         
         let product: Product = product_opt.unwrap();
-        
         NotificationService.notify(&product.product_type, "PROMOTION", product.clone());
         
         return Ok(product);