rasi-ext 0.1.11

This library includes extend features or experimental features that are useful for asynchronous programming.
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
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
100
101
102
103
104
105
106
107
108
109
110

use std::path::Path;

use boring::ssl::{SslAcceptor, SslFiletype, SslMethod};
use http::{Response, StatusCode};
use rasi::{executor::spawn, net::TcpListener};
use rasi_ext::net::http::{client::HttpRequestSend, server::HttpServer, types::Request};

mod init;

#[futures_test::test]
async fn test_http() {
    init::init();

    let listener = TcpListener::bind("127.0.0.1:0").await.unwrap();

    let raddr = listener.local_addr().unwrap();

    spawn(async move {
        HttpServer::on(listener)
            .serve(|req, resp| async move {
                assert_eq!(req.uri().path(), "/hello");

                resp.write(
                    Response::builder()
                        .status(StatusCode::OK)
                        .body("hello world")
                        .unwrap(),
                )
                .await?;

                Ok(())
            })
            .await
            .unwrap();
    });

    let response = Request::get(format!("http://{:?}/hello", raddr))
        .body("")
        .send()
        .response()
        .await
        .unwrap();

    assert_eq!(response.status(), StatusCode::OK);

    let (_, body) = response.into_parts();

    assert_eq!(body.into_bytes(1024, None).await.unwrap(), "hello world");
}

#[futures_test::test]
async fn test_https() {
    init::init();

    let listener = TcpListener::bind("127.0.0.1:0").await.unwrap();

    let raddr = listener.local_addr().unwrap();

    spawn(async move {
        let root_path = Path::new(env!("CARGO_MANIFEST_DIR"));

        let mut acceptor = SslAcceptor::mozilla_intermediate(SslMethod::tls()).unwrap();

        acceptor
            .set_private_key_file(root_path.join("cert/server.key"), SslFiletype::PEM)
            .unwrap();
        acceptor
            .set_certificate_chain_file(root_path.join("cert/server.crt"))
            .unwrap();

        acceptor.check_private_key().unwrap();

        HttpServer::on(listener)
            .with_ssl(acceptor.build())
            .serve(|req, resp| async move {
                assert_eq!(req.uri().path(), "/hello");

                resp.write(
                    Response::builder()
                        .status(StatusCode::OK)
                        .body("hello world")
                        .unwrap(),
                )
                .await?;

                Ok(())
            })
            .await
            .unwrap();
    });

    let root_path = Path::new(env!("CARGO_MANIFEST_DIR"));

    let ca_file = root_path.join("cert/rasi_ca.pem");

    let response = Request::get(format!("https://rasi.quic/hello"))
        .body("")
        .send()
        .redirect(raddr)
        .with_ca_file(ca_file)
        .response()
        .await
        .unwrap();

    assert_eq!(response.status(), StatusCode::OK);

    let (_, body) = response.into_parts();

    assert_eq!(body.into_bytes(1024, None).await.unwrap(), "hello world");
}