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

pub(crate) fn apply_checksum_response_headers(
    mut response: S3HttpResponse,
    checksums: ValidatedWriteChecksums,
) -> S3HttpResponse {
    if let Some(value) = checksums.content_md5 {
        response.headers.insert("content-md5".to_string(), value);
    }
    if let Some(value) = checksums.checksum_sha256 {
        response
            .headers
            .insert("x-amz-checksum-sha256".to_string(), value);
    }
    response
}

pub(crate) fn apply_encryption_response_headers(
    mut response: S3HttpResponse,
    encryption: Option<&ServerSideEncryption>,
) -> S3HttpResponse {
    if let Some(encryption) = encryption {
        response.headers.insert(
            "x-amz-server-side-encryption".to_string(),
            encryption.algorithm.clone(),
        );
        if let Some(kms_key_id) = &encryption.kms_key_id {
            response.headers.insert(
                "x-amz-server-side-encryption-aws-kms-key-id".to_string(),
                kms_key_id.clone(),
            );
        }
    }
    response
}

pub(crate) fn apply_response_header_overrides(
    mut response: S3HttpResponse,
    query: &BTreeMap<String, String>,
) -> S3HttpResponse {
    for (query_key, header_name) in [
        ("response-cache-control", "cache-control"),
        ("response-content-disposition", "content-disposition"),
        ("response-content-encoding", "content-encoding"),
        ("response-content-language", "content-language"),
        ("response-content-type", "content-type"),
        ("response-expires", "expires"),
    ] {
        if let Some(value) = query.get(query_key) {
            response.headers.insert(header_name.to_string(), value.clone());
        }
    }
    response
}

pub(crate) fn apply_replication_status_header(
    mut response: S3HttpResponse,
    status: Option<&str>,
) -> S3HttpResponse {
    if let Some(status) = status {
        response
            .headers
            .insert("x-amz-replication-status".to_string(), status.to_string());
    }
    response
}