summaryrefslogtreecommitdiff
path: root/src/message/routes
diff options
context:
space:
mode:
Diffstat (limited to 'src/message/routes')
-rw-r--r--src/message/routes/message/mod.rs61
-rw-r--r--src/message/routes/message/test.rs184
-rw-r--r--src/message/routes/mod.rs9
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))
-}