feat: Add support for flexible checksums on streaming payloads

Package.swift

@@ -34,7 +34,7 @@ let package = Package(
         .library(name: "SmithyTestUtil", targets: ["SmithyTestUtil"]),
     ],
     dependencies: [
-        .package(url: "https://github.com/awslabs/aws-crt-swift.git", exact: "0.26.0"),
+        .package(url: "https://github.com/awslabs/aws-crt-swift.git", exact: "0.28.0"),
         .package(url: "https://github.com/apple/swift-log.git", from: "1.0.0"),
     ],
     targets: [

Sources/ClientRuntime/Networking/AwsChunked/AwsChunkedBufferedStream.swift

@@ -0,0 +1,95 @@
+//
+// Copyright Amazon.com Inc. or its affiliates.
+// All Rights Reserved.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+import AwsCommonRuntimeKit
+
+class AwsChunkedBufferedStream {
+    private var stream: BufferedStream
+    private var signingConfig: SigningConfig
+    private var previousSignature: String
+    private var trailingHeaders: Headers
+    private var chunkedReader: AwsChunkedReader
+
+    init(stream: BufferedStream, signingConfig: SigningConfig, previousSignature: String, trailingHeaders: Headers, checksumAlgorithm: HashFunction? = nil) {
+        self.stream = stream
+        self.signingConfig = signingConfig
+        self.previousSignature = previousSignature
+        self.trailingHeaders = trailingHeaders
+
+        self.chunkedReader = AwsChunkedReader(
+            stream: self.stream,
+            signingConfig: self.signingConfig,
+            previousSignature: self.previousSignature,
+            trailingHeaders: self.trailingHeaders,
+            checksum: checksumAlgorithm
+        )
+    }
+}
+
+extension AwsChunkedBufferedStream: Stream {
+
+    var position: Data.Index {
+        self.stream.position
+    }
+
+    var length: Int? {
+        self.stream.length
+    }
+
+    var isEmpty: Bool {
+        self.stream.isEmpty
+    }
+
+    var isSeekable: Bool {
+        self.stream.isSeekable
+    }
+
+    func read(upToCount count: Int) throws -> Data? {
+        try self.stream.read(upToCount: count)
+    }
+
+    func readAsync(upToCount count: Int) async throws -> Data? {
+        try await self.stream.readAsync(upToCount: count)
+    }
+
+    func readToEnd() throws -> Data? {
+        try self.stream.readToEnd()
+    }
+
+    func readToEndAsync() async throws -> Data? {
+        try await self.stream.readToEndAsync()
+    }
+
+    func write(contentsOf data: Data) throws {
+        try self.stream.write(contentsOf: data)
+    }
+
+    func close() {
+        self.stream.close()
+    }
+
+    func closeWithError(_ error: Error) {
+        self.stream.closeWithError(error)
+    }
+
+}
+
+extension AwsChunkedBufferedStream: AwsChunkedStream {
+
+    func getChunkedReader() -> AwsChunkedReader {
+        return self.chunkedReader
+    }
+
+    var checksumAlgorithm: HashFunction? {
+        get {
+            return self.chunkedReader.getChecksumAlgorithm()
+        }
+        set {
+            self.chunkedReader.setChecksumAlgorithm(checksum: newValue)
+        }
+    }
+}

Sources/ClientRuntime/Networking/AwsChunked/AwsChunkedFileStream.swift

@@ -0,0 +1,95 @@
+//
+// Copyright Amazon.com Inc. or its affiliates.
+// All Rights Reserved.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+import AwsCommonRuntimeKit
+
+class AwsChunkedFileStream {
+    private var stream: FileStream
+    private var signingConfig: SigningConfig
+    private var previousSignature: String
+    private var trailingHeaders: Headers
+    private var chunkedReader: AwsChunkedReader
+
+    init(stream: FileStream, signingConfig: SigningConfig, previousSignature: String, trailingHeaders: Headers, checksumAlgorithm: HashFunction? = nil) {
+        self.stream = stream
+        self.signingConfig = signingConfig
+        self.previousSignature = previousSignature
+        self.trailingHeaders = trailingHeaders
+
+        self.chunkedReader = AwsChunkedReader(
+            stream: self.stream,
+            signingConfig: self.signingConfig,
+            previousSignature: self.previousSignature,
+            trailingHeaders: self.trailingHeaders,
+            checksum: checksumAlgorithm
+        )
+    }
+}
+
+extension AwsChunkedFileStream: Stream {
+
+    var position: Data.Index {
+        self.stream.position
+    }
+
+    var length: Int? {
+        self.stream.length
+    }
+
+    var isEmpty: Bool {
+        self.stream.isEmpty
+    }
+
+    var isSeekable: Bool {
+        self.stream.isSeekable
+    }
+
+    func read(upToCount count: Int) throws -> Data? {
+        try self.stream.read(upToCount: count)
+    }
+
+    func readAsync(upToCount count: Int) async throws -> Data? {
+        try await self.stream.readAsync(upToCount: count)
+    }
+
+    func readToEnd() throws -> Data? {
+        try self.stream.readToEnd()
+    }
+
+    func readToEndAsync() async throws -> Data? {
+        try await self.stream.readToEndAsync()
+    }
+
+    func write(contentsOf data: Data) throws {
+        try self.stream.write(contentsOf: data)
+    }
+
+    func close() {
+        self.stream.close()
+    }
+
+    func closeWithError(_ error: Error) {
+        self.stream.closeWithError(error)
+    }
+
+}
+
+extension AwsChunkedFileStream: AwsChunkedStream {
+
+    func getChunkedReader() -> AwsChunkedReader {
+        return self.chunkedReader
+    }
+
+    var checksumAlgorithm: HashFunction? {
+        get {
+            return self.chunkedReader.getChecksumAlgorithm()
+        }
+        set {
+            self.chunkedReader.setChecksumAlgorithm(checksum: newValue)
+        }
+    }
+}