cargo fmt
This commit is contained in:
@@ -36,7 +36,7 @@ pub mod response {
|
|||||||
#[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
|
#[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
|
||||||
pub struct GetScheduledMessageResponse {
|
pub struct GetScheduledMessageResponse {
|
||||||
pub message: String,
|
pub message: String,
|
||||||
pub data: Vec<textsender_models::message::scheduling::ScheduledMessage>
|
pub data: Vec<textsender_models::message::scheduling::ScheduledMessage>,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -124,7 +124,9 @@ pub mod endpoint {
|
|||||||
)]
|
)]
|
||||||
pub async fn get_scheduled_messages(
|
pub async fn get_scheduled_messages(
|
||||||
axum::Extension(pool): axum::Extension<sqlx::PgPool>,
|
axum::Extension(pool): axum::Extension<sqlx::PgPool>,
|
||||||
axum::extract::Query(params): axum::extract::Query<super::request::GetScheduledMessageParams>,
|
axum::extract::Query(params): axum::extract::Query<
|
||||||
|
super::request::GetScheduledMessageParams,
|
||||||
|
>,
|
||||||
) -> (
|
) -> (
|
||||||
axum::http::StatusCode,
|
axum::http::StatusCode,
|
||||||
axum::Json<super::response::GetScheduledMessageResponse>,
|
axum::Json<super::response::GetScheduledMessageResponse>,
|
||||||
|
|||||||
@@ -75,13 +75,14 @@ pub async fn get_with_user_id(
|
|||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
Ok(rows) => {
|
Ok(rows) => {
|
||||||
let mut messages: Vec<textsender_models::message::scheduling::ScheduledMessage> = Vec::new();
|
let mut messages: Vec<textsender_models::message::scheduling::ScheduledMessage> =
|
||||||
|
Vec::new();
|
||||||
for row in rows {
|
for row in rows {
|
||||||
let id: uuid::Uuid = row.try_get("id")?;
|
let id: uuid::Uuid = row.try_get("id")?;
|
||||||
let scheduled: time::OffsetDateTime = row.try_get("scheduled")?;
|
let scheduled: time::OffsetDateTime = row.try_get("scheduled")?;
|
||||||
let status: String = row.try_get("status")?;
|
let status: String = row.try_get("status")?;
|
||||||
let created: time::OffsetDateTime = row.try_get("created")?;
|
let created: time::OffsetDateTime = row.try_get("created")?;
|
||||||
let user_id: uuid::Uuid = row.try_get("user_id")?;
|
let user_id: uuid::Uuid = row.try_get("user_id")?;
|
||||||
|
|
||||||
let message = textsender_models::message::scheduling::ScheduledMessage {
|
let message = textsender_models::message::scheduling::ScheduledMessage {
|
||||||
id,
|
id,
|
||||||
|
|||||||
+6
-3
@@ -355,7 +355,10 @@ mod request {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn get_scheduled_messages(app: &axum::Router, id: &uuid::Uuid) -> Result<axum::response::Response, axum::http::Error> {
|
pub async fn get_scheduled_messages(
|
||||||
|
app: &axum::Router,
|
||||||
|
id: &uuid::Uuid,
|
||||||
|
) -> Result<axum::response::Response, axum::http::Error> {
|
||||||
let uri = format!(
|
let uri = format!(
|
||||||
"{}?id={}",
|
"{}?id={}",
|
||||||
textsender_api::caller::endpoints::GET_SCHEDULE_MESSAGE,
|
textsender_api::caller::endpoints::GET_SCHEDULE_MESSAGE,
|
||||||
@@ -668,11 +671,11 @@ async fn test_get_scheduled_message() {
|
|||||||
if let Some(parsed_id) = id {
|
if let Some(parsed_id) = id {
|
||||||
match request::message::scheduling::get_scheduled_messages(&app, &parsed_id).await {
|
match request::message::scheduling::get_scheduled_messages(&app, &parsed_id).await {
|
||||||
Ok(response) => {
|
Ok(response) => {
|
||||||
let resp = util::get_resp_data::<
|
let resp = util::get_resp_data::<
|
||||||
textsender_api::caller::message::scheduling::response::GetScheduledMessageResponse,
|
textsender_api::caller::message::scheduling::response::GetScheduledMessageResponse,
|
||||||
>(response)
|
>(response)
|
||||||
.await;
|
.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) => {
|
Err(err) => {
|
||||||
assert!(false, "Error: {err:?}");
|
assert!(false, "Error: {err:?}");
|
||||||
|
|||||||
Reference in New Issue
Block a user