Get schedule message endpoint (#16)
textsender_api PR / Rustfmt (pull_request) Successful in 38s
textsender_api PR / Check (pull_request) Successful in 1m38s
textsender_api PR / Clippy (pull_request) Successful in 2m3s

Reviewed-on: phoenix/textsender_api#16
This commit was merged in pull request #16.
This commit is contained in:
2026-06-18 14:19:21 -04:00
parent d1bc5eb830
commit 825575930e
7 changed files with 222 additions and 2 deletions
+63
View File
@@ -354,6 +354,25 @@ mod request {
Err(err) => Err(err),
}
}
pub async fn get_scheduled_messages(
app: &axum::Router,
id: &uuid::Uuid,
) -> Result<axum::response::Response, axum::http::Error> {
let uri = format!(
"{}?id={}",
textsender_api::caller::endpoints::GET_SCHEDULE_MESSAGE,
id
);
match super::super::run_post(None, &uri, axum::http::Method::GET, false).await {
Ok(req) => match app.clone().oneshot(req).await {
Ok(response) => Ok(response),
Err(err) => Err(axum::http::Error::from(err)),
},
Err(err) => Err(err),
}
}
}
}
@@ -624,3 +643,47 @@ async fn test_schedule_message() {
let _ = db_mgr::drop_database(&tm_pool, &db_name).await;
}
#[tokio::test]
async fn test_get_scheduled_message() {
let (tm_pool, db_name, pool) = db_mgr::get_database_ready().await;
let app = init::app(pool).await;
let mut id: Option<uuid::Uuid> = None;
match request::message::scheduling::create_scheduled_message(&app).await {
Ok(response) => {
eprintln!("Response: {response:?}");
println!("Response: {response:?}");
let resp = util::get_resp_data::<
textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
>(response)
.await;
assert_eq!(false, resp.data.is_empty(), "Should not be empty");
let scheduled_message = &resp.data[0];
id = Some(scheduled_message.id);
}
Err(err) => {
assert!(false, "Error: {err:?}");
}
}
if let Some(parsed_id) = id {
match request::message::scheduling::get_scheduled_messages(&app, &parsed_id).await {
Ok(response) => {
let resp = util::get_resp_data::<
textsender_api::caller::message::scheduling::response::GetScheduledMessageResponse,
>(response)
.await;
assert_eq!(false, resp.data.is_empty(), "Should not be empty");
}
Err(err) => {
assert!(false, "Error: {err:?}");
}
}
} else {
assert!(false, "Scheduled Message Id could not be retrieved");
}
let _ = db_mgr::drop_database(&tm_pool, &db_name).await;
}