rename .fixed to .known

Author: dnadoba

Sources/AsyncHTTPClient/AsyncAwait/HTTPClientRequest+Prepared.swift

@@ -63,9 +63,9 @@ extension RequestBodyLength {
     init(_ body: HTTPClientRequest.Body?) {
         switch body?.mode {
         case .none:
-            self = .fixed(0)
+            self = .known(0)
         case .byteBuffer(let buffer):
-            self = .fixed(buffer.readableBytes)
+            self = .known(buffer.readableBytes)
         case .sequence(let length, _, _), .asyncSequence(let length, _):
             self = length
         }

Sources/AsyncHTTPClient/AsyncAwait/HTTPClientRequest.swift

@@ -63,7 +63,7 @@ extension HTTPClientRequest.Body {
         _ bytes: Bytes
     ) -> Self where Bytes.Element == UInt8 {
         self.init(.sequence(
-            length: .fixed(bytes.count),
+            length: .known(bytes.count),
             canBeConsumedMultipleTimes: true
         ) { allocator in
             if let buffer = bytes.withContiguousStorageIfAvailable({ allocator.buffer(bytes: $0) }) {
@@ -161,8 +161,8 @@ extension HTTPClientRequest.Body {
         /// size of the request body is not known before starting the request
         public static let unknown: Self = .init(storage: .unknown)
         /// size of the request body is fixed and exactly `count` bytes
-        public static func fixed(_ count: Int) -> Self {
-            .init(storage: .fixed(count))
+        public static func known(_ count: Int) -> Self {
+            .init(storage: .known(count))
         }
 
         @usableFromInline

Sources/AsyncHTTPClient/ConnectionPool/RequestBodyLength.swift

@@ -18,5 +18,5 @@ internal enum RequestBodyLength: Hashable {
     /// size of the request body is not known before starting the request
     case unknown
     /// size of the request body is fixed and exactly `count` bytes
-    case fixed(_ count: Int)
+    case known(_ count: Int)
 }

Sources/AsyncHTTPClient/HTTPHandler.swift

@@ -683,13 +683,13 @@ internal struct RedirectHandler<ResponseType> {
 extension RequestBodyLength {
     init(_ body: HTTPClient.Body?) {
         guard let body = body else {
-            self = .fixed(0)
+            self = .known(0)
             return
         }
         guard let length = body.length else {
             self = .unknown
             return
         }
-        self = .fixed(length)
+        self = .known(length)
     }
 }

Sources/AsyncHTTPClient/RequestValidation.swift

@@ -24,9 +24,9 @@ extension HTTPHeaders {
 
         if case .TRACE = method {
             switch bodyLength {
-            case .fixed(0):
+            case .known(0):
                 break
-            case .unknown, .fixed:
+            case .unknown, .known:
                 // A client MUST NOT send a message body in a TRACE request.
                 // https://tools.ietf.org/html/rfc7230#section-4.3.8
                 throw HTTPClientError.traceRequestWithBody
@@ -39,7 +39,7 @@ extension HTTPHeaders {
         switch bodyLength {
         case .unknown:
             return .init(connectionClose: connectionClose, body: .stream)
-        case .fixed(let length):
+        case .known(let length):
             return .init(connectionClose: connectionClose, body: .fixedSize(length))
         }
     }
@@ -88,7 +88,7 @@ extension HTTPHeaders {
         self.remove(name: "Transfer-Encoding")
 
         switch bodyLength {
-        case .fixed(0):
+        case .known(0):
             // if we don't have a body we might not need to send the Content-Length field
             // https://tools.ietf.org/html/rfc7230#section-3.3.2
             switch method {
@@ -103,7 +103,7 @@ extension HTTPHeaders {
                 // for an enclosed payload body.
                 self.add(name: "Content-Length", value: "0")
             }
-        case .fixed(let length):
+        case .known(let length):
             self.add(name: "Content-Length", value: String(length))
         case .unknown:
             self.add(name: "Transfer-Encoding", value: "chunked")

Tests/AsyncHTTPClientTests/HTTPClientRequestTests.swift

@@ -334,7 +334,7 @@ class HTTPClientRequestTests: XCTestCase {
             request.method = .POST
 
             let sequence = AnySequence(ByteBuffer(string: "post body").readableBytesView)
-            request.body = .bytes(length: .fixed(9), sequence)
+            request.body = .bytes(length: .known(9), sequence)
             var preparedRequest: PreparedRequest?
             XCTAssertNoThrow(preparedRequest = try PreparedRequest(request))
             guard let preparedRequest = preparedRequest else { return }
@@ -452,7 +452,7 @@ class HTTPClientRequestTests: XCTestCase {
                 .asAsyncSequence()
                 .map { ByteBuffer($0) }
 
-            request.body = .stream(length: .fixed(9), asyncSequence)
+            request.body = .stream(length: .known(9), asyncSequence)
             var preparedRequest: PreparedRequest?
             XCTAssertNoThrow(preparedRequest = try PreparedRequest(request))
             guard let preparedRequest = preparedRequest else { return }
@@ -500,7 +500,7 @@ extension Optional where Wrapped == HTTPClientRequest.Body {
             return buffer
         case .sequence(let announcedLength, _, let generate):
             let buffer = generate(ByteBufferAllocator())
-            if case .fixed(let announcedLength) = announcedLength,
+            if case .known(let announcedLength) = announcedLength,
                announcedLength != buffer.readableBytes {
                 throw LengthMismatch(announcedLength: announcedLength, actualLength: buffer.readableBytes)
             }
@@ -510,7 +510,7 @@ extension Optional where Wrapped == HTTPClientRequest.Body {
             while var buffer = try await generate(ByteBufferAllocator()) {
                 accumulatedBuffer.writeBuffer(&buffer)
             }
-            if case .fixed(let announcedLength) = announcedLength,
+            if case .known(let announcedLength) = announcedLength,
                announcedLength != accumulatedBuffer.readableBytes {
                 throw LengthMismatch(announcedLength: announcedLength, actualLength: accumulatedBuffer.readableBytes)
             }