From 7c6d82015c31d10589febcab6c25309c5d8ed28f Mon Sep 17 00:00:00 2001 From: phoenix Date: Fri, 19 Jun 2026 15:58:20 -0400 Subject: [PATCH] cargo fmt --- src/caller/message/scheduling.rs | 10 +++++++--- src/repo/message/scheduling.rs | 29 +++++++++++++---------------- tests/test.rs | 17 +++++++++++++---- 3 files changed, 33 insertions(+), 23 deletions(-) diff --git a/src/caller/message/scheduling.rs b/src/caller/message/scheduling.rs index dc3733c..161673d 100644 --- a/src/caller/message/scheduling.rs +++ b/src/caller/message/scheduling.rs @@ -358,7 +358,6 @@ pub mod endpoint { (axum::http::StatusCode::OK, axum::Json(response)) } - /// Endpoint to delete the Scheduled Message Event #[utoipa::path( delete, @@ -380,7 +379,9 @@ pub mod endpoint { let mut response = super::response::DeleteScheduledMessageEventResponse::default(); match scheduling_repo::sched_msg_event::get(&pool, &id).await { Ok(scheduled_message_event) => { - match scheduling_repo::sched_msg_event::delete(&pool, &scheduled_message_event).await { + match scheduling_repo::sched_msg_event::delete(&pool, &scheduled_message_event) + .await + { Ok(_) => { response.message = String::from(super::super::super::response::SUCCESSFUL); response.data.push(scheduled_message_event); @@ -389,7 +390,10 @@ pub mod endpoint { Err(err) => { eprintln!("Error: {err:?}"); response.message = String::from("Error deleting"); - (axum::http::StatusCode::INTERNAL_SERVER_ERROR, axum::Json(response)) + ( + axum::http::StatusCode::INTERNAL_SERVER_ERROR, + axum::Json(response), + ) } } } diff --git a/src/repo/message/scheduling.rs b/src/repo/message/scheduling.rs index e68c72d..5e3fe71 100644 --- a/src/repo/message/scheduling.rs +++ b/src/repo/message/scheduling.rs @@ -189,27 +189,24 @@ pub mod sched_msg_event { } } -pub async fn delete( - pool: &sqlx::PgPool, - scheduled_message_event: &textsender_models::message::scheduling::ScheduledMessageEvent, -) -> Result<(), sqlx::Error> { - match sqlx::query( - r#" + pub async fn delete( + pool: &sqlx::PgPool, + scheduled_message_event: &textsender_models::message::scheduling::ScheduledMessageEvent, + ) -> Result<(), sqlx::Error> { + match sqlx::query( + r#" DELETE FROM "scheduled_message_events" WHERE id = $1 "#, - ) - .bind(scheduled_message_event.id) - .execute(pool) - .await { - Ok(_) => { - Ok(()) - } - Err(err) => { - Err(err) + ) + .bind(scheduled_message_event.id) + .execute(pool) + .await + { + Ok(_) => Ok(()), + Err(err) => Err(err), } } -} async fn parse_row( row: &sqlx::postgres::PgRow, diff --git a/tests/test.rs b/tests/test.rs index 16e9b66..d359804 100644 --- a/tests/test.rs +++ b/tests/test.rs @@ -437,7 +437,11 @@ mod request { scheduled_message_id ); */ - let uri = super::super::super::util::format_url_with_value(textsender_api::caller::endpoints::DELETE_SCHEDULED_MESSAGE_EVENT, scheduled_message_event_id).await; + let uri = super::super::super::util::format_url_with_value( + textsender_api::caller::endpoints::DELETE_SCHEDULED_MESSAGE_EVENT, + scheduled_message_event_id, + ) + .await; println!("Link: {uri:?}"); match super::super::run_post(None, &uri, axum::http::Method::DELETE, false).await { @@ -1006,13 +1010,18 @@ async fn test_delete_scheduled_message_event() { .await; assert_eq!(false, resp.data.is_empty(), "Should not be empty"); let scheduled_message_event = &resp.data[0]; - match request::message::scheduling::delete_scheduled_message_event(&app, &scheduled_message_event.id).await { + match request::message::scheduling::delete_scheduled_message_event( + &app, + &scheduled_message_event.id, + ) + .await + { Ok(response) => { - let resp = util::get_resp_data::< + let resp = util::get_resp_data::< textsender_api::caller::message::scheduling::response::DeleteScheduledMessageEventResponse, >(response) .await; - assert_eq!(false, resp.data.is_empty(), "Should not be empty"); + assert_eq!(false, resp.data.is_empty(), "Should not be empty"); } Err(err) => { assert!(false, "Error: {err:?}");