amiya 0.0.6

experimental middleware-based minimalism async HTTP server framework
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

use {
    amiya::{m, middleware::Router, Context, Result, StatusCode},
    serde::{Deserialize, Serialize},
    serde_json::{Map, Value},
};

async fn parse_body_urlencoded(mut ctx: Context<'_, ()>) -> Result {
    if let Some(ct) = ctx.req.header("content-type") {
        if ct.as_str().starts_with("application/x-www-form-urlencoded") {
            let body: Map<String, Value> = ctx.body().unwrap().into_form().await?;
            ctx.resp.set_body(Value::Object(body));
            return Ok(());
        }
    }

    ctx.resp.set_status(StatusCode::BadRequest);
    Ok(())
}

#[derive(Debug, Deserialize, Serialize)]
struct SendCommentBody {
    uid: String,
    attitude: Option<String>,
    comment: String,
}

async fn parse_body_struct(mut ctx: Context<'_, ()>) -> Result {
    if let Some(ct) = ctx.req.header("content-type") {
        if ct.as_str().starts_with("application/x-www-form-urlencoded") {
            let body: SendCommentBody = if let Ok(body) = ctx.body().unwrap().into_form().await {
                body
            } else {
                ctx.resp.set_status(StatusCode::BadRequest);
                return Ok(());
            };
            ctx.resp.set_body(serde_json::to_value(body)?);
            return Ok(());
        }
    }

    ctx.resp.set_status(StatusCode::BadRequest);
    Ok(())
}

fn main() {
    #[rustfmt::skip]
    let router = Router::new()
        .at("object").post(m!(parse_body_urlencoded)).done()
        .at("struct").post(m!(parse_body_struct)).done();

    let app = amiya::new().uses(router);

    app.listen("[::]:8080").unwrap();

    std::thread::park();
}