Adapt unix scheme for sockets

Author: krzyzanowskim

Sources/AsyncHTTPClient/HTTPClient.swift

@@ -282,7 +282,7 @@ public class HTTPClient {
         }
 
         let eventLoopChannel: EventLoopFuture<Channel>
-        if request.scheme == "file", let baseURL = request.url.baseURL {
+        if request.scheme == "unix", let baseURL = request.url.baseURL {
             eventLoopChannel = bootstrap.connect(unixDomainSocketPath: baseURL.path)
         } else {
             let address = self.resolveAddress(request: request, proxy: self.configuration.proxy)

Sources/AsyncHTTPClient/HTTPHandler.swift

@@ -165,7 +165,7 @@ extension HTTPClient {
         ///     - `unsupportedScheme` if URL does contains unsupported HTTP scheme.
         ///     - `emptyHost` if URL does not contains a host.
         public init(url: URL, method: HTTPMethod = .GET, headers: HTTPHeaders = HTTPHeaders(), body: Body? = nil) throws {
-            if url.isFileURL {
+          if url.scheme?.lowercased() == "unix" {
                 self.value = try UnixDomainRequest(url: url, method: method, headers: headers, body: body)
             } else {
                 self.value = try HostRequest(url: url, method: method, headers: headers, body: body)
@@ -269,12 +269,12 @@ extension HTTPClient {
         ///     - `unsupportedScheme` if URL does contains unsupported HTTP scheme.
         ///     - `emptyHost` if URL does not contains a host.
         public init(url: URL, method: HTTPMethod = .GET, headers: HTTPHeaders = HTTPHeaders(), body: Body? = nil) throws {
-            guard url.isFileURL else {
-                throw HTTPClientError.invalidURL
+            guard let scheme = url.scheme?.lowercased() else {
+              throw HTTPClientError.emptyScheme
             }
 
-            guard let scheme = url.scheme?.lowercased() else {
-                throw HTTPClientError.emptyScheme
+            guard scheme == "unix" else {
+                throw HTTPClientError.invalidURL
             }
 
             self.method = method
@@ -286,7 +286,7 @@ extension HTTPClient {
         }
 
         static func isSchemeSupported(scheme: String) -> Bool {
-            return scheme == "file"
+            return scheme == "unix"
         }
 
     }

Tests/AsyncHTTPClientTests/HTTPClientTests.swift

@@ -48,7 +48,7 @@ class HTTPClientTests: XCTestCase {
         let request2 = try Request(url: "https://someserver.com")
         XCTAssertEqual(request2.url.path, "")
 
-        let request3 = try Request(url: "file:///tmp/file")
+        let request3 = try Request(url: "unix:///tmp/file")
         XCTAssertNil(request3.url.host)
         XCTAssertEqual(request3.host, "")
         XCTAssertEqual(request3.url.path, "/tmp/file")
@@ -70,7 +70,7 @@ class HTTPClientTests: XCTestCase {
 
     func testSchemaCasing() throws {
         XCTAssertNoThrow(try Request(url: "hTTpS://someserver.com:8888/some/path?foo=bar"))
-        XCTAssertNoThrow(try Request(url: "File://someserver.com:8888/some/path?foo=bar"))
+        XCTAssertNoThrow(try Request(url: "uNIx:///some/path"))
     }
 
     func testGet() throws {