aws-sdk-s3 1.141.0

AWS SDK for Amazon Simple Storage Service
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

/*
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: Apache-2.0
 */

use std::sync::atomic::{AtomicI32, Ordering};
use std::sync::Arc;

use aws_config::{BehaviorVersion, Region};
use aws_credential_types::{
    provider::{future::ProvideCredentials as ProvideCredentialsFuture, ProvideCredentials},
    Credentials,
};
use aws_sdk_s3::Client;
use aws_smithy_http_client::test_util::infallible_client_fn;

// NOTE: These tests are _not_ S3 specific and would apply to any AWS SDK but due to the need to consume `aws-config`
// (which depends on relocated runtime crates) we can't make this an `awsSdkIntegrationTest(..)`.

#[tokio::test]
async fn test_identity_cache_reused_by_default() {
    let http_client = infallible_client_fn(|_req| {
        http_1x::Response::builder()
            .status(200)
            .body("OK!")
            .unwrap()
    });

    let provider = TestCredProvider::new();
    let config = aws_config::defaults(BehaviorVersion::latest())
        .http_client(http_client)
        .credentials_provider(provider.clone())
        .region(Region::new("us-west-2"))
        .load()
        .await;

    let c1 = Client::new(&config);
    let _ = c1.list_buckets().send().await;
    assert_eq!(1, provider.invoke_count.load(Ordering::SeqCst));

    let c2 = Client::new(&config);
    let _ = c2.list_buckets().send().await;
    assert_eq!(1, provider.invoke_count.load(Ordering::SeqCst));
}

#[allow(deprecated)] // intentionally testing an old behavior version
#[tokio::test]
async fn test_identity_cache_ga_behavior_version() {
    let http_client = infallible_client_fn(|_req| {
        http_1x::Response::builder()
            .status(200)
            .body("OK!")
            .unwrap()
    });

    let provider = TestCredProvider::new();

    // no cache is defined in this behavior version by default so each client should get their own
    let config = aws_config::defaults(BehaviorVersion::v2023_11_09())
        .http_client(http_client)
        .credentials_provider(provider.clone())
        .region(Region::new("us-west-2"))
        .load()
        .await;

    let c1 = Client::new(&config);
    let _ = c1.list_buckets().send().await;
    assert_eq!(1, provider.invoke_count.load(Ordering::SeqCst));

    let c2 = Client::new(&config);
    let _ = c2.list_buckets().send().await;
    assert_eq!(2, provider.invoke_count.load(Ordering::SeqCst));
}

#[derive(Clone, Debug)]
struct TestCredProvider {
    invoke_count: Arc<AtomicI32>,
    creds: Credentials,
}

impl TestCredProvider {
    fn new() -> Self {
        TestCredProvider {
            invoke_count: Arc::new(AtomicI32::default()),
            creds: Credentials::for_tests(),
        }
    }
}

impl ProvideCredentials for TestCredProvider {
    fn provide_credentials<'a>(
        &'a self,
    ) -> aws_credential_types::provider::future::ProvideCredentials<'a>
    where
        Self: 'a,
    {
        self.invoke_count.fetch_add(1, Ordering::SeqCst);
        ProvideCredentialsFuture::ready(Ok(self.creds.clone()))
    }
}