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
    fraction: String,
30
    symbol: String,
31
    name: String,
32
}
33

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

            
41
    // Parse the fraction with proper error handling
42
4
    let fraction_value = if let Ok(val) = form.fraction.parse::<i64>() {
43
3
        val
44
    } else {
45
1
        let error_response = serde_json::json!({
46
1
            "status": "fail",
47
1
            "message":                t!("Provide the correct fraction value"),
48
        });
49
1
        return Err((StatusCode::BAD_REQUEST, Json(error_response)));
50
    };
51

            
52
    // Execute command
53
3
    match server::command::commodity::CreateCommodity::new()
54
3
        .fraction(fraction_value.into())
55
3
        .symbol(form.symbol)
56
3
        .name(form.name)
57
3
        .user_id(user.id)
58
3
        .run()
59
3
        .await
60
    {
61
        Ok(result) => match result {
62
            Some(id) => Ok(format!("{}: {}", t!("New commodity id"), id)),
63
            None => Ok("New commodity created".to_string()),
64
        },
65
3
        Err(e) => {
66
3
            let error_response = serde_json::json!({
67
3
                "status": "fail",
68
3
                "message": t!("Failed to create commodity"),
69
            });
70

            
71
3
            log::error!("Failed to create commodity: {e:?}");
72
3
            Err((StatusCode::INTERNAL_SERVER_ERROR, Json(error_response)))
73
        }
74
    }
75
4
}