wasmio 0.0.13

WasmIO a S3 Implementation on steroid
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

use std::str::FromStr;

use bytes::Bytes;
use h2::client;
use http::header::CONTENT_TYPE;
use http::{Method, Request};
use tokio::net::TcpStream;

mod utils;

#[tokio::test]
#[ntest::timeout(10_000)]
pub async fn test_simple_flow() -> anyhow::Result<()> {
    let addr = utils::start_simple_server().await?;

    let tcp = TcpStream::connect(&addr).await?;
    let (mut client, h2) = client::handshake(tcp).await?;

    let req = Request::builder()
        .method(Method::PUT)
        .uri(format!("http://{addr}/new-buck"))
        .header(CONTENT_TYPE, "application/xml")
        .body(())?;

    tokio::spawn(async move {
        if let Err(e) = h2.await {
            println!("GOT ERR={:?}", e);
        }
    });

    let (response, mut stream) = client.send_request(req, false).unwrap();
    let a = r###"
    <CreateBucketConfiguration xmlns="http://s3.amazonaws.com/doc/2006-03-01/">
    </CreateBucketConfiguration>
        "###;
    stream.send_data(Bytes::from(a), true)?;

    let res = response.await?;
    assert_eq!(res.status().as_u16(), 200);

    Ok(())
}