forklaunch 1.35.1

Launch faster with forklaunch
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

//! Products and the public catalog.
use crate::registrations::AppState;
use axum::{
    Extension, Json,
    extract::{Path, RawQuery, State},
    routing::any,
};
use forklaunch_axum::session::AuthenticatedSession;
use forklaunch_ecommerce_interface::{
    CreateProductDto, ProductDto, ProductService, UpdateProductDto, catalog::CatalogPage,
};
use forklaunch_ecommerce_stripe::http::{EcommerceHttp, Failure, Handler, JsonBody, query};

/// Creates a product.
pub fn create_product(state: &AppState) -> Handler {
    any(create).with_state(state.ecommerce.clone())
}

async fn create(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    JsonBody(input): JsonBody<CreateProductDto>,
) -> Result<Json<ProductDto>, Failure> {
    Ok(Json(ecommerce.service(&session)?.create_product(input).await?))
}

/// Searches products by ID, title, price, stock and option.
pub fn list_products(state: &AppState) -> Handler {
    any(search).with_state(state.ecommerce.clone())
}

async fn search(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    RawQuery(raw): RawQuery,
) -> Result<Json<Vec<ProductDto>>, Failure> {
    let filters = query::search(raw.as_deref())?;
    Ok(Json(ecommerce.service(&session)?.search_products(filters).await?))
}

/// Pages the catalog with each product's variants and stock.
pub fn list_catalog(state: &AppState) -> Handler {
    any(catalog).with_state(state.ecommerce.clone())
}

async fn catalog(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    RawQuery(raw): RawQuery,
) -> Result<Json<CatalogPage>, Failure> {
    let page = query::catalog(raw.as_deref())?;
    Ok(Json(ecommerce.service(&session)?.list_catalog(page).await?))
}

/// Reads a product by its handle.
pub fn get_product_by_handle(state: &AppState) -> Handler {
    any(by_handle).with_state(state.ecommerce.clone())
}

async fn by_handle(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    Path(handle): Path<String>,
) -> Result<Json<ProductDto>, Failure> {
    Ok(Json(ecommerce.service(&session)?.get_product_by_handle(&handle).await?))
}

/// Reads a product.
pub fn get_product(state: &AppState) -> Handler {
    any(get).with_state(state.ecommerce.clone())
}

async fn get(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    Path(id): Path<String>,
) -> Result<Json<ProductDto>, Failure> {
    Ok(Json(ecommerce.service(&session)?.get_product(&id).await?))
}

/// Updates a product.
pub fn update_product(state: &AppState) -> Handler {
    any(update).with_state(state.ecommerce.clone())
}

async fn update(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    JsonBody(input): JsonBody<UpdateProductDto>,
) -> Result<Json<ProductDto>, Failure> {
    Ok(Json(ecommerce.service(&session)?.update_product(input).await?))
}

/// Deletes a product.
pub fn delete_product(state: &AppState) -> Handler {
    any(delete).with_state(state.ecommerce.clone())
}

async fn delete(
    State(ecommerce): State<EcommerceHttp>,
    Extension(session): Extension<AuthenticatedSession>,
    Path(id): Path<String>,
) -> Result<&'static str, Failure> {
    ecommerce.service(&session)?.delete_product(&id).await?;
    Ok("Deleted product")
}