feat: Add NIOHTTPClient based on async-http-client and SwiftNIO (#995)

Author: dayaffe

Package.swift

@@ -53,12 +53,16 @@ let package = Package(
         .library(name: "SmithyCBOR", targets: ["SmithyCBOR"]),
         .library(name: "SmithyWaitersAPI", targets: ["SmithyWaitersAPI"]),
         .library(name: "SmithyTestUtil", targets: ["SmithyTestUtil"]),
+        .library(name: "SmithySwiftNIO", targets: ["SmithySwiftNIO"]),
+        .library(name: "SmithyTelemetryAPI", targets: ["SmithyTelemetryAPI"]),
+        .library(name: "SmithyHTTPClientAPI", targets: ["SmithyHTTPClientAPI"]),
     ],
     dependencies: {
         var dependencies: [Package.Dependency] = [
             .package(url: "https://github.com/awslabs/aws-crt-swift.git", exact: "0.54.2"),
             .package(url: "https://github.com/apple/swift-log.git", from: "1.0.0"),
             .package(url: "https://github.com/open-telemetry/opentelemetry-swift", from: "1.13.0"),
+            .package(url: "https://github.com/swift-server/async-http-client.git", from: "1.22.0"),
         ]
 
         let isDocCEnabled = ProcessInfo.processInfo.environment["AWS_SWIFT_SDK_ENABLE_DOCC"] != nil
@@ -74,10 +78,26 @@ let package = Package(
                 .product(name: "Logging", package: "swift-log"),
             ]
         ),
+        .target(
+            name: "SmithyTelemetryAPI",
+            dependencies: [
+                "Smithy",
+            ]
+        ),
+        .target(
+            name: "SmithyHTTPClientAPI",
+            dependencies: [
+                "Smithy",
+                "SmithyHTTPAPI",
+                "SmithyTelemetryAPI",
+            ]
+        ),
         .target(
             name: "ClientRuntime",
             dependencies: [
                 "Smithy",
+                "SmithyTelemetryAPI",
+                "SmithyHTTPClientAPI",
                 "SmithyRetriesAPI",
                 "SmithyRetries",
                 "SmithyXML",
@@ -123,6 +143,17 @@ let package = Package(
                 .copy("PrivacyInfo.xcprivacy")
             ]
         ),
+        .target(
+            name: "SmithySwiftNIO",
+            dependencies: [
+                "Smithy",
+                "SmithyHTTPAPI",
+                "SmithyStreams",
+                "SmithyHTTPClientAPI",
+                .product(name: "AsyncHTTPClient", package: "async-http-client"),
+            ],
+            path: "Sources/SmithySwiftNIO"
+        ),
         .target(
             name: "SmithyRetriesAPI"
         ),
@@ -268,6 +299,13 @@ let package = Package(
             ],
             resources: [ .process("Resources") ]
         ),
+        .testTarget(
+            name: "SmithySwiftNIOTests",
+            dependencies: [
+                "SmithySwiftNIO",
+                "SmithyTestUtil",
+            ]
+        ),
         .testTarget(
             name: "SmithyCBORTests",
             dependencies: ["SmithyCBOR", "ClientRuntime", "SmithyTestUtil"]

Sources/ClientRuntime/Config/DefaultSDKRuntimeConfiguration.swift

@@ -13,6 +13,7 @@ import protocol SmithyHTTPAuthAPI.AuthSchemeResolver
 import protocol SmithyHTTPAuthAPI.AuthSchemeResolverParameters
 import struct SmithyRetries.DefaultRetryStrategy
 import struct SmithyRetries.ExponentialBackoffStrategy
+import SmithyTelemetryAPI
 import protocol SmithyRetriesAPI.RetryErrorInfoProvider
 import protocol SmithyRetriesAPI.RetryStrategy
 import struct SmithyRetriesAPI.RetryStrategyOptions

Sources/ClientRuntime/Networking/Http/CRT/CRTClientEngine.swift

@@ -19,7 +19,10 @@ import protocol SmithyHTTPAPI.HTTPClient
 import class SmithyHTTPAPI.HTTPRequest
 import class SmithyHTTPAPI.HTTPResponse
 import enum SmithyHTTPAPI.HTTPStatusCode
+import class SmithyHTTPClientAPI.HttpTelemetry
+import enum SmithyHTTPClientAPI.HttpMetricsAttributesKeys
 import class SmithyStreams.BufferedStream
+import SmithyTelemetryAPI
 #if os(Linux)
 import Glibc
 #elseif !os(Windows)

Sources/ClientRuntime/Networking/Http/CRT/CRTClientEngineConfig.swift

@@ -3,6 +3,8 @@
  * SPDX-License-Identifier: Apache-2.0.
  */
 
+import class SmithyHTTPClientAPI.HttpTelemetry
+
 struct CRTClientEngineConfig: Sendable {
 
     /// Max connections the manager can contain per endpoint

Sources/ClientRuntime/Networking/Http/CRT/HTTP2Stream+ByteStream.swift

@@ -8,6 +8,8 @@
 import AwsCommonRuntimeKit
 import struct Smithy.Attributes
 import enum Smithy.ByteStream
+import class SmithyHTTPClientAPI.HttpTelemetry
+import enum SmithyHTTPClientAPI.HttpMetricsAttributesKeys
 
 extension HTTP2Stream {
     /// Returns the recommended size, in bytes, for the data to write

Sources/ClientRuntime/Networking/Http/HttpClientConfiguration.swift

@@ -5,87 +5,8 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
-import AwsCommonRuntimeKit
-import struct Foundation.TimeInterval
-import enum Smithy.URIScheme
-import struct SmithyHTTPAPI.Headers
+import SmithyHTTPClientAPI
 
-public class HttpClientConfiguration {
-
-    /// The timeout for establishing a connection, in seconds.
-    ///
-    /// If none is provided, the client will use default values based on the platform.
-    public var connectTimeout: TimeInterval?
-
-    /// The timeout for socket, in seconds.
-    /// Sets maximum time to wait between two data packets.
-    /// Used to close stale connections that have no activity.
-    ///
-    /// Defaults to 60 seconds if no value is provided.
-    public var socketTimeout: TimeInterval
-
-    /// HTTP headers to be submitted with every HTTP request.
-    ///
-    /// If none is provided, defaults to no extra headers.
-    public var defaultHeaders: Headers
-
-    /// The maximum connections the HTTP client makes per host or per endpoint depending on the OS.
-    ///
-    /// For Apple platforms, it will be per host.
-    /// For Linux, it will be per endpoint (protocol + host + port).
-    public var maxConnections: Int
-
-    // add any other properties here you want to give the service operations
-    // control over to be mapped to the Http Client
-
-    /// The URL scheme to be used for HTTP requests.  Supported values are `http` and `https`.
-    ///
-    /// If none is provided, the default protocol for the operation will be used
-    public var protocolType: URIScheme?
-
-    /// Custom TLS configuration for HTTPS connections.
-    ///
-    /// Enables specifying client certificates and trust stores for secure communication.
-    /// Defaults to system's TLS settings if `nil`.
-    public var tlsConfiguration: (any TLSConfiguration)?
-
-    /// HTTP Client Telemetry
-    public var telemetry: HttpTelemetry?
-
-    /// Creates a configuration object for a SDK HTTP client.
-    ///
-    /// Not all configuration settings may be followed by all clients.
-    /// - Parameters:
-    ///   - connectTimeout: The maximum time to wait for a connection to be established.
-    ///   - socketTimeout: The maximum time to wait between data packets.
-    ///   - defaultHeaders: HTTP headers to be included with every HTTP request.
-    ///   Note that certain headers may cause your API request to fail.  Defaults to no headers.
-    ///   - protocolType: The HTTP scheme (`http` or `https`) to be used for API requests.  Defaults to the operation's standard configuration.
-    ///   - tlsConfiguration: Optional custom TLS configuration for HTTPS requests. If `nil`, defaults to a standard configuration.
-    ///   - maxConnections: The maximum number of connections the HTTP client makes per host (for Apple platforms) or per endpoint (for Linux). For non-mac Apple platforms, defaults to 6. For macOS and Linux, defaults to 50.
-    public init(
-        connectTimeout: TimeInterval? = nil,
-        socketTimeout: TimeInterval = 60.0,
-        protocolType: URIScheme = .https,
-        defaultHeaders: Headers = Headers(),
-        tlsConfiguration: (any TLSConfiguration)? = nil,
-        telemetry: HttpTelemetry? = nil,
-        maxConnections: Int? = nil
-    ) {
-        self.socketTimeout = socketTimeout
-        self.protocolType = protocolType
-        self.defaultHeaders = defaultHeaders
-        self.connectTimeout = connectTimeout
-        self.tlsConfiguration = tlsConfiguration
-        self.telemetry = telemetry
-        if let maxConnections {
-            self.maxConnections = maxConnections
-        } else {
-            #if os(macOS) || os(Linux)
-            self.maxConnections = 50
-            #else // iOS, ipadOS, watchOS, tvOS.
-            self.maxConnections = 6 // URLSession default.
-            #endif
-        }
-    }
-}
+/// Typealias for backward compatibility.
+/// The actual implementation is now in SmithyHTTPClientAPI.
+public typealias HttpClientConfiguration = SmithyHTTPClientAPI.HTTPClientConfiguration

Sources/ClientRuntime/Networking/Http/TLSConfiguration.swift

@@ -0,0 +1,12 @@
+//
+// Copyright Amazon.com Inc. or its affiliates.
+// All Rights Reserved.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+import SmithyHTTPClientAPI
+
+/// Typealias for backward compatibility.
+/// The actual implementation is now in SmithyHTTPClientAPI.
+public typealias TLSConfiguration = SmithyHTTPClientAPI.TLSConfiguration

Sources/ClientRuntime/Networking/Http/URLSession/FoundationStreamBridge.swift

@@ -13,6 +13,8 @@ import class Foundation.DispatchQueue
 import class Foundation.InputStream
 import class Foundation.NSObject
 import class Foundation.OutputStream
+import class SmithyHTTPClientAPI.HttpTelemetry
+import enum SmithyHTTPClientAPI.HttpMetricsAttributesKeys
 import class Foundation.RunLoop
 import class Foundation.Stream
 import protocol Foundation.StreamDelegate

Sources/ClientRuntime/Networking/Http/URLSession/URLSessionHTTPClient.swift

@@ -18,6 +18,8 @@ import class Foundation.NSRecursiveLock
 import var Foundation.NSURLAuthenticationMethodClientCertificate
 import var Foundation.NSURLAuthenticationMethodServerTrust
 import struct Foundation.TimeInterval
+import class SmithyHTTPClientAPI.HttpTelemetry
+import enum SmithyHTTPClientAPI.HttpMetricsAttributesKeys
 import class Foundation.URLAuthenticationChallenge
 import struct Foundation.URLComponents
 import class Foundation.URLCredential
@@ -27,6 +29,7 @@ import class Foundation.URLResponse
 import class Foundation.URLSession
 import class Foundation.URLSessionConfiguration
 import protocol Foundation.URLSessionDataDelegate
+import SmithyTelemetryAPI
 import class Foundation.URLSessionDataTask
 import class Foundation.URLSessionTask
 import class Foundation.URLSessionTaskMetrics

Sources/ClientRuntime/Plugins/TelemetryPlugin.swift

@@ -5,6 +5,8 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
+import SmithyTelemetryAPI
+
 public class TelemetryPlugin: Plugin {
     private let telemetryProvider: TelemetryProvider