From ea74daca4809e4008dd8d01039db9fff3be659d9 Mon Sep 17 00:00:00 2001 From: Owen Jacobson Date: Wed, 16 Oct 2024 20:14:33 -0400 Subject: Organizational pass on endpoints and routes. --- src/message/routes/message.rs | 43 +++++++++++++++++++++++++++++++++++++++++++ src/message/routes/mod.rs | 9 +++++++++ 2 files changed, 52 insertions(+) create mode 100644 src/message/routes/message.rs create mode 100644 src/message/routes/mod.rs (limited to 'src/message/routes') diff --git a/src/message/routes/message.rs b/src/message/routes/message.rs new file mode 100644 index 0000000..059b8c1 --- /dev/null +++ b/src/message/routes/message.rs @@ -0,0 +1,43 @@ +pub mod delete { + use axum::{ + extract::{Path, State}, + http::StatusCode, + response::{IntoResponse, Response}, + }; + + use crate::{ + app::App, + clock::RequestedAt, + error::{Internal, NotFound}, + login::Login, + message::{self, app::DeleteError}, + }; + + pub async fn handler( + State(app): State, + Path(message): Path, + RequestedAt(deleted_at): RequestedAt, + _: Login, + ) -> Result { + app.messages().delete(&message, &deleted_at).await?; + + Ok(StatusCode::ACCEPTED) + } + + #[derive(Debug, thiserror::Error)] + #[error(transparent)] + pub struct Error(#[from] pub DeleteError); + + impl IntoResponse for Error { + fn into_response(self) -> Response { + let Self(error) = self; + #[allow(clippy::match_wildcard_for_single_variants)] + match error { + DeleteError::ChannelNotFound(_) | DeleteError::NotFound(_) => { + NotFound(error).into_response() + } + other => Internal::from(other).into_response(), + } + } + } +} diff --git a/src/message/routes/mod.rs b/src/message/routes/mod.rs new file mode 100644 index 0000000..dfe8628 --- /dev/null +++ b/src/message/routes/mod.rs @@ -0,0 +1,9 @@ +use axum::{routing::delete, Router}; + +use crate::app::App; + +mod message; + +pub fn router() -> Router { + Router::new().route("/api/messages/:message", delete(message::delete::handler)) +} -- cgit v1.2.3