summaryrefslogtreecommitdiff
path: root/src/channel/handlers/send/mod.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/channel/handlers/send/mod.rs')
-rw-r--r--src/channel/handlers/send/mod.rs63
1 files changed, 0 insertions, 63 deletions
diff --git a/src/channel/handlers/send/mod.rs b/src/channel/handlers/send/mod.rs
deleted file mode 100644
index bde39e5..0000000
--- a/src/channel/handlers/send/mod.rs
+++ /dev/null
@@ -1,63 +0,0 @@
-use axum::{
- extract::{Json, Path, State},
- http::StatusCode,
- response::{self, IntoResponse},
-};
-
-use crate::channel::handlers::PathInfo;
-use crate::{
- app::App,
- clock::RequestedAt,
- error::{Internal, NotFound},
- message::{Body, Message, app::SendError},
- token::extract::Identity,
-};
-
-#[cfg(test)]
-mod test;
-
-pub async fn handler(
- State(app): State<App>,
- Path(channel): Path<PathInfo>,
- RequestedAt(sent_at): RequestedAt,
- identity: Identity,
- Json(request): Json<Request>,
-) -> Result<Response, Error> {
- let message = app
- .messages()
- .send(&channel, &identity.user, &sent_at, &request.body)
- .await?;
-
- Ok(Response(message))
-}
-
-#[derive(serde::Deserialize)]
-pub struct Request {
- pub body: Body,
-}
-
-#[derive(Debug)]
-pub struct Response(pub Message);
-
-impl IntoResponse for Response {
- fn into_response(self) -> response::Response {
- let Self(message) = self;
- (StatusCode::ACCEPTED, Json(message)).into_response()
- }
-}
-
-#[derive(Debug, thiserror::Error)]
-#[error(transparent)]
-pub struct Error(#[from] pub SendError);
-
-impl IntoResponse for Error {
- fn into_response(self) -> response::Response {
- let Self(error) = self;
- match error {
- SendError::ChannelNotFound(_) | SendError::ChannelDeleted(_) => {
- NotFound(error).into_response()
- }
- SendError::Name(_) | SendError::Database(_) => Internal::from(error).into_response(),
- }
- }
-}