swift format

soto-project · Oct 16, 2024 · f2c05b0 · f2c05b0
1 parent 6760b13
commit f2c05b0
Show file tree

Hide file tree

Showing 19 changed files with 61 additions and 63 deletions.
diff --git a/Sources/Soto/Extensions/CognitoIdentity/CognitoIdentity+IdentityProvider.swift b/Sources/Soto/Extensions/CognitoIdentity/CognitoIdentity+IdentityProvider.swift
@@ -41,7 +41,7 @@ public struct IdentityProviderFactory: Sendable {
         self.cb = cb
     }
 
-    internal func createProvider(context: Context) -> IdentityProvider {
+    func createProvider(context: Context) -> IdentityProvider {
         self.cb(context)
     }
 }

diff --git a/Sources/Soto/Extensions/DynamoDB/DynamoDB+Codable.swift b/Sources/Soto/Extensions/DynamoDB/DynamoDB+Codable.swift
@@ -269,9 +269,9 @@ extension DynamoDB {
             var item = try DynamoDBEncoder().encode(self.updateItem)
             // extract key from input object
             var key: [String: AttributeValue] = [:]
-            self.key.forEach {
-                key[$0] = item[$0]!
-                item[$0] = nil
+            for element in self.key {
+                key[element] = item[element]!
+                item[element] = nil
             }
             // construct expression attribute name and value arrays from name attribute value map.
             // if names already provided along with a custom update expression then use the provided names

diff --git a/Sources/Soto/Extensions/DynamoDB/DynamoDBDecoder.swift b/Sources/Soto/Extensions/DynamoDB/DynamoDBDecoder.swift
@@ -216,7 +216,7 @@ private class _DynamoDBDecoder: Decoder {
         var attribute: DynamoDB.AttributeValue
         let decoder: _DynamoDBDecoder
 
-        internal init(attribute: DynamoDB.AttributeValue, decoder: _DynamoDBDecoder) {
+        init(attribute: DynamoDB.AttributeValue, decoder: _DynamoDBDecoder) {
             self.attribute = attribute
             self.decoder = decoder
             self.codingPath = decoder.codingPath

diff --git a/Sources/Soto/Extensions/DynamoDB/DynamoDBEncoder.swift b/Sources/Soto/Extensions/DynamoDB/DynamoDBEncoder.swift
@@ -151,7 +151,7 @@ class _DynamoDBEncoder: Encoder {
         let container: _EncoderKeyedContainer
         let encoder: _DynamoDBEncoder
 
-        internal init(container: _EncoderKeyedContainer, encoder: _DynamoDBEncoder) {
+        init(container: _EncoderKeyedContainer, encoder: _DynamoDBEncoder) {
             self.container = container
             self.encoder = encoder
             self.codingPath = encoder.codingPath
@@ -274,7 +274,7 @@ class _DynamoDBEncoder: Encoder {
         let container: _EncoderUnkeyedContainer
         let encoder: _DynamoDBEncoder
 
-        internal init(container: _EncoderUnkeyedContainer, encoder: _DynamoDBEncoder) {
+        init(container: _EncoderUnkeyedContainer, encoder: _DynamoDBEncoder) {
             self.container = container
             self.encoder = encoder
             self.codingPath = encoder.codingPath

diff --git a/Sources/Soto/Extensions/S3/S3+multipart.swift b/Sources/Soto/Extensions/S3/S3+multipart.swift
@@ -402,11 +402,10 @@ extension S3 {
 
             // create array of upload part requests.
             let uploadPartRequests: [UploadPartCopyRequest] = (1...numParts).map { part in
-                let copyRange: String
-                if part != numParts {
-                    copyRange = "bytes=\((part - 1) * partSize)-\(part * partSize - 1)"
+                let copyRange = if part != numParts {
+                    "bytes=\((part - 1) * partSize)-\(part * partSize - 1)"
                 } else {
-                    copyRange = "bytes=\((part - 1) * partSize)-\((part - 1) * partSize + finalPartSize - 1)"
+                    "bytes=\((part - 1) * partSize)-\((part - 1) * partSize + finalPartSize - 1)"
                 }
                 return .init(bucket: input.bucket, copySource: input.copySource, copySourceRange: copyRange, copySourceSSECustomerAlgorithm: input.copySourceSSECustomerAlgorithm, copySourceSSECustomerKey: input.copySourceSSECustomerKey, copySourceSSECustomerKeyMD5: input.copySourceSSECustomerKeyMD5, expectedBucketOwner: input.expectedBucketOwner, expectedSourceBucketOwner: input.expectedSourceBucketOwner, key: input.key, partNumber: part, requestPayer: input.requestPayer, sseCustomerAlgorithm: input.sseCustomerAlgorithm, sseCustomerKey: input.sseCustomerKey, sseCustomerKeyMD5: input.sseCustomerKeyMD5, uploadId: uploadId)
             }
@@ -687,11 +686,10 @@ extension S3 {
                         results.append(element)
                     }
                 }
-                let body: AWSHTTPBody
-                if let progress = newProgress {
-                    body = .init(asyncSequence: buffer.asyncSequence(chunkSize: 64 * 1024).reportProgress(reportFn: progress), length: buffer.readableBytes)
+                let body: AWSHTTPBody = if let progress = newProgress {
+                    .init(asyncSequence: buffer.asyncSequence(chunkSize: 64 * 1024).reportProgress(reportFn: progress), length: buffer.readableBytes)
                 } else {
-                    body = .init(asyncSequence: buffer.asyncSequence(chunkSize: 64 * 1024), length: buffer.readableBytes)
+                    .init(asyncSequence: buffer.asyncSequence(chunkSize: 64 * 1024), length: buffer.readableBytes)
                 }
                 group.addTask {
                     // Multipart uploads part numbers start at 1 not 0
@@ -748,11 +746,12 @@ extension S3 {
     // from bucket, key and version id from a copySource string
     func getBucketKeyVersion(from copySource: String) -> (bucket: String, key: String, versionId: String?)? {
         let path: Substring
-        // drop first slash if it exists
-        if copySource.first == "/" {
-            path = copySource.dropFirst()
+            // drop first slash if it exists
+            = if copySource.first == "/"
+        {
+            copySource.dropFirst()
         } else {
-            path = Substring(copySource)
+            Substring(copySource)
         }
         // find first slash
         guard let slashIndex = path.firstIndex(of: "/") else { return nil }

diff --git a/Sources/Soto/Extensions/STS/Environment.swift b/Sources/Soto/Extensions/STS/Environment.swift
@@ -18,8 +18,8 @@ import Glibc
 import Darwin.C
 #endif
 
-internal enum Environment {
-    internal static subscript(_ name: String) -> String? {
+enum Environment {
+    static subscript(_ name: String) -> String? {
         guard let value = getenv(name) else {
             return nil
         }

diff --git a/Tests/SotoTests/Services/APIGateway/APIGatewayTests.swift b/Tests/SotoTests/Services/APIGateway/APIGatewayTests.swift
@@ -30,12 +30,12 @@ class APIGatewayTests: XCTestCase {
     static var restApiId: String!
 
     override class func setUp() {
-        Self.client = AWSClient(
+        self.client = AWSClient(
             credentialProvider: TestEnvironment.credentialProvider,
             middleware: TestEnvironment.middlewares,
             logger: TestEnvironment.logger
         )
-        Self.apiGateway = APIGateway(
+        self.apiGateway = APIGateway(
             client: APIGatewayTests.client,
             region: .euwest1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")

diff --git a/Tests/SotoTests/Services/ApiGatewayV2/APIGatewayV2Tests.swift b/Tests/SotoTests/Services/ApiGatewayV2/APIGatewayV2Tests.swift
@@ -28,13 +28,13 @@ class APIGatewayV2Tests: XCTestCase {
 
     override class func setUp() {
         guard !TestEnvironment.isUsingLocalstack else { return }
-        Self.client = AWSClient(
+        self.client = AWSClient(
             credentialProvider: TestEnvironment.credentialProvider,
             middleware: TestEnvironment.middlewares,
             logger: TestEnvironment.logger
         )
-        Self.apiGatewayV2 = ApiGatewayV2(
-            client: Self.client,
+        self.apiGatewayV2 = ApiGatewayV2(
+            client: self.client,
             region: .euwest1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )

diff --git a/Tests/SotoTests/Services/CloudTrail/CloudTrailTests.swift b/Tests/SotoTests/Services/CloudTrail/CloudTrailTests.swift
@@ -20,8 +20,8 @@ class CloudTrailTests: XCTestCase {
     static var cloudTrail: CloudTrail!
 
     override class func setUp() {
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.cloudTrail = CloudTrail(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.cloudTrail = CloudTrail(
             client: CloudTrailTests.client,
             region: .euwest1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")

diff --git a/Tests/SotoTests/Services/DynamoDB/DynamoDBTests.swift b/Tests/SotoTests/Services/DynamoDB/DynamoDBTests.swift
@@ -31,8 +31,8 @@ class DynamoDBTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.dynamoDB = DynamoDB(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.dynamoDB = DynamoDB(
             client: DynamoDBTests.client,
             region: .useast1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")

diff --git a/Tests/SotoTests/Services/Glacier/GlacierTests.swift b/Tests/SotoTests/Services/Glacier/GlacierTests.swift
@@ -22,8 +22,8 @@ class GlacierTests: XCTestCase {
     static var glacier: Glacier!
 
     override class func setUp() {
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.glacier = Glacier(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.glacier = Glacier(
             client: GlacierTests.client,
             region: .euwest1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")

diff --git a/Tests/SotoTests/Services/IAM/IAMTests.swift b/Tests/SotoTests/Services/IAM/IAMTests.swift
@@ -29,15 +29,15 @@ class IAMTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.iam = IAM(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.iam = IAM(
             client: IAMTests.client,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )
     }
 
     override class func tearDown() {
-        XCTAssertNoThrow(try Self.client.syncShutdown())
+        XCTAssertNoThrow(try self.client.syncShutdown())
     }
 
     /// create SNS topic with supplied name and run supplied closure

diff --git a/Tests/SotoTests/Services/Lambda/LambdaTests.swift b/Tests/SotoTests/Services/Lambda/LambdaTests.swift
@@ -103,17 +103,17 @@ class LambdaTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(
+        self.client = AWSClient(
             credentialProvider: TestEnvironment.credentialProvider,
             middleware: TestEnvironment.middlewares
         )
-        Self.lambda = Lambda(
+        self.lambda = Lambda(
             client: LambdaTests.client,
             region: .euwest1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         ).with(middleware: TestEnvironment.middlewares)
-        Self.iam = IAM(
-            client: Self.client,
+        self.iam = IAM(
+            client: self.client,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         ).with(middleware: TestEnvironment.middlewares)
 

diff --git a/Tests/SotoTests/Services/S3/S3Tests.swift b/Tests/SotoTests/Services/S3/S3Tests.swift
@@ -34,20 +34,20 @@ class S3Tests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(
+        self.client = AWSClient(
             credentialProvider: TestEnvironment.credentialProvider,
             middleware: TestEnvironment.middlewares
         )
-        Self.s3 = S3(
-            client: Self.client,
+        self.s3 = S3(
+            client: self.client,
             region: .useast1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )
-        Self.randomBytes = self.createRandomBuffer(size: 11 * 1024 * 1024)
+        self.randomBytes = self.createRandomBuffer(size: 11 * 1024 * 1024)
     }
 
     override class func tearDown() {
-        XCTAssertNoThrow(try Self.client.syncShutdown())
+        XCTAssertNoThrow(try self.client.syncShutdown())
     }
 
     static func createRandomBuffer(size: Int) -> ByteBuffer {
@@ -124,11 +124,10 @@ class S3Tests: XCTestCase {
 
     func testPutGetObjectWithSpecialName() async throws {
         let name = TestEnvironment.generateResourceName()
-        let filename: String
-        if TestEnvironment.isUsingLocalstack {
-            filename = "test $filé+!@£$%^&*()_=-[]{}\\|';:\",./?><~`.txt"
+        let filename = if TestEnvironment.isUsingLocalstack {
+            "test $filé+!@£$%^&*()_=-[]{}\\|';:\",./?><~`.txt"
         } else {
-            filename = "test $filé+!@£$%2F%^&*()_=-[]{}\\|';:\",./?><~`.txt"
+            "test $filé+!@£$%2F%^&*()_=-[]{}\\|';:\",./?><~`.txt"
         }
         try await self.testPutGetObject(
             bucket: name,

diff --git a/Tests/SotoTests/Services/SES/SESTests.swift b/Tests/SotoTests/Services/SES/SESTests.swift
@@ -28,16 +28,16 @@ class SESTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.ses = SES(
-            client: Self.client,
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.ses = SES(
+            client: self.client,
             region: .useast1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )
     }
 
     override class func tearDown() {
-        XCTAssertNoThrow(try Self.client.syncShutdown())
+        XCTAssertNoThrow(try self.client.syncShutdown())
     }
 
     // Tests query protocol requests with no body

diff --git a/Tests/SotoTests/Services/SNS/SNSTests.swift b/Tests/SotoTests/Services/SNS/SNSTests.swift
@@ -28,16 +28,16 @@ class SNSTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.sns = SNS(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.sns = SNS(
             client: SNSTests.client,
             region: .useast1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )
     }
 
     override class func tearDown() {
-        XCTAssertNoThrow(try Self.client.syncShutdown())
+        XCTAssertNoThrow(try self.client.syncShutdown())
     }
 
     /// create SNS topic with supplied name and run supplied closure

diff --git a/Tests/SotoTests/Services/SQS/SQSTests.swift b/Tests/SotoTests/Services/SQS/SQSTests.swift
@@ -28,16 +28,16 @@ class SQSTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.sqs = SQS(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.sqs = SQS(
             client: SQSTests.client,
             region: .useast1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )
     }
 
     override class func tearDown() {
-        XCTAssertNoThrow(try Self.client.syncShutdown())
+        XCTAssertNoThrow(try self.client.syncShutdown())
     }
 
     /// create SQS queue with supplied name and run supplied closure

diff --git a/Tests/SotoTests/Services/SSM/SSMTests.swift b/Tests/SotoTests/Services/SSM/SSMTests.swift
@@ -28,16 +28,16 @@ class SSMTests: XCTestCase {
             print("Connecting to AWS")
         }
 
-        Self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
-        Self.ssm = SSM(
+        self.client = AWSClient(credentialProvider: TestEnvironment.credentialProvider, middleware: TestEnvironment.middlewares)
+        self.ssm = SSM(
             client: SSMTests.client,
             region: .useast1,
             endpoint: TestEnvironment.getEndPoint(environment: "LOCALSTACK_ENDPOINT")
         )
     }
 
     override class func tearDown() {
-        XCTAssertNoThrow(try Self.client.syncShutdown())
+        XCTAssertNoThrow(try self.client.syncShutdown())
     }
 
     /// put parameter, test it, delete it

diff --git a/Tests/SotoTests/test.swift b/Tests/SotoTests/test.swift
@@ -30,7 +30,7 @@ extension Task where Failure == Error {
     ///
     /// - Note: This function blocks the thread until the given operation is finished. The caller is responsible for managing multithreading.
     @available(*, noasync, message: "synchronous() can block indefinitely")
-    internal func syncAwait() throws -> Success {
+    func syncAwait() throws -> Success {
         let semaphore = DispatchSemaphore(value: 0)
         let resultBox = SendableBox<Result<Success, Failure>>()
 
@@ -56,7 +56,7 @@ extension Task where Failure == Never {
     ///
     /// - Note: This function blocks the thread until the given operation is finished. The caller is responsible for managing multithreading.
     @available(*, noasync, message: "synchronous() can block indefinitely")
-    internal func syncAwait() -> Success {
+    func syncAwait() -> Success {
         let semaphore = DispatchSemaphore(value: 0)
         let resultBox = SendableBox<Success>()