AWS SDK

AWS SDK

rev. ce76c569583a3fdee1e9d39e082a8d5efd7b13b7 (ignoring whitespace)

Files changed:

tmp-codegen-diff/aws-sdk/sdk/s3/src/operation/put_bucket_lifecycle_configuration.rs

@@ -281,281 +345,346 @@

↥ Expand context

-281
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .set_force_path_style(cfg.load::<crate::config::ForcePathStyle>().map(|ty| ty.0))
             .set_use_arn_region(cfg.load::<crate::config::UseArnRegion>().map(|ty| ty.0))
             .set_disable_multi_region_access_points(cfg.load::<crate::config::DisableMultiRegionAccessPoints>().map(|ty| ty.0))
             .set_accelerate(cfg.load::<crate::config::Accelerate>().map(|ty| ty.0))
             .set_disable_s3_express_session_auth(cfg.load::<crate::config::DisableS3ExpressSessionAuth>().map(|ty| ty.0))
             .set_use_s3_express_control_endpoint(Some(true))
             .set_bucket(Some(
                 _input
                     .bucket
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("bucket", "A required field was not set"))?,
             ))
             .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(())
-307
+    }
-308
+}
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod put_bucket_lifecycle_configuration_request_test {
 mod put_bucket_lifecycle_configuration_test {
-+
     /// This test validates that the content md5 header is set correctly
     /// Test ID: PutBucketLifecycleConfiguration
     #[::tokio::test]
     #[allow(unused_mut)]
     #[::tracing_test::traced_test]
     async fn put_bucket_lifecycle_configuration_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::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")));
-323
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client

↧ Expand context

             .put_bucket_lifecycle_configuration()
             .set_bucket(::std::option::Option::Some("test-bucket".to_owned()))
             .set_lifecycle_configuration(::std::option::Option::Some(
                 crate::types::BucketLifecycleConfiguration::builder()
                     .set_rules(::std::option::Option::Some(vec![crate::types::LifecycleRule::builder()
                         .set_expiration(::std::option::Option::Some(
                             crate::types::LifecycleExpiration::builder()
                                 .set_days(::std::option::Option::Some(1))
                                 .build(),
                         ))
                         .set_status(::std::option::Option::Some(
                             "Enabled"
                                 .parse::<crate::types::ExpirationStatus>()
                                 .expect("static value validated to member"),
                         ))
                         .set_id(::std::option::Option::Some("Expire".to_owned()))
                         .build()
                         .unwrap()]))
                     .build()
                     .unwrap(),

tmp-codegen-diff/aws-sdk/sdk/s3/src/operation/put_object.rs

@@ -276,276 +368,369 @@

↥ Expand context

             .set_force_path_style(cfg.load::<crate::config::ForcePathStyle>().map(|ty| ty.0))
             .set_use_arn_region(cfg.load::<crate::config::UseArnRegion>().map(|ty| ty.0))
             .set_disable_multi_region_access_points(cfg.load::<crate::config::DisableMultiRegionAccessPoints>().map(|ty| ty.0))
             .set_accelerate(cfg.load::<crate::config::Accelerate>().map(|ty| ty.0))
             .set_disable_s3_express_session_auth(cfg.load::<crate::config::DisableS3ExpressSessionAuth>().map(|ty| ty.0))
             .set_bucket(Some(
                 _input
                     .bucket
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("bucket", "A required field was not set"))?,
             ))
             .set_key(Some(
                 _input
                     .key
                     .clone()
                     .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
                     .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("key", "A required field was not set"))?,
             ))
             .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(())
-302
+    }
-303
+}
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod put_object_request_test {
 mod put_object_test {
-+
     /// This test validates that if a content-type is specified, that only one content-type header is sent
     /// Test ID: DontSendDuplicateContentType
     #[::tokio::test]
     #[allow(unused_mut)]
     #[::tracing_test::traced_test]
     async fn dont_send_duplicate_content_type_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::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")));
-318
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client
             .put_object()
             .set_bucket(::std::option::Option::Some("test-bucket".to_owned()))
             .set_key(::std::option::Option::Some("test-key".to_owned()))
             .set_content_type(::std::option::Option::Some("text/html".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [("content-type", "text/html")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "PUT", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/test-key", "path was incorrect");
-335
+    }
     /// This test validates that if a content-length is specified, that only one content-length header is sent
     /// Test ID: DontSendDuplicateContentLength
     #[::tokio::test]
     #[allow(unused_mut)]
     #[::tracing_test::traced_test]
     async fn dont_send_duplicate_content_length_request() {
         let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::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")));
-346
         let config = config_builder.http_client(http_client).build();
         let client = crate::Client::from_conf(config);
         let result = client

↧ Expand context

             .put_object()
             .set_bucket(::std::option::Option::Some("test-bucket".to_owned()))
             .set_key(::std::option::Option::Some("test-key".to_owned()))
             .set_content_length(::std::option::Option::Some(2))
             .set_body(::std::option::Option::Some(::aws_smithy_types::byte_stream::ByteStream::from_static(
                 b"ab",
             )))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [("content-length", "2")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "PUT", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/test-key", "path was incorrect");
-366
+    }
-367
+}
-368
 /// Error type for the `PutObjectError` operation.

Pages: 1 2