Client Test

Client Test

rev. 9f5fb9826a6af51ebfb3736d0a778b00ec7b08b3

Files changed:

tmp-codegen-diff/codegen-client-test/aws_query/rust-client-codegen/src/operation/xml_maps_xml_name.rs

@@ -190,190 +254,255 @@
  210    210   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  211    211   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  212    212   
        })?;
  213    213   
        cfg.interceptor_state()
  214    214   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  215    215   
        ::std::result::Result::Ok(())
  216    216   
    }
  217    217   
}
  218    218   
#[allow(unreachable_code, unused_variables)]
  219    219   
#[cfg(test)]
  220         -
mod xml_maps_xml_name_request_test {
         220  +
mod xml_maps_xml_name_test {
         221  +
  221    222   
    /// Serializes XML lists
  222    223   
    /// Test ID: QueryQueryXmlMapsXmlName
  223    224   
    #[::tokio::test]
  224         -
    #[allow(unused_mut)]
         225  +
    #[::tracing_test::traced_test]
  225    226   
    async fn query_query_xml_maps_xml_name_response() {
  226    227   
        let expected_output = crate::operation::xml_maps_xml_name::XmlMapsXmlNameOutput::builder()
  227    228   
            .set_my_map(::std::option::Option::Some({
  228    229   
                let mut ret = ::std::collections::HashMap::new();
  229    230   
                ret.insert(
  230    231   
                    "foo".to_owned(),
  231    232   
                    crate::types::GreetingStruct::builder()
  232    233   
                        .set_hi(::std::option::Option::Some("there".to_owned()))
  233    234   
                        .build(),
  234    235   
                );

tmp-codegen-diff/codegen-client-test/aws_query/rust-client-codegen/src/operation/xml_namespaces.rs

@@ -189,189 +253,254 @@
  209    209   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  210    210   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  211    211   
        })?;
  212    212   
        cfg.interceptor_state()
  213    213   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  214    214   
        ::std::result::Result::Ok(())
  215    215   
    }
  216    216   
}
  217    217   
#[allow(unreachable_code, unused_variables)]
  218    218   
#[cfg(test)]
  219         -
mod xml_namespaces_request_test {
         219  +
mod xml_namespaces_test {
         220  +
  220    221   
    /// Serializes XML namespaces
  221    222   
    /// Test ID: QueryXmlNamespaces
  222    223   
    #[::tokio::test]
  223         -
    #[allow(unused_mut)]
         224  +
    #[::tracing_test::traced_test]
  224    225   
    async fn query_xml_namespaces_response() {
  225    226   
        let expected_output = crate::operation::xml_namespaces::XmlNamespacesOutput::builder()
  226    227   
            .set_nested(::std::option::Option::Some(
  227    228   
                crate::types::XmlNamespaceNested::builder()
  228    229   
                    .set_foo(::std::option::Option::Some("Foo".to_owned()))
  229    230   
                    .set_values(::std::option::Option::Some(vec!["Bar".to_owned(), "Baz".to_owned()]))
  230    231   
                    .build(),
  231    232   
            ))
  232    233   
            .build();
  233    234   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

tmp-codegen-diff/codegen-client-test/aws_query/rust-client-codegen/src/operation/xml_timestamps.rs

@@ -189,189 +607,608 @@
  209    209   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  210    210   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  211    211   
        })?;
  212    212   
        cfg.interceptor_state()
  213    213   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  214    214   
        ::std::result::Result::Ok(())
  215    215   
    }
  216    216   
}
  217    217   
#[allow(unreachable_code, unused_variables)]
  218    218   
#[cfg(test)]
  219         -
mod xml_timestamps_request_test {
         219  +
mod xml_timestamps_test {
         220  +
  220    221   
    /// Tests how normal timestamps are serialized
  221    222   
    /// Test ID: QueryXmlTimestamps
  222    223   
    #[::tokio::test]
  223         -
    #[allow(unused_mut)]
         224  +
    #[::tracing_test::traced_test]
  224    225   
    async fn query_xml_timestamps_response() {
  225    226   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  226    227   
            .set_normal(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  227    228   
                1398796238, 0_f64,
  228    229   
            )))
  229    230   
            .build();
  230    231   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  231    232   
        .header("Content-Type", "text/xml")
  232    233   
        .status(200)
  233    234   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <normal>2014-04-29T18:30:38Z</normal>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))
  234    235   
                    .unwrap()
  235    236   
                    ).unwrap();
  236    237   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  237    238   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  238    239   
  239    240   
        let op = crate::operation::xml_timestamps::XmlTimestamps::new();
  240    241   
        let config = op.config().expect("the operation has config");
  241    242   
        let de = config
  242    243   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  243    244   
            .expect("the config must have a deserializer");
  244    245   
  245    246   
        let parsed = de.deserialize_streaming(&mut http_response);
  246    247   
        let parsed = parsed.unwrap_or_else(|| {
  247    248   
            let http_response =
  248    249   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  249    250   
            de.deserialize_nonstreaming(&http_response)
  250    251   
        });
  251    252   
        let parsed = parsed
  252    253   
            .expect("should be successful response")
  253    254   
            .downcast::<crate::operation::xml_timestamps::XmlTimestampsOutput>()
  254    255   
            .unwrap();
  255    256   
        ::pretty_assertions::assert_eq!(parsed.normal, expected_output.normal, "Unexpected value for `normal`");
  256    257   
        ::pretty_assertions::assert_eq!(parsed.date_time, expected_output.date_time, "Unexpected value for `date_time`");
  257    258   
        ::pretty_assertions::assert_eq!(
  258    259   
            parsed.date_time_on_target,
  259    260   
            expected_output.date_time_on_target,
  260    261   
            "Unexpected value for `date_time_on_target`"
  261    262   
        );
  262    263   
        ::pretty_assertions::assert_eq!(
  263    264   
            parsed.epoch_seconds,
  264    265   
            expected_output.epoch_seconds,
  265    266   
            "Unexpected value for `epoch_seconds`"
  266    267   
        );
  267    268   
        ::pretty_assertions::assert_eq!(
  268    269   
            parsed.epoch_seconds_on_target,
  269    270   
            expected_output.epoch_seconds_on_target,
  270    271   
            "Unexpected value for `epoch_seconds_on_target`"
  271    272   
        );
  272    273   
        ::pretty_assertions::assert_eq!(parsed.http_date, expected_output.http_date, "Unexpected value for `http_date`");
  273    274   
        ::pretty_assertions::assert_eq!(
  274    275   
            parsed.http_date_on_target,
  275    276   
            expected_output.http_date_on_target,
  276    277   
            "Unexpected value for `http_date_on_target`"
  277    278   
        );
  278    279   
    }
  279    280   
    /// Ensures that the timestampFormat of date-time works like normal timestamps
  280    281   
    /// Test ID: QueryXmlTimestampsWithDateTimeFormat
  281    282   
    #[::tokio::test]
  282         -
    #[allow(unused_mut)]
         283  +
    #[::tracing_test::traced_test]
  283    284   
    async fn query_xml_timestamps_with_date_time_format_response() {
  284    285   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  285    286   
            .set_date_time(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  286    287   
                1398796238, 0_f64,
  287    288   
            )))
  288    289   
            .build();
  289    290   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  290    291   
        .header("Content-Type", "text/xml")
  291    292   
        .status(200)
  292    293   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <dateTime>2014-04-29T18:30:38Z</dateTime>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))
  293    294   
                    .unwrap()
  294    295   
                    ).unwrap();
  295    296   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  296    297   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  297    298   
  298    299   
        let op = crate::operation::xml_timestamps::XmlTimestamps::new();
  299    300   
        let config = op.config().expect("the operation has config");
  300    301   
        let de = config
  301    302   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  302    303   
            .expect("the config must have a deserializer");
  303    304   
  304    305   
        let parsed = de.deserialize_streaming(&mut http_response);
  305    306   
        let parsed = parsed.unwrap_or_else(|| {
  306    307   
            let http_response =
  307    308   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  308    309   
            de.deserialize_nonstreaming(&http_response)
  309    310   
        });
  310    311   
        let parsed = parsed
  311    312   
            .expect("should be successful response")
  312    313   
            .downcast::<crate::operation::xml_timestamps::XmlTimestampsOutput>()
  313    314   
            .unwrap();
  314    315   
        ::pretty_assertions::assert_eq!(parsed.normal, expected_output.normal, "Unexpected value for `normal`");
  315    316   
        ::pretty_assertions::assert_eq!(parsed.date_time, expected_output.date_time, "Unexpected value for `date_time`");
  316    317   
        ::pretty_assertions::assert_eq!(
  317    318   
            parsed.date_time_on_target,
  318    319   
            expected_output.date_time_on_target,
  319    320   
            "Unexpected value for `date_time_on_target`"
  320    321   
        );
  321    322   
        ::pretty_assertions::assert_eq!(
  322    323   
            parsed.epoch_seconds,
  323    324   
            expected_output.epoch_seconds,
  324    325   
            "Unexpected value for `epoch_seconds`"
  325    326   
        );
  326    327   
        ::pretty_assertions::assert_eq!(
  327    328   
            parsed.epoch_seconds_on_target,
  328    329   
            expected_output.epoch_seconds_on_target,
  329    330   
            "Unexpected value for `epoch_seconds_on_target`"
  330    331   
        );
  331    332   
        ::pretty_assertions::assert_eq!(parsed.http_date, expected_output.http_date, "Unexpected value for `http_date`");
  332    333   
        ::pretty_assertions::assert_eq!(
  333    334   
            parsed.http_date_on_target,
  334    335   
            expected_output.http_date_on_target,
  335    336   
            "Unexpected value for `http_date_on_target`"
  336    337   
        );
  337    338   
    }
  338    339   
    /// Ensures that the timestampFormat of date-time on the target shape works like normal timestamps
  339    340   
    /// Test ID: QueryXmlTimestampsWithDateTimeOnTargetFormat
  340    341   
    #[::tokio::test]
  341         -
    #[allow(unused_mut)]
         342  +
    #[::tracing_test::traced_test]
  342    343   
    async fn query_xml_timestamps_with_date_time_on_target_format_response() {
  343    344   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  344    345   
            .set_date_time_on_target(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  345    346   
                1398796238, 0_f64,
  346    347   
            )))
  347    348   
            .build();
  348    349   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  349    350   
        .header("Content-Type", "text/xml")
  350    351   
        .status(200)
  351    352   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <dateTimeOnTarget>2014-04-29T18:30:38Z</dateTimeOnTarget>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))
  352    353   
                    .unwrap()
  353    354   
                    ).unwrap();
  354    355   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  355    356   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  356    357   
  357    358   
        let op = crate::operation::xml_timestamps::XmlTimestamps::new();
  358    359   
        let config = op.config().expect("the operation has config");
  359    360   
        let de = config
  360    361   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  361    362   
            .expect("the config must have a deserializer");
  362    363   
  363    364   
        let parsed = de.deserialize_streaming(&mut http_response);
  364    365   
        let parsed = parsed.unwrap_or_else(|| {
  365    366   
            let http_response =
  366    367   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  367    368   
            de.deserialize_nonstreaming(&http_response)
  368    369   
        });
  369    370   
        let parsed = parsed
  370    371   
            .expect("should be successful response")
  371    372   
            .downcast::<crate::operation::xml_timestamps::XmlTimestampsOutput>()
  372    373   
            .unwrap();
  373    374   
        ::pretty_assertions::assert_eq!(parsed.normal, expected_output.normal, "Unexpected value for `normal`");
  374    375   
        ::pretty_assertions::assert_eq!(parsed.date_time, expected_output.date_time, "Unexpected value for `date_time`");
  375    376   
        ::pretty_assertions::assert_eq!(
  376    377   
            parsed.date_time_on_target,
  377    378   
            expected_output.date_time_on_target,
  378    379   
            "Unexpected value for `date_time_on_target`"
  379    380   
        );
  380    381   
        ::pretty_assertions::assert_eq!(
  381    382   
            parsed.epoch_seconds,
  382    383   
            expected_output.epoch_seconds,
  383    384   
            "Unexpected value for `epoch_seconds`"
  384    385   
        );
  385    386   
        ::pretty_assertions::assert_eq!(
  386    387   
            parsed.epoch_seconds_on_target,
  387    388   
            expected_output.epoch_seconds_on_target,
  388    389   
            "Unexpected value for `epoch_seconds_on_target`"
  389    390   
        );
  390    391   
        ::pretty_assertions::assert_eq!(parsed.http_date, expected_output.http_date, "Unexpected value for `http_date`");
  391    392   
        ::pretty_assertions::assert_eq!(
  392    393   
            parsed.http_date_on_target,
  393    394   
            expected_output.http_date_on_target,
  394    395   
            "Unexpected value for `http_date_on_target`"
  395    396   
        );
  396    397   
    }
  397    398   
    /// Ensures that the timestampFormat of epoch-seconds works
  398    399   
    /// Test ID: QueryXmlTimestampsWithEpochSecondsFormat
  399    400   
    #[::tokio::test]
  400         -
    #[allow(unused_mut)]
         401  +
    #[::tracing_test::traced_test]
  401    402   
    async fn query_xml_timestamps_with_epoch_seconds_format_response() {
  402    403   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  403    404   
            .set_epoch_seconds(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  404    405   
                1398796238, 0_f64,
  405    406   
            )))
  406    407   
            .build();
  407    408   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  408    409   
        .header("Content-Type", "text/xml")
  409    410   
        .status(200)
  410    411   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <epochSeconds>1398796238</epochSeconds>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))
  411    412   
                    .unwrap()
  412    413   
                    ).unwrap();
  413    414   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  414    415   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  415    416   
  416    417   
        let op = crate::operation::xml_timestamps::XmlTimestamps::new();
  417    418   
        let config = op.config().expect("the operation has config");
  418    419   
        let de = config
  419    420   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  420    421   
            .expect("the config must have a deserializer");
  421    422   
  422    423   
        let parsed = de.deserialize_streaming(&mut http_response);
  423    424   
        let parsed = parsed.unwrap_or_else(|| {
  424    425   
            let http_response =
  425    426   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  426    427   
            de.deserialize_nonstreaming(&http_response)
  427    428   
        });
  428    429   
        let parsed = parsed
  429    430   
            .expect("should be successful response")
  430    431   
            .downcast::<crate::operation::xml_timestamps::XmlTimestampsOutput>()
  431    432   
            .unwrap();
  432    433   
        ::pretty_assertions::assert_eq!(parsed.normal, expected_output.normal, "Unexpected value for `normal`");
  433    434   
        ::pretty_assertions::assert_eq!(parsed.date_time, expected_output.date_time, "Unexpected value for `date_time`");
  434    435   
        ::pretty_assertions::assert_eq!(
  435    436   
            parsed.date_time_on_target,
  436    437   
            expected_output.date_time_on_target,
  437    438   
            "Unexpected value for `date_time_on_target`"
  438    439   
        );
  439    440   
        ::pretty_assertions::assert_eq!(
  440    441   
            parsed.epoch_seconds,
  441    442   
            expected_output.epoch_seconds,
  442    443   
            "Unexpected value for `epoch_seconds`"
  443    444   
        );
  444    445   
        ::pretty_assertions::assert_eq!(
  445    446   
            parsed.epoch_seconds_on_target,
  446    447   
            expected_output.epoch_seconds_on_target,
  447    448   
            "Unexpected value for `epoch_seconds_on_target`"
  448    449   
        );
  449    450   
        ::pretty_assertions::assert_eq!(parsed.http_date, expected_output.http_date, "Unexpected value for `http_date`");
  450    451   
        ::pretty_assertions::assert_eq!(
  451    452   
            parsed.http_date_on_target,
  452    453   
            expected_output.http_date_on_target,
  453    454   
            "Unexpected value for `http_date_on_target`"
  454    455   
        );
  455    456   
    }
  456    457   
    /// Ensures that the timestampFormat of epoch-seconds on the target shape works
  457    458   
    /// Test ID: QueryXmlTimestampsWithEpochSecondsOnTargetFormat
  458    459   
    #[::tokio::test]
  459         -
    #[allow(unused_mut)]
         460  +
    #[::tracing_test::traced_test]
  460    461   
    async fn query_xml_timestamps_with_epoch_seconds_on_target_format_response() {
  461    462   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  462    463   
            .set_epoch_seconds_on_target(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  463    464   
                1398796238, 0_f64,
  464    465   
            )))
  465    466   
            .build();
  466    467   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  467    468   
        .header("Content-Type", "text/xml")
  468    469   
        .status(200)
  469    470   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <epochSecondsOnTarget>1398796238</epochSecondsOnTarget>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))
  470    471   
                    .unwrap()
  471    472   
                    ).unwrap();
  472    473   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  473    474   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  474    475   
  475    476   
        let op = crate::operation::xml_timestamps::XmlTimestamps::new();
  476    477   
        let config = op.config().expect("the operation has config");
  477    478   
        let de = config
  478    479   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  479    480   
            .expect("the config must have a deserializer");
  480    481   
  481    482   
        let parsed = de.deserialize_streaming(&mut http_response);
  482    483   
        let parsed = parsed.unwrap_or_else(|| {
  483    484   
            let http_response =
  484    485   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  485    486   
            de.deserialize_nonstreaming(&http_response)
  486    487   
        });
  487    488   
        let parsed = parsed
  488    489   
            .expect("should be successful response")
  489    490   
            .downcast::<crate::operation::xml_timestamps::XmlTimestampsOutput>()
  490    491   
            .unwrap();
  491    492   
        ::pretty_assertions::assert_eq!(parsed.normal, expected_output.normal, "Unexpected value for `normal`");
  492    493   
        ::pretty_assertions::assert_eq!(parsed.date_time, expected_output.date_time, "Unexpected value for `date_time`");
  493    494   
        ::pretty_assertions::assert_eq!(
  494    495   
            parsed.date_time_on_target,
  495    496   
            expected_output.date_time_on_target,
  496    497   
            "Unexpected value for `date_time_on_target`"
  497    498   
        );
  498    499   
        ::pretty_assertions::assert_eq!(
  499    500   
            parsed.epoch_seconds,
  500    501   
            expected_output.epoch_seconds,
  501    502   
            "Unexpected value for `epoch_seconds`"
  502    503   
        );
  503    504   
        ::pretty_assertions::assert_eq!(
  504    505   
            parsed.epoch_seconds_on_target,
  505    506   
            expected_output.epoch_seconds_on_target,
  506    507   
            "Unexpected value for `epoch_seconds_on_target`"
  507    508   
        );
  508    509   
        ::pretty_assertions::assert_eq!(parsed.http_date, expected_output.http_date, "Unexpected value for `http_date`");
  509    510   
        ::pretty_assertions::assert_eq!(
  510    511   
            parsed.http_date_on_target,
  511    512   
            expected_output.http_date_on_target,
  512    513   
            "Unexpected value for `http_date_on_target`"
  513    514   
        );
  514    515   
    }
  515    516   
    /// Ensures that the timestampFormat of http-date works
  516    517   
    /// Test ID: QueryXmlTimestampsWithHttpDateFormat
  517    518   
    #[::tokio::test]
  518         -
    #[allow(unused_mut)]
         519  +
    #[::tracing_test::traced_test]
  519    520   
    async fn query_xml_timestamps_with_http_date_format_response() {
  520    521   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  521    522   
            .set_http_date(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  522    523   
                1398796238, 0_f64,
  523    524   
            )))
  524    525   
            .build();
  525    526   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  526    527   
        .header("Content-Type", "text/xml")
  527    528   
        .status(200)
  528    529   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <httpDate>Tue, 29 Apr 2014 18:30:38 GMT</httpDate>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))
  529    530   
                    .unwrap()
  530    531   
                    ).unwrap();
  531    532   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  532    533   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  533    534   
  534    535   
        let op = crate::operation::xml_timestamps::XmlTimestamps::new();
  535    536   
        let config = op.config().expect("the operation has config");
  536    537   
        let de = config
  537    538   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  538    539   
            .expect("the config must have a deserializer");
  539    540   
  540    541   
        let parsed = de.deserialize_streaming(&mut http_response);
  541    542   
        let parsed = parsed.unwrap_or_else(|| {
  542    543   
            let http_response =
  543    544   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  544    545   
            de.deserialize_nonstreaming(&http_response)
  545    546   
        });
  546    547   
        let parsed = parsed
  547    548   
            .expect("should be successful response")
  548    549   
            .downcast::<crate::operation::xml_timestamps::XmlTimestampsOutput>()
  549    550   
            .unwrap();
  550    551   
        ::pretty_assertions::assert_eq!(parsed.normal, expected_output.normal, "Unexpected value for `normal`");
  551    552   
        ::pretty_assertions::assert_eq!(parsed.date_time, expected_output.date_time, "Unexpected value for `date_time`");
  552    553   
        ::pretty_assertions::assert_eq!(
  553    554   
            parsed.date_time_on_target,
  554    555   
            expected_output.date_time_on_target,
  555    556   
            "Unexpected value for `date_time_on_target`"
  556    557   
        );
  557    558   
        ::pretty_assertions::assert_eq!(
  558    559   
            parsed.epoch_seconds,
  559    560   
            expected_output.epoch_seconds,
  560    561   
            "Unexpected value for `epoch_seconds`"
  561    562   
        );
  562    563   
        ::pretty_assertions::assert_eq!(
  563    564   
            parsed.epoch_seconds_on_target,
  564    565   
            expected_output.epoch_seconds_on_target,
  565    566   
            "Unexpected value for `epoch_seconds_on_target`"
  566    567   
        );
  567    568   
        ::pretty_assertions::assert_eq!(parsed.http_date, expected_output.http_date, "Unexpected value for `http_date`");
  568    569   
        ::pretty_assertions::assert_eq!(
  569    570   
            parsed.http_date_on_target,
  570    571   
            expected_output.http_date_on_target,
  571    572   
            "Unexpected value for `http_date_on_target`"
  572    573   
        );
  573    574   
    }
  574    575   
    /// Ensures that the timestampFormat of http-date on the target shape works
  575    576   
    /// Test ID: QueryXmlTimestampsWithHttpDateOnTargetFormat
  576    577   
    #[::tokio::test]
  577         -
    #[allow(unused_mut)]
         578  +
    #[::tracing_test::traced_test]
  578    579   
    async fn query_xml_timestamps_with_http_date_on_target_format_response() {
  579    580   
        let expected_output = crate::operation::xml_timestamps::XmlTimestampsOutput::builder()
  580    581   
            .set_http_date_on_target(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  581    582   
                1398796238, 0_f64,
  582    583   
            )))
  583    584   
            .build();
  584    585   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  585    586   
        .header("Content-Type", "text/xml")
  586    587   
        .status(200)
  587    588   
                    .body(::aws_smithy_types::body::SdkBody::from("<XmlTimestampsResponse xmlns=\"https://example.com/\">\n    <XmlTimestampsResult>\n        <httpDateOnTarget>Tue, 29 Apr 2014 18:30:38 GMT</httpDateOnTarget>\n    </XmlTimestampsResult>\n</XmlTimestampsResponse>\n"))

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/Cargo.toml

@@ -25,25 +62,65 @@
   45     45   
features = ["client", "test-util"]
   46     46   
[dev-dependencies.aws-smithy-types]
   47     47   
path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"
   48     48   
[dev-dependencies.bytes]
   49     49   
version = "1.4.0"
   50     50   
[dev-dependencies.pretty_assertions]
   51     51   
version = "1.3.0"
   52     52   
[dev-dependencies.tokio]
   53     53   
version = "1.23.1"
   54     54   
features = ["macros", "test-util", "rt-multi-thread"]
          55  +
[dev-dependencies.tracing-test]
          56  +
version = "0.2.5"
          57  +
features = ["no-env-filter"]
   55     58   
[features]
   56     59   
test-util = ["aws-smithy-runtime/test-util"]
   57     60   
rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
   58     61   
behavior-version-latest = []
   59     62   
rustls = ["aws-smithy-runtime/tls-rustls"]
   60     63   
default = ["rt-tokio", "rustls"]
   61     64   
   62     65   

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/datetime_offsets.rs

@@ -189,189 +290,291 @@
  209    209   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  210    210   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  211    211   
        })?;
  212    212   
        cfg.interceptor_state()
  213    213   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  214    214   
        ::std::result::Result::Ok(())
  215    215   
    }
  216    216   
}
  217    217   
#[allow(unreachable_code, unused_variables)]
  218    218   
#[cfg(test)]
  219         -
mod datetime_offsets_request_test {
         219  +
mod datetime_offsets_test {
         220  +
  220    221   
    /// Ensures that clients can correctly parse datetime (timestamps) with offsets
  221    222   
    /// Test ID: Ec2QueryDateTimeWithNegativeOffset
  222    223   
    #[::tokio::test]
  223         -
    #[allow(unused_mut)]
         224  +
    #[::tracing_test::traced_test]
  224    225   
    async fn ec2_query_date_time_with_negative_offset_response() {
  225    226   
        let expected_output = crate::operation::datetime_offsets::DatetimeOffsetsOutput::builder()
  226    227   
            .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  227    228   
                1576540098, 0_f64,
  228    229   
            )))
  229    230   
            .build();
  230    231   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  231    232   
        .header("Content-Type", "text/xml;charset=UTF-8")
  232    233   
        .status(200)
  233    234   
                    .body(::aws_smithy_types::body::SdkBody::from("<DatetimeOffsetsResponse xmlns=\"https://example.com/\">\n    <datetime>2019-12-16T22:48:18-01:00</datetime>\n    <RequestId>requestid</RequestId>\n</DatetimeOffsetsResponse>\n"))
  234    235   
                    .unwrap()
  235    236   
                    ).unwrap();
  236    237   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  237    238   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  238    239   
  239    240   
        let op = crate::operation::datetime_offsets::DatetimeOffsets::new();
  240    241   
        let config = op.config().expect("the operation has config");
  241    242   
        let de = config
  242    243   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  243    244   
            .expect("the config must have a deserializer");
  244    245   
  245    246   
        let parsed = de.deserialize_streaming(&mut http_response);
  246    247   
        let parsed = parsed.unwrap_or_else(|| {
  247    248   
            let http_response =
  248    249   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  249    250   
            de.deserialize_nonstreaming(&http_response)
  250    251   
        });
  251    252   
        let parsed = parsed
  252    253   
            .expect("should be successful response")
  253    254   
            .downcast::<crate::operation::datetime_offsets::DatetimeOffsetsOutput>()
  254    255   
            .unwrap();
  255    256   
        ::pretty_assertions::assert_eq!(parsed.datetime, expected_output.datetime, "Unexpected value for `datetime`");
  256    257   
    }
  257    258   
    /// Ensures that clients can correctly parse datetime (timestamps) with offsets
  258    259   
    /// Test ID: Ec2QueryDateTimeWithPositiveOffset
  259    260   
    #[::tokio::test]
  260         -
    #[allow(unused_mut)]
         261  +
    #[::tracing_test::traced_test]
  261    262   
    async fn ec2_query_date_time_with_positive_offset_response() {
  262    263   
        let expected_output = crate::operation::datetime_offsets::DatetimeOffsetsOutput::builder()
  263    264   
            .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  264    265   
                1576540098, 0_f64,
  265    266   
            )))
  266    267   
            .build();
  267    268   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  268    269   
        .header("Content-Type", "text/xml;charset=UTF-8")
  269    270   
        .status(200)
  270    271   
                    .body(::aws_smithy_types::body::SdkBody::from("<DatetimeOffsetsResponse xmlns=\"https://example.com/\">\n    <datetime>2019-12-17T00:48:18+01:00</datetime>\n    <RequestId>requestid</RequestId>\n</DatetimeOffsetsResponse>\n"))

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/empty_input_and_empty_output.rs

@@ -196,196 +284,285 @@
  216    216   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  217    217   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  218    218   
        })?;
  219    219   
        cfg.interceptor_state()
  220    220   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  221    221   
        ::std::result::Result::Ok(())
  222    222   
    }
  223    223   
}
  224    224   
#[allow(unreachable_code, unused_variables)]
  225    225   
#[cfg(test)]
  226         -
mod empty_input_and_empty_output_request_test {
         226  +
mod empty_input_and_empty_output_test {
         227  +
  227    228   
    /// Empty input serializes no extra query params
  228    229   
    /// Test ID: Ec2QueryEmptyInputAndEmptyOutput
  229    230   
    #[::tokio::test]
  230         -
    #[allow(unused_mut)]
         231  +
    #[::tracing_test::traced_test]
  231    232   
    async fn ec2_query_empty_input_and_empty_output_request() {
  232    233   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  233    234   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  234    235   
  235    236   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  236    237   
        let result = client.empty_input_and_empty_output().send().await;
  237    238   
        let _ = dbg!(result);
  238    239   
        let http_request = request_receiver.expect_request();
  239    240   
        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];
  240    241   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
  241    242   
        let body = http_request.body().bytes().expect("body should be strict");
  242    243   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
  243    244   
            body,
  244    245   
            "Action=EmptyInputAndEmptyOutput&Version=2020-01-08",
  245    246   
            ::aws_smithy_protocol_test::MediaType::from("application/x-www-form-urlencoded"),
  246    247   
        ));
  247    248   
        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
  248    249   
        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
  249    250   
        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
  250    251   
    }
  251    252   
    /// Empty output
  252    253   
    /// Test ID: Ec2QueryEmptyInputAndEmptyOutput
  253    254   
    #[::tokio::test]
  254         -
    #[allow(unused_mut)]
         255  +
    #[::tracing_test::traced_test]
  255    256   
    async fn ec2_query_empty_input_and_empty_output_response() {
  256    257   
        let expected_output = crate::operation::empty_input_and_empty_output::EmptyInputAndEmptyOutputOutput::builder().build();
  257    258   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  258    259   
        .header("Content-Type", "text/xml;charset=UTF-8")
  259    260   
        .status(200)
  260    261   
                    .body(::aws_smithy_types::body::SdkBody::from("<EmptyInputAndEmptyOutputResponse xmlns=\"https://example.com/\">\n    <RequestId>requestid</RequestId>\n</EmptyInputAndEmptyOutputResponse>\n"))
  261    262   
                    .unwrap()
  262    263   
                    ).unwrap();
  263    264   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  264    265   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/endpoint_operation.rs

@@ -195,195 +260,261 @@
  215    215   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  216    216   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  217    217   
        })?;
  218    218   
        cfg.interceptor_state()
  219    219   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  220    220   
        ::std::result::Result::Ok(())
  221    221   
    }
  222    222   
}
  223    223   
#[allow(unreachable_code, unused_variables)]
  224    224   
#[cfg(test)]
  225         -
mod endpoint_operation_request_test {
         225  +
mod endpoint_operation_test {
         226  +
  226    227   
    /// Operations can prepend to the given host if they define the
  227    228   
    /// endpoint trait.
  228    229   
    /// Test ID: Ec2QueryEndpointTrait
  229    230   
    #[::tokio::test]
  230         -
    #[allow(unused_mut)]
         231  +
    #[::tracing_test::traced_test]
  231    232   
    async fn ec2_query_endpoint_trait_request() {
  232    233   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  233    234   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  234    235   
  235    236   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  236    237   
        let result = client.endpoint_operation().send().await;
  237    238   
        let _ = dbg!(result);
  238    239   
        let http_request = request_receiver.expect_request();
  239    240   
        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];
  240    241   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/endpoint_with_host_label_operation.rs

@@ -216,216 +282,283 @@
  236    236   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  237    237   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  238    238   
        })?;
  239    239   
        cfg.interceptor_state()
  240    240   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  241    241   
        ::std::result::Result::Ok(())
  242    242   
    }
  243    243   
}
  244    244   
#[allow(unreachable_code, unused_variables)]
  245    245   
#[cfg(test)]
  246         -
mod endpoint_with_host_label_operation_request_test {
         246  +
mod endpoint_with_host_label_operation_test {
         247  +
  247    248   
    /// Operations can prepend to the given host if they define the
  248    249   
    /// endpoint trait, and can use the host label trait to define
  249    250   
    /// further customization based on user input.
  250    251   
    /// Test ID: Ec2QueryEndpointTraitWithHostLabel
  251    252   
    #[::tokio::test]
  252         -
    #[allow(unused_mut)]
         253  +
    #[::tracing_test::traced_test]
  253    254   
    async fn ec2_query_endpoint_trait_with_host_label_request() {
  254    255   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  255    256   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  256    257   
  257    258   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  258    259   
        let result = client
  259    260   
            .endpoint_with_host_label_operation()
  260    261   
            .set_label(::std::option::Option::Some("bar".to_owned()))
  261    262   
            .send()
  262    263   
            .await;

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/fractional_seconds.rs

@@ -190,190 +254,255 @@
  210    210   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  211    211   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  212    212   
        })?;
  213    213   
        cfg.interceptor_state()
  214    214   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  215    215   
        ::std::result::Result::Ok(())
  216    216   
    }
  217    217   
}
  218    218   
#[allow(unreachable_code, unused_variables)]
  219    219   
#[cfg(test)]
  220         -
mod fractional_seconds_request_test {
         220  +
mod fractional_seconds_test {
         221  +
  221    222   
    /// Ensures that clients can correctly parse datetime timestamps with fractional seconds
  222    223   
    /// Test ID: Ec2QueryDateTimeWithFractionalSeconds
  223    224   
    #[::tokio::test]
  224         -
    #[allow(unused_mut)]
         225  +
    #[::tracing_test::traced_test]
  225    226   
    async fn ec2_query_date_time_with_fractional_seconds_response() {
  226    227   
        let expected_output = crate::operation::fractional_seconds::FractionalSecondsOutput::builder()
  227    228   
            .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
  228    229   
                946845296, 0.123_f64,
  229    230   
            )))
  230    231   
            .build();
  231    232   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  232    233   
        .header("Content-Type", "text/xml;charset=UTF-8")
  233    234   
        .status(200)
  234    235   
                    .body(::aws_smithy_types::body::SdkBody::from("<FractionalSecondsResponse xmlns=\"https://example.com/\">\n    <datetime>2000-01-02T20:34:56.123Z</datetime>\n    <RequestId>requestid</RequestId>\n</FractionalSecondsResponse>\n"))

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/greeting_with_errors.rs

@@ -190,190 +326,327 @@
  210    210   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  211    211   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  212    212   
        })?;
  213    213   
        cfg.interceptor_state()
  214    214   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  215    215   
        ::std::result::Result::Ok(())
  216    216   
    }
  217    217   
}
  218    218   
#[allow(unreachable_code, unused_variables)]
  219    219   
#[cfg(test)]
  220         -
mod greeting_with_errors_request_test {
         220  +
mod greeting_with_errors_test {
         221  +
  221    222   
    /// Ensures that operations with errors successfully know how to deserialize the successful response
  222    223   
    /// Test ID: Ec2GreetingWithErrors
  223    224   
    #[::tokio::test]
  224         -
    #[allow(unused_mut)]
         225  +
    #[::tracing_test::traced_test]
  225    226   
    async fn ec2_greeting_with_errors_response() {
  226    227   
        let expected_output = crate::operation::greeting_with_errors::GreetingWithErrorsOutput::builder()
  227    228   
            .set_greeting(::std::option::Option::Some("Hello".to_owned()))
  228    229   
            .build();
  229    230   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  230    231   
        .header("Content-Type", "text/xml;charset=UTF-8")
  231    232   
        .status(200)
  232    233   
                    .body(::aws_smithy_types::body::SdkBody::from("<GreetingWithErrorsResponse xmlns=\"https://example.com/\">\n    <greeting>Hello</greeting>\n    <RequestId>requestid</RequestId>\n</GreetingWithErrorsResponse>\n"))
  233    234   
                    .unwrap()
  234    235   
                    ).unwrap();
  235    236   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  236    237   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  237    238   
  238    239   
        let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();
  239    240   
        let config = op.config().expect("the operation has config");
  240    241   
        let de = config
  241    242   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  242    243   
            .expect("the config must have a deserializer");
  243    244   
  244    245   
        let parsed = de.deserialize_streaming(&mut http_response);
  245    246   
        let parsed = parsed.unwrap_or_else(|| {
  246    247   
            let http_response =
  247    248   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  248    249   
            de.deserialize_nonstreaming(&http_response)
  249    250   
        });
  250    251   
        let parsed = parsed
  251    252   
            .expect("should be successful response")
  252    253   
            .downcast::<crate::operation::greeting_with_errors::GreetingWithErrorsOutput>()
  253    254   
            .unwrap();
  254    255   
        ::pretty_assertions::assert_eq!(parsed.greeting, expected_output.greeting, "Unexpected value for `greeting`");
  255    256   
    }
  256    257   
    /// Parses simple XML errors
  257    258   
    /// Test ID: Ec2InvalidGreetingError
  258    259   
    #[::tokio::test]
  259         -
    #[allow(unused_mut)]
         260  +
    #[::tracing_test::traced_test]
  260    261   
    async fn ec2_invalid_greeting_error_response() {
  261    262   
        let expected_output = crate::types::error::InvalidGreeting::builder()
  262    263   
            .set_message(::std::option::Option::Some("Hi".to_owned()))
  263    264   
            .build();
  264    265   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  265    266   
        .header("Content-Type", "text/xml;charset=UTF-8")
  266    267   
        .status(400)
  267    268   
                    .body(::aws_smithy_types::body::SdkBody::from("<Response>\n    <Errors>\n        <Error>\n            <Code>InvalidGreeting</Code>\n            <Message>Hi</Message>\n        </Error>\n    </Errors>\n    <RequestId>foo-id</RequestId>\n</Response>\n"))
  268    269   
                    .unwrap()
  269    270   
                    ).unwrap();
  270    271   
        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
  271    272   
        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
  272    273   
  273    274   
        let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();
  274    275   
        let config = op.config().expect("the operation has config");
  275    276   
        let de = config
  276    277   
            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
  277    278   
            .expect("the config must have a deserializer");
  278    279   
  279    280   
        let parsed = de.deserialize_streaming(&mut http_response);
  280    281   
        let parsed = parsed.unwrap_or_else(|| {
  281    282   
            let http_response =
  282    283   
                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));
  283    284   
            de.deserialize_nonstreaming(&http_response)
  284    285   
        });
  285    286   
        let parsed = parsed.expect_err("should be error response");
  286    287   
        let parsed: &crate::operation::greeting_with_errors::GreetingWithErrorsError =
  287    288   
            parsed.as_operation_error().expect("operation error").downcast_ref().unwrap();
  288    289   
        if let crate::operation::greeting_with_errors::GreetingWithErrorsError::InvalidGreeting(parsed) = parsed {
  289    290   
            ::pretty_assertions::assert_eq!(parsed.message, expected_output.message, "Unexpected value for `message`");
  290    291   
        } else {
  291    292   
            panic!("wrong variant: Got: {:?}. Expected: {:?}", parsed, expected_output);
  292    293   
        }
  293    294   
    }
  294    295   
    /// Test ID: Ec2ComplexError
  295    296   
    #[::tokio::test]
  296         -
    #[allow(unused_mut)]
         297  +
    #[::tracing_test::traced_test]
  297    298   
    async fn ec2_complex_error_response() {
  298    299   
        let expected_output = crate::types::error::ComplexError::builder()
  299    300   
            .set_top_level(::std::option::Option::Some("Top level".to_owned()))
  300    301   
            .set_nested(::std::option::Option::Some(
  301    302   
                crate::types::ComplexNestedErrorData::builder()
  302    303   
                    .set_foo(::std::option::Option::Some("bar".to_owned()))
  303    304   
                    .build(),
  304    305   
            ))
  305    306   
            .build();
  306    307   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/host_with_path_operation.rs

@@ -190,190 +254,255 @@
  210    210   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  211    211   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  212    212   
        })?;
  213    213   
        cfg.interceptor_state()
  214    214   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  215    215   
        ::std::result::Result::Ok(())
  216    216   
    }
  217    217   
}
  218    218   
#[allow(unreachable_code, unused_variables)]
  219    219   
#[cfg(test)]
  220         -
mod host_with_path_operation_request_test {
         220  +
mod host_with_path_operation_test {
         221  +
  221    222   
    /// Custom endpoints supplied by users can have paths
  222    223   
    /// Test ID: Ec2QueryHostWithPath
  223    224   
    #[::tokio::test]
  224         -
    #[allow(unused_mut)]
         225  +
    #[::tracing_test::traced_test]
  225    226   
    async fn ec2_query_host_with_path_request() {
  226    227   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  227    228   
        let config_builder = crate::config::Config::builder()
  228    229   
            .with_test_defaults()
  229    230   
            .endpoint_url("https://example.com/custom");
  230    231   
  231    232   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  232    233   
        let result = client.host_with_path_operation().send().await;
  233    234   
        let _ = dbg!(result);
  234    235   
        let http_request = request_receiver.expect_request();

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/ignores_wrapping_xml_name.rs

@@ -196,196 +260,261 @@
  216    216   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  217    217   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  218    218   
        })?;
  219    219   
        cfg.interceptor_state()
  220    220   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  221    221   
        ::std::result::Result::Ok(())
  222    222   
    }
  223    223   
}
  224    224   
#[allow(unreachable_code, unused_variables)]
  225    225   
#[cfg(test)]
  226         -
mod ignores_wrapping_xml_name_request_test {
         226  +
mod ignores_wrapping_xml_name_test {
         227  +
  227    228   
    /// The xmlName trait on the output structure is ignored in the ec2 protocol
  228    229   
    /// Test ID: Ec2IgnoresWrappingXmlName
  229    230   
    #[::tokio::test]
  230         -
    #[allow(unused_mut)]
         231  +
    #[::tracing_test::traced_test]
  231    232   
    async fn ec2_ignores_wrapping_xml_name_response() {
  232    233   
        let expected_output = crate::operation::ignores_wrapping_xml_name::IgnoresWrappingXmlNameOutput::builder()
  233    234   
            .set_foo(::std::option::Option::Some("bar".to_owned()))
  234    235   
            .build();
  235    236   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()
  236    237   
        .header("Content-Type", "text/xml;charset=UTF-8")
  237    238   
        .status(200)
  238    239   
                    .body(::aws_smithy_types::body::SdkBody::from("<IgnoresWrappingXmlNameResponse xmlns=\"https://example.com/\">\n    <foo>bar</foo>\n    <RequestId>requestid</RequestId>\n</IgnoresWrappingXmlNameResponse>\n"))
  239    240   
                    .unwrap()
  240    241   
                    ).unwrap();

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/nested_structures.rs

@@ -193,193 +257,258 @@
  213    213   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  214    214   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  215    215   
        })?;
  216    216   
        cfg.interceptor_state()
  217    217   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  218    218   
        ::std::result::Result::Ok(())
  219    219   
    }
  220    220   
}
  221    221   
#[allow(unreachable_code, unused_variables)]
  222    222   
#[cfg(test)]
  223         -
mod nested_structures_request_test {
         223  +
mod nested_structures_test {
         224  +
  224    225   
    /// Serializes nested structures using dots
  225    226   
    /// Test ID: Ec2NestedStructures
  226    227   
    #[::tokio::test]
  227         -
    #[allow(unused_mut)]
         228  +
    #[::tracing_test::traced_test]
  228    229   
    async fn ec2_nested_structures_request() {
  229    230   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  230    231   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  231    232   
  232    233   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  233    234   
        let result = client
  234    235   
            .nested_structures()
  235    236   
            .set_nested(::std::option::Option::Some(
  236    237   
                crate::types::StructArg::builder()
  237    238   
                    .set_string_arg(::std::option::Option::Some("foo".to_owned()))

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/no_input_and_output.rs

@@ -190,190 +278,279 @@
  210    210   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  211    211   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  212    212   
        })?;
  213    213   
        cfg.interceptor_state()
  214    214   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  215    215   
        ::std::result::Result::Ok(())
  216    216   
    }
  217    217   
}
  218    218   
#[allow(unreachable_code, unused_variables)]
  219    219   
#[cfg(test)]
  220         -
mod no_input_and_output_request_test {
         220  +
mod no_input_and_output_test {
         221  +
  221    222   
    /// No input serializes no payload
  222    223   
    /// Test ID: Ec2QueryNoInputAndOutput
  223    224   
    #[::tokio::test]
  224         -
    #[allow(unused_mut)]
         225  +
    #[::tracing_test::traced_test]
  225    226   
    async fn ec2_query_no_input_and_output_request() {
  226    227   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  227    228   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  228    229   
  229    230   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  230    231   
        let result = client.no_input_and_output().send().await;
  231    232   
        let _ = dbg!(result);
  232    233   
        let http_request = request_receiver.expect_request();
  233    234   
        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];
  234    235   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
  235    236   
        let body = http_request.body().bytes().expect("body should be strict");
  236    237   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
  237    238   
            body,
  238    239   
            "Action=NoInputAndOutput&Version=2020-01-08",
  239    240   
            ::aws_smithy_protocol_test::MediaType::from("application/x-www-form-urlencoded"),
  240    241   
        ));
  241    242   
        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
  242    243   
        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
  243    244   
        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
  244    245   
    }
  245    246   
    /// Empty output
  246    247   
    /// Test ID: Ec2QueryNoInputAndOutput
  247    248   
    #[::tokio::test]
  248         -
    #[allow(unused_mut)]
         249  +
    #[::tracing_test::traced_test]
  249    250   
    async fn ec2_query_no_input_and_output_response() {
  250    251   
        let expected_output = crate::operation::no_input_and_output::NoInputAndOutputOutput::builder().build();
  251    252   
        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(
  252    253   
            ::http::response::Builder::new()
  253    254   
                .header("Content-Type", "text/xml;charset=UTF-8")
  254    255   
                .status(200)
  255    256   
                .body(::aws_smithy_types::body::SdkBody::from(
  256    257   
                    "<NoInputAndOutputResponse xmlns=\"https://example.com/\">\n    <RequestId>requestid</RequestId>\n</NoInputAndOutputResponse>\n",
  257    258   
                ))
  258    259   
                .unwrap(),

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/put_with_content_encoding.rs

@@ -201,201 +292,293 @@
  221    221   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  222    222   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  223    223   
        })?;
  224    224   
        cfg.interceptor_state()
  225    225   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  226    226   
        ::std::result::Result::Ok(())
  227    227   
    }
  228    228   
}
  229    229   
#[allow(unreachable_code, unused_variables)]
  230    230   
#[cfg(test)]
  231         -
mod put_with_content_encoding_request_test {
         231  +
mod put_with_content_encoding_test {
         232  +
  232    233   
    /// Compression algorithm encoding is appended to the Content-Encoding header.
  233    234   
    /// Test ID: SDKAppliedContentEncoding_ec2Query
  234    235   
    #[::tokio::test]
  235         -
    #[allow(unused_mut)]
         236  +
    #[::tracing_test::traced_test]
  236    237   
    async fn sdk_applied_content_encoding_ec2_query_request() {
  237    238   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  238    239   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  239    240   
  240    241   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  241    242   
        let result = client.put_with_content_encoding()
  242    243   
        .set_data(
  243    244   
            ::std::option::Option::Some(
  244    245   
                "RjCEL3kBwqPivZUXGiyA5JCujtWgJAkKRlnTEsNYfBRGOS0f7LT6R3bCSOXeJ4auSHzQ4BEZZTklUyj5\n1HEojihShQC2jkQJrNdGOZNSW49yRO0XbnGmeczUHbZqZRelLFKW4xjru9uTuB8lFCtwoGgciFsgqTF8\n5HYcoqINTRxuAwGuRUMoNO473QT0BtCQoKUkAyVaypG0hBZdGNoJhunBfW0d3HWTYlzz9pXElyZhq3C1\n2PDB17GEoOYXmTxDecysmPOdo5z6T0HFhujfeJFIQQ8dirmXcG4F3v0bZdf6AZ3jsiVh6RnEXIPxPbOi\ngIXDWTMUr4Pg3f2LdYCM01eAb2qTdgsEN0MUDhEIfn68I2tnWvcozyUFpg1ez6pyWP8ssWVfFrckREIM\nMb0cTUVqSVSM8bnFiF9SoXM6ZoGMKfX1mT708OYk7SqZ1JlCTkecDJDoR5ED2q2MWKUGR6jjnEV0GtD8\nWJO6AcF0DptY9Hk16Bav3z6c5FeBvrGDrxTFVgRUk8SychzjrcqJ4qskwN8rL3zslC0oqobQRnLFOvwJ\nprSzBIwdH2yAuxokXAdVRa1u9NGNRvfWJfKkwbbVz8yV76RUF9KNhAUmwyYDrLnxNj8ROl8B7dv8Gans\n7Bit52wcdiJyjBW1pAodB7zqqVwtBx5RaSpF7kEMXexYXp9N0J1jlXzdeg5Wgg4pO7TJNr2joiPVAiFf\nefwMMCNBkYx2z7cRxVxCJZMXXzxSKMGgdTN24bJ5UgE0TxyV52RC0wGWG49S1x5jGrvmxKCIgYPs0w3Z\n0I3XcdB0WEj4x4xRztB9Cx2Mc4qFYQdzS9kOioAgNBti1rBySZ8lFZM2zqxvBsJTTJsmcKPr1crqiXjM\noVWdM4ObOO6QA7Pu4c1hT68CrTmbcecjFcxHkgsqdixnFtN6keMGL9Z2YMjZOjYYzbUEwLJqUVWalkIB\nBkgBRqZpzxx5nB5t0qDH35KjsfKM5cinQaFoRq9y9Z82xdCoKZOsUbxZkk1kVmy1jPDCBhkhixkc5PKS\nFoSKTbeK7kuCEZCtR9OfF2k2MqbygGFsFu2sgb1Zn2YdDbaRwRGeaLhswta09UNSMUo8aTixgoYVHxwy\nvraLB6olPSPegeLOnmBeWyKmEfPdbpdGm4ev4vA2AUFuLIeFz0LkCSN0NgQMrr8ALEm1UNpJLReg1ZAX\nzZh7gtQTZUaBVdMJokaJpLk6FPxSA6zkwB5TegSqhrFIsmvpY3VNWmTUq7H0iADdh3dRQ8Is97bTsbwu\nvAEOjh4FQ9wPSFzEtcSJeYQft5GfWYPisDImjjvHVFshFFkNy2nN18pJmhVPoJc456tgbdfEIdGhIADC\n6UPcSSzE1FxlPpILqZrp3i4NvvKoiOa4a8tnALd2XRHHmsvALn2Wmfu07b86gZlu4yOyuUFNoWI6tFvd\nbHnqSJYNQlFESv13gJw609DBzNnrIgBGYBAcDRrIGAnflRKwVDUnDFrUQmE8xNG6jRlyb1p2Y2RrfBtG\ncKqhuGNiT2DfxpY89ektZ98waPhJrFEPJToNH8EADzBorh3T0h4YP1IeLmaI7SOxeuVrk1kjRqMK0rUB\nlUJgJNtCE35jCyoHMwPQlyi78ZaVv8COVQ24zcGpw0MTy6JUsDzAC3jLNY6xCb40SZV9XzG7nWvXA5Ej\nYC1gTXxF4AtFexIdDZ4RJbtYMyXt8LsEJerwwpkfqvDwsiFuqYC6vIn9RoZO5kI0F35XtUITDQYKZ4eq\nWBV0itxTyyR5Rp6g30pZEmEqOusDaIh96CEmHpOBYAQZ7u1QTfzRdysIGMpzbx5gj9Dxm2PO1glWzY7P\nlVqQiBlXSGDOkBkrB6SkiAxknt9zsPdTTsf3r3nid4hdiPrZmGWNgjOO1khSxZSzBdltrCESNnQmlnP5\nZOHA0eSYXwy8j4od5ZmjA3IpFOEPW2MutMbxIbJpg5dIx2x7WxespftenRLgl3CxcpPDcnb9w8LCHBg7\nSEjrEer6Y8wVLFWsQiv6nTdCPZz9cGqwgtCaiHRy8lTWFgdfWd397vw9rduGld3uUFeFRGjYrphqEmHi\nhiG0GhE6wRFVUsGJtvOCYkVREvbEdxPFeJvlAvOcs9HKbtptlTusvYB86vR2bNcIY4f5JZu2X6sGa354\n7LRk0ps2zqYjat3hMR7XDC8KiKceBteFsXoDjfVxTYKelpedTxqWAafrKhaoAVuNM98PSnkuIWGzjSUC\nNsDJTt6vt1D1afBVPWVmnQ7ZQdtEtLIEwAWYjemAztreELIr1E9fPEILm1Ke4KctP9I0I72Dh4eylNZD\n0DEr2Hg7cWFckuZ0Av5d0IPRARXikEGDHl8uh12TXL9v2Uh0ZVSJMEYvxGSbZvkWz8TjWSk3hKA2a7GL\nJm3Ho7e1C34gE1XRGcEthxvURxt4OKBqN3ZNaMIuDTWinoQAutMcUqtm4MoL7RGPiCHUrvTwQPSirsmA\nQmOEu8nOpnP77Fivh9jLGx5ta7nL6jrsWUsBqiN1lzpdPYLRR4mUIAj6sNWiDEk4pkbHSMEcqbWw6Zl7\npsEyPDHalCNhWMA3RSK3skURzQDZ0oBV5W7vjVIZ4d3uCKsk6zrzEI9u5mx7p9RdNKodXfzqYt0ULdtc\n3RW0hIfw2KvrO3BD2QrtgAkfrFBGVvlJSUoh0MvLz8DeXxfuiuq9Ttu7wvsqVI4Piah6WNEXtHHGPJO3\nGhc75Bnv2To4VS2v8rmyKAPIIVTuYBHZN6sZ4FhFzbrslCIdk0eadaU60naqiNWU3CsxplIYGyeThmJ7\n9u4h6Y2OmiPZjFPS2bAzwgAozYTVefII9aEaWZ0hxHZeu1FW7r79dkdO73ZqRfas9u8Z7LLBPCw5pV0F\n5I0pHDgNb6MogoxF4NZJfVtIX1vCHhhVLrXjrYNJU2fD9Fw8kT8Ie2HDBJnqAvYKmryQ1r9ulo3Me3rH\nq9s2Y5uCDxu9iQNhnpwIm57WYGFeqd2fnQeY2IziD3Jgx0KSrmOH0jgi0RwJyfGXaORPq3bQQqljuACo\nkO6io9t5VI8PbNxSHTRbtYiPciUslbT0g7SpCLrRPOBRJ4DDk56pjghpeoUagJ5xJ4wjBzBuXnAGkNnP\nTfpiuz2r3oSBAi8sB9wiYK2z9sp4gZyQsqdVNzAEgKatOxBRBmJCBYpjO98ZQrF83XApPpfFg0ujB2PW\n1iYF9NkgwIKB5oB6KVTOmSKJk11mVermPgeugHbzdd2zUP6fP8fWbhseqk2t8ahGvqjs2CDHFIWXl5jc\nfCknbykE3ANt7lnAfJQ2ddduLGiqrX4HWx6jcWw08Es6BkleO0IDbaWrb95d5isvFlzJsf0TyDIXF4uq\nbBDCi0XPWqtRJ2iqmnJa2GbBe9GmAOWMkBFSilMyC4sR395WSDpD56fx0NGoU6cHrRu9xF2Bgh7RGSfl\nch2GXEeE02fDpSHFNvJBlOEqqfkIX6oCa6KY9NThqeIjYsT184XR2ZI7akXRaw1gMOGpk4FmUxk6WIuX\n4ei1SLQgSdl7OEdRtJklZ76eFrMbkJQ2TDhu8f7mVuiy53GUMIvCrP9xYGZGmCIDm2e4U2BDi3F7C5xK\n3bDZXwlQp6z4BSqTy2OVEWxXUJfjPMOL5Mc7AvDeKtxAS73pVIv0HgHIa4NBAdC7uLG0zXuu1FF6z2XY\nyUhk03fMZhYe7vVxsul3WE7U01fuN8z2y0eKwBW1RFBE1eKIaR9Y01sIWQWbSrfHfDrdZiElhmhHehfs\n0EfrR4sLYdQshJuvhTeKGJDaEhtPQwwJ9mUYGtuCL9RozWx1XI4bHNlzBTW0BVokYiJGlPe7wdxNzJD7\nJgS7Lwv6jGKngVf86imGZyzqwiteWFPdNUoWdTvUPSMO5xIUK9mo5QpwbBOAmyYzVq42o3Qs90N9khEV\nU36LB99fw8PtGHH5wsCHshfauwnNPj0blGXzke0kQ4JNCVH7Jtn0Y0aeejkSxFtwtxoYs6zHl1Lxxpsd\nsw5vBy49CEtoltDW367lVAwDjWdx20msGB7qJCkEDrzu7EXSO22782QX9NBRcN9ppX0C25I0FMA4Wnhz\n9zIpiXRrsTH35jzM8Cjt4EVLGNU3O0HuEvAer3cENnMJtngdrT86ox3fihMQbiuy4Bh4DEcP5in2VjbT\n3qbnoCNvOi8Fmmf7KlGlWAOceL5OHVE5lljjQEMzEQOCEgrk5mDKgwSBJQBNauIDSC1a5iEQjB8Xxp4C\nqeKyyWY9IOntNrtU5ny4lNprHJd36dKFeBLKcGCOvgHBXdOZloMF0YTRExw7hreEO9IoTGVHJ4teWsNr\nHdtagUHjkeZkdMMfnUGNv5aBNtFMqhcZH6EitEa9lGPkKBbJpoom3u8D8EHSIF1H5EZqqx9TLY5hWAIG\nPwJ4qwkpCGw5rCLVrjw7ARKukIFzNULANqjHUMcJ002TlUosJM4xJ4aAgckpLVGOGuPDhGAAexEcQmbg\nUsZdmqQrtuVUyyLteLbLbqtR6CTlcAIwY3xyMCmPgyefE0FEUODBoxQtRUuYTL9RC5o1sYb2PvcxUQfb\niJFi2CAl99pAzcckU2qVCxniARslIxM5pmMRGsQX9ZzYAfZrbg6ce6S74I8UMlgRQ2QVyvUjKKOE6IrJ\nLng370emHfe5m6LZULD5YiZutkD5ipjL2Bz77DvTE5kNPUhuoKBcTJcUgytfXAKUTWOcRKNlq0GImrxM\nJfr7AWbLFFNKGLeTrVDBwpcokJCv0zcOKWe8fd2xkeXkZTdmM66IgM27cyYmtQ6YF26Kd0qrWJeVZJV9\n3fyLYYvKN5csbRY2BHoYE5ERARRW65IrpkXMf48OrCXMtDIP0Z7wxI9DiTeKKeH4uuguhCJnwzR3WxLA\nVU6eBJEd7ZjS6JA83w7decq8uDI7LGKjcz1FySp3B7fE9DkHRGXxbsL7Fjar6vW2mAv8CuvI20B6jctp\n2yLDs24sPfB3sSxrrlhbuT1m6DZqiN0dl6umKx7NGZhmOTVGr20jfcxhqPQwTJfd7kel4rvxip4BqkvT\n7STy8knJ2BXGyJeNgwo1PXUZRDVy0LCTsSF1RFuRZe8cktHl9lgw8ntdPn1pVFL0MwJkJfdXBNUp5gNv\n50FTkrpo1t6wq4CVbcfj2XOrOzvBUzNH26sXGABI1gGxCdp2jEZrHgqQaWIaTJVTuguZhxqDvdYsrwFW\nYN58uuNcKHIrGdRSigyZInwQDYk0pjcqdSeU0WVU3Y9htzZBR7XRaCJr5YTZvq7fwermb5tuwb37lPLq\nB2IGg0iftkVbXaSyfCwVaRbfLBb88so0QqpmJGirFu8FcDiXOV1zTr8yW9XLdYQuUjh43xrXLdgsuYff\nCagInUk1eU1aLjVZoJRsNmStmOEpAqlYMwTvx7w6j2f421Cxr5cNZBIVlAxlXN2QiDqJ9v3sHhHkTanc\nlQuH8ptUyX8qncpBuXXBn7cSez9N0EoxCBl1GHUagbjstgJo4gzLvTmVIY6MiWYOBitzNUHfyqKwtKUr\nVoSCdZcGeA9lHUPA7PUprRRaT3m1hGKPyshtVS2ikG48w3oVerln1N1qGdtz46gZCrndw3LZ1B362RfW\nzDPuXbpsyLsRMTt1Rz1oKHRXp3iE41hkhQH6pxlvyCW2INnHt5XU8zRamOB3oW0udOhMpQFDjRkOcy06\nb4t0QTHvoRqmBna3WXzIMZyeK3GChF5eF8oDXRbjhk7BB6YKCgqwWUzEJ5K47HMSlhFkBUjaPRjdGM0z\nzOMwhW6b1NvSwP7XM1P5yi1oPvOspts1vr29SXqrMMrBhVogeodWyd69NqrO4jkyBxKmlXifoTowpfiY\n2cUCE0XMZqxUN39LCP09JqZifaEcBEo3mgtm1tWu5QR2GNq7UyQf4RIPSDOpDCAtwoPhRgdT1lJdcj4U\nlnH0wrJ8Uwu7c08L7ErnIrDATqCrOjpSbzGP1xHENABYONC4TknFPrJ8pe40A8fzGT0qBw9mAM1SKcHO\nfoiLcMC9AjHTqJzDG3xplSLPG9or2rMeq7Fzp9r0y7uJRMxgg51EbjfvYlH466A3ggvL2WQlDXjJqPW3\nBJGWAWDNN9LK8f46bADKPxakpkx23S9O47rGSXfDhVSIZsDympxWX1UOzWwMZRHkofVeKqizgbKkGgUT\nWykE9gRoRAOd9wfHZDYKa9i0LaPDiaUMvnU1gdBIqIoiVsdJ9swX47oxvMtOxtcS0zlD6llDkBuIiU5g\nPwRCYmtkkb25c8iRJXwGFPjI1wJ34I1z1ENicPdosPiUe9ZC2jnXIKzEdv01x2ER7DNDF3yxOwOhxNxI\nGqsmC92j25UQQFu9ZstOZ28AoCkuOYs0Uycm5u8jR1T39dMBwrko09rC65ENLnsxM8oebmyFCPiGJ1ED\n5Xqc9qZ237f1OnETAoEOwqUSvrdPTv56U7hV91EMTyC812MLQpr2710E3VVpsUCUMNhIxdt7UXZ1UNFb\njgzpZLXnf4DHrv6B7kq6UI50KMxcw1HZE2GpODfUTzNFLaqdrvzxKe5eUWdcojBaRbD4fFdVYJTElYDH\nNNVh6ofkoeWcs9CWGFmSBe0T4K8phFeygQg0prKMELNEy6qENzVtG9ZDcqj3a7L6ZLtvq50anWp7fAVu\nfwz55g4iM2Z2fA0pnwHDL7tt67zTxGITvsnJsZSpeq1EQsZcwtkBV9liu7Rl7jiVT1IIRtchB8TsTiaA\nwVHIQQ9RIOTiPQdKNqi1kC9iGlUqWK93gblNWlBw1eYB9Wk8FQogutwTf0caNMx8D4nPbANcmOOlskIy\nzALh15OlTrWnhP95rf08AN2J026zDE2DUF9k0eCevYBQIDjqKNW4XCZnjbHoIcKzbY5VzPbMs3ZyMz8K\nSucBmgPg6wrSK5ykbkapS5vuqvXc9GbjQJ8bPNzoxoWGyjbZvDs2OBrIqBmcQb2DLJ8v38McQ4mC4UsS\njf4PyfSCtpk274QZjvLCZbLiCBxQegk7jUU0NmTFJAcYCxd9xMWdlFkiszcltT2YzwuFFz7iA6aa4n5L\nHpBNfUA01GcAi1aCMYhmooS4zSlYcSOZkovMz36U3Fd9WtqIEOJLi7HMgHQDgNMdK6DTzAdHQtxerxVF\nHJnPrfNVG7270r3bp0bPnLNYLhObbAn6zqSAUeLtI2Y4KJDjBKCAh2vvYGbu0e2REYJWRj7MkGevsSSy\nb1kCXLt6tKGWAb7lt5c0xyJgUIJW7pdtnwgT0ZCa24BecCAwNnG5U2EwQbcjZGsFxqNGfaemd3oFEhES\nBaE0Fxms9UKTnMafu8wvZ2xymMrUduuRzOjDeX7oD5YsLC88V8CGMLxbbxIpt94KGykbr6e7L0R4oZl1\ntKMgFwQ2p9Txdbp0Y293LcsJymKizqI0F2xEp7y4SmWOJqHZtsbz80wVV9nv41CvtfxuSoGZJ5cNB7pI\nBgzNcQCeH3Jt0RaGGwboxxpuFbzilmkMFXxJm87tD4WNgu01nHfGCKeQcySEBZpVfJgi6sDFJ8uWnvKm\n9mPLHurtWzEfKqUEa1iC71bXjw5wrvhv9BYW8JSUELHmDquftQyKdq0DZXhULMHGQLf4e95WIaoA14LL\nbThz77kuhKULPTu2MNrBUKGorurhGugo5gs4ZUezSsUOe3KxYdrFMdGgny1GgTxMSMTp2RAZytKjv4kQ\nVx7XgzvpQLIbDjUPAkJv6lScwIRq1W3Ne0Rh0V6Bmn6U5uIuWnJjULmbaQiSODj3z0mAZvak0mSWIGwT\nTX83HztcC4W7e1f6a1thmcc5K61Icehla2hBELWPpixTkyC4eEVmk9Rq0m0ZXtx0JX2ZQXqXDEyePyMe\nJ70sdSzXk72zusqhY4yuOMGgbYNHqxOToK6NxujR7e4dV3Wk5JnSUthym8scjcPeCiKDNY4cHfTMnDXJ\n9zLVy01LtNKYpJ1s8FxVxigmxQNKEbIamxhx6yqwGC4aiISVOOUEjvNOdaUfXfUsE6jEwtwxyGxjlRK1\ncLyxXttq4QWN6PehgHv7jXykzPjInbEysebFvvPOOMdunmJvcCNMSvjUda8fL6xfGo0FDrLg8XZipd6S\noPVdYtyIM1Dg40KbBA3JuumPYtXuJaHrZnjZmdnM5OVo4ZNxktfCVT0c6bnD4bAeyn4bYt1ZPaX6hQHh\nJtvNYfpD0ONYlmqKuToQAMlz52Fh6bj45EbX89L5eLlSpWeyBlGotzriB0EPlclrGi5l2B5oPb1aB1ag\nyyYuu44l0F1oOVYnBIZsxIsHVITxi9lEuVPFkWASOUNuVQXfM4n5hxWR9qtuKnIcPsvbJsv1U10XlKh3\nKisqPhHU15xrCLr5gwFxPUKiNTLUBrkzgBOHXPVsHcLCiSD0YU56TRGfvEom43TWUKPPfl9Z54tgVQuT\njCRlaljAzeniQIcbbHZnn3f0HxbDG3DFYqWSxNrXabHhRsIOhhUHSPENyhGSTVO5t0XX5CdMspJPCd02\n3Oqv32ccbUK4O3YH6LEvp0WO3kSl5n50odVkI9B0i0iq4UPFGMkM8bEQJbgJoOH71P10vtdevJFQE4g2\nyhimiM53ZJRWgSZveHtENZc0Gjo0F9eioak9BnPpY1QxAFPC817svuhEstcU69bLCA4D1rO5R8AuIIBq\nyQJcifFLvbpAEYTLKJqysZrU8EEl3TSdC13A9hZvk4NC8VGEDAxcNrKw313dZp17kZPO5HSd1y6sljAW\nA9M1d6FMYV5SlBWf3WZNCUPS7qKNlda2YBsC6IUVB363f5RLGQOQHwbaijBSRCkrVoRxBHtc0Bd5J9V9\nP5uMTXkpZOxRcCQvImGgcmGuxxLb5zTqfS2xu7v3Sf3IIesSt9tVzcEcdbEvLGVJkLk4mb3G30DbIbri\nPZ09JkweDvMaQ3bxT2nfkz3Ilihkw9jqikkCCCz7E8h6z6KbhQErEW9VzJZzMCgJsyPjFam6iNwpe07S\nhyOvNVw2t9wpzL5xM11DvVzQwDaWEytNRHzDBs4KwEtpI2IpjUyVZHSwA0UGqqkzoCgrJFlNOvPlXqcS\nIcREouUIBmuttkrhPWJtSxOOgpsdvBR3kTOzAXNzSKxoaBAb0c5SDMUc6FIyGA8x5wg5DkUgjFUUodEt\nOYaB2VHVePW9mxHeBTdKWLzJow4ZZvjnoBuVigXljKCNh137ckV2y3Yg3Xi4UzJEI2V5Rw9AfnMs7xUw\nVHOFCg189maD3bmZAe7b4eaGZhyy4HVKjqCXmIH7vsEjRvbnfB0SQxxpuqBDJbHNCtW4vM643ZQQBVPP\na7oXSQIq9w2dHp0A7dtkocCZdQp9FKR9XdJAFIbVSHzIF1ZogeZlc0pXuNE0tagvD57xwDRFkAuoQyMu\nYDdZasXrpSmEE5UjHVkyYsISn8QsfXurzDybX468aoRoks654jjmRY5zi1oB8TcMdC2c3sicNaqfeuhd\nH1nPX7l4RpdqWMR7gGx9slXtG8S3KxpOi4qCD7yg3saD66nun4dzksQURoTUdXyrJR5UpHsfIlTF1aJa\nMdXyQtQnrkl00TeghQd00rRFZsCnhi0qrCSKiBfB2EVrd9RPpbgwJGZHuIQecdBmNetc2ylSEClqVBPR\nGOPPIxrnswEZjmnS0jxKW9VSM1QVxSPJnPFswCqT95SoKD6CP4xdX28WIUGiNaIKodXXJHEIsXBCxLsr\nPwWPCtoplC6hhpKmW5dQo92iCTyY2KioKzO8XR6FKm6qonMKVEwQNtlYE9c97KMtEnp25VOdMP46SQXS\nYsSVp7vm8LP87VYI8SOKcW3s2oedYFtt45rvDzoTF0GmS6wELQ9uo98HhjQAI1Dt91cgjJOwygNmLoZE\nX5K2zQiNA163uMCl5xzaBqY4YTL0wgALg3IFdYSp0RFYLWdt6IxoGI1tnoxcjlUEPo5eGIc3mS3SmaLn\nOdumfUQQ4Jgmgaa5anUVQsfBDrlAN5oaX7O0JO71SSPSWiHBsT9WIPy2J1Cace9ZZLRxblFPSXcvsuHh\nhvnhWQltEDAe7MgvkFQ8lGVFa8jhzijoF9kLmMhMILSzYnfXnZPNP7TlAAwlLHK1RqlpHskJqb6CPpGP\nQvOAhEMsM3zJ2KejZx0esxkjxA0ZufVvGAMN3vTUMplQaF4RiQkp9fzBXf3CMk01dWjOMMIEXTeKzIQe\nEcffzjixWU9FpAyGp2rVl4ETRgqljOGw4UgK31r0ZIEGnH0xGz1FtbW1OcQM008JVujRqulCucEMmntr\n".to_owned()
  245    246   
            )
  246    247   
        )
  247    248   
        .send().await;
  248    249   
        let _ = dbg!(result);
  249    250   
        let http_request = request_receiver.expect_request();
  250    251   
        let expected_headers = [("Content-Encoding", "gzip")];
  251    252   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
  252    253   
        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
  253    254   
        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
  254    255   
        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
  255    256   
    }
  256    257   
    /// Compression algorithm encoding is appended to the Content-Encoding header, and the
  257    258   
    /// user-provided content-encoding is NOT in the Content-Encoding header since HTTP binding
  258    259   
    /// traits are ignored in the ec2Query protocol.
  259    260   
    ///
  260    261   
    /// Test ID: SDKAppendsGzipAndIgnoresHttpProvidedEncoding_ec2Query
  261    262   
    #[::tokio::test]
  262         -
    #[allow(unused_mut)]
         263  +
    #[::tracing_test::traced_test]
  263    264   
    async fn sdk_appends_gzip_and_ignores_http_provided_encoding_ec2_query_request() {
  264    265   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  265    266   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  266    267   
  267    268   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  268    269   
        let result = client.put_with_content_encoding()
  269    270   
        .set_encoding(
  270    271   
            ::std::option::Option::Some(
  271    272   
                "custom".to_owned()
  272    273   
            )

tmp-codegen-diff/codegen-client-test/ec2_query/rust-client-codegen/src/operation/query_idempotency_token_auto_fill.rs

@@ -209,209 +299,300 @@
  229    229   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  230    230   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  231    231   
        })?;
  232    232   
        cfg.interceptor_state()
  233    233   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  234    234   
        ::std::result::Result::Ok(())
  235    235   
    }
  236    236   
}
  237    237   
#[allow(unreachable_code, unused_variables)]
  238    238   
#[cfg(test)]
  239         -
mod query_idempotency_token_auto_fill_request_test {
         239  +
mod query_idempotency_token_auto_fill_test {
         240  +
  240    241   
    /// Automatically adds idempotency token when not set
  241    242   
    /// Test ID: Ec2ProtocolIdempotencyTokenAutoFill
  242    243   
    #[::tokio::test]
  243         -
    #[allow(unused_mut)]
         244  +
    #[::tracing_test::traced_test]
  244    245   
    async fn ec2_protocol_idempotency_token_auto_fill_request() {
  245    246   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  246    247   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  247    248   
  248    249   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  249    250   
        let result = client.query_idempotency_token_auto_fill().send().await;
  250    251   
        let _ = dbg!(result);
  251    252   
        let http_request = request_receiver.expect_request();
  252    253   
        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];
  253    254   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
  254    255   
        let required_headers = &["Content-Length"];
  255    256   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::require_headers(http_request.headers(), required_headers));
  256    257   
        let body = http_request.body().bytes().expect("body should be strict");
  257    258   
        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
  258    259   
            body,
  259    260   
            "Action=QueryIdempotencyTokenAutoFill&Version=2020-01-08&Token=00000000-0000-4000-8000-000000000000",
  260    261   
            ::aws_smithy_protocol_test::MediaType::from("application/x-www-form-urlencoded"),
  261    262   
        ));
  262    263   
        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
  263    264   
        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
  264    265   
        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
  265    266   
    }
  266    267   
    /// Uses the given idempotency token as-is
  267    268   
    /// Test ID: Ec2ProtocolIdempotencyTokenAutoFillIsSet
  268    269   
    #[::tokio::test]
  269         -
    #[allow(unused_mut)]
         270  +
    #[::tracing_test::traced_test]
  270    271   
    async fn ec2_protocol_idempotency_token_auto_fill_is_set_request() {
  271    272   
        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);
  272    273   
        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
  273    274   
  274    275   
        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
  275    276   
        let result = client
  276    277   
            .query_idempotency_token_auto_fill()
  277    278   
            .set_token(::std::option::Option::Some("00000000-0000-4000-8000-000000000123".to_owned()))
  278    279   
            .send()
  279    280   
            .await;