phoenix/schedtxt_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update scheduled message status endpoint #20

Merged
phoenix merged 9 commits from update_scheduled_message_status-endpoint into alot_of_changes 2026-06-19 18:34:40 -04:00
Conversation 0 Commits 9 Files Changed 7
+42 -28
2 changed files with 42 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 700bc61d92 - Show all commits
src/caller/message/scheduling.rs
+32 -26
View File
@@ -51,12 +51,13 @@ pub mod request {
impl UpdateScheduledMessageStatusRequest {
pub fn is_valid(&self) -> bool {
if !self.status.is_empty() || !self.scheduled_message_id.is_nil() {
if self.status == textsender_models::message::scheduling::PENDING ||
self.status == textsender_models::message::scheduling::READY ||
self.status == textsender_models::message::scheduling::PROCESSING ||
self.status == textsender_models::message::scheduling::DONE {
true
if !self.status.is_empty() || !self.scheduled_message_id.is_nil() {
if self.status == textsender_models::message::scheduling::PENDING
|| self.status == textsender_models::message::scheduling::READY
|| self.status == textsender_models::message::scheduling::PROCESSING
|| self.status == textsender_models::message::scheduling::DONE
{
true
} else {
false
}
@@ -270,26 +271,31 @@ pub mod endpoint {
match scheduling_repo::get(&pool, &payload.scheduled_message_id).await {
Ok(scheduled_message) => {
let old_status = scheduled_message.status;
match scheduling_repo::update_status(
&pool,
&scheduled_message.id,
&payload.status,
)
.await
{
Ok(_) => {
response.message =
String::from(super::super::super::response::SUCCESSFUL);
response.data = vec![super::response::ChangedStatus { old_status }];
(axum::http::StatusCode::OK, axum::Json(response))
}
Err(err) => {
eprintln!("Error: {err:?}");
response.message = String::from("Invalid");
(
axum::http::StatusCode::INTERNAL_SERVER_ERROR,
axum::Json(response),
)
if old_status == payload.status {
response.message = String::from("No change");
(axum::http::StatusCode::NOT_MODIFIED, axum::Json(response))
} else {
match scheduling_repo::update_status(
&pool,
&scheduled_message.id,
&payload.status,
)
.await
{
Ok(_) => {
response.message =
String::from(super::super::super::response::SUCCESSFUL);
response.data = vec![super::response::ChangedStatus { old_status }];
(axum::http::StatusCode::OK, axum::Json(response))
}
Err(err) => {
eprintln!("Error: {err:?}");
response.message = String::from("Invalid");
(
axum::http::StatusCode::INTERNAL_SERVER_ERROR,
axum::Json(response),
)
}
}
}
}
tests/test.rs
+10 -2
View File
@@ -388,7 +388,9 @@ mod request {
"status": updated_status
});
match super::super::run_post(Some(&payload), &uri, axum::http::Method::PATCH, true).await {
match super::super::run_post(Some(&payload), &uri, axum::http::Method::PATCH, true)
.await
{
Ok(req) => match app.clone().oneshot(req).await {
Ok(response) => Ok(response),
Err(err) => Err(axum::http::Error::from(err)),
@@ -1120,7 +1122,13 @@ async fn test_update_scheduled_message_status() {
}
}
match request::message::scheduling::update_scheduled_message_status(&app, &scheduled_message_id, textsender_models::message::scheduling::READY).await {
match request::message::scheduling::update_scheduled_message_status(
&app,
&scheduled_message_id,
textsender_models::message::scheduling::READY,
)
.await
{
Ok(response) => {
let resp = util::get_resp_data::<
textsender_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,