deboa-extras 0.0.9-beta.11

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

use deboa::{
    catcher::DeboaCatcher,
    response::{DeboaResponse, IntoBody},
    Result,
};
use http::{Response, StatusCode};

use crate::{catcher::encoding::EncodingCatcher, io::brotli::BrotliDecompressor};

use deboa_tests::{
    data::{BROTLI_COMPRESSED, DECOMPRESSED},
    utils::fake_url,
};

#[tokio::test]
async fn test_brotli_decompress() -> Result<()> {
    let encoding_catcher = EncodingCatcher::register_decoders(vec![BrotliDecompressor]);

    let response = Response::builder()
        .status(StatusCode::OK)
        .header("Content-Encoding", "br")
        .body(BROTLI_COMPRESSED.into_body())
        .unwrap();

    let mut response = DeboaResponse::new(fake_url().into(), response);

    encoding_catcher
        .on_response(&mut response)
        .await?;

    assert_eq!(
        response
            .raw_body()
            .await,
        DECOMPRESSED
    );
    Ok(())
}