Run generate_linux_tests.rb and SwiftFormat

Author: dnadoba

Sources/AsyncHTTPClient/HTTPHandler.swift

@@ -356,7 +356,7 @@ extension HTTPClient {
 ///
 /// This ``HTTPClientResponseDelegate`` buffers a complete HTTP response in memory. It does not stream the response body in.
 /// The resulting ``Response`` type is ``HTTPClient/Response``.
-final public class ResponseAccumulator: HTTPClientResponseDelegate {
+public final class ResponseAccumulator: HTTPClientResponseDelegate {
     public typealias Response = HTTPClient.Response
 
     enum State {
@@ -366,29 +366,29 @@ final public class ResponseAccumulator: HTTPClientResponseDelegate {
         case end
         case error(Error)
     }
-    
+
     public struct ResponseTooBigError: Error, CustomStringConvertible {
         var maxBodySize: Int
-        
+
         public var description: String {
-            return "ResponseTooBigError: received response body exceeds maximum accepted size of \(maxBodySize) bytes"
+            return "ResponseTooBigError: received response body exceeds maximum accepted size of \(self.maxBodySize) bytes"
         }
     }
 
     var state = State.idle
     let request: HTTPClient.Request
-    
+
     static let maxByteBufferSize = Int(UInt32.max)
-    
+
     /// Maximum size in bytes of the HTTP response body that ``ResponseAccumulator`` will accept
     /// until it will abort the request and throw an ``ResponseTooBigError``.
-    /// 
+    ///
     /// Default is 2^32.
     /// - precondition: not allowed to exceed 2^32 because ``ByteBuffer`` can not store more bytes
     public var maxBodySize: Int = maxByteBufferSize {
         didSet {
             precondition(
-                maxBodySize <= Self.maxByteBufferSize,
+                self.maxBodySize <= Self.maxByteBufferSize,
                 "maxBodyLength is not allowed to exceed 2^32 because ByteBuffer can not store more bytes"
             )
         }
@@ -408,7 +408,7 @@ final public class ResponseAccumulator: HTTPClientResponseDelegate {
                 self.state = .error(error)
                 return task.eventLoop.makeFailedFuture(error)
             }
-                
+
             self.state = .head(head)
         case .head:
             preconditionFailure("head already set")
@@ -440,7 +440,7 @@ final public class ResponseAccumulator: HTTPClientResponseDelegate {
                 self.state = .error(error)
                 return task.eventLoop.makeFailedFuture(error)
             }
-            
+
             // The compiler can't prove that `self.state` is dead here (and it kinda isn't, there's
             // a cross-module call in the way) so we need to drop the original reference to `body` in
             // `self.state` or we'll get a CoW. To fix that we temporarily set the state to `.end` (which

Tests/AsyncHTTPClientTests/HTTPClientTestUtils.swift

@@ -365,8 +365,7 @@ internal final class HTTPBin<RequestHandler: ChannelInboundHandler> where
     var socketAddress: SocketAddress {
         return self.serverChannel.localAddress!
     }
-    
-        
+
     var baseURL: String {
         let scheme: String = {
             switch mode {

Tests/AsyncHTTPClientTests/HTTPClientTests+XCTest.swift

@@ -132,6 +132,10 @@ extension HTTPClientTests {
             ("testSSLHandshakeErrorPropagationDelayedClose", testSSLHandshakeErrorPropagationDelayedClose),
             ("testWeCloseConnectionsWhenConnectionCloseSetByServer", testWeCloseConnectionsWhenConnectionCloseSetByServer),
             ("testBiDirectionalStreaming", testBiDirectionalStreaming),
+            ("testResponseAccumulatorMaxBodySizeLimitExceedingWithContentLength", testResponseAccumulatorMaxBodySizeLimitExceedingWithContentLength),
+            ("testResponseAccumulatorMaxBodySizeLimitNotExceedingWithContentLength", testResponseAccumulatorMaxBodySizeLimitNotExceedingWithContentLength),
+            ("testResponseAccumulatorMaxBodySizeLimitExceedingWithTransferEncodingChuncked", testResponseAccumulatorMaxBodySizeLimitExceedingWithTransferEncodingChuncked),
+            ("testResponseAccumulatorMaxBodySizeLimitNotExceedingWithTransferEncodingChuncked", testResponseAccumulatorMaxBodySizeLimitNotExceedingWithTransferEncodingChuncked),
             ("testBiDirectionalStreamingEarly200", testBiDirectionalStreamingEarly200),
             ("testBiDirectionalStreamingEarly200DoesntPreventUsFromSendingMoreRequests", testBiDirectionalStreamingEarly200DoesntPreventUsFromSendingMoreRequests),
             ("testCloseConnectionAfterEarly2XXWhenStreaming", testCloseConnectionAfterEarly2XXWhenStreaming),

Tests/AsyncHTTPClientTests/HTTPClientTests.swift

@@ -3091,13 +3091,13 @@ class HTTPClientTests: XCTestCase {
         XCTAssertNoThrow(try future.wait())
         XCTAssertNil(try delegate.next().wait())
     }
-    
+
     func testResponseAccumulatorMaxBodySizeLimitExceedingWithContentLength() throws {
         let httpBin = HTTPBin(.http1_1(ssl: false, compress: false)) { _ in HTTPEchoHandler() }
         defer { XCTAssertNoThrow(try httpBin.shutdown()) }
-        
+
         let body = ByteBuffer(bytes: 0..<11)
-        
+
         var request = try Request(url: httpBin.baseURL)
         request.body = .byteBuffer(body)
         let delegate = ResponseAccumulator(request: request)
@@ -3109,13 +3109,13 @@ class HTTPClientTests: XCTestCase {
             XCTAssertTrue(error is ResponseAccumulator.ResponseTooBigError, "unexpected error \(error)")
         }
     }
-    
+
     func testResponseAccumulatorMaxBodySizeLimitNotExceedingWithContentLength() throws {
         let httpBin = HTTPBin(.http1_1(ssl: false, compress: false)) { _ in HTTPEchoHandler() }
         defer { XCTAssertNoThrow(try httpBin.shutdown()) }
-        
+
         let body = ByteBuffer(bytes: 0..<10)
-        
+
         var request = try Request(url: httpBin.baseURL)
         request.body = .byteBuffer(body)
         let delegate = ResponseAccumulator(request: request)
@@ -3124,16 +3124,16 @@ class HTTPClientTests: XCTestCase {
             request: request,
             delegate: delegate
         ).wait()
-        
+
         XCTAssertEqual(response.body, body)
     }
-    
+
     func testResponseAccumulatorMaxBodySizeLimitExceedingWithTransferEncodingChuncked() throws {
         let httpBin = HTTPBin(.http1_1(ssl: false, compress: false)) { _ in HTTPEchoHandler() }
         defer { XCTAssertNoThrow(try httpBin.shutdown()) }
-        
+
         let body = ByteBuffer(bytes: 0..<11)
-        
+
         var request = try Request(url: httpBin.baseURL)
         request.body = .stream { writer in
             writer.write(.byteBuffer(body))
@@ -3147,13 +3147,13 @@ class HTTPClientTests: XCTestCase {
             XCTAssertTrue(error is ResponseAccumulator.ResponseTooBigError, "unexpected error \(error)")
         }
     }
-    
+
     func testResponseAccumulatorMaxBodySizeLimitNotExceedingWithTransferEncodingChuncked() throws {
         let httpBin = HTTPBin(.http1_1(ssl: false, compress: false)) { _ in HTTPEchoHandler() }
         defer { XCTAssertNoThrow(try httpBin.shutdown()) }
-        
+
         let body = ByteBuffer(bytes: 0..<10)
-        
+
         var request = try Request(url: httpBin.baseURL)
         request.body = .stream { writer in
             writer.write(.byteBuffer(body))
@@ -3164,7 +3164,7 @@ class HTTPClientTests: XCTestCase {
             request: request,
             delegate: delegate
         ).wait()
-        
+
         XCTAssertEqual(response.body, body)
     }