feat: make outgoing request based on wasi-http proposal

aws/rust-runtime/aws-config/Cargo.toml

@@ -1,7 +1,10 @@
 [package]
 name = "aws-config"
 version = "0.0.0-smithy-rs-head"
-authors = ["AWS Rust SDK Team <[email protected]>", "Russell Cohen <[email protected]>"]
+authors = [
+    "AWS Rust SDK Team <[email protected]>",
+    "Russell Cohen <[email protected]>",
+]
 description = "AWS SDK config and credential provider implementations."
 edition = "2021"
 exclude = ["test-data/*", "integration-tests/*"]

aws/sdk/integration-tests/webassembly/.cargo/config.toml

@@ -3,3 +3,9 @@ target = "wasm32-wasi"
 
 [target.wasm32-wasi]
 rustflags = ["-C", "opt-level=1"]
+runner = [
+    "wasmtime",
+    "--disable-cache",
+    "--preview2",
+    "--wasi-modules=experimental-wasi-http",
+]

aws/sdk/integration-tests/webassembly/Cargo.toml

@@ -2,7 +2,9 @@
 [package]
 name = "webassembly"
 version = "0.1.0"
-authors = ["Eduardo Rodrigues <[email protected]>"]
+authors = [
+    "Eduardo Rodrigues <[email protected]>",
+]
 description = """
 These tests ensure that things will fail (or not fail) as expected
 when target is set to wasm32-wasi for all SDK and runtime crates.
@@ -12,20 +14,22 @@ license = "Apache-2.0"
 repository = "https://github.com/smithy-lang/smithy-rs"
 publish = false
 
-[lib]
-crate-type = ["cdylib"]
-
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
-[dependencies]
-aws-config = { path = "../../build/aws-sdk/sdk/aws-config", default-features = false, features = ["rt-tokio", "behavior-version-latest"]}
+[target.'cfg(target_family = "wasm")'.dependencies]
+aws-config = { path = "../../build/aws-sdk/sdk/aws-config", default-features = false, features = [
+    "rt-tokio",
+    "behavior-version-latest"
+] }
 aws-credential-types = { path = "../../build/aws-sdk/sdk/aws-credential-types", features = ["hardcoded-credentials"] }
 aws-sdk-s3 = { path = "../../build/aws-sdk/sdk/s3", default-features = false }
 aws-smithy-http = { path = "../../build/aws-sdk/sdk/aws-smithy-http" }
 aws-smithy-runtime = { path = "../../build/aws-sdk/sdk/aws-smithy-runtime", features = ["client"] }
 aws-smithy-runtime-api = { path = "../../build/aws-sdk/sdk/aws-smithy-runtime-api", features = ["client"] }
 aws-smithy-types = { path = "../../build/aws-sdk/sdk/aws-smithy-types" }
-aws-types = { path = "../../build/aws-sdk/sdk/aws-types" }
-http = "0.2.8"
-tokio = { version = "1.24.2", features = ["macros", "rt"] }
-tower = "0.4.13"
+aws-smithy-wasm = { path = "../../build/aws-sdk/sdk/aws-smithy-wasm" }
+http = "0.2.9"
+tokio = { version = "1.32.0", features = ["macros", "rt"] }
+
+[target.'cfg(all(target_family = "wasm", target_os = "wasi"))'.dependencies]
+wit-bindgen = { version = "0.11.0", features = ["macros", "realloc"] }

aws/sdk/integration-tests/webassembly/src/default_config.rs

@@ -5,28 +5,22 @@
 
 use crate::http::WasmHttpConnector;
 use aws_config::retry::RetryConfig;
-use aws_credential_types::Credentials;
 use aws_smithy_types::timeout::TimeoutConfig;
-use aws_types::region::Region;
-use std::future::Future;
 
-pub(crate) fn get_default_config() -> impl Future<Output = aws_config::SdkConfig> {
+pub(crate) async fn get_default_config() -> aws_config::SdkConfig {
     aws_config::from_env()
-        .region(Region::from_static("us-west-2"))
-        .credentials_provider(Credentials::from_keys(
-            "access_key",
-            "secret_key",
-            Some("session_token".to_string()),
-        ))
+        .region("us-east-2")
         .timeout_config(TimeoutConfig::disabled())
         .retry_config(RetryConfig::disabled())
+        .no_credentials()
         .http_client(WasmHttpConnector::new())
         .load()
+        .await
 }
 
 #[tokio::test]
 pub async fn test_default_config() {
     let shared_config = get_default_config().await;
     let client = aws_sdk_s3::Client::new(&shared_config);
-    assert_eq!(client.config().region().unwrap().to_string(), "us-west-2")
+    assert_eq!(client.config().region().unwrap().to_string(), "us-east-2")
 }

aws/sdk/integration-tests/webassembly/src/lib.rs

@@ -3,11 +3,13 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
+#![allow(dead_code)]
+
+#[cfg(target_family = "wasm")]
 mod default_config;
+#[cfg(target_family = "wasm")]
 mod http;
-mod list_buckets;
-
-#[tokio::main(flavor = "current_thread")]
-pub async fn main() {
-    crate::list_buckets::s3_list_buckets().await
-}
+#[cfg(target_family = "wasm")]
+mod list_objects;
+#[cfg(all(target_family = "wasm", target_os = "wasi"))]
+mod wasi;

aws/sdk/integration-tests/webassembly/src/list_objects.rs

@@ -0,0 +1,31 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+use aws_sdk_s3::operation::list_objects_v2::ListObjectsV2Output;
+
+async fn s3_list_objects() -> ListObjectsV2Output {
+    use crate::default_config::get_default_config;
+    use aws_sdk_s3::Client;
+
+    let shared_config = get_default_config().await;
+    let client = Client::new(&shared_config);
+    let operation = client
+        .list_objects_v2()
+        .bucket("nara-national-archives-catalog")
+        .delimiter("/")
+        .prefix("authority-records/organization/")
+        .max_keys(5)
+        .customize()
+        .await
+        .unwrap();
+    operation.send().await.unwrap()
+}
+
+#[tokio::test]
+pub async fn test_s3_list_objects() {
+    let result = s3_list_objects().await;
+    let objects = result.contents();
+    assert!(objects.len() > 1);
+}

aws/sdk/integration-tests/webassembly/src/wasi.rs

@@ -0,0 +1,32 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+// Needed for WASI-compliant environment as it expects specific functions
+// to be exported such as `cabi_realloc`, `_start`, etc.
+
+wit_bindgen::generate!({
+    inline: "
+        package aws:component
+
+        interface run {
+            run: func() -> result
+        }
+
+        world main {
+            export run
+        }
+    ",
+    exports: {
+        "aws:component/run": Component
+    }
+});
+
+struct Component;
+
+impl exports::aws::component::run::Guest for Component {
+    fn run() -> Result<(), ()> {
+        Ok(())
+    }
+}

buildSrc/src/main/kotlin/CrateSet.kt

@@ -69,6 +69,7 @@ object CrateSet {
             "aws-smithy-runtime-api",
             "aws-smithy-types",
             "aws-smithy-types-convert",
+            "aws-smithy-wasm",
             "aws-smithy-xml",
         ).map { Crate(it, version(it)) }
 

rust-runtime/Cargo.toml

@@ -18,5 +18,6 @@ members = [
     "aws-smithy-runtime-api",
     "aws-smithy-types",
     "aws-smithy-types-convert",
+    "aws-smithy-wasm",
     "aws-smithy-xml",
 ]

rust-runtime/aws-smithy-wasm/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "aws-smithy-wasm"
+version = "0.0.0-smithy-rs-head"
+authors = [
+  "AWS Rust SDK Team <[email protected]>",
+  "Eduardo Rodrigues <[email protected]>",
+]
+description = "Smithy WebAssembly configuration for smithy-rs."
+edition = "2021"
+license = "Apache-2.0"
+repository = "https://github.com/awslabs/smithy-rs"
+
+[target.'cfg(all(target_family = "wasm", target_os = "wasi"))'.dependencies]
+aws-smithy-runtime-api = { path = "../aws-smithy-runtime-api" }
+aws-smithy-http = { path = "../aws-smithy-http" }
+bytes = "1"
+http = "0.2.4"
+tower = { version = "0.4.8" }
+tracing = "0.1"
+wasi-preview2-prototype = { version = "0.0.3", features = ["http-client"] }
+
+[package.metadata.docs.rs]
+all-features = true
+targets = ["x86_64-unknown-linux-gnu"]
+cargo-args = ["-Zunstable-options", "-Zrustdoc-scrape-examples"]
+rustdoc-args = ["--cfg", "docsrs"]
+# End of docs.rs metadata