Adding test
This commit is contained in:
+126
-2
@@ -124,12 +124,10 @@ mod util {
|
|||||||
serde_json::from_slice(&body).unwrap()
|
serde_json::from_slice(&body).unwrap()
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
pub async fn format_url_with_value(endpoint: &str, value: &uuid::Uuid) -> String {
|
pub async fn format_url_with_value(endpoint: &str, value: &uuid::Uuid) -> String {
|
||||||
let last = endpoint.len() - 5;
|
let last = endpoint.len() - 5;
|
||||||
format!("{}/{value}", &endpoint[0..last])
|
format!("{}/{value}", &endpoint[0..last])
|
||||||
}
|
}
|
||||||
*/
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn token_fields() -> (String, String, String) {
|
pub fn token_fields() -> (String, String, String) {
|
||||||
@@ -427,6 +425,29 @@ mod request {
|
|||||||
Err(err) => Err(err),
|
Err(err) => Err(err),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn delete_scheduled_message_event(
|
||||||
|
app: &axum::Router,
|
||||||
|
scheduled_message_event_id: &uuid::Uuid,
|
||||||
|
) -> Result<axum::response::Response, axum::http::Error> {
|
||||||
|
/*
|
||||||
|
let uri = format!(
|
||||||
|
"{}?scheduled_message_id={}",
|
||||||
|
textsender_api::caller::endpoints::GET_SCHEDULED_MESSAGE_EVENT,
|
||||||
|
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;
|
||||||
|
println!("Link: {uri:?}");
|
||||||
|
|
||||||
|
match super::super::run_post(None, &uri, axum::http::Method::DELETE, 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),
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -902,3 +923,106 @@ async fn test_get_scheduled_message_event() {
|
|||||||
|
|
||||||
let _ = db_mgr::drop_database(&tm_pool, &db_name).await;
|
let _ = db_mgr::drop_database(&tm_pool, &db_name).await;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[tokio::test]
|
||||||
|
async fn test_delete_scheduled_message_event() {
|
||||||
|
let (tm_pool, db_name, pool) = db_mgr::get_database_ready().await;
|
||||||
|
let app = init::app(pool).await;
|
||||||
|
|
||||||
|
let mut contact_id: uuid::Uuid = uuid::Uuid::nil();
|
||||||
|
let mut message_id: uuid::Uuid = uuid::Uuid::nil();
|
||||||
|
let mut scheduled_message_id: uuid::Uuid = uuid::Uuid::nil();
|
||||||
|
|
||||||
|
match request::create_contact(&app).await {
|
||||||
|
Ok(response) => {
|
||||||
|
let resp = util::get_resp_data::<
|
||||||
|
textsender_api::caller::contact::response::AddContactResponse,
|
||||||
|
>(response)
|
||||||
|
.await;
|
||||||
|
assert_eq!(false, resp.data.is_empty(), "Should not be empty");
|
||||||
|
contact_id = resp.data[0].id.unwrap();
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
assert!(false, "Error: {:?}", err);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
match request::message::create_message(&app).await {
|
||||||
|
Ok(response) => {
|
||||||
|
let resp = util::get_resp_data::<
|
||||||
|
textsender_api::caller::message::response::AddMessageResponse,
|
||||||
|
>(response)
|
||||||
|
.await;
|
||||||
|
assert_eq!(false, resp.data.is_empty(), "Should not be empty");
|
||||||
|
let message = &resp.data[0];
|
||||||
|
message_id = message.id.unwrap();
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
assert!(false, "Error: {:?}", err);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
match request::message::scheduling::create_scheduled_message(&app).await {
|
||||||
|
Ok(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");
|
||||||
|
scheduled_message_id = resp.data[0].id;
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
assert!(false, "Error: {err:?}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
match request::message::scheduling::create_scheduled_message_event(
|
||||||
|
&app,
|
||||||
|
&contact_id,
|
||||||
|
&message_id,
|
||||||
|
&scheduled_message_id,
|
||||||
|
)
|
||||||
|
.await
|
||||||
|
{
|
||||||
|
Ok(response) => {
|
||||||
|
let resp = util::get_resp_data::<
|
||||||
|
textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
|
||||||
|
>(response)
|
||||||
|
.await;
|
||||||
|
assert_eq!(false, resp.data.is_empty(), "Should not be empty");
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
assert!(false, "Error: {err:?}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
match request::message::scheduling::get_scheduled_message_events(&app, &scheduled_message_id)
|
||||||
|
.await
|
||||||
|
{
|
||||||
|
Ok(response) => {
|
||||||
|
let resp = util::get_resp_data::<
|
||||||
|
textsender_api::caller::message::scheduling::response::GetScheduledMessageEventResponse,
|
||||||
|
>(response)
|
||||||
|
.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 {
|
||||||
|
Ok(response) => {
|
||||||
|
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");
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
assert!(false, "Error: {err:?}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
assert!(false, "Error: {err:?}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let _ = db_mgr::drop_database(&tm_pool, &db_name).await;
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user