chore(storage): adds listParts support to support debugging (#103)

Author: brennanMKE

AmplifyPlugins/Storage/AWSS3StoragePlugin/Dependency/AWSS3Adapter.swift

@@ -100,6 +100,22 @@ class AWSS3Adapter: AWSS3Behavior {
             }
         }
     }
+
+    func listParts(bucket: String, key: String, uploadId: UploadID, completion: @escaping (Result<AWSS3ListUploadPartResponse, StorageError>) -> Void) {
+        let input = ListPartsInput(bucket: bucket, key: key, uploadId: uploadId)
+        awsS3.listParts(input: input) { result in
+            switch result {
+            case .success(let sdkResponse):
+                guard let response = AWSS3ListUploadPartResponse(response: sdkResponse) else {
+                    completion(.failure(StorageError.unknown("ListParts response is invalid", nil)))
+                    return
+                }
+                completion(.success(response))
+            case .failure(let error):
+                completion(.failure(error.storageError))
+            }
+        }
+    }
 
     /// Completed a MultipartUpload
     /// - Parameters:

AmplifyPlugins/Storage/AWSS3StoragePlugin/Dependency/AWSS3Behavior.swift

@@ -25,6 +25,9 @@ protocol AWSS3Behavior {
     // Creates a Multipart Upload.
     func createMultipartUpload(_ request: CreateMultipartUploadRequest, completion: @escaping (Result<AWSS3CreateMultipartUploadResponse, StorageError>) -> Void)
 
+    // Get list of uploaded parts (supports development)
+    func listParts(bucket: String, key: String, uploadId: UploadID, completion: @escaping (SdkResult<ListPartsOutputResponse, ListPartsOutputError>) -> Void)
+
     // Completes a Multipart Upload.
     func completeMultipartUpload(_ request: AWSS3CompleteMultipartUploadRequest, completion: @escaping (Result<AWSS3CompleteMultipartUploadResponse, StorageError>) -> Void)
 
@@ -35,3 +38,9 @@ protocol AWSS3Behavior {
     func getS3() -> S3Client
 
 }
+
+extension AWSS3Behavior {
+    func listParts(bucket: String, key: String, uploadId: UploadID, completion: @escaping (SdkResult<ListPartsOutputResponse, ListPartsOutputError>) -> Void) {
+        // do nothing
+    }
+}

AmplifyPlugins/Storage/AWSS3StoragePlugin/Dependency/AWSS3ListUploadPartResponse.swift

@@ -0,0 +1,45 @@
+//
+// Copyright Amazon.com Inc. or its affiliates.
+// All Rights Reserved.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+import Foundation
+
+import Amplify
+import AWSS3
+
+struct AWSS3ListUploadPartResponse {
+    let bucket: String
+    let key: String
+    let uploadId: String
+    let parts: AWSS3MultipartUploadRequestCompletedParts
+
+    init(bucket: String,
+         key: String,
+         uploadId: String,
+         parts: AWSS3MultipartUploadRequestCompletedParts) {
+        self.bucket = bucket
+        self.key = key
+        self.uploadId = uploadId
+        self.parts = parts
+    }
+}
+
+extension AWSS3ListUploadPartResponse {
+
+    init?(response: ListPartsOutputResponse) {
+        guard let bucket = response.bucket,
+              let key = response.key,
+              let uploadId = response.uploadId,
+              let parts = response.parts else {
+                  return nil
+              }
+        self.bucket = bucket
+        self.key = key
+        self.uploadId = uploadId
+        self.parts = AWSS3MultipartUploadRequestCompletedParts(parts: parts)
+    }
+    
+}

AmplifyPlugins/Storage/AWSS3StoragePlugin/Dependency/AWSS3MultipartUploadRequestCompletedPart.swift

@@ -7,6 +7,8 @@
 
 import Foundation
 
+import AWSS3
+
 struct AWSS3MultipartUploadRequestCompletedPart {
     let partNumber: Int
     let eTag: String
@@ -29,4 +31,13 @@ extension AWSS3MultipartUploadRequestCompletedParts {
         self = parts
     }
 
+    init(parts: [S3ClientTypes.Part]) {
+        self = parts.compactMap {
+            guard let eTag = $0.eTag else {
+                return nil
+            }
+            return AWSS3MultipartUploadRequestCompletedPart(partNumber: $0.partNumber, eTag: eTag)
+        }
+    }
+
 }