bucketwarden-server 0.1.0

BucketWarden storage server runtime.
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

mod common;

use bucketwarden_s3::S3HttpRequest;
use common::*;

#[test]
fn addressing_depth_supports_path_and_virtual_host_buckets() {
    let mut runtime = runtime();

    let path_bucket = runtime
        .handle_s3_http(
            S3HttpRequest::new("alice", "PUT", "/archive-path")
                .with_header("host", "s3.bucketwarden.test"),
        )
        .expect("path bucket");
    assert_eq!(path_bucket.status, 200);

    let path_put = runtime
        .handle_s3_http(
            S3HttpRequest::new("alice", "PUT", "/archive-path/path.txt")
                .with_header("host", "s3.bucketwarden.test")
                .with_body(b"path".to_vec()),
        )
        .expect("path put");
    assert_eq!(path_put.status, 200);

    let virtual_bucket = runtime
        .handle_s3_http(
            S3HttpRequest::new("alice", "PUT", "/")
                .with_header("host", "archive-vhost.s3.bucketwarden.test"),
        )
        .expect("virtual bucket");
    assert_eq!(virtual_bucket.status, 200);

    let virtual_put = runtime
        .handle_s3_http(
            S3HttpRequest::new("alice", "PUT", "/records/vhost.txt")
                .with_header("host", "archive-vhost.s3.bucketwarden.test")
                .with_body(b"virtual".to_vec()),
        )
        .expect("virtual put");
    assert_eq!(virtual_put.status, 200);

    let virtual_get = runtime
        .handle_s3_http(
            S3HttpRequest::new("alice", "GET", "/records/vhost.txt")
                .with_header("host", "archive-vhost.s3.bucketwarden.test"),
        )
        .expect("virtual get");
    assert_eq!(virtual_get.body, b"virtual");
}

#[test]
fn addressing_depth_enforces_dns_bucket_name_validation() {
    let mut runtime = runtime();
    for (host, expected_status) in [
        ("valid-bucket.s3.bucketwarden.test", 200),
        ("-bad.s3.bucketwarden.test", 400),
        ("bad-.s3.bucketwarden.test", 400),
        ("BadUpper.s3.bucketwarden.test", 400),
    ] {
        let response = runtime
            .handle_s3_http(S3HttpRequest::new("alice", "PUT", "/").with_header("host", host))
            .expect("bucket create");
        assert_eq!(response.status, expected_status, "{host}");
    }

    let invalid = runtime
        .handle_s3_http(
            S3HttpRequest::new("alice", "PUT", "/bad_bucket")
                .with_header("host", "s3.bucketwarden.test"),
        )
        .expect("invalid path bucket");
    assert_error_response(&invalid, 400, "InvalidBucketName", false);
}