From 19ee6ebb67d408ca4dea66f3ca67683ae079fbed Mon Sep 17 00:00:00 2001
From: Christian Raphael Heryanto <christian.raphael@ui.ac.id>
Date: Fri, 28 Mar 2025 15:58:06 +0800
Subject: [PATCH] Implement unsubscribe function in Notification service.
---
src/service/notification.rs | 40 +++++++++++++++++++++++++++++++++++++
1 file changed, 40 insertions(+)
diff --git a/src/service/notification.rs b/src/service/notification.rs
index 0351519..6c6c14a 100644
--- a/src/service/notification.rs
+++ b/src/service/notification.rs
@@ -53,4 +53,44 @@ impl NotificationService {
.join()
.unwrap();
}
+
+ #[tokio::main]
+ async fn unsubscribe_request(product_type: String) -> Result<SubscriberRequest> {
+ let product_type_upper: String = product_type.to_uppercase();
+ let product_type_str: &str = product_type_upper.as_str();
+ let notification_receiver_url: String =
+ format!("{}/receive", APP_CONFIG.get_instance_root_url());
+
+ let request_url: String = format!(
+ "{}/notification/unsubscribe/{}?url={}",
+ APP_CONFIG.get_publisher_root_url(),
+ product_type_str,
+ notification_receiver_url
+ );
+ let request = REQWEST_CLIENT
+ .post(request_url.clone())
+ .header("Content-Type", "application/json")
+ .header("Accept", "application/json")
+ .send()
+ .await;
+ log::warn_!("Sent unsubscribe request to: {}", request_url);
+
+ return match request {
+ Ok(f) => match f.json::<SubscriberRequest>().await {
+ Ok(x) => Ok(x),
+ Err(_y) => Err(compose_error_response(
+ Status::NotFound,
+ String::from("Already unsubscribed to the topic."),
+ )),
+ },
+ Err(e) => Err(compose_error_response(Status::NotFound, e.to_string())),
+ };
+ }
+
+ pub fn unsubscribe(product_type: &str) -> Result<SubscriberRequest> {
+ let product_type_clone = String::from(product_type);
+ return thread::spawn(move || Self::unsubscribe_request(product_type_clone))
+ .join()
+ .unwrap();
+ }
}
--
GitLab