Feature: Add smithy orchestrator

aws/sdk/integration-tests/Cargo.toml

@@ -2,6 +2,7 @@
 # `./gradlew -Paws.fullsdk=true :aws:sdk:assemble` these tests are copied into their respective Service crates.
 [workspace]
 members = [
+    "aws-smithy-runtime-test",
     "dynamodb",
     "ec2",
     "glacier",

aws/sdk/integration-tests/aws-smithy-runtime-test/Cargo.toml

@@ -0,0 +1,25 @@
+[package]
+name = "aws-smithy-runtime-test"
+version = "0.1.0"
+edition = "2021"
+publish = false
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+aws-credential-types = { path = "../../build/aws-sdk/sdk/aws-credential-types", features = ["test-util"] }
+aws-config = { path = "../../build/aws-sdk/sdk/aws-config" }
+aws-http = { path = "../../build/aws-sdk/sdk/aws-http" }
+aws-sigv4 = { path = "../../build/aws-sdk/sdk/aws-sigv4" }
+aws-sdk-s3 = { path = "../../build/aws-sdk/sdk/s3" }
+aws-smithy-async = { path = "../../build/aws-sdk/sdk/aws-smithy-async", features = ["rt-tokio"] }
+aws-smithy-client = { path = "../../build/aws-sdk/sdk/aws-smithy-client" }
+aws-smithy-types = { path = "../../build/aws-sdk/sdk/aws-smithy-types" }
+aws-smithy-http = { path = "../../build/aws-sdk/sdk/aws-smithy-http" }
+aws-smithy-runtime = { path = "../../build/aws-sdk/sdk/aws-smithy-runtime" }
+aws-smithy-runtime-api = { path = "../../build/aws-sdk/sdk/aws-smithy-runtime-api" }
+aws-types = { path = "../../build/aws-sdk/sdk/aws-types" }
+tokio = { version = "1.8.4", features = ["macros", "test-util", "rt-multi-thread"] }
+tracing = "0.1.37"
+tracing-subscriber = { version = "0.3.15", features = ["env-filter", "json"] }
+http = "0.2.3"
+http-body = "0.4.5"

aws/sdk/integration-tests/aws-smithy-runtime-test/src/auth.rs

@@ -0,0 +1,55 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+use aws_smithy_http::body::SdkBody;
+use aws_smithy_runtime::{AuthOrchestrator, BoxError, ConfigBag};
+
+#[derive(Debug)]
+pub struct GetObjectAuthOrc {}
+
+impl GetObjectAuthOrc {
+    pub fn _new() -> Self {
+        Self {}
+    }
+}
+
+impl AuthOrchestrator<http::Request<SdkBody>> for GetObjectAuthOrc {
+    fn auth_request(
+        &self,
+        _req: &mut http::Request<SdkBody>,
+        _cfg: &ConfigBag,
+    ) -> Result<(), BoxError> {
+        todo!()
+    }
+}
+
+//     signer: Arc::new(|req: &mut http::Request<SdkBody>, props: &PropertyBag| {
+//         use aws_smithy_orchestrator::auth::error::Error;
+//
+//         let signer = SigV4Signer::new();
+//         let operation_config = props
+//             .get::<OperationSigningConfig>()
+//             .ok_or(Error::SignRequest("missing signing config".into()))?;
+//
+//         let (operation_config, request_config, creds) = match &operation_config
+//             .signing_requirements
+//         {
+//             SigningRequirements::Disabled => return Ok(()),
+//             SigningRequirements::Optional => {
+//                 match aws_sig_auth::middleware::signing_config(props) {
+//                     Ok(parts) => parts,
+//                     Err(_) => return Ok(()),
+//                 }
+//             }
+//             SigningRequirements::Required => aws_sig_auth::middleware::signing_config(props)
+//                 .map_err(|err| Error::SignRequest(Box::new(err)))?,
+//         };
+//
+//         let _signature = signer
+//             .sign(&operation_config, &request_config, &creds, req)
+//             .expect("signing goes just fine");
+//
+//         Ok(())
+//     }),

aws/sdk/integration-tests/aws-smithy-runtime-test/src/conn.rs

@@ -0,0 +1,33 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+use aws_smithy_client::conns::Https;
+use aws_smithy_client::hyper_ext::Adapter;
+use aws_smithy_http::body::SdkBody;
+use aws_smithy_runtime::{BoxFallibleFut, ConfigBag, Connection};
+
+#[derive(Debug)]
+pub struct HyperConnection {
+    _adapter: Adapter<Https>,
+}
+
+impl HyperConnection {
+    pub fn _new() -> Self {
+        Self {
+            _adapter: Adapter::builder().build(aws_smithy_client::conns::https()),
+        }
+    }
+}
+
+impl Connection<http::Request<SdkBody>, http::Response<SdkBody>> for HyperConnection {
+    fn call(
+        &self,
+        _req: &mut http::Request<SdkBody>,
+        _cfg: &ConfigBag,
+    ) -> BoxFallibleFut<http::Response<SdkBody>> {
+        todo!("hyper's connector wants to take ownership of req");
+        // self.adapter.call(req)
+    }
+}