diff --git a/src/caller/message/scheduling.rs b/src/caller/message/scheduling.rs index 5604f67..5f3c3b5 100644 --- a/src/caller/message/scheduling.rs +++ b/src/caller/message/scheduling.rs @@ -36,6 +36,12 @@ pub mod request { || !self.scheduled_message_id.is_nil() } } + + #[derive(Debug, Default, serde::Deserialize, serde::Serialize, utoipa::ToSchema)] + pub struct GetScheduledMessageEventParams { + pub id: Option, + pub scheduled_message_id: Option, + } } pub mod response { @@ -59,6 +65,8 @@ pub mod response { pub message: String, pub data: Vec, } + + pub use CreateScheduleMessageEventResponse as GetScheduledMessageEventResponse; } pub mod endpoint { @@ -278,4 +286,73 @@ pub mod endpoint { (axum::http::StatusCode::BAD_REQUEST, axum::Json(response)) } } + + /// Endpoint to get Scheduled Message Event + #[utoipa::path( + get, + path = crate::caller::endpoints::GET_SCHEDULED_MESSAGE_EVENT, + params( + ("id" = uuid::Uuid, Path, description = "Id of Scheduled Message Event"), + ("scheduled_message_id" = uuid::Uuid, Path, description = "Scheduled Message Id associated with the Scheduled Message Event") + ), + responses( + (status = 200, description = "Scheduled Message Event found", body = super::response::GetScheduledMessageEventResponse), + (status = 400, description = "Invalid request", body = super::response::GetScheduledMessageEventResponse), + (status = 500, description = "Error getting Scheduled Message Event", body = super::response::GetScheduledMessageEventResponse) + ) + )] + pub async fn get_scheduled_message_events( + axum::Extension(pool): axum::Extension, + axum::extract::Query(params): axum::extract::Query< + super::request::GetScheduledMessageEventParams, + >, + ) -> ( + axum::http::StatusCode, + axum::Json, + ) { + let mut response = super::response::GetScheduledMessageEventResponse::default(); + + let scheduled_message_events = match params.id { + Some(id) => match scheduling_repo::sched_msg_event::get(&pool, &id).await { + Ok(scheduled_message) => { + vec![scheduled_message] + } + Err(err) => { + eprintln!("Error: {err:?}"); + return ( + axum::http::StatusCode::INTERNAL_SERVER_ERROR, + axum::Json(response), + ); + } + }, + None => match params.scheduled_message_id { + Some(scheduled_message_id) => { + match scheduling_repo::sched_msg_event::get_with_scheduled_message_id( + &pool, + &scheduled_message_id, + ) + .await + { + Ok(scheduled_messages) => scheduled_messages, + Err(err) => { + eprintln!("Error: {err:?}"); + return ( + axum::http::StatusCode::INTERNAL_SERVER_ERROR, + axum::Json(response), + ); + } + } + } + None => { + response.message = String::from("Invalid parameter"); + return (axum::http::StatusCode::BAD_REQUEST, axum::Json(response)); + } + }, + }; + + response.data = scheduled_message_events; + response.message = String::from(super::super::super::response::SUCCESSFUL); + + (axum::http::StatusCode::OK, axum::Json(response)) + } } diff --git a/src/config/mod.rs b/src/config/mod.rs index 6cb9a0d..bbf64e4 100644 --- a/src/config/mod.rs +++ b/src/config/mod.rs @@ -142,6 +142,12 @@ pub mod init { axum::middleware::from_fn(crate::auth::auth::), ), ) + .route( + crate::caller::endpoints::GET_SCHEDULED_MESSAGE_EVENT, + get(scheduling_endpoints::get_scheduled_message_events).route_layer( + axum::middleware::from_fn(crate::auth::auth::), + ), + ) .layer(cors::configure_cors().await) }