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

//! Public catch-all website pages + home fallback.

use axum::{
    extract::{OriginalUri, Query},
    response::{IntoResponse, Redirect, Response},
};
use serde::Deserialize;
use std::sync::Arc;

use crate::{
    grapesjs::GrapesJsCapability,
    http::Cap,
    plugins::{
        users::middleware::OptionalAuth,
        website::{
            match_route::find_matching_db_route, render::render_db_route, state::WebsiteState,
        },
    },
};

#[derive(Debug, Deserialize, Default)]
pub struct EmptyQuery {
    #[serde(flatten)]
    pub rest: std::collections::HashMap<String, String>,
}

fn query_pairs(q: &EmptyQuery) -> Vec<(String, String)> {
    q.rest.iter().map(|(k, v)| (k.clone(), v.clone())).collect()
}

/// `GET /` — render matching DB route or redirect login/dashboard.
pub async fn home(
    Cap(state): Cap<WebsiteState>,
    Cap(grapes): Cap<Arc<GrapesJsCapability>>,
    OptionalAuth(auth): OptionalAuth,
    uri: OriginalUri,
    Query(q): Query<EmptyQuery>,
) -> Response {
    let path = uri.0.path();
    match find_matching_db_route(&state.db, path).await {
        Ok(Some(route)) => {
            render_db_route(
                &state.db,
                state.store.as_ref(),
                &grapes,
                &route,
                path,
                query_pairs(&q),
            )
            .await
        }
        Ok(None) => {
            if auth.is_some() {
                Redirect::to("/dashboard").into_response()
            } else {
                Redirect::to("/users/login").into_response()
            }
        }
        Err(e) => {
            tracing::error!(error = %e, "website: home route match failed");
            (
                axum::http::StatusCode::INTERNAL_SERVER_ERROR,
                "Internal Server Error",
            )
                .into_response()
        }
    }
}

/// `GET /{*path}` — public dynamic website pages.
pub async fn catch_all(
    Cap(state): Cap<WebsiteState>,
    Cap(grapes): Cap<Arc<GrapesJsCapability>>,
    uri: OriginalUri,
    Query(q): Query<EmptyQuery>,
) -> Response {
    let path = uri.0.path();
    match find_matching_db_route(&state.db, path).await {
        Ok(Some(route)) => {
            render_db_route(
                &state.db,
                state.store.as_ref(),
                &grapes,
                &route,
                path,
                query_pairs(&q),
            )
            .await
        }
        Ok(None) => (axum::http::StatusCode::NOT_FOUND, "404 Not Found").into_response(),
        Err(e) => {
            tracing::error!(error = %e, "website: catch-all match failed");
            (
                axum::http::StatusCode::INTERNAL_SERVER_ERROR,
                "Internal Server Error",
            )
                .into_response()
        }
    }
}