by-loco 0.15.1

The one-person 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
86
87
88
89
90

use loco_rs::{prelude::*, tests_cfg};
use serde::{Deserialize, Serialize};
use validator::Validate;

use crate::infra_cfg;

#[derive(Debug, Deserialize, Serialize, Validate)]
pub struct Data {
    #[validate(length(min = 5, message = "message_str"))]
    pub name: String,
    #[validate(email)]
    pub email: String,
}

async fn validation_with_response(
    JsonValidateWithMessage(_params): JsonValidateWithMessage<Data>,
) -> Result<Response> {
    format::json(())
}

async fn simple_validation(JsonValidate(_params): JsonValidate<Data>) -> Result<Response> {
    format::json(())
}

#[tokio::test]
async fn can_validation_with_response() {
    let ctx = tests_cfg::app::get_app_context().await;

    let port = get_available_port().await;
    let handle =
        infra_cfg::server::start_with_route(ctx, "/", post(validation_with_response), Some(port))
            .await;

    let client = reqwest::Client::new();
    let res = client
        .post(get_base_url_port(port))
        .json(&serde_json::json!({"name": "test", "email": "invalid"}))
        .send()
        .await
        .expect("Valid response");

    assert_eq!(res.status(), 400);

    let res_text = res.text().await.expect("response text");
    let res_json: serde_json::Value = serde_json::from_str(&res_text).expect("Valid JSON response");

    let expected_json = serde_json::json!(
        {
            "errors":{
                "email":[{"code":"email","message":null,"params":{"value":"invalid"}}],
                "name":[{"code":"length","message":"message_str","params":{"min":5,"value":"test"}}]
        }
    });

    assert_eq!(res_json, expected_json);

    handle.abort();
}

#[tokio::test]
async fn can_validation_without_response() {
    let ctx = tests_cfg::app::get_app_context().await;

    let port = get_available_port().await;
    let handle =
        infra_cfg::server::start_with_route(ctx, "/", post(simple_validation), Some(port)).await;

    let client = reqwest::Client::new();
    let res = client
        .post(get_base_url_port(port))
        .json(&serde_json::json!({"name": "test", "email": "invalid"}))
        .send()
        .await
        .expect("Valid response");

    assert_eq!(res.status(), 400);

    let res_text = res.text().await.expect("response text");
    let res_json: serde_json::Value = serde_json::from_str(&res_text).expect("Valid JSON response");

    let expected_json = serde_json::json!(
        {
            "error": "Bad Request"
        }
    );

    assert_eq!(res_json, expected_json);

    handle.abort();
}