summaryrefslogtreecommitdiff
path: root/src/channel/handlers/delete
diff options
context:
space:
mode:
Diffstat (limited to 'src/channel/handlers/delete')
-rw-r--r--src/channel/handlers/delete/mod.rs59
-rw-r--r--src/channel/handlers/delete/test.rs184
2 files changed, 0 insertions, 243 deletions
diff --git a/src/channel/handlers/delete/mod.rs b/src/channel/handlers/delete/mod.rs
deleted file mode 100644
index b986bec..0000000
--- a/src/channel/handlers/delete/mod.rs
+++ /dev/null
@@ -1,59 +0,0 @@
-use axum::{
- extract::{Json, Path, State},
- http::StatusCode,
- response::{self, IntoResponse},
-};
-
-use crate::{
- app::App,
- channel::{self, app, handlers::PathInfo},
- clock::RequestedAt,
- error::{Internal, NotFound},
- token::extract::Identity,
-};
-
-#[cfg(test)]
-mod test;
-
-pub async fn handler(
- State(app): State<App>,
- Path(channel): Path<PathInfo>,
- RequestedAt(deleted_at): RequestedAt,
- _: Identity,
-) -> Result<Response, Error> {
- app.channels().delete(&channel, &deleted_at).await?;
-
- Ok(Response { id: channel })
-}
-
-#[derive(Debug, serde::Serialize)]
-pub struct Response {
- pub id: channel::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 app::DeleteError);
-
-impl IntoResponse for Error {
- fn into_response(self) -> response::Response {
- let Self(error) = self;
- match error {
- app::DeleteError::NotFound(_) | app::DeleteError::Deleted(_) => {
- NotFound(error).into_response()
- }
- app::DeleteError::NotEmpty(_) => {
- (StatusCode::CONFLICT, error.to_string()).into_response()
- }
- app::DeleteError::Name(_) | app::DeleteError::Database(_) => {
- Internal::from(error).into_response()
- }
- }
- }
-}
diff --git a/src/channel/handlers/delete/test.rs b/src/channel/handlers/delete/test.rs
deleted file mode 100644
index 99c19db..0000000
--- a/src/channel/handlers/delete/test.rs
+++ /dev/null
@@ -1,184 +0,0 @@
-use axum::extract::{Path, State};
-use itertools::Itertools;
-
-use crate::{channel::app, test::fixtures};
-
-#[tokio::test]
-pub async fn valid_channel() {
- // Set up the environment
-
- let app = fixtures::scratch_app().await;
- let channel = fixtures::channel::create(&app, &fixtures::now()).await;
-
- // Send the request
-
- let deleter = fixtures::identity::create(&app, &fixtures::now()).await;
- let response = super::handler(
- State(app.clone()),
- Path(channel.id.clone()),
- fixtures::now(),
- deleter,
- )
- .await
- .expect("deleting a valid channel succeeds");
-
- // Verify the response
-
- assert_eq!(channel.id, response.id);
-
- // Verify the semantics
-
- let snapshot = app.boot().snapshot().await.expect("boot always succeeds");
- let created = snapshot
- .events
- .into_iter()
- .filter_map(fixtures::event::channel)
- .filter_map(fixtures::event::channel::created)
- .exactly_one()
- .expect("only one channel has been created");
- // We don't expect `channel` to match the event exactly, as the name will have been
- // tombstoned and the channel given a `deleted_at` date.
- assert_eq!(channel.id, created.channel.id);
-}
-
-#[tokio::test]
-pub async fn invalid_channel_id() {
- // Set up the environment
-
- let app = fixtures::scratch_app().await;
-
- // Send the request
-
- let deleter = fixtures::identity::create(&app, &fixtures::now()).await;
- let channel = fixtures::channel::fictitious();
- let super::Error(error) = super::handler(
- State(app.clone()),
- Path(channel.clone()),
- fixtures::now(),
- deleter,
- )
- .await
- .expect_err("deleting a nonexistent channel fails");
-
- // Verify the response
-
- assert!(matches!(error, app::DeleteError::NotFound(id) if id == channel));
-}
-
-#[tokio::test]
-pub async fn channel_deleted() {
- // Set up the environment
-
- let app = fixtures::scratch_app().await;
- let channel = fixtures::channel::create(&app, &fixtures::now()).await;
-
- app.channels()
- .delete(&channel.id, &fixtures::now())
- .await
- .expect("deleting a recently-sent channel succeeds");
-
- // Send the request
-
- let deleter = fixtures::identity::create(&app, &fixtures::now()).await;
- let super::Error(error) = super::handler(
- State(app.clone()),
- Path(channel.id.clone()),
- fixtures::now(),
- deleter,
- )
- .await
- .expect_err("deleting a deleted channel fails");
-
- // Verify the response
-
- assert!(matches!(error, app::DeleteError::Deleted(id) if id == channel.id));
-}
-
-#[tokio::test]
-pub async fn channel_expired() {
- // Set up the environment
-
- let app = fixtures::scratch_app().await;
- let channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
-
- app.channels()
- .expire(&fixtures::now())
- .await
- .expect("expiring channels always succeeds");
-
- // Send the request
-
- let deleter = fixtures::identity::create(&app, &fixtures::now()).await;
- let super::Error(error) = super::handler(
- State(app.clone()),
- Path(channel.id.clone()),
- fixtures::now(),
- deleter,
- )
- .await
- .expect_err("deleting an expired channel fails");
-
- // Verify the response
-
- assert!(matches!(error, app::DeleteError::Deleted(id) if id == channel.id));
-}
-
-#[tokio::test]
-pub async fn channel_purged() {
- // Set up the environment
-
- let app = fixtures::scratch_app().await;
- let channel = fixtures::channel::create(&app, &fixtures::ancient()).await;
-
- app.channels()
- .expire(&fixtures::old())
- .await
- .expect("expiring channels always succeeds");
-
- app.channels()
- .purge(&fixtures::now())
- .await
- .expect("purging channels always succeeds");
-
- // Send the request
-
- let deleter = fixtures::identity::create(&app, &fixtures::now()).await;
- let super::Error(error) = super::handler(
- State(app.clone()),
- Path(channel.id.clone()),
- fixtures::now(),
- deleter,
- )
- .await
- .expect_err("deleting a purged channel fails");
-
- // Verify the response
-
- assert!(matches!(error, app::DeleteError::NotFound(id) if id == channel.id));
-}
-
-#[tokio::test]
-pub async fn channel_not_empty() {
- // Set up the environment
-
- let app = fixtures::scratch_app().await;
- let channel = fixtures::channel::create(&app, &fixtures::now()).await;
- let sender = fixtures::user::create(&app, &fixtures::now()).await;
- fixtures::message::send(&app, &channel, &sender, &fixtures::now()).await;
-
- // Send the request
-
- let deleter = fixtures::identity::create(&app, &fixtures::now()).await;
- let super::Error(error) = super::handler(
- State(app.clone()),
- Path(channel.id.clone()),
- fixtures::now(),
- deleter,
- )
- .await
- .expect_err("deleting a channel with messages fails");
-
- // Verify the response
-
- assert!(matches!(error, app::DeleteError::NotEmpty(id) if id == channel.id));
-}