1
use std::sync::Arc;
2

            
3
use askama::Template;
4
use axum::{Extension, Json, extract::State, http::StatusCode, response::IntoResponse};
5
use serde::Deserialize;
6

            
7
use crate::{AppState, jwt_auth::JWTAuthMiddleware, pages::HtmlTemplate};
8

            
9
#[derive(Template)]
10
#[template(path = "pages/commodity/create.html")]
11
struct CommodityCreatePage;
12

            
13
pub 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")]
20
struct CommodityFormTemplate;
21

            
22
pub async fn commodity_form() -> impl IntoResponse {
23
    let template = CommodityFormTemplate {};
24
    HtmlTemplate(template)
25
}
26

            
27
#[derive(Deserialize)]
28
pub struct CommodityForm {
29
    symbol: String,
30
    name: String,
31
}
32

            
33
3
pub async fn commodity_submit(
34
3
    State(_data): State<Arc<AppState>>,
35
3
    Extension(jwt_auth): Extension<JWTAuthMiddleware>,
36
3
    Json(form): Json<CommodityForm>,
37
3
) -> Result<impl IntoResponse, (StatusCode, Json<serde_json::Value>)> {
38
3
    let user = &jwt_auth.user;
39

            
40
    // Execute command
41
3
    match server::command::commodity::CreateCommodity::new()
42
3
        .symbol(form.symbol)
43
3
        .name(form.name)
44
3
        .user_id(user.id)
45
3
        .run()
46
3
        .await
47
    {
48
        Ok(result) => match result {
49
            Some(id) => Ok(format!("{}: {}", t!("New commodity id"), id)),
50
            None => Ok("New commodity created".to_string()),
51
        },
52
3
        Err(e) => {
53
3
            let error_response = serde_json::json!({
54
3
                "status": "fail",
55
3
                "message": t!("Failed to create commodity"),
56
            });
57

            
58
3
            log::error!("Failed to create commodity: {e:?}");
59
3
            Err((StatusCode::INTERNAL_SERVER_ERROR, Json(error_response)))
60
        }
61
    }
62
3
}