diff --git a/src/repo/message/scheduling.rs b/src/repo/message/scheduling.rs index 5e3fe71..8e7a7dc 100644 --- a/src/repo/message/scheduling.rs +++ b/src/repo/message/scheduling.rs @@ -84,6 +84,27 @@ pub async fn get_with_user_id( } } +pub async fn update_status( + pool: &sqlx::PgPool, + id: &uuid::Uuid, + status: &str, + ) -> Result<(), sqlx::Error> { + match sqlx::query( + r#" + UPDATE "scheduled_message" SET status = $1 WHERE id = $2; + "#, + ) + .bind(status) + .bind(id) + .execute(pool) + .await { + Ok(_row) => { + Ok(()) + } + Err(err) => Err(err) + } +} + async fn parse_row( row: &sqlx::postgres::PgRow, ) -> Result {