The Rust web framework that feels like Express.

app.get("/users/:id", |req| async move {
    let id: u64 = req.param("id")?;          // 400 if not a number
    Ok::<_, ServerError>(Json(json!({ "id": id })))
});

app.post("/users", |req| async move {
    let user: NewUser = req.json()?;         // 415 / 400 / 422 for bad input
    Ok::<_, ServerError>((201, Json(user)))
});

app.middleware(from_fn(|req, next| async move {
    let start = Instant::now();
    let res = next.handle(req).await?;
    println!("{} in {:?}", res.status, start.elapsed());
    Ok(res)
}));

app.layer(TimeoutLayer::with_status_code(    // any tower layer works too
    StatusCode::REQUEST_TIMEOUT,
    Duration::from_secs(10),
));

let jwt = Jwt::hs256(&secret);

let mut api = Router::new();
api.middleware(jwt.middleware::<Claims>());  // 401 without a valid token
api.get("/me", |req| async move {
    req.extension::<Claims>().map(|c| c.sub.clone())
});
app.mount("/api", api);

app.get("/ws", |mut req| async move {
    req.upgrade_websocket(|mut socket| async move {
        while let Some(Ok(message)) = socket.recv().await {
            if socket.send(message).await.is_err() {
                break;
            }
        }
    })
});

#[tokio::test]
async fn says_hello() {
    let app = app().into_app().await.unwrap();
    let res = app.call(Request::new(Method::GET, "/hello/Ada")).await;
    assert_eq!(res.status, 200);
    assert_eq!(res.body_text(), "Hello, Ada!");
}