Use NIOTSConnectionBootstrap(validatingGroup:)

Author: adam-fowler

Package.swift

@@ -21,10 +21,10 @@ let package = Package(
         .library(name: "AsyncHTTPClient", targets: ["AsyncHTTPClient"]),
     ],
     dependencies: [
-        .package(url: "https://github.com/apple/swift-nio.git", from: "2.13.1"),
+        .package(url: "https://github.com/apple/swift-nio.git", from: "2.16.0"),
         .package(url: "https://github.com/apple/swift-nio-ssl.git", from: "2.7.0"),
         .package(url: "https://github.com/apple/swift-nio-extras.git", from: "1.3.0"),
-        .package(url: "https://github.com/adam-fowler/swift-nio-transport-services.git", .branch("public-niots-eventloop")),
+        .package(url: "https://github.com/apple/swift-nio-transport-services.git", from: "1.5.1"),
     ],
     targets: [
         .target(

Sources/AsyncHTTPClient/Utils.swift

@@ -53,8 +53,7 @@ public final class HTTPClientCopyingDelegate: HTTPClientResponseDelegate {
 }
 
 extension ClientBootstrap {
-    fileprivate static func makeBootstrap(
-        on eventLoop: EventLoop,
+    fileprivate func makeClientTCPBootstrap(
         host: String,
         requiresTLS: Bool,
         configuration: HTTPClient.Configuration
@@ -63,7 +62,7 @@ extension ClientBootstrap {
         let sslContext = try NIOSSLContext(configuration: tlsConfiguration)
         let hostname = (!requiresTLS || host.isIPAddress) ? nil : host
         let tlsProvider = try NIOSSLClientTLSProvider<ClientBootstrap>(context: sslContext, serverHostname: hostname)
-        return NIOClientTCPBootstrap(ClientBootstrap(group: eventLoop), tls: tlsProvider)
+        return NIOClientTCPBootstrap(self, tls: tlsProvider)
     }
 }
 
@@ -79,10 +78,11 @@ extension NIOClientTCPBootstrap {
         let bootstrap: NIOClientTCPBootstrap
         #if canImport(Network)
         // if eventLoop is compatible with NIOTransportServices create a NIOTSConnectionBootstrap
-        if #available(OSX 10.14, iOS 12.0, tvOS 12.0, watchOS 6.0, *), eventLoop is NIOTSEventLoop {
-            let tsBootstrap = NIOTSConnectionBootstrap(group: eventLoop).channelOption(NIOTSChannelOptions.waitForActivity, value: false)
-            let tlsConfiguration = configuration.tlsConfiguration ?? TLSConfiguration.forClient()
+        if #available(OSX 10.14, iOS 12.0, tvOS 12.0, watchOS 6.0, *),
+            var tsBootstrap = NIOTSConnectionBootstrap(validatingGroup: eventLoop) {
 
+            tsBootstrap = tsBootstrap.channelOption(NIOTSChannelOptions.waitForActivity, value: false)
+            let tlsConfiguration = configuration.tlsConfiguration ?? TLSConfiguration.forClient()
             // if we have a proxy and require TLS then use NIOSSL tls support
             if configuration.proxy != nil, requiresTLS {
                 let sslContext = try NIOSSLContext(configuration: tlsConfiguration)
@@ -94,13 +94,19 @@ extension NIOClientTCPBootstrap {
                 let tlsProvider = NIOTSClientTLSProvider(tlsOptions: parameters)
                 bootstrap = NIOClientTCPBootstrap(tsBootstrap, tls: tlsProvider)
             }
+        } else if let clientBootstrap = ClientBootstrap(validatingGroup: eventLoop) {
+            bootstrap = try clientBootstrap.makeClientTCPBootstrap(host: host, requiresTLS: requiresTLS, configuration: configuration)
         } else {
-            bootstrap = try ClientBootstrap.makeBootstrap(on: eventLoop, host: host, requiresTLS: requiresTLS, configuration: configuration)
+            preconditionFailure("Cannot create bootstrap for the supplied EventLoop")
         }
         #else
-        bootstrap = try ClientBootstrap.makeBootstrap(on: eventLoop, host: host, requiresTLS: requiresTLS, configuration: configuration)
+        if let clientBootstrap = ClientBootstrap(validatingGroup: eventLoop) {
+            bootstrap = try clientBootstrap.makeClientTCPBootstrap(host: host, requiresTLS: requiresTLS, configuration: configuration)
+        } else {
+            preconditionFailure("Cannot create bootstrap for the supplied EventLoop")
+        }
         #endif
-
+        
         // don't enable TLS if we have a proxy, this will be enabled later on
         if requiresTLS, configuration.proxy == nil {
             return bootstrap.enableTLS()

Tests/AsyncHTTPClientTests/HTTPClientTests.swift

@@ -1679,13 +1679,15 @@ class HTTPClientTests: XCTestCase {
         }
 
         XCTAssertThrowsError(try httpClient.get(url: "http://localhost:\(port)").wait()) { error in
+            #if canImport(Network)
             if isTestingNIOTS() {
-                guard let ioError = error as? IOError, ioError.errnoCode == ECONNREFUSED else {
+                guard let ioError = error as? NWPOSIXError, ioError.errorCode == .ECONNREFUSED else {
                     XCTFail("Unexpected error: \(error)")
                     return
                 }
                 return
             }
+            #endif
             guard error is NIOConnectionError else {
                 XCTFail("Unexpected error: \(error)")
                 return