diff options
Diffstat (limited to 'src/message/routes')
| -rw-r--r-- | src/message/routes/message/mod.rs | 61 | ||||
| -rw-r--r-- | src/message/routes/message/test.rs | 184 | ||||
| -rw-r--r-- | src/message/routes/mod.rs | 9 |
3 files changed, 0 insertions, 254 deletions
diff --git a/src/message/routes/message/mod.rs b/src/message/routes/message/mod.rs deleted file mode 100644 index a05d344..0000000 --- a/src/message/routes/message/mod.rs +++ /dev/null @@ -1,61 +0,0 @@ -#[cfg(test)] -mod test; - -pub mod delete { - use axum::{ - extract::{Json, Path, State}, - http::StatusCode, - response::{self, IntoResponse}, - }; - - use crate::{ - app::App, - clock::RequestedAt, - error::{Internal, NotFound}, - message::{self, app::DeleteError}, - token::extract::Identity, - }; - - pub async fn handler( - State(app): State<App>, - Path(message): Path<message::Id>, - RequestedAt(deleted_at): RequestedAt, - identity: Identity, - ) -> Result<Response, Error> { - app.messages() - .delete(&identity.user, &message, &deleted_at) - .await?; - - Ok(Response { id: message }) - } - - #[derive(Debug, serde::Serialize)] - pub struct Response { - pub id: message::Id, - } - - impl IntoResponse for Response { - fn into_response(self) -> response::Response { - (StatusCode::ACCEPTED, Json(self)).into_response() - } - } - - #[derive(Debug, thiserror::Error)] - #[error(transparent)] - pub struct Error(#[from] pub DeleteError); - - impl IntoResponse for Error { - fn into_response(self) -> response::Response { - let Self(error) = self; - match error { - DeleteError::NotSender(_) => { - (StatusCode::FORBIDDEN, error.to_string()).into_response() - } - DeleteError::NotFound(_) | DeleteError::Deleted(_) => { - NotFound(error).into_response() - } - DeleteError::Database(_) => Internal::from(error).into_response(), - } - } - } -} diff --git a/src/message/routes/message/test.rs b/src/message/routes/message/test.rs deleted file mode 100644 index 1888be7..0000000 --- a/src/message/routes/message/test.rs +++ /dev/null @@ -1,184 +0,0 @@ -use axum::extract::{Path, State}; - -use super::delete; -use crate::{message::app, test::fixtures}; - -#[tokio::test] -pub async fn delete_message() { - // Set up the environment - - let app = fixtures::scratch_app().await; - let sender = fixtures::identity::create(&app, &fixtures::now()).await; - let channel = fixtures::channel::create(&app, &fixtures::now()).await; - let message = fixtures::message::send(&app, &channel, &sender.user, &fixtures::now()).await; - - // Send the request - - let response = delete::handler( - State(app.clone()), - Path(message.id.clone()), - fixtures::now(), - sender, - ) - .await - .expect("deleting a valid message succeeds"); - - // Verify the response - - assert_eq!(message.id, response.id); - - // Verify the semantics - - let snapshot = app.boot().snapshot().await.expect("boot always succeeds"); - assert!(!snapshot.messages.contains(&message)); -} - -#[tokio::test] -pub async fn delete_invalid_message_id() { - // Set up the environment - - let app = fixtures::scratch_app().await; - - // Send the request - - let deleter = fixtures::identity::create(&app, &fixtures::now()).await; - let message = fixtures::message::fictitious(); - let delete::Error(error) = delete::handler( - State(app.clone()), - Path(message.clone()), - fixtures::now(), - deleter, - ) - .await - .expect_err("deleting a nonexistent message fails"); - - // Verify the response - - assert!(matches!(error, app::DeleteError::NotFound(id) if id == message)); -} - -#[tokio::test] -pub async fn delete_deleted() { - // Set up the environment - - let app = fixtures::scratch_app().await; - let sender = fixtures::user::create(&app, &fixtures::now()).await; - let channel = fixtures::channel::create(&app, &fixtures::now()).await; - let message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await; - - app.messages() - .delete(&sender, &message.id, &fixtures::now()) - .await - .expect("deleting a recently-sent message succeeds"); - - // Send the request - - let deleter = fixtures::identity::create(&app, &fixtures::now()).await; - let delete::Error(error) = delete::handler( - State(app.clone()), - Path(message.id.clone()), - fixtures::now(), - deleter, - ) - .await - .expect_err("deleting a deleted message fails"); - - // Verify the response - - assert!(matches!(error, app::DeleteError::Deleted(id) if id == message.id)); -} - -#[tokio::test] -pub async fn delete_expired() { - // Set up the environment - - let app = fixtures::scratch_app().await; - let sender = fixtures::user::create(&app, &fixtures::ancient()).await; - let channel = fixtures::channel::create(&app, &fixtures::ancient()).await; - let message = fixtures::message::send(&app, &channel, &sender, &fixtures::ancient()).await; - - app.messages() - .expire(&fixtures::now()) - .await - .expect("expiring messages always succeeds"); - - // Send the request - - let deleter = fixtures::identity::create(&app, &fixtures::now()).await; - let delete::Error(error) = delete::handler( - State(app.clone()), - Path(message.id.clone()), - fixtures::now(), - deleter, - ) - .await - .expect_err("deleting an expired message fails"); - - // Verify the response - - assert!(matches!(error, app::DeleteError::Deleted(id) if id == message.id)); -} - -#[tokio::test] -pub async fn delete_purged() { - // Set up the environment - - let app = fixtures::scratch_app().await; - let sender = fixtures::user::create(&app, &fixtures::ancient()).await; - let channel = fixtures::channel::create(&app, &fixtures::ancient()).await; - let message = fixtures::message::send(&app, &channel, &sender, &fixtures::ancient()).await; - - app.messages() - .expire(&fixtures::old()) - .await - .expect("expiring messages always succeeds"); - - app.messages() - .purge(&fixtures::now()) - .await - .expect("purging messages always succeeds"); - - // Send the request - - let deleter = fixtures::identity::create(&app, &fixtures::now()).await; - let delete::Error(error) = delete::handler( - State(app.clone()), - Path(message.id.clone()), - fixtures::now(), - deleter, - ) - .await - .expect_err("deleting a purged message fails"); - - // Verify the response - - assert!(matches!(error, app::DeleteError::NotFound(id) if id == message.id)); -} - -#[tokio::test] -pub async fn delete_not_sender() { - // Set up the environment - - let app = fixtures::scratch_app().await; - let sender = fixtures::user::create(&app, &fixtures::now()).await; - let channel = fixtures::channel::create(&app, &fixtures::now()).await; - let message = fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await; - - // Send the request - - let deleter = fixtures::identity::create(&app, &fixtures::now()).await; - let delete::Error(error) = delete::handler( - State(app.clone()), - Path(message.id.clone()), - fixtures::now(), - deleter.clone(), - ) - .await - .expect_err("deleting a message someone else sent fails"); - - // Verify the response - - assert!( - matches!(error, app::DeleteError::NotSender(error_sender) if deleter.user == error_sender) - ); -} diff --git a/src/message/routes/mod.rs b/src/message/routes/mod.rs deleted file mode 100644 index 00b2b1a..0000000 --- a/src/message/routes/mod.rs +++ /dev/null @@ -1,9 +0,0 @@ -use axum::{Router, routing::delete}; - -use crate::app::App; - -mod message; - -pub fn router() -> Router<App> { - Router::new().route("/api/messages/{message}", delete(message::delete::handler)) -} |
