diff --git a/src/controller/mod.rs b/src/controller/mod.rs index 08a540d7202c90e21865ad69008ba590c1fb343a..1567487f77b9d46c16d18eef8ebf1b8d571c60d8 100644 --- a/src/controller/mod.rs +++ b/src/controller/mod.rs @@ -7,6 +7,6 @@ pub fn route_stage() -> AdHoc { return AdHoc::on_ignite("Initializing controller routes...", |rocket| async { rocket .mount("/product", routes![product::create, product::list, product::read, product::delete]) - .mount("/notification", routes![]) + .mount("/notification", routes![notification::subscribe]) }); } diff --git a/src/controller/notification.rs b/src/controller/notification.rs index 9964baa0739f99f79779f5f54dad540df7147e84..ba9f7a12e453521b23c98835325b1c379dce4ca0 100644 --- a/src/controller/notification.rs +++ b/src/controller/notification.rs @@ -1,6 +1,14 @@ use rocket::response::status::Created; - use rocket::serde::json::Json; - - use bambangshop::Result; - use crate::model::subscriber::Subscriber; - use crate::service::notification::NotificationService; \ No newline at end of file +use rocket::serde::json::Json; + +use bambangshop::Result; +use crate::model::subscriber::Subscriber; +use crate::service::notification::NotificationService; + +# [post("/subscribe/<product_type>", data = "<subscriber>")] +pub fn subscribe(product_type: &str, subscriber: Json<Subscriber>) -> Result<Created<Json<Subscriber>>, Error> { + return match NotificationService::subscribe(product_type, subscriber.into_inner()) { + Ok(f) => Ok(Created::new("/").body(Json::from(f))), + Err(e) => Err(e), + }; +} \ No newline at end of file