deboa-extras 0.0.9-beta.7

deboa extras (serialization, compression, websockets, streams, catchers (middleware) and sse support).
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

use crate::http::serde::cbor::CborBody;
use deboa::errors::{ContentError, DeboaError};
use deboa::{request::DeboaRequest, response::DeboaResponse, Result};
use deboa_tests::data::{sample_post, Post};
use deboa_tests::utils::fake_url;
use http_body_util::BodyExt;

fn build_sample_cbor_body() -> Vec<u8> {
    let mut buf = Vec::new();
    let body = sample_post();
    ciborium::ser::into_writer(&body, &mut buf).unwrap();
    buf
}

async fn do_test_set_cbor() -> Result<()> {
    let request = DeboaRequest::post(fake_url())?
        .body_as(CborBody, sample_post())?
        .build()?;

    let bytes = request
        .body()
        .collect()
        .await
        .unwrap()
        .to_bytes();

    assert_eq!(bytes, build_sample_cbor_body());

    Ok(())
}

#[tokio::test]
async fn test_set_cbor() {
    do_test_set_cbor()
        .await
        .unwrap();
}

#[test]
fn test_set_cbor_registers_headers() -> Result<()> {
    let request = DeboaRequest::post(fake_url())?
        .body_as(CborBody, sample_post())?
        .build()?;

    assert_eq!(
        request
            .headers()
            .get(http::header::CONTENT_TYPE)
            .unwrap()
            .to_str()
            .unwrap(),
        "application/cbor"
    );
    assert_eq!(
        request
            .headers()
            .get(http::header::ACCEPT)
            .unwrap()
            .to_str()
            .unwrap(),
        "application/cbor"
    );

    Ok(())
}

#[tokio::test]
async fn test_response_cbor() -> Result<()> {
    let data = sample_post();

    let response = DeboaResponse::builder(fake_url())
        .status(http::StatusCode::OK)
        .header(http::header::CONTENT_TYPE, "application/cbor")
        .body(build_sample_cbor_body())
        .build();
    let response: Post = response
        .body_as(CborBody)
        .await?;

    assert_eq!(response, data);

    Ok(())
}

#[tokio::test]
async fn test_response_cbor_invalid_body() {
    let response = DeboaResponse::builder(fake_url())
        .status(http::StatusCode::OK)
        .header(http::header::CONTENT_TYPE, "application/cbor")
        .body(vec![0xff])
        .build();

    let result: Result<Post> = response
        .body_as(CborBody)
        .await;
    let err = result.unwrap_err();

    assert!(matches!(err, DeboaError::Content(ContentError::Deserialization { .. })));
}