AWS SDK

rev. 1fb202108840af7ccb1069c5b8afebf43a5e5aec

Files changed:

tmp-codegen-diff/aws-sdk/sdk/dynamodb/Cargo.toml

@@ -1,1 +0,148 @@

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-dynamodb"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon DynamoDB"
 edition = "2021"
 license = "Apache-2.0"

 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.81.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]
 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.1"
 version = "1.2.2"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.5"
 version = "1.5.6"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.4"
 version = "1.2.5"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.61.1"
 version = "0.62.0"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.2"
 version = "0.61.3"
-36
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.7.8"
 version = "1.8.0"
-41
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.7.3"
 version = "1.7.4"
-46
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.2.13"
 version = "1.3.0"
-50
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.5"
 version = "1.3.6"
-54
 [dependencies.bytes]
 version = "1.4.0"
-57
 [dependencies.fastrand]
 version = "2.0.0"
-60
 [dependencies.http]
 version = "0.2.9"
-63
 [dependencies.once_cell]
 version = "1.16"
-66
 [dependencies.regex-lite]
 version = "0.1.5"
-69
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.approx]
 version = "0.5.1"
-74
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.5.18"
 version = "1.6.0"
-78
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.1"
 version = "1.2.2"
-83
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.5"
 version = "1.5.6"
-88
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.4"
 version = "1.2.5"
-+
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.0.0"
-98
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.0"
 version = "0.63.1"
-102
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util", "wire-mock"]
 version = "1.7.8"
 features = ["test-util"]
 version = "1.8.0"
-107
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.7.3"
 version = "1.7.4"
-112
 [dev-dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["test-util"]
 version = "1.2.13"
 version = "1.3.0"
-117
 [dev-dependencies.criterion]
 version = "0.5.0"
-120
 [dev-dependencies.futures-util]
 version = "0.3.25"
 features = ["alloc"]
 default-features = false
-125
 [dev-dependencies.http-1x]
 version = "1"
 package = "http"
-+
 [dev-dependencies.serde_json]
 version = "1.0.0"
-132
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-136
 [dev-dependencies.tracing-subscriber]
 version = "0.3.16"
 features = ["env-filter", "json"]
-140
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
 test-util = ["aws-credential-types/test-util", "aws-smithy-runtime/test-util"]
 gated-tests = []
 default = ["rustls", "rt-tokio"]
 default = ["rustls", "default-https-client", "rt-tokio"]

tmp-codegen-diff/aws-sdk/sdk/dynamodb/benches/deserialization_bench.rs

@@ -1,1 +47,47 @@

↥ Expand context

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_sdk_dynamodb::operation::query::QueryOutput;

 use aws_smithy_runtime_api::client::orchestrator::HttpResponse;
 use aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
 use aws_smithy_runtime_api::client::ser_de::{DeserializeResponse, SharedResponseDeserializer};
 use aws_smithy_types::body::SdkBody;
 use criterion::{criterion_group, criterion_main, Criterion};
-12
 fn do_bench() {
     use aws_sdk_dynamodb::operation::query::Query;
     use bytes::Bytes;
-16
     let response = HttpResponse::try_from(http::Response::builder()
     let response = HttpResponse::try_from(http_1x::Response::builder()
         .header("server", "Server")
         .header("date", "Mon, 08 Mar 2021 15:51:23 GMT")
         .header("content-type", "application/x-amz-json-1.0")
         .header("content-length", "1231")
         .header("connection", "keep-alive")
         .header("x-amzn-requestid", "A5FGSJ9ET4OKB8183S9M47RQQBVV4KQNSO5AEMVJF66Q9ASUAAJG")
         .header("x-amz-crc32", "624725176")
         .status(http::StatusCode::from_u16(200).unwrap())
         .status(http_1x::StatusCode::from_u16(200).unwrap())
         .body(SdkBody::from(Bytes::copy_from_slice(br#"{"Count":2,"Items":[{"year":{"N":"2013"},"info":{"M":{"actors":{"L":[{"S":"Daniel Bruhl"},{"S":"Chris Hemsworth"},{"S":"Olivia Wilde"}]},"plot":{"S":"A re-creation of the merciless 1970s rivalry between Formula One rivals James Hunt and Niki Lauda."},"release_date":{"S":"2013-09-02T00:00:00Z"},"image_url":{"S":"http://ia.media-imdb.com/images/M/MV5BMTQyMDE0MTY0OV5BMl5BanBnXkFtZTcwMjI2OTI0OQ@@._V1_SX400_.jpg"},"genres":{"L":[{"S":"Action"},{"S":"Biography"},{"S":"Drama"},{"S":"Sport"}]},"directors":{"L":[{"S":"Ron Howard"}]},"rating":{"N":"8.3"},"rank":{"N":"2"},"running_time_secs":{"N":"7380"}}},"title":{"S":"Rush"}},{"year":{"N":"2013"},"info":{"M":{"actors":{"L":[{"S":"David Matthewman"},{"S":"Ann Thomas"},{"S":"Jonathan G. Neff"}]},"release_date":{"S":"2013-01-18T00:00:00Z"},"plot":{"S":"A rock band plays their music at high volumes, annoying the neighbors."},"genres":{"L":[{"S":"Comedy"},{"S":"Drama"}]},"image_url":{"S":"http://ia.media-imdb.com/images/N/O9ERWAU7FS797AJ7LU8HN09AMUP908RLlo5JF90EWR7LJKQ7@@._V1_SX400_.jpg"},"directors":{"L":[{"S":"Alice Smith"},{"S":"Bob Jones"}]},"rating":{"N":"6.2"},"rank":{"N":"11"},"running_time_secs":{"N":"5215"}}},"title":{"S":"Turn It Down, Or Else!"}}],"ScannedCount":2}"#)))
         .unwrap()).unwrap();
-28
     let operation = Query::new();
     let config = operation.config().expect("operation should have config");
     let deserializer = config
         .load::<SharedResponseDeserializer>()
         .expect("operation should set a deserializer");
-34
     let output = deserializer

↧ Expand context

         .deserialize_nonstreaming(&response)
         .expect("success");
     let output = output.downcast::<QueryOutput>().expect("correct type");
     assert_eq!(2, output.count);
-40
+}
-41
 fn bench_group(c: &mut Criterion) {
     c.bench_function("deserialization_bench", |b| b.iter(do_bench));
-44
+}
-45
 criterion_group!(benches, bench_group);
 criterion_main!(benches);

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/auth_scheme_error.rs

@@ -1,1 +32,32 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_sdk_dynamodb::config::Region;
 use aws_sdk_dynamodb::error::DisplayErrorContext;
 use aws_sdk_dynamodb::{Client, Config};
 use aws_smithy_http_client::test_util::capture_request;
 use aws_smithy_runtime::assert_str_contains;
 use aws_smithy_runtime::client::http::test_util::capture_request;
-11
 #[tokio::test]
 async fn auth_scheme_error() {
     let (http_client, _) = capture_request(None);
     let config = Config::builder()
         .behavior_version_latest()
         .http_client(http_client)
         .region(Region::new("us-west-2"))
         // intentionally omitting credentials_provider
         .build();

↧ Expand context

     let client = Client::from_conf(config);
-22
     let err = client
         .list_tables()
         .send()
         .await
         .expect_err("there is no credential provider, so this must fail");
     assert_str_contains!(
         DisplayErrorContext(&err).to_string(),
         "\"sigv4\" wasn't a valid option because there was no identity resolver for it. Be sure to set an identity"
     );
-32
+}

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/endpoints.rs

@@ -1,1 +39,39 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_sdk_dynamodb::config::{self, Credentials, Region};
 use aws_smithy_runtime::client::http::test_util::capture_request;
 use aws_smithy_http_client::test_util::capture_request;
 use aws_types::SdkConfig;
 use http::Uri;
 use http_1x::Uri;
-10
 async fn expect_uri(
     conf: SdkConfig,
     uri: &'static str,
     customize: fn(config::Builder) -> config::Builder,
 ) {
     let (http_client, request) = capture_request(None);
     let conf = customize(
         aws_sdk_dynamodb::config::Builder::from(&conf)
             .credentials_provider(Credentials::for_tests())

↧ Expand context

             .stalled_stream_protection(
                 aws_sdk_dynamodb::config::StalledStreamProtectionConfig::disabled(),
-22
+            )
             .http_client(http_client),
-24
+    )
     .build();
     let svc = aws_sdk_dynamodb::Client::from_conf(conf);
     // dbg to see why the request failed if this test is failing
     let _ = dbg!(svc.list_tables().send().await);
     assert_eq!(request.expect_request().uri(), &Uri::from_static(uri));
-30
+}
-31
 /// Integration test of loading clients from shared configuration
 #[tokio::test]
 async fn endpoints_can_be_overridden_globally() {
     let conf = aws_types::SdkConfig::builder()
         .region(Region::new("us-east-4"))
         .endpoint_url("http://localhost:8000")
         .build();
-39

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/movies.rs

@@ -1,1 +48,48 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_sdk_dynamodb as dynamodb;
 use aws_smithy_async::assert_elapsed;
 use aws_smithy_runtime::client::http::test_util::{ReplayEvent, StaticReplayClient};
 use aws_smithy_http_client::test_util::{ReplayEvent, StaticReplayClient};
 use aws_smithy_types::body::SdkBody;
 use dynamodb::config::{Credentials, Region};
 use dynamodb::operation::query::QueryOutput;
 use dynamodb::types::{
     AttributeDefinition, AttributeValue, KeySchemaElement, KeyType, ProvisionedThroughput,
     ScalarAttributeType, TableStatus,
 };
 use dynamodb::Client;
 use http::header::AUTHORIZATION;
 use http::Uri;
 use http_1x::header::AUTHORIZATION;
 use http_1x::Uri;
 use serde_json::Value;
 use std::collections::HashMap;
 use std::time::Duration;
-22
 async fn create_table(client: &Client, table_name: &str) {
     client
         .create_table()
         .table_name(table_name)
         .key_schema(
             KeySchemaElement::builder()

↧ Expand context

                 .attribute_name("year")
                 .key_type(KeyType::Hash)
                 .build()
                 .unwrap(),
-33
+        )
         .key_schema(
             KeySchemaElement::builder()
                 .attribute_name("title")
                 .key_type(KeyType::Range)
                 .build()
                 .unwrap(),
-40
+        )
         .attribute_definitions(
             AttributeDefinition::builder()
                 .attribute_name("year")
                 .attribute_type(ScalarAttributeType::N)
                 .build()
                 .unwrap(),
-47
+        )
         .attribute_definitions(

@@ -169,169 +379,379 @@

↥ Expand context

-169
+    }
     let films_2222 = movies_in_year(&client, table_name, 2222).await;
     // this isn't "Back To The Future", there are no movies from 2222
     assert_eq!(films_2222.count, 0);
-173
     let films_2013 = movies_in_year(&client, table_name, 2013).await;
     assert_eq!(films_2013.count, 2);
     let titles: Vec<AttributeValue> = films_2013
         .items
         .unwrap()
         .into_iter()
         .map(|mut row| row.remove("title").expect("row should have title"))
         .collect();
     assert_eq!(
         titles,
         vec![
             AttributeValue::S("Rush".to_string()),
             AttributeValue::S("Turn It Down, Or Else!".to_string())
-187
+        ]
     );

-189
     http_client.assert_requests_match(&[AUTHORIZATION.as_str(), "x-amz-date"]);
-191
+}
-192
 /// Test connection for the movies IT
 /// headers are signed with actual creds, at some point we could replace them with verifiable test
 /// credentials, but there are plenty of other tests that target signing
 fn movies_it_test_connection() -> StaticReplayClient {
     StaticReplayClient::new(vec![
         ReplayEvent::new(
          http::Request::builder()
          http_1x::Request::builder()
                  .header("content-type", "application/x-amz-json-1.0")
                  .header("x-amz-target", "DynamoDB_20120810.CreateTable")
                  .header("content-length", "313")
                  .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=4a832eba37651836b524b587986be607607b077ad133c57b4bf7300d2e02f476")
                  .header("x-amz-date", "20210308T155118Z")
                  .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
                  .body(SdkBody::from(r#"{"AttributeDefinitions":[{"AttributeName":"year","AttributeType":"N"},{"AttributeName":"title","AttributeType":"S"}],"TableName":"Movies-5","KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"ReadCapacityUnits":10,"WriteCapacityUnits":10}}"#)).unwrap(),
          http::Response::builder()
          http_1x::Response::builder()
                  .header("server", "Server")
                  .header("date", "Mon, 08 Mar 2021 15:51:18 GMT")
                  .header("content-type", "application/x-amz-json-1.0")
                  .header("content-length", "572")
                  .header("connection", "keep-alive")
                  .header("x-amzn-requestid", "RCII0AALE00UALC7LJ9AD600B7VV4KQNSO5AEMVJF66Q9ASUAAJG")
                  .header("x-amz-crc32", "3715137447")
                  .status(http::StatusCode::from_u16(200).unwrap())
                  .status(http_1x::StatusCode::from_u16(200).unwrap())
                  .body(SdkBody::from(r#"{"TableDescription":{"AttributeDefinitions":[{"AttributeName":"title","AttributeType":"S"},{"AttributeName":"year","AttributeType":"N"}],"CreationDateTime":1.615218678973E9,"ItemCount":0,"KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"NumberOfDecreasesToday":0,"ReadCapacityUnits":10,"WriteCapacityUnits":10},"TableArn":"arn:aws:dynamodb:us-east-1:134095065856:table/Movies-5","TableId":"b08c406a-7dbc-4f7d-b7c6-672a43ec21cd","TableName":"Movies-5","TableSizeBytes":0,"TableStatus":"CREATING"}}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
                   .header("content-type", "application/x-amz-json-1.0")
                   .header("x-amz-target", "DynamoDB_20120810.DescribeTable")
                   .header("content-length", "24")
                   .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=01b0129a2a4fb3af14559fde8163d59de9c43907152a12479002b3a7c75fa0df")
                   .header("x-amz-date", "20210308T155119Z")
                   .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
                   .body(SdkBody::from(r#"{"TableName":"Movies-5"}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:18 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "561")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "O1C6QKCG8GT7D2K922T4QRL9N3VV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "46742265")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Table":{"AttributeDefinitions":[{"AttributeName":"title","AttributeType":"S"},{"AttributeName":"year","AttributeType":"N"}],"CreationDateTime":1.615218678973E9,"ItemCount":0,"KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"NumberOfDecreasesToday":0,"ReadCapacityUnits":10,"WriteCapacityUnits":10},"TableArn":"arn:aws:dynamodb:us-east-1:134095065856:table/Movies-5","TableId":"b08c406a-7dbc-4f7d-b7c6-672a43ec21cd","TableName":"Movies-5","TableSizeBytes":0,"TableStatus":"CREATING"}}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.DescribeTable")
               .header("content-length", "24")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=7f3a743bb460f26296640ae775d282f0153eda750855ec00ace1815becfd2de5")
               .header("x-amz-date", "20210308T155120Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/")).body(SdkBody::from(r#"{"TableName":"Movies-5"}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:20 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "561")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "EN5N26BO1FAOEMUUSD7B7SUPPVVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "46742265")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Table":{"AttributeDefinitions":[{"AttributeName":"title","AttributeType":"S"},{"AttributeName":"year","AttributeType":"N"}],"CreationDateTime":1.615218678973E9,"ItemCount":0,"KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"NumberOfDecreasesToday":0,"ReadCapacityUnits":10,"WriteCapacityUnits":10},"TableArn":"arn:aws:dynamodb:us-east-1:134095065856:table/Movies-5","TableId":"b08c406a-7dbc-4f7d-b7c6-672a43ec21cd","TableName":"Movies-5","TableSizeBytes":0,"TableStatus":"CREATING"}}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.DescribeTable")
               .header("content-length", "24")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=46a148c560139bc0da171bd915ea8c0b96a7012629f5db7b6bf70fcd1a66fd24")
               .header("x-amz-date", "20210308T155121Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r#"{"TableName":"Movies-5"}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:21 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "561")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "PHCMGEVI6JLN9JNMKSSA3M76H3VV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "46742265")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Table":{"AttributeDefinitions":[{"AttributeName":"title","AttributeType":"S"},{"AttributeName":"year","AttributeType":"N"}],"CreationDateTime":1.615218678973E9,"ItemCount":0,"KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"NumberOfDecreasesToday":0,"ReadCapacityUnits":10,"WriteCapacityUnits":10},"TableArn":"arn:aws:dynamodb:us-east-1:134095065856:table/Movies-5","TableId":"b08c406a-7dbc-4f7d-b7c6-672a43ec21cd","TableName":"Movies-5","TableSizeBytes":0,"TableStatus":"CREATING"}}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.DescribeTable")
               .header("content-length", "24")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=15bb7c9b2350747d62349091b3ea59d9e1800d1dca04029943329259bba85cb4")
               .header("x-amz-date", "20210308T155122Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r#"{"TableName":"Movies-5"}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:22 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "561")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "1Q22O983HD3511TN6Q5RRTP0MFVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "46742265")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Table":{"AttributeDefinitions":[{"AttributeName":"title","AttributeType":"S"},{"AttributeName":"year","AttributeType":"N"}],"CreationDateTime":1.615218678973E9,"ItemCount":0,"KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"NumberOfDecreasesToday":0,"ReadCapacityUnits":10,"WriteCapacityUnits":10},"TableArn":"arn:aws:dynamodb:us-east-1:134095065856:table/Movies-5","TableId":"b08c406a-7dbc-4f7d-b7c6-672a43ec21cd","TableName":"Movies-5","TableSizeBytes":0,"TableStatus":"CREATING"}}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.DescribeTable")
               .header("content-length", "24")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=6d0a78087bc112c68a91b4b2d457efd8c09149b85b8f998f8c4b3f9916c8a743")
               .header("x-amz-date", "20210308T155123Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r#"{"TableName":"Movies-5"}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:23 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "559")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "ONJBNV2A9GBNUT34KH73JLL23BVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "24113616")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Table":{"AttributeDefinitions":[{"AttributeName":"title","AttributeType":"S"},{"AttributeName":"year","AttributeType":"N"}],"CreationDateTime":1.615218678973E9,"ItemCount":0,"KeySchema":[{"AttributeName":"year","KeyType":"HASH"},{"AttributeName":"title","KeyType":"RANGE"}],"ProvisionedThroughput":{"NumberOfDecreasesToday":0,"ReadCapacityUnits":10,"WriteCapacityUnits":10},"TableArn":"arn:aws:dynamodb:us-east-1:134095065856:table/Movies-5","TableId":"b08c406a-7dbc-4f7d-b7c6-672a43ec21cd","TableName":"Movies-5","TableSizeBytes":0,"TableStatus":"ACTIVE"}}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.PutItem")
               .header("content-length", "619")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=85fc7d2064a0e6d9c38d64751d39d311ad415ae4079ef21ef254b23ecf093519")
               .header("x-amz-date", "20210308T155123Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r#"{"TableName":"Movies-5","Item":{"info":{"M":{"rating":{"N":"6.2"},"genres":{"L":[{"S":"Comedy"},{"S":"Drama"}]},"image_url":{"S":"http://ia.media-imdb.com/images/N/O9ERWAU7FS797AJ7LU8HN09AMUP908RLlo5JF90EWR7LJKQ7@@._V1_SX400_.jpg"},"release_date":{"S":"2013-01-18T00:00:00Z"},"actors":{"L":[{"S":"David Matthewman"},{"S":"Ann Thomas"},{"S":"Jonathan G. Neff"}]},"plot":{"S":"A rock band plays their music at high volumes, annoying the neighbors."},"running_time_secs":{"N":"5215"},"rank":{"N":"11"},"directors":{"L":[{"S":"Alice Smith"},{"S":"Bob Jones"}]}}},"title":{"S":"Turn It Down, Or Else!"},"year":{"N":"2013"}}}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:23 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "2")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "E6TGS5HKHHV08HSQA31IO1IDMFVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "2745614147")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.PutItem")
               .header("content-length", "636")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=e4b1658c9f5129b3656381f6592a30e0061b1566263fbf27d982817ea79483f6")
               .header("x-amz-date", "20210308T155123Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r#"{"TableName":"Movies-5","Item":{"info":{"M":{"plot":{"S":"A re-creation of the merciless 1970s rivalry between Formula One rivals James Hunt and Niki Lauda."},"rating":{"N":"8.3"},"rank":{"N":"2"},"release_date":{"S":"2013-09-02T00:00:00Z"},"directors":{"L":[{"S":"Ron Howard"}]},"image_url":{"S":"http://ia.media-imdb.com/images/M/MV5BMTQyMDE0MTY0OV5BMl5BanBnXkFtZTcwMjI2OTI0OQ@@._V1_SX400_.jpg"},"actors":{"L":[{"S":"Daniel Bruhl"},{"S":"Chris Hemsworth"},{"S":"Olivia Wilde"}]},"running_time_secs":{"N":"7380"},"genres":{"L":[{"S":"Action"},{"S":"Biography"},{"S":"Drama"},{"S":"Sport"}]}}},"title":{"S":"Rush"},"year":{"N":"2013"}}}"#)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:23 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "2")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "B63D54LP2FOGQK9JE5KLJT49HJVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "2745614147")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.Query")
               .header("content-length", "156")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=c9a0fdd0c7c3a792faddabca1fc154c8fbb54ddee7b06a8082e1c587615198b5")
               .header("x-amz-date", "20210308T155123Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r##"{"TableName":"Movies-5","KeyConditionExpression":"#yr = :yyyy","ExpressionAttributeNames":{"#yr":"year"},"ExpressionAttributeValues":{":yyyy":{"N":"2222"}}}"##)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:23 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "39")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "AUAS9KJ0TK9BSR986TRPC2RGTRVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "3413411624")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Count":0,"Items":[],"ScannedCount":0}"#)).unwrap()),
          ReplayEvent::new(http::Request::builder()
          ReplayEvent::new(http_1x::Request::builder()
               .header("content-type", "application/x-amz-json-1.0")
               .header("x-amz-target", "DynamoDB_20120810.Query")
               .header("content-length", "156")
               .header("authorization", "AWS4-HMAC-SHA256 Credential=ASIAR6OFQKMAFQIIYZ5T/20210308/us-east-1/dynamodb/aws4_request, SignedHeaders=content-length;content-type;host;x-amz-target, Signature=504d6b4de7093b20255b55057085937ec515f62f3c61da68c03bff3f0ce8a160")
               .header("x-amz-date", "20210308T155123Z")
               .uri(Uri::from_static("https://dynamodb.us-east-1.amazonaws.com/"))
               .body(SdkBody::from(r##"{"TableName":"Movies-5","KeyConditionExpression":"#yr = :yyyy","ExpressionAttributeNames":{"#yr":"year"},"ExpressionAttributeValues":{":yyyy":{"N":"2013"}}}"##)).unwrap(),
           http::Response::builder()
           http_1x::Response::builder()
               .header("server", "Server")
               .header("date", "Mon, 08 Mar 2021 15:51:23 GMT")
               .header("content-type", "application/x-amz-json-1.0")
               .header("content-length", "1231")
               .header("connection", "keep-alive")
               .header("x-amzn-requestid", "A5FGSJ9ET4OKB8183S9M47RQQBVV4KQNSO5AEMVJF66Q9ASUAAJG")
               .header("x-amz-crc32", "624725176")
               .status(http::StatusCode::from_u16(200).unwrap())
               .status(http_1x::StatusCode::from_u16(200).unwrap())
               .body(SdkBody::from(r#"{"Count":2,"Items":[{"year":{"N":"2013"},"info":{"M":{"actors":{"L":[{"S":"Daniel Bruhl"},{"S":"Chris Hemsworth"},{"S":"Olivia Wilde"}]},"plot":{"S":"A re-creation of the merciless 1970s rivalry between Formula One rivals James Hunt and Niki Lauda."},"release_date":{"S":"2013-09-02T00:00:00Z"},"image_url":{"S":"http://ia.media-imdb.com/images/M/MV5BMTQyMDE0MTY0OV5BMl5BanBnXkFtZTcwMjI2OTI0OQ@@._V1_SX400_.jpg"},"genres":{"L":[{"S":"Action"},{"S":"Biography"},{"S":"Drama"},{"S":"Sport"}]},"directors":{"L":[{"S":"Ron Howard"}]},"rating":{"N":"8.3"},"rank":{"N":"2"},"running_time_secs":{"N":"7380"}}},"title":{"S":"Rush"}},{"year":{"N":"2013"},"info":{"M":{"actors":{"L":[{"S":"David Matthewman"},{"S":"Ann Thomas"},{"S":"Jonathan G. Neff"}]},"release_date":{"S":"2013-01-18T00:00:00Z"},"plot":{"S":"A rock band plays their music at high volumes, annoying the neighbors."},"genres":{"L":[{"S":"Comedy"},{"S":"Drama"}]},"image_url":{"S":"http://ia.media-imdb.com/images/N/O9ERWAU7FS797AJ7LU8HN09AMUP908RLlo5JF90EWR7LJKQ7@@._V1_SX400_.jpg"},"directors":{"L":[{"S":"Alice Smith"},{"S":"Bob Jones"}]},"rating":{"N":"6.2"},"rank":{"N":"11"},"running_time_secs":{"N":"5215"}}},"title":{"S":"Turn It Down, Or Else!"}}],"ScannedCount":2}"#)).unwrap())
     ])
-379
+}

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/paginators.rs

@@ -1,1 +87,87 @@

↥ Expand context

  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use std::collections::HashMap;
 use std::iter::FromIterator;
-8
 use aws_credential_types::Credentials;
 use aws_sdk_dynamodb::types::AttributeValue;
 use aws_sdk_dynamodb::{Client, Config};
 use aws_smithy_http_client::test_util::{capture_request, ReplayEvent, StaticReplayClient};
 use aws_smithy_protocol_test::{assert_ok, validate_body, MediaType};
 use aws_smithy_runtime::client::http::test_util::{
     capture_request, ReplayEvent, StaticReplayClient,
 };
 use aws_smithy_runtime_api::client::http::HttpClient;
 use aws_smithy_types::body::SdkBody;
 use aws_types::region::Region;
-17
 fn stub_config(http_client: impl HttpClient + 'static) -> Config {
     Config::builder()
         .region(Region::new("us-east-1"))
         .credentials_provider(Credentials::for_tests())
         .http_client(http_client)
         .build()
-24
+}
-25
 /// Validate that arguments are passed on to the paginator
 #[tokio::test]
 async fn paginators_pass_args() {
     let (http_client, request) = capture_request(None);
     let client = Client::from_conf(stub_config(http_client));
     let mut paginator = client
         .scan()
         .table_name("test-table")
         .into_paginator()
         .page_size(32)
         .send();
     let _ = paginator.next().await;
     let request = request.expect_request();
     let body = request.body().bytes().expect("data is loaded");
     assert_ok(validate_body(
         body,
         r#"{"TableName":"test-table","Limit":32}"#,
         MediaType::Json,
     ));
-45
+}
-46
 fn mk_request(body: &'static str) -> http::Request<SdkBody> {
     http::Request::builder()
 fn mk_request(body: &'static str) -> http_1x::Request<SdkBody> {
     http_1x::Request::builder()
         .uri("https://dynamodb.us-east-1.amazonaws.com/")
         .body(SdkBody::from(body))
         .unwrap()
-52
+}
-53
 fn mk_response(body: &'static str) -> http::Response<SdkBody> {
     http::Response::builder().body(SdkBody::from(body)).unwrap()
 fn mk_response(body: &'static str) -> http_1x::Response<SdkBody> {
     http_1x::Response::builder()
         .body(SdkBody::from(body))
         .unwrap()
-58
+}
-59
 #[tokio::test(flavor = "current_thread")]
 async fn paginators_loop_until_completion() {
     let http_client = StaticReplayClient::new(vec![
         ReplayEvent::new(
             mk_request(r#"{"TableName":"test-table","Limit":32}"#),
             mk_response(
                 r#"{
                             "Count": 1,

↧ Expand context

                             "Items": [{
                                 "PostedBy": {
                                     "S": "joe@example.com"
-71
+                                }
                             }],
                             "LastEvaluatedKey": {
                                 "PostedBy": { "S": "joe@example.com" }
-75
+                            }
                         }"#,
             ),
         ),
         ReplayEvent::new(
             mk_request(
                 r#"{"TableName":"test-table","Limit":32,"ExclusiveStartKey":{"PostedBy":{"S":"joe@example.com"}}}"#,
             ),
             mk_response(
                 r#"{
                             "Count": 1,
                             "Items": [{
                                 "PostedBy": {

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/retries-with-client-rate-limiting.rs

@@ -1,1 +74,74 @@

↥ Expand context

  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_sdk_dynamodb::config::{
     Credentials, Region, SharedAsyncSleep, StalledStreamProtectionConfig,
 };
 use aws_sdk_dynamodb::{config::retry::RetryConfig, error::ProvideErrorMetadata};
 use aws_smithy_async::test_util::instant_time_and_sleep;
 use aws_smithy_async::time::SharedTimeSource;
 use aws_smithy_runtime::client::http::test_util::{ReplayEvent, StaticReplayClient};
 use aws_smithy_http_client::test_util::{ReplayEvent, StaticReplayClient};
 use aws_smithy_runtime::client::retries::RetryPartition;
 use aws_smithy_types::body::SdkBody;
 use std::time::{Duration, SystemTime};
-16
 fn req() -> http::Request<SdkBody> {
     http::Request::builder()
 fn req() -> http_1x::Request<SdkBody> {
     http_1x::Request::builder()
         .body(SdkBody::from("request body"))
         .unwrap()
-21
+}
-22
 fn ok() -> http::Response<SdkBody> {
 fn ok() -> http_1x::Response<SdkBody> {
     let body = "{ \"TableNames\": [ \"Test\" ] }";
     http::Response::builder()
     http_1x::Response::builder()
         .status(200)
         .header("server", "Server")
         .header("content-type", "application/x-amz-json-1.0")
         .header("content-length", body.len().to_string())
         .header("connection", "keep-alive")
         .header("x-amz-crc32", "2335643545")
         .body(SdkBody::from(body))
         .unwrap()
-34
+}
-35
 fn err() -> http::Response<SdkBody> {
     http::Response::builder()
 fn err() -> http_1x::Response<SdkBody> {
     http_1x::Response::builder()
         .status(500)
         .body(SdkBody::from("{ \"message\": \"The request has failed because of an unknown error, exception or failure.\", \"code\": \"InternalServerError\" }"))
         .unwrap()
-41
+}
-42
 fn throttling_err() -> http::Response<SdkBody> {
     http::Response::builder()
 fn throttling_err() -> http_1x::Response<SdkBody> {
     http_1x::Response::builder()
         .status(400)
         .body(SdkBody::from("{ \"message\": \"The request was denied due to request throttling.\", \"code\": \"ThrottlingException\" }"))
         .unwrap()
-48
+}
-49
 #[tokio::test]
 async fn test_adaptive_retries_with_no_throttling_errors() {
     let (time_source, sleep_impl) = instant_time_and_sleep(SystemTime::UNIX_EPOCH);
-53
     let events = vec![

↧ Expand context

         // First operation
         ReplayEvent::new(req(), err()),
         ReplayEvent::new(req(), err()),
         ReplayEvent::new(req(), ok()),
         // Second operation
         ReplayEvent::new(req(), err()),
         ReplayEvent::new(req(), ok()),
         // Third operation will fail, only errors
         ReplayEvent::new(req(), err()),
         ReplayEvent::new(req(), err()),
         ReplayEvent::new(req(), err()),
         ReplayEvent::new(req(), err()),
     ];
-68
     let http_client = StaticReplayClient::new(events);
     let config = aws_sdk_dynamodb::Config::builder()
         .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
         .credentials_provider(Credentials::for_tests())
         .region(Region::new("us-east-1"))
         .retry_config(

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/shared-config.rs

@@ -1,1 +29,29 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_sdk_dynamodb::config::{Credentials, Region, StalledStreamProtectionConfig};
 use aws_smithy_runtime::client::http::test_util::capture_request;
 use http::Uri;
 use aws_smithy_http_client::test_util::capture_request;
 use http_1x::Uri;
-9
 /// Iterative test of loading clients from shared configuration
 #[tokio::test]
 async fn shared_config_testbed() {
     let shared_config = aws_types::SdkConfig::builder()
         .region(Region::new("us-east-4"))
         .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
         .build();
     let (http_client, request) = capture_request(None);
     let conf = aws_sdk_dynamodb::config::Builder::from(&shared_config)

↧ Expand context

         .credentials_provider(Credentials::for_tests())
         .http_client(http_client)
         .endpoint_url("http://localhost:8000")
         .build();
     let svc = aws_sdk_dynamodb::Client::from_conf(conf);
     let _ = svc.list_tables().send().await;
     assert_eq!(
         request.expect_request().uri(),
         &Uri::from_static("http://localhost:8000")
     );
-29
+}

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/test-error-classification.rs

@@ -1,1 +43,42 @@

↥ Expand context

  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use std::time::Duration;
-7
 use aws_credential_types::Credentials;
 use aws_sdk_dynamodb::types::AttributeValue;
 use aws_sdk_dynamodb::Client;
 use aws_smithy_async::rt::sleep::{SharedAsyncSleep, TokioSleep};
 use aws_smithy_runtime::client::http::test_util::wire::{ReplayedEvent, WireMockServer};
 use aws_smithy_runtime::{ev, match_events};
 use aws_smithy_http_client::test_util::wire::{ev, match_events, ReplayedEvent, WireMockServer};
 use aws_smithy_types::retry::RetryConfig;
 use aws_smithy_types::timeout::TimeoutConfig;
 use aws_types::region::Region;
 use bytes::Bytes;
-17
 const DYNAMO_THROTTLING_RESPONSE: &str = r#"{"__type":"com.amazonaws.dynamodb.v20120810#ThrottlingException",
 "message":"enhance your calm"}"#;
-20
 const DYNAMODB_DB_SUCCESS_RESPONSE: &str = r#"{"Count":0,"Items":[],"ScannedCount":2}"#;
-22

↧ Expand context

 #[tokio::test]
 async fn test_no_reconnect_500_throttling() {
     assert_error_not_transient(ReplayedEvent::HttpResponse {
         status: 500,
         body: Bytes::from(DYNAMO_THROTTLING_RESPONSE),
     })
     .await
-30
+}
-31
 #[tokio::test]
 async fn test_no_reconnect_429_throttling() {
     assert_error_not_transient(ReplayedEvent::HttpResponse {
         status: 429,
         body: Bytes::from(DYNAMO_THROTTLING_RESPONSE),
     })
     .await
-39
+}
-40
 async fn assert_error_not_transient(error: ReplayedEvent) {
     let mock = WireMockServer::start(vec![

tmp-codegen-diff/aws-sdk/sdk/dynamodb/tests/timeouts.rs

@@ -1,1 +42,42 @@

↥ Expand context

  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use std::time::Duration;
-7
 use aws_credential_types::provider::SharedCredentialsProvider;
 use aws_sdk_dynamodb::config::{Credentials, Region, StalledStreamProtectionConfig};
 use aws_sdk_dynamodb::error::SdkError;
 use aws_smithy_async::rt::sleep::{AsyncSleep, SharedAsyncSleep, Sleep};
 use aws_smithy_runtime::client::http::test_util::NeverClient;
 use aws_smithy_http_client::test_util::NeverClient;
 use aws_smithy_types::retry::RetryConfig;
 use aws_smithy_types::timeout::TimeoutConfig;
 use aws_types::SdkConfig;
-16
 #[derive(Debug, Clone)]
 struct InstantSleep;
 impl AsyncSleep for InstantSleep {
     fn sleep(&self, _duration: Duration) -> Sleep {
         Sleep::new(Box::pin(async move {}))
-22
+    }

↧ Expand context

-23
+}
-24
 #[tokio::test]
 async fn api_call_timeout_retries() {
     let http_client = NeverClient::new();
     let conf = SdkConfig::builder()
         .region(Region::new("us-east-2"))
         .http_client(http_client.clone())
         .credentials_provider(SharedCredentialsProvider::new(Credentials::for_tests()))
         .timeout_config(
             TimeoutConfig::builder()
                 .operation_attempt_timeout(Duration::new(123, 0))
                 .build(),
-36
+        )
         .retry_config(RetryConfig::standard())
         .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
         .sleep_impl(SharedAsyncSleep::new(InstantSleep))
         .build();
     let client = aws_sdk_dynamodb::Client::new(&conf);
     let resp = client

tmp-codegen-diff/aws-sdk/sdk/ec2/Cargo.toml

@@ -1,1 +0,147 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-ec2"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon Elastic Compute Cloud"
 edition = "2021"
 license = "Apache-2.0"

 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.81.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]
 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.1"
 version = "1.2.2"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.5"
 version = "1.5.6"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.4"
 version = "1.2.5"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.61.1"
 version = "0.62.0"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.2"
 version = "0.61.3"
-36
 [dependencies.aws-smithy-query]
 path = "../aws-smithy-query"
 version = "0.60.7"
-40
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.7.8"
 version = "1.8.0"
-45
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.7.3"
 version = "1.7.4"
-50
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.2.13"
 version = "1.3.0"
-54
 [dependencies.aws-smithy-xml]
 path = "../aws-smithy-xml"
 version = "0.60.9"
-58
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.5"
 version = "1.3.6"
-62
 [dependencies.fastrand]
 version = "2.0.0"
-65
 [dependencies.http]
 version = "0.2.9"
-68
 [dependencies.once_cell]
 version = "1.16"
-71
 [dependencies.regex-lite]
 version = "0.1.5"
-74
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.5.18"
 version = "1.6.0"
-80
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.1"
 version = "1.2.2"
-85
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.5"
 version = "1.5.6"
-90
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.4"
 version = "1.2.5"
-+
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.0.0"
-100
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.0"
 version = "0.63.1"
-104
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util", "wire-mock"]
 version = "1.7.8"
 features = ["test-util"]
 version = "1.8.0"
-109
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.7.3"
 version = "1.7.4"
-114
 [dev-dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["test-util"]
 version = "1.2.13"
 version = "1.3.0"
-119
 [dev-dependencies.futures-util]
 version = "0.3.25"
 features = ["alloc"]
 default-features = false
-124
 [dev-dependencies.http-1x]
 version = "1"
 package = "http"
-+
 [dev-dependencies.serde_json]
 version = "1.0.0"
-131
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-135
 [dev-dependencies.tracing-subscriber]
 version = "0.3.16"
 features = ["env-filter", "json"]
-139
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
 test-util = ["aws-credential-types/test-util", "aws-smithy-runtime/test-util"]
 gated-tests = []
 default = ["rustls", "rt-tokio"]
 default = ["rustls", "default-https-client", "rt-tokio"]

tmp-codegen-diff/aws-sdk/sdk/ec2/tests/paginators.rs

@@ -1,1 +102,102 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_runtime::user_agent::test_util::assert_ua_contains_metric_values;
 use aws_sdk_ec2::{config::Credentials, config::Region, types::InstanceType, Client, Config};
 use aws_smithy_runtime::client::http::test_util::capture_request;
 use aws_smithy_http_client::test_util::capture_request;
 use aws_smithy_runtime_api::client::http::HttpClient;
 use aws_smithy_types::body::SdkBody;
 use std::collections::HashSet;
-12
 fn stub_config(http_client: impl HttpClient + 'static) -> Config {
     Config::builder()
         .region(Region::new("us-east-1"))
         .credentials_provider(Credentials::for_tests())
         .http_client(http_client)
         .build()
-19
+}
-20
 fn validate_query_string(expected_str: &str, actual_str: &str) {
     assert_eq!(expected_str.len(), actual_str.len());
     let expected = expected_str.split('&').collect::<HashSet<_>>();
     let actual = actual_str.split('&').collect::<HashSet<_>>();
     assert_eq!(expected, actual);
-26
+}
-27
 /// See https://github.com/awslabs/aws-sdk-rust/issues/391
 ///
 /// EC2 replies with `<nextToken></nextToken>` which our XML parser parses as empty string and not "none"
 #[tokio::test]
 async fn paginators_handle_empty_tokens() {
     let response = r#"<?xml version="1.0" encoding="UTF-8"?>
         <DescribeSpotPriceHistoryResponse xmlns="http://ec2.amazonaws.com/doc/2016-11-15/">
             <requestId>edf3e86c-4baf-47c1-9228-9a5ea09542e8</requestId>
             <spotPriceHistorySet/>
             <nextToken></nextToken>
         </DescribeSpotPriceHistoryResponse>"#;
     let response = http::Response::builder()
     let response = http_1x::Response::builder()
         .status(200)
         .body(SdkBody::from(response))
         .unwrap();
     let (http_client, captured_request) = capture_request(Some(response));
     let client = Client::from_conf(stub_config(http_client.clone()));
     let instance_type = InstanceType::from("g5.48xlarge");
     let mut paginator = client
         .describe_spot_price_history()
         .instance_types(instance_type)
         .product_descriptions("Linux/UNIX")
         .availability_zone("eu-north-1a")
         .into_paginator()
         .items()
         .send();
     let first_item = paginator.try_next().await.expect("success");
     assert_eq!(first_item, None);
     let req = captured_request.expect_request();
     let actual_body = std::str::from_utf8(req.body().bytes().unwrap()).unwrap();
     let expected_body = "Action=DescribeSpotPriceHistory&Version=2016-11-15&AvailabilityZone=eu-north-1a&InstanceType.1=g5.48xlarge&ProductDescription.1=Linux%2FUNIX";
     validate_query_string(expected_body, actual_body);
-60
+}
-61
 /// See https://github.com/awslabs/aws-sdk-rust/issues/405
 ///
 /// EC2 can also reply with the token truly unset which will be interpreted as `None`
 #[tokio::test]
 async fn paginators_handle_unset_tokens() {
     let response = r#"<?xml version="1.0" encoding="UTF-8"?>
         <DescribeSpotPriceHistoryResponse xmlns="http://ec2.amazonaws.com/doc/2016-11-15/">
             <requestId>edf3e86c-4baf-47c1-9228-9a5ea09542e8</requestId>
             <spotPriceHistorySet/>
         </DescribeSpotPriceHistoryResponse>"#;
     let response = http::Response::builder()
     let response = http_1x::Response::builder()
         .status(200)
         .body(SdkBody::from(response))
         .unwrap();
     let (http_client, captured_request) = capture_request(Some(response));
     let client = Client::from_conf(stub_config(http_client.clone()));
     let instance_type = InstanceType::from("g5.48xlarge");
     let mut paginator = client
         .describe_spot_price_history()
         .instance_types(instance_type)
         .product_descriptions("Linux/UNIX")

↧ Expand context

         .availability_zone("eu-north-1a")
         .into_paginator()
         .items()
         .send();
     let first_item = paginator.try_next().await.expect("success");
     assert_eq!(first_item, None);
     let req = captured_request.expect_request();
     let actual_body = std::str::from_utf8(req.body().bytes().unwrap()).unwrap();
     let expected_body = "Action=DescribeSpotPriceHistory&Version=2016-11-15&AvailabilityZone=eu-north-1a&InstanceType.1=g5.48xlarge&ProductDescription.1=Linux%2FUNIX";
     validate_query_string(expected_body, actual_body);
-93
+}
-94
 #[tokio::test]
 async fn should_emit_business_metric_for_paginator_in_user_agent() {
     let (http_client, captured_request) = capture_request(None);
     let client = Client::from_conf(stub_config(http_client.clone()));
     let instance_type = InstanceType::from("g5.48xlarge");
     let _ = client
         .describe_spot_price_history()
         .instance_types(instance_type)

tmp-codegen-diff/aws-sdk/sdk/ec2/tests/waiters.rs

@@ -1,1 +43,42 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use aws_runtime::user_agent::test_util::assert_ua_contains_metric_values;
 use aws_sdk_ec2::{client::Waiters, config::Region, error::DisplayErrorContext, Client};
 use aws_smithy_async::test_util::tick_advance_sleep::{
     tick_advance_time_and_sleep, TickAdvanceTime,
 };
 use aws_smithy_runtime::{
     client::http::test_util::dvr::ReplayingClient, test_util::capture_test_logs::show_test_logs,
 };
 use aws_smithy_http_client::test_util::dvr::ReplayingClient;
 use aws_smithy_runtime::test_util::capture_test_logs::show_test_logs;
 use aws_smithy_runtime_api::client::waiters::error::WaiterError;
 use aws_smithy_types::retry::RetryConfig;
 use std::time::Duration;
-16
 async fn prerequisites() -> (Client, ReplayingClient, TickAdvanceTime) {
     let (time_source, sleep_impl) = tick_advance_time_and_sleep();
     let client =
         ReplayingClient::from_file("tests/instance-status-ok-waiter-success.json").unwrap();
     let config = aws_sdk_ec2::Config::builder()
         .with_test_defaults()

↧ Expand context

         .http_client(client.clone())
         .time_source(time_source.clone())
         .sleep_impl(sleep_impl)
         .region(Region::new("us-west-2"))
         .retry_config(RetryConfig::standard())
         .build();
     (aws_sdk_ec2::Client::from_conf(config), client, time_source)
-30
+}
-31
 #[tokio::test]
 async fn waiters_success() {
     let _logs = show_test_logs();
-35
     let (ec2, http_client, time_source) = prerequisites().await;
-37
     ec2.start_instances()
         .instance_ids("i-09fb4224219ac6902")
         .send()
         .await
         .unwrap();

tmp-codegen-diff/aws-sdk/sdk/ecs/Cargo.toml

@@ -1,1 +0,92 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-ecs"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon EC2 Container Service"
 edition = "2021"
 license = "Apache-2.0"

 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.81.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]
 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.1"
 version = "1.2.2"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.5"
 version = "1.5.6"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.4"
 version = "1.2.5"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.61.1"
 version = "0.62.0"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.2"
 version = "0.61.3"
-36
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.7.8"
 version = "1.8.0"
-41
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.7.3"
 version = "1.7.4"
-46
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.2.13"
 version = "1.3.0"
-50
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.5"
 version = "1.3.6"
-54
 [dependencies.bytes]
 version = "1.4.0"
-57
 [dependencies.fastrand]
 version = "2.0.0"
-60
 [dependencies.http]
 version = "0.2.9"
-63
 [dependencies.once_cell]
 version = "1.16"
-66
 [dependencies.regex-lite]
 version = "0.1.5"
-69
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.5.18"
 version = "1.6.0"
-75
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.1"
 version = "1.2.2"
-80
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-84
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
 test-util = ["aws-credential-types/test-util", "aws-smithy-runtime/test-util"]
 gated-tests = []
 default = ["rustls", "rt-tokio"]
 default = ["rustls", "default-https-client", "rt-tokio"]

tmp-codegen-diff/aws-sdk/sdk/glacier/Cargo.toml

@@ -1,1 +0,156 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-glacier"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon Glacier"
 edition = "2021"
 license = "Apache-2.0"

 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.81.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]
 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.1"
 version = "1.2.2"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.5"
 version = "1.5.6"
-24
 [dependencies.aws-sigv4]
 path = "../aws-sigv4"
 version = "1.2.9"
 version = "1.3.0"
-28
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.4"
 version = "1.2.5"
-32
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.61.1"
 version = "0.62.0"
-36
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.2"
 version = "0.61.3"
-40
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.7.8"
 version = "1.8.0"
-45
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.7.3"
 version = "1.7.4"
-50
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.2.13"
 version = "1.3.0"
-54
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.5"
 version = "1.3.6"
-58
 [dependencies.bytes]
 version = "1.4.0"
-61
 [dependencies.hex]
 version = "0.4.3"
-64
 [dependencies.http]
 version = "0.2.9"
-67
 [dependencies.http-1x]
 version = "1"
 package = "http"
-+
 [dependencies.once_cell]
 version = "1.16"
-74
 [dependencies.regex-lite]
 version = "0.1.5"
-77
 [dependencies.ring]
 version = "0.17.5"
-80
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.5.18"
 version = "1.6.0"
-86
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.1"
 version = "1.2.2"
-91
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.5"
 version = "1.5.6"
-96
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.4"
 version = "1.2.5"
-+
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.0.0"
-106
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.0"
 version = "0.63.1"
-110
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util", "wire-mock", "client"]
 version = "1.7.8"
 features = ["test-util"]
 version = "1.8.0"
-115
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.7.3"
 version = "1.7.4"
-120
 [dev-dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["test-util"]
 version = "1.2.13"
 version = "1.3.0"
-125
 [dev-dependencies.futures-util]
 version = "0.3.25"
 features = ["alloc"]
 default-features = false
-130
 [dev-dependencies.pretty_assertions]
 version = "1.3.0"
-133
 [dev-dependencies.serde_json]
 version = "1.0.0"
-136
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-140
 [dev-dependencies.tracing-subscriber]
 version = "0.3.16"
 features = ["env-filter", "json"]
-144
 [dev-dependencies.tracing-test]
 version = "0.2.5"
 features = ["no-env-filter"]
-148
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 test-util = ["aws-credential-types/test-util", "aws-smithy-runtime/test-util"]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
 gated-tests = []
 default = ["rustls", "rt-tokio"]
 default = ["rustls", "default-https-client", "rt-tokio"]

tmp-codegen-diff/aws-sdk/sdk/glacier/src/operation/upload_archive.rs

@@ -250,250 +420,420 @@

↥ Expand context

             .downcast_ref::<UploadArchiveInput>()
             .ok_or("failed to downcast to UploadArchiveInput")?;
-252
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-265
+    }
-266
+}
-267
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.

-270
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod upload_archive_test {
-274
     /// Glacier requires that a version header be set on all requests.
     /// Test ID: GlacierVersionHeader
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn glacier_version_header_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
         let config_builder = config_builder.region(::aws_types::region::Region::new("us-east-1"));
         let mut config_builder = config_builder;
         config_builder.set_region(Some(crate::config::Region::new("us-east-1")));
-285
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client
             .upload_archive()
             .set_account_id(::std::option::Option::Some("foo".to_owned()))
             .set_vault_name(::std::option::Option::Some("bar".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [("X-Amz-Glacier-Version", "2012-06-01")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         // No body.
         ::pretty_assertions::assert_eq!(&body, &bytes::Bytes::new());
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/foo/vaults/bar/archives", "path was incorrect");
-304
+    }
-305
     /// Glacier requires checksum headers that are cumbersome to provide.
     /// Test ID: GlacierChecksums
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn glacier_checksums_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
         let config_builder = config_builder.region(::aws_types::region::Region::new("us-east-1"));
         let mut config_builder = config_builder;
         config_builder.set_region(Some(crate::config::Region::new("us-east-1")));
-316
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client
             .upload_archive()
             .set_account_id(::std::option::Option::Some("foo".to_owned()))
             .set_vault_name(::std::option::Option::Some("bar".to_owned()))
             .set_body(::std::option::Option::Some(::aws_smithy_types::byte_stream::ByteStream::from_static(
                 b"hello world",
             )))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [
             ("X-Amz-Content-Sha256", "b94d27b9934d3e08a52e52d7da7dabfac484efe37a5380ee9088f7ace2efcde9"),
             ("X-Amz-Glacier-Version", "2012-06-01"),
-333
+            (
                 "X-Amz-Sha256-Tree-Hash",
                 "b94d27b9934d3e08a52e52d7da7dabfac484efe37a5380ee9088f7ace2efcde9",
             ),
         ];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             body,
             "hello world",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/foo/vaults/bar/archives", "path was incorrect");
-348
+    }
-349
     /// Glacier requires that the account id be set, but you can just use a
     /// hyphen (-) to indicate the current account. This should be default
     /// behavior if the customer provides a null or empty string.
     /// Test ID: GlacierAccountIdEmpty
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn glacier_account_id_empty_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
         let config_builder = config_builder.region(::aws_types::region::Region::new("us-east-1"));
         let mut config_builder = config_builder;
         config_builder.set_region(Some(crate::config::Region::new("us-east-1")));
-362
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client
             .upload_archive()
             .set_account_id(::std::option::Option::Some("".to_owned()))
             .set_vault_name(::std::option::Option::Some("bar".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [("X-Amz-Glacier-Version", "2012-06-01")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         // No body.
         ::pretty_assertions::assert_eq!(&body, &bytes::Bytes::new());
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/-/vaults/bar/archives", "path was incorrect");
-381
+    }
-382
     /// Glacier requires that the account id be set, but you can just use a
     /// hyphen (-) to indicate the current account. This should be default
     /// behavior if the customer provides a null or empty string.
     /// Test ID: GlacierAccountIdUnset
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn glacier_account_id_unset_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
         let config_builder = config_builder.region(::aws_types::region::Region::new("us-east-1"));
         let mut config_builder = config_builder;
         config_builder.set_region(Some(crate::config::Region::new("us-east-1")));
-395
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client
             .upload_archive()
             .set_vault_name(::std::option::Option::Some("bar".to_owned()))

↧ Expand context

             .set_account_id(::std::option::Option::None)
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [("X-Amz-Glacier-Version", "2012-06-01")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         // No body.
         ::pretty_assertions::assert_eq!(&body, &bytes::Bytes::new());
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/-/vaults/bar/archives", "path was incorrect");
-414
+    }
-415
+}
-416
 /// Error type for the `UploadArchiveError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]
 pub enum UploadArchiveError {

Pages: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15