lariv-rs 0.1.0

Compile-time plugin web application framework built on Axum, SeaORM, Maud, and HTMX
Documentation 
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

use axum::{extract::Query, http::Uri};
use sea_orm::{EntityTrait, PaginatorTrait, QueryOrder};
use serde::Deserialize;

use crate::{
    components::ObjectList,
    http::Cap,
    picker::respond_picker_select,
    plugins::users::middleware::RequireAuth,
    web::{Htmx, QueryPage, QueryPageSize},
};

use crate::plugins::finance_accounts::{
    entities::source_doc::{self, Entity as SourceDocEntity},
    keys::{SourceDocSelectModalKey, SourceDocSelectTableKey},
    scope::scope_superuser,
    source_doc_label::resolve_source_doc_display,
    source_doc_registry::SourceDocRegistry,
    state::AccountsState,
    templates::{SourceDocRow, SourceDocSelectPage},
};

use super::util::path_and_query;

#[derive(Debug, Deserialize, Default)]
pub struct SourceDocSelectQuery {
    #[serde(default)]
    pub sort: Option<String>,
    #[serde(default)]
    pub page: QueryPage,
    #[serde(default)]
    pub page_size: QueryPageSize,
    #[serde(default)]
    pub target_input: Option<String>,
}

pub async fn select(
    Cap(state): Cap<AccountsState>,
    Cap(source_docs): Cap<SourceDocRegistry>,
    RequireAuth(ctx): RequireAuth,
    htmx: Htmx,
    uri: Uri,
    Query(q): Query<SourceDocSelectQuery>,
) -> maud::Markup {
    let page_num = q.page.get();
    let mut query = scope_superuser(SourceDocEntity::find(), &ctx);
    let sort = q.sort.as_deref().unwrap_or("").trim();
    query = match sort {
        s if s.eq_ignore_ascii_case("Type DESC") => {
            query.order_by_desc(source_doc::Column::SourceDocType)
        }
        s if s.eq_ignore_ascii_case("Type ASC") || s.eq_ignore_ascii_case("Type") => {
            query.order_by_asc(source_doc::Column::SourceDocType)
        }
        s if s.eq_ignore_ascii_case("Reference DESC") => {
            query.order_by_desc(source_doc::Column::SourceDocId)
        }
        s if s.eq_ignore_ascii_case("Reference ASC") || s.eq_ignore_ascii_case("Reference") => {
            query.order_by_asc(source_doc::Column::SourceDocId)
        }
        _ => query.order_by_desc(source_doc::Column::Id),
    };
    let paginator = query.paginate(&state.db, q.page_size.get() as u64);
    let total = paginator.num_items().await.unwrap_or(0);
    let models = paginator
        .fetch_page((page_num as u64).saturating_sub(1))
        .await
        .unwrap_or_default();
    let mut rows = Vec::with_capacity(models.len());
    for d in models {
        let display = resolve_source_doc_display(&state.db, &source_docs, d.id).await;
        rows.push(SourceDocRow {
            id: d.id,
            source_doc_type: display.type_label.clone(),
            source_doc_id: d.source_doc_id,
            label: display.summary_label(),
        });
    }
    let docs = ObjectList::from_page(rows, page_num, q.page_size.get(), total);
    let page = SourceDocSelectPage {
        docs,
        target_input: q.target_input.unwrap_or_else(|| "SourceDocID".into()),
        sort: q.sort.clone().unwrap_or_default(),
        path_and_query: path_and_query(&uri),
        page_size: q.page_size.get(),
    };
    respond_picker_select::<SourceDocSelectTableKey, SourceDocSelectModalKey, _>(&htmx, &page)
}