summaryrefslogtreecommitdiff
path: root/src/handlers
diff options
context:
space:
mode:
authorWriterV2 <primary-v2@protonmail.com>2024-11-07 18:35:27 +0100
committerWriterV2 <primary-v2@protonmail.com>2024-11-07 18:35:27 +0100
commit680867b4bb5e2708f02fc3f8c21c3563975c44c7 (patch)
tree0e90e583f1696d3c7c66484a5f8dbd919c75245d /src/handlers
parent99fc959383d5b7b26d8e80f6257adf8b98989f41 (diff)
Feat: Add admin API route to delete story by product id
Diffstat (limited to 'src/handlers')
-rw-r--r--src/handlers/admin.rs18
-rw-r--r--src/handlers/mod.rs4
2 files changed, 20 insertions, 2 deletions
diff --git a/src/handlers/admin.rs b/src/handlers/admin.rs
index 7c016dd..3d16b32 100644
--- a/src/handlers/admin.rs
+++ b/src/handlers/admin.rs
@@ -132,3 +132,21 @@ pub async fn upload_story(
.await?;
Ok((StatusCode::CREATED, Json(story)).into_response())
}
+
+pub async fn delete_story(
+ ctx: Extension<ApiContext>,
+ mut multipart: Multipart,
+) -> Result<impl IntoResponse, AppError> {
+ if let Some(field) = multipart.next_field().await? {
+ if let Some(label) = field.name() {
+ if label == "id" {
+ let pid = field.text().await?.parse::<i64>()?;
+ Story::delete(&ctx.pool, pid).await?;
+ return Ok((StatusCode::NO_CONTENT).into_response());
+ }
+ return Ok(StatusCode::BAD_REQUEST.into_response());
+ }
+ return Ok(StatusCode::BAD_REQUEST.into_response());
+ }
+ Ok(StatusCode::BAD_REQUEST.into_response())
+}
diff --git a/src/handlers/mod.rs b/src/handlers/mod.rs
index e2063eb..14ac176 100644
--- a/src/handlers/mod.rs
+++ b/src/handlers/mod.rs
@@ -9,7 +9,7 @@ use sqlx::SqlitePool;
use tower_http::add_extension::AddExtensionLayer;
use tower_http::services::ServeDir;
-use admin::{admin_healthcheck, admin_middleware, generate_token, upload_story};
+use admin::{admin_healthcheck, admin_middleware, delete_story, generate_token, upload_story};
use frontend_builder::home;
use crate::db::story::Story;
@@ -35,7 +35,7 @@ pub async fn router(pool: SqlitePool) -> Router {
};
Router::new()
- .route("/admin/story", post(upload_story))
+ .route("/admin/story", post(upload_story).delete(delete_story))
.route("/admin", get(admin_healthcheck))
.layer(middleware::from_fn_with_state(
state.clone(),