tideway 0.1.0

A batteries-included Rust web framework built on Axum for building SaaS applications quickly
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
150
151
152
153
154
155

//! Validation Example
//!
//! Demonstrates request validation with ValidatedJson, ValidatedQuery,
//! and custom validators.

#[cfg(not(feature = "validation"))]
fn main() {
    println!("This example requires the 'validation' feature:");
    println!("cargo run --example validation_example --features validation");
}

#[cfg(feature = "validation")]
fn main() {
    println!("Validation example - see tests in the source code");
    println!("Run: cargo test --example validation_example --features validation");
}

#[cfg(feature = "validation")]
#[cfg(test)]
mod tests {
    use axum::{routing::{get as axum_get, post as axum_post}, Router, Json};
    use serde::Deserialize;
    use tideway::{
        testing::{get as test_get, post as test_post},
        validation::{ValidatedJson, ValidatedQuery, validate_uuid, validate_slug},
    };
    use validator::Validate;

    #[derive(Deserialize, Validate)]
    struct CreateUserRequest {
        #[validate(email)]
        email: String,

        #[validate(length(min = 8))]
        password: String,

        #[validate(custom = "validate_uuid")]
        organization_id: String,

        #[validate(custom = "validate_slug")]
        username: String,
    }

    #[derive(Deserialize, Validate)]
    struct SearchQuery {
        #[validate(length(min = 1, max = 100))]
        q: String,

        #[validate(range(min = 1, max = 100))]
        limit: Option<u32>,
    }

    async fn create_user(
        ValidatedJson(req): ValidatedJson<CreateUserRequest>,
    ) -> tideway::Result<Json<serde_json::Value>> {
        Ok(Json(serde_json::json!({
            "status": "created",
            "user": {
                "email": req.email,
                "username": req.username,
            }
        })))
    }

    async fn search(
        ValidatedQuery(query): ValidatedQuery<SearchQuery>,
    ) -> tideway::Result<Json<serde_json::Value>> {
        Ok(Json(serde_json::json!({
            "query": query.q,
            "limit": query.limit.unwrap_or(10),
            "results": []
        })))
    }

    #[tokio::test]
    async fn test_valid_user_creation() {
        let app = Router::new().route("/users", axum_post(create_user));

        test_post(app, "/users")
            .with_json(&serde_json::json!({
                "email": "test@example.com",
                "password": "password123",
                "organization_id": "550e8400-e29b-41d4-a716-446655440000",
                "username": "test-user"
            }))
            .execute()
            .await
            .assert_status(200)
            .assert_json_path("status", serde_json::json!("created"));
    }

    #[tokio::test]
    async fn test_invalid_email() {
        let app = Router::new().route("/users", axum_post(create_user));

        test_post(app, "/users")
            .with_json(&serde_json::json!({
                "email": "invalid-email",
                "password": "password123",
                "organization_id": "550e8400-e29b-41d4-a716-446655440000",
                "username": "test-user"
            }))
            .execute()
            .await
            .assert_bad_request()
            .assert_json_path("field_errors.email", serde_json::json!(["must be a valid email"]));
    }

    #[tokio::test]
    async fn test_invalid_uuid() {
        let app = Router::new().route("/users", axum_post(create_user));

        test_post(app, "/users")
            .with_json(&serde_json::json!({
                "email": "test@example.com",
                "password": "password123",
                "organization_id": "invalid-uuid",
                "username": "test-user"
            }))
            .execute()
            .await
            .assert_bad_request();
    }

    #[tokio::test]
    async fn test_valid_search() {
        use tideway::testing::get as test_get;
        use axum::routing::get as axum_get;

        let app = Router::new().route("/search", axum_get(search));

        let response = test_get(app, "/search")
            .with_query(&[("q", "test"), ("limit", "20")])
            .execute()
            .await
            .assert_ok();

        response.assert_json_path("query", serde_json::json!("test")).await;
        response.assert_json_path("limit", serde_json::json!(20)).await;
    }

    #[tokio::test]
    async fn test_invalid_search_limit() {
        use tideway::testing::get as test_get;
        use axum::routing::get as axum_get;

        let app = Router::new().route("/search", axum_get(search));

        test_get(app, "/search")
            .with_query(&[("q", "test"), ("limit", "200")]) // limit > 100
            .execute()
            .await
            .assert_bad_request();
    }
}