tokio-rs/axum
1
0
Fork 0
mirror of https://github.com/tokio-rs/axum.git synced 2026-08-27 00:00:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

[test] the validator example (#3276)

Browse Source
This commit is contained in:
Gábor Szabó
2025-03-18 10:51:30 +01:00
committed by GitHub
parent c997137383
commit 6fa7cce19d
3 changed files with 92 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Cargo.lock
Generated
+2
View File
@@ -1951,9 +1951,11 @@ name = "example-validator"
version = "0.1.0" version = "0.1.0"
dependencies = [ dependencies = [
"axum", "axum",
"http-body-util",
"serde", "serde",
"thiserror 1.0.69", "thiserror 1.0.69",
"tokio", "tokio",
"tower 0.5.2",
"tracing", "tracing",
"tracing-subscriber", "tracing-subscriber",
"validator", "validator",
examples/validator/Cargo.toml
+4
View File
@@ -12,3 +12,7 @@ tokio = { version = "1.0", features = ["full"] }
tracing = "0.1" tracing = "0.1"
tracing-subscriber = { version = "0.3", features = ["env-filter"] } tracing-subscriber = { version = "0.3", features = ["env-filter"] }
validator = { version = "0.18.1", features = ["derive"] } validator = { version = "0.18.1", features = ["derive"] }
[dev-dependencies]
http-body-util = "0.1.0"
tower = { version = "0.5.2", features = ["util"] }
examples/validator/src/main.rs
+86 -2
View File
@@ -34,7 +34,7 @@ async fn main() {
.init(); .init();
// build our application with a route // build our application with a route
let app = Router::new().route("/", get(handler)); let app = app();
// run it // run it
let listener = TcpListener::bind("127.0.0.1:3000").await.unwrap(); let listener = TcpListener::bind("127.0.0.1:3000").await.unwrap();
@@ -42,9 +42,13 @@ async fn main() {
axum::serve(listener, app).await.unwrap(); axum::serve(listener, app).await.unwrap();
} }
fn app() -> Router {
Router::new().route("/", get(handler))
}
#[derive(Debug, Deserialize, Validate)] #[derive(Debug, Deserialize, Validate)]
pub struct NameInput { pub struct NameInput {
#[validate(length(min = 1, message = "Can not be empty"))] #[validate(length(min = 2, message = "Can not be empty"))]
pub name: String, pub name: String,
} }
@@ -91,3 +95,83 @@ impl IntoResponse for ServerError {
.into_response() .into_response()
} }
} }
#[cfg(test)]
mod tests {
use super::*;
use axum::{
body::Body,
http::{Request, StatusCode},
};
use http_body_util::BodyExt;
use tower::ServiceExt;
async fn get_html(response: Response<Body>) -> String {
let body = response.into_body();
let bytes = body.collect().await.unwrap().to_bytes();
String::from_utf8(bytes.to_vec()).unwrap()
}
#[tokio::test]
async fn test_no_param() {
let response = app()
.oneshot(Request::builder().uri("/").body(Body::empty()).unwrap())
.await
.unwrap();
assert_eq!(response.status(), StatusCode::BAD_REQUEST);
let html = get_html(response).await;
assert_eq!(html, "Failed to deserialize form: missing field `name`");
}
#[tokio::test]
async fn test_with_param_without_value() {
let response = app()
.oneshot(
Request::builder()
.uri("/?name=")
.body(Body::empty())
.unwrap(),
)
.await
.unwrap();
assert_eq!(response.status(), StatusCode::BAD_REQUEST);
let html = get_html(response).await;
assert_eq!(html, "Input validation error: [name: Can not be empty]");
}
#[tokio::test]
async fn test_with_param_with_short_value() {
let response = app()
.oneshot(
Request::builder()
.uri("/?name=X")
.body(Body::empty())
.unwrap(),
)
.await
.unwrap();
assert_eq!(response.status(), StatusCode::BAD_REQUEST);
let html = get_html(response).await;
assert_eq!(html, "Input validation error: [name: Can not be empty]");
}
#[tokio::test]
async fn test_with_param_and_value() {
let response = app()
.oneshot(
Request::builder()
.uri("/?name=LT")
.body(Body::empty())
.unwrap(),
)
.await
.unwrap();
assert_eq!(response.status(), StatusCode::OK);
let html = get_html(response).await;
assert_eq!(html, "<h1>Hello, LT!</h1>");
}
}