sova-core 0.1.13

Core HTTP primitives for Sova (App, Router, Request, Response)
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

//! Extractor handlers + legacy `Fn(Request)` regression.

use http::Method;
use serde::{Deserialize, Serialize};
use sova_core::extract::{Json, Path, State};
use sova_core::{App, Cell, Request, Response};

#[derive(Clone)]
struct Counter {
    n: Cell<u64>,
}

impl Default for Counter {
    fn default() -> Self {
        Self { n: Cell::new(0) }
    }
}

#[derive(Deserialize)]
struct IdPath {
    id: String,
}

#[derive(Deserialize, Serialize)]
struct Body {
    msg: String,
}

#[tokio::test]
async fn extractors_path_json_state() {
    let mut app = App::new();
    app.state(Counter::default());
    app.post("/echo/:id", echo);

    let res = app
        .handle_request(Method::POST, "/echo/42", r#"{"msg":"hi"}"#)
        .await;
    assert_eq!(res.status_code().as_u16(), 200);
    let v: serde_json::Value = serde_json::from_slice(res.body_bytes().unwrap()).unwrap();
    assert_eq!(v["id"], "42");
    assert_eq!(v["msg"], "hi");
    assert_eq!(v["n"], 1);
}

async fn echo(
    Path(IdPath { id }): Path<IdPath>,
    Json(Body { msg }): Json<Body>,
    State(counter): State<Counter>,
) -> Response {
    counter.n.update(|v| v + 1);
    let n = counter.n.get();
    Response::json(&serde_json::json!({ "id": id, "msg": msg, "n": n }))
}

#[tokio::test]
async fn legacy_request_handler_still_works() {
    let mut app = App::new();
    app.get("/ping", |req: Request| async move {
        format!("pong:{}", req.path)
    });
    let res = app.handle_request(Method::GET, "/ping", "").await;
    assert_eq!(res.status_code().as_u16(), 200);
    let body = String::from_utf8_lossy(res.body_bytes().unwrap());
    assert_eq!(body, "pong:/ping");
}