glaredb_http 25.6.3

HTTP and Object Storage functionality for GlareDB
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

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct S3ListResponse<'a> {
    pub is_truncated: bool,
    pub next_continuation_token: Option<&'a str>,
    pub contents: Option<Vec<S3ListContents<'a>>>,
    pub common_prefixes: Option<Vec<S3Prefix<'a>>>,
}

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct S3ListContents<'a> {
    pub key: &'a str,
    pub last_modified: DateTime<Utc>,
    pub size: usize,
}

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct S3Prefix<'a> {
    pub prefix: &'a str,
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn basic_no_continuation() {
        let input = r#"
          <ListBucketResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/">
              <Name>bucket</Name>
              <Prefix/>
              <KeyCount>205</KeyCount>
              <MaxKeys>1000</MaxKeys>
              <IsTruncated>false</IsTruncated>
              <Contents>
                  <Key>my-image.jpg</Key>
                  <LastModified>2009-10-12T17:50:30.000Z</LastModified>
                  <ETag>"fba9dede5f27731c9771645a39863328"</ETag>
                  <Size>434234</Size>
                  <StorageClass>STANDARD</StorageClass>
              </Contents>
          </ListBucketResult>
        "#;

        let resp: S3ListResponse = quick_xml::de::from_str(input).unwrap();

        let expected = S3ListResponse {
            is_truncated: false,
            next_continuation_token: None,
            contents: Some(vec![S3ListContents {
                key: "my-image.jpg",
                last_modified: DateTime::parse_from_rfc3339("2009-10-12T17:50:30.000Z")
                    .unwrap()
                    .to_utc(),
                size: 434234,
            }]),
            common_prefixes: None,
        };

        assert_eq!(expected, resp);
    }

    #[test]
    fn basic_with_continuation() {
        let input = r#"
          <ListBucketResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/">
              <Name>bucket</Name>
              <Prefix/>
              <NextContinuationToken>1ueGcxLPRx1Tr/XYExHnhbYLgveDs2J/wm36Hy4vbOwM=</NextContinuationToken>
              <KeyCount>205</KeyCount>
              <MaxKeys>1000</MaxKeys>
              <IsTruncated>true</IsTruncated>
              <Contents>
                  <Key>my-image.jpg</Key>
                  <LastModified>2009-10-12T17:50:30.000Z</LastModified>
                  <ETag>"fba9dede5f27731c9771645a39863328"</ETag>
                  <Size>434234</Size>
                  <StorageClass>STANDARD</StorageClass>
              </Contents>
          </ListBucketResult>
        "#;

        let resp: S3ListResponse = quick_xml::de::from_str(input).unwrap();

        let expected = S3ListResponse {
            is_truncated: true,
            next_continuation_token: Some("1ueGcxLPRx1Tr/XYExHnhbYLgveDs2J/wm36Hy4vbOwM="),
            contents: Some(vec![S3ListContents {
                key: "my-image.jpg",
                last_modified: DateTime::parse_from_rfc3339("2009-10-12T17:50:30.000Z")
                    .unwrap()
                    .to_utc(),
                size: 434234,
            }]),
            common_prefixes: None,
        };

        assert_eq!(expected, resp);
    }
}