zero4rs 2.0.0

zero4rs is a powerful, pragmatic, and extremely fast web framework for Rust
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

use crate::commons::validatorr::validation_flatten;
use crate::prelude2::*;

use crate::services::note_service::CreateNoteSchema;
use crate::services::note_service::FilterOptions;
use crate::services::note_service::UpdateNoteSchema;

use crate::services::note_service::delete_note_by_id;
use crate::services::note_service::note_update;
use crate::services::note_service::save_note;
use crate::services::note_service::select_by_id;
use crate::services::note_service::select_nodes;

// 查询列表
pub async fn list_notes(
    opts: web::Query<FilterOptions>,
    app_state: web::Data<AppContext>,
    request: HttpRequest,
) -> impl Responder {
    if let Some(err) = validation_flatten(&opts.0) {
        return request.json(200, R::invalid(err));
    }

    let limit = opts.limit.unwrap_or(10);
    let offset = (opts.page.unwrap_or(1) - 1) * limit;
    let note_responses = select_nodes(limit, offset, app_state.mysql()).await?;

    request.json(200, R::ok(note_responses))
}

// 创建
pub async fn create_note(
    body: web::Json<CreateNoteSchema>,
    app_state: web::Data<AppContext>,
    request: HttpRequest,
) -> impl Responder {
    if let Some(err) = validation_flatten(&body.0) {
        return request.json(200, R::invalid(err));
    }

    let user_id = save_note(&body.0, app_state.mysql()).await?;

    request.json(200, R::ok(user_id))
}

// 查询详情
pub async fn note_details(
    note_id: web::Path<String>,
    app_state: web::Data<AppContext>,
    request: HttpRequest,
) -> impl Responder {
    let note_id = note_id.into_inner();
    let result = select_by_id(&note_id, app_state.mysql()).await?;

    request.json(200, R::ok(result))
}

// 更新
pub async fn update_note(
    note_id: web::Path<String>,
    body: web::Json<UpdateNoteSchema>,
    app_state: web::Data<AppContext>,
    request: HttpRequest,
) -> impl Responder {
    if let Some(err) = validation_flatten(&body.0) {
        return request.json(200, R::invalid(err));
    }

    let note_id = note_id.into_inner();
    let result = note_update(&note_id, &body.0, app_state.mysql()).await?;

    request.json(200, R::ok(result))
}

// 删除
pub async fn delete_note(
    note_id: web::Path<String>,
    app_state: web::Data<AppContext>,
    request: HttpRequest,
) -> impl Responder {
    let note_id = note_id.into_inner();
    let result = delete_note_by_id(&note_id, app_state.mysql()).await?;

    request.json(200, R::ok(result))
}