raisfast 0.2.23

The last backend you'll ever need. Rust-powered headless CMS with built-in blog, ecommerce, wallet, payment and 4 plugin engines.
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

//! {{ singular }} model and database queries

use serde::{Deserialize, Serialize};
#[cfg(feature = "export-types")]
use ts_rs::TS;

use crate::errors::app_error::{AppError, AppResult};
{% if has_timestamp %}
use crate::utils::tz::Timestamp;
{% endif %}

#[cfg_attr(feature = "export-types", derive(TS))]
#[derive(Debug, Serialize, Deserialize, Clone, sqlx::FromRow)]
pub struct {{ struct_name }} {
{% for col in columns %}
    pub {{ col.name }}: {{ col.rust_type }},
{% endfor %}
}

pub async fn find_all(
    pool: &crate::db::Pool{% if has_tenant_id %},
    tenant_id: Option<&str>{% endif %}
) -> AppResult<Vec<{{ struct_name }}>> {
    raisfast_derive::crud_list!(pool, "{{ name }}", {{ struct_name }}{% if has_tenant_id %}, tenant: tenant_id{% endif %})
        .map_err(Into::into)
}

pub async fn find_paginated(
    pool: &crate::db::Pool{% if has_tenant_id %},
    tenant_id: Option<&str>{% endif %},
    page: i64,
    page_size: i64,
) -> AppResult<(Vec<{{ struct_name }}>, i64)> {
    let result = raisfast_derive::crud_query_paged!(
        pool, {{ struct_name }},
        data_sql: "SELECT * FROM {{ name }} WHERE 1=1{tenant}",
        count_sql: "SELECT COUNT(*) FROM {{ name }} WHERE 1=1{tenant}",
        binds: [],
{% if has_tenant_id %}
        tenant: tenant_id,
{% endif %}
        page: page,
        page_size: page_size
    );
    Ok(result)
}

pub async fn find_by_id(
    pool: &crate::db::Pool,
    id: i64{% if has_tenant_id %},
    tenant_id: Option<&str>{% endif %}
) -> AppResult<{{ struct_name }}> {
    raisfast_derive::crud_find_one!(pool, "{{ name }}", {{ struct_name }}, "id" => id{% if has_tenant_id %}, tenant: tenant_id{% endif %})
        .map_err(Into::into)
}

pub async fn delete(
    pool: &crate::db::Pool,
    id: i64{% if has_tenant_id %},
    tenant_id: Option<&str>{% endif %}
) -> AppResult<()> {
    let result = raisfast_derive::crud_delete!(pool, "{{ name }}", "id" => id{% if has_tenant_id %}, tenant: tenant_id{% endif %})?;
    AppError::expect_affected(&result, "{{ singular }}")
}

pub async fn create(
    pool: &crate::db::Pool{% if has_tenant_id %},
    tenant_id: Option<&str>{% endif %}
    // TODO: add parameters
) -> AppResult<{{ struct_name }}> {
    todo!("implement create for {{ struct_name }}")
}

pub async fn update(
    pool: &crate::db::Pool{% if has_tenant_id %},
    tenant_id: Option<&str>{% endif %}
    // TODO: add parameters
) -> AppResult<{{ struct_name }}> {
    todo!("implement update for {{ struct_name }}")
}