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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149

use axum::{
    extract::Query,
    response::{IntoResponse, Response},
};
use chrono::Utc;
use sea_orm::{ActiveModelTrait, ActiveValue::Set};

use crate::{
    components::{SharedChromeFolder, SlotCtx},
    html_form::HtmlFormBody,
    http::Cap,
    plugins::users::{
        auth,
        entities::user,
        forms::{PasswordForm, SelfEditForm},
        keys::SelfEditModalKey,
        middleware::RequireAuth,
        routes::{UsersSelfChangePasswordPostRouteTag, UsersSelfRouteTag},
        state::UsersState,
        templates::{ChangePasswordPage, SelfDetailPage, SelfEditModalPage},
    },
    web::{
        Htmx, html_built_page_or_app_layout, html_built_page_with_slots, respond_edit_modal_done,
    },
};

use super::users::ModalNameQuery;

/// HTTP handler: `detail`.
pub async fn detail(
    Cap(chrome): Cap<SharedChromeFolder>,
    RequireAuth(ctx): RequireAuth,
    htmx: Htmx,
) -> maud::Markup {
    let slot_ctx = SlotCtx::from_auth(&ctx);
    let page = SelfDetailPage {
        name: ctx.user.name.clone(),
        email: ctx.user.email.to_string(),
        phone: ctx.user.phone.to_string(),
        timezone: ctx.user.timezone.to_string(),
        role: ctx.role.clone(),
        is_superuser: ctx.user.is_superuser,
    };
    html_built_page_or_app_layout(&page, &htmx, &chrome, &slot_ctx)
}

/// HTTP handler: `edit_get`.
pub async fn edit_get(
    Cap(chrome): Cap<SharedChromeFolder>,
    RequireAuth(ctx): RequireAuth,
    Query(q): Query<ModalNameQuery>,
) -> maud::Markup {
    let slot_ctx = SlotCtx::from_auth(&ctx);
    let page = SelfEditModalPage {
        form_name: q.form_name(),
        name: ctx.user.name.clone(),
        email: ctx.user.email.to_string(),
        phone: ctx.user.phone.to_string(),
        timezone: ctx.user.timezone.to_string(),
        error: String::new(),
    };
    html_built_page_with_slots(&page, &chrome, &slot_ctx)
}

/// HTTP handler: `edit_post`.
pub async fn edit_post(
    Cap(state): Cap<UsersState>,
    Cap(chrome): Cap<SharedChromeFolder>,
    RequireAuth(ctx): RequireAuth,
    htmx: Htmx,
    Query(q): Query<ModalNameQuery>,
    HtmlFormBody(form): HtmlFormBody<SelfEditForm>,
) -> Response {
    let mut am: user::ActiveModel = ctx.user.clone().into();
    am.name = Set(form.name.clone());
    am.email = Set(form.email.clone().into());
    am.phone = Set(form.phone.clone().into());
    am.timezone = Set(form.timezone.clone().into());
    am.updated_at = Set(Some(Utc::now()));
    match am.update(&state.db).await {
        Ok(_) => respond_edit_modal_done::<SelfEditModalKey>(&htmx, &UsersSelfRouteTag.url()),
        Err(e) => {
            let slot_ctx = SlotCtx::from_auth(&ctx);
            let page = SelfEditModalPage {
                form_name: q.form_name(),
                name: form.name,
                email: form.email,
                phone: form.phone,
                timezone: form.timezone,
                error: e.to_string(),
            };
            html_built_page_with_slots(&page, &chrome, &slot_ctx).into_response()
        }
    }
}

/// HTTP handler: `change_password_get`.
pub async fn change_password_get(
    Cap(chrome): Cap<SharedChromeFolder>,
    RequireAuth(ctx): RequireAuth,
    htmx: Htmx,
) -> maud::Markup {
    let slot_ctx = SlotCtx::from_auth(&ctx);
    let page = ChangePasswordPage {
        user_id: 0,
        user_name: ctx.user.name.clone(),
        action: UsersSelfChangePasswordPostRouteTag.path(),
        error: String::new(),
        is_self: true,
    };
    html_built_page_or_app_layout(&page, &htmx, &chrome, &slot_ctx)
}

/// HTTP handler: `change_password_post`.
pub async fn change_password_post(
    Cap(state): Cap<UsersState>,
    Cap(chrome): Cap<SharedChromeFolder>,
    RequireAuth(ctx): RequireAuth,
    htmx: Htmx,
    HtmlFormBody(form): HtmlFormBody<PasswordForm>,
) -> Response {
    let user_name = ctx.user.name.clone();
    if form.new_password != form.confirm_password {
        let slot_ctx = SlotCtx::from_auth(&ctx);
        let page = ChangePasswordPage {
            user_id: 0,
            user_name,
            action: UsersSelfChangePasswordPostRouteTag.path(),
            error: "Passwords do not match".into(),
            is_self: true,
        };
        return html_built_page_or_app_layout(&page, &htmx, &chrome, &slot_ctx).into_response();
    }
    let am: user::ActiveModel = ctx.user.clone().into();
    match auth::set_password(&state.db, am, &form.new_password).await {
        Ok(_) => htmx.redirect("/users/self/"),
        Err(e) => {
            let slot_ctx = SlotCtx::from_auth(&ctx);
            let page = ChangePasswordPage {
                user_id: 0,
                user_name,
                action: UsersSelfChangePasswordPostRouteTag.path(),
                error: e.to_string(),
                is_self: true,
            };
            html_built_page_or_app_layout(&page, &htmx, &chrome, &slot_ctx).into_response()
        }
    }
}