web/pages/commodity/create/
submit.rs

1use std::sync::Arc;
2
3use askama::Template;
4use axum::{Extension, Json, extract::State, http::StatusCode, response::IntoResponse};
5use serde::Deserialize;
6
7use crate::{AppState, jwt_auth::JWTAuthMiddleware, pages::HtmlTemplate};
8
9#[derive(Template)]
10#[template(path = "pages/commodity/create.html")]
11struct CommodityCreatePage;
12
13pub async fn commodity_create_page() -> impl IntoResponse {
14    let template = CommodityCreatePage {};
15    HtmlTemplate(template)
16}
17
18#[derive(Template)]
19#[template(path = "components/commodity/create.html")]
20struct CommodityFormTemplate;
21
22#[derive(Deserialize)]
23pub struct CommodityForm {
24    symbol: String,
25    name: String,
26}
27
28pub async fn commodity_submit(
29    State(_data): State<Arc<AppState>>,
30    Extension(jwt_auth): Extension<JWTAuthMiddleware>,
31    Json(form): Json<CommodityForm>,
32) -> Result<impl IntoResponse, (StatusCode, Json<serde_json::Value>)> {
33    let user = &jwt_auth.user;
34
35    // Execute command
36    match server::command::commodity::CreateCommodity::new()
37        .symbol(form.symbol)
38        .name(form.name)
39        .user_id(user.id)
40        .run()
41        .await
42    {
43        Ok(result) => match result {
44            Some(id) => Ok(format!("{}: {}", t!("New commodity id"), id)),
45            None => Ok("New commodity created".to_string()),
46        },
47        Err(e) => {
48            let error_response = serde_json::json!({
49                "status": "fail",
50                "message": t!("Failed to create commodity"),
51            });
52
53            log::error!("Failed to create commodity: {e:?}");
54            Err((StatusCode::INTERNAL_SERVER_ERROR, Json(error_response)))
55        }
56    }
57}
web/pages/commodity/create/submit.rs

web/pages/commodity/create/
submit.rs
