Address warnings under -strict-concurrency=complete compiler flag. (#18)

Address warnings under -strict-concurrency=complete compiler flag.

Author: tachyonics

README.md

@@ -176,7 +176,7 @@ All or a subset of the rows from a partition can be retrieved using a query-
 enum TestPolymorphicOperationReturnType: PolymorphicOperationReturnType {
  typealias AttributesType = StandardPrimaryKeyAttributes
 
- static var types: [(Codable.Type, PolymorphicOperationReturnOption<StandardPrimaryKeyAttributes, Self>)] = [
+ static let types: [(Codable.Type, PolymorphicOperationReturnOption<StandardPrimaryKeyAttributes, Self>)] = [
  (TypeA.self, .init( {.typeA($0)} )),
  (TypeB.self, .init( {.typeB($0)} )),
  ]
@@ -728,8 +728,8 @@ public struct MyTimeToLiveAttributes: TimeToLiveAttributes {
 If the `Codable` type is used for a row type also conforms to the `CustomRowTypeIdentifier`, the *rowTypeIdentifier* property of this type will be used as the RowType recorded in the database row.
 
 ```swift
-struct TypeB: Codable, CustomRowTypeIdentifier {
- static var rowTypeIdentifier: String? = "TypeBCustom"
+struct TypeB: SCodable, CustomRowTypeIdentifier {
+ static let rowTypeIdentifier: String? = "TypeBCustom"
 
  let thirdly: String
  let fourthly: String

Sources/DynamoDBTables/AWSDynamoDBCompositePrimaryKeyTable+monomorphicGetItems.swift

@@ -42,7 +42,7 @@ public extension AWSDynamoDBCompositePrimaryKeyTable {
  monitors the unprocessed items returned in the response from DynamoDB and uses an exponential backoff algorithm to retry those items using
  the same retry configuration as the underlying DynamoDB client.
  */
- private class MonomorphicGetItemsRetriable<AttributesType: PrimaryKeyAttributes, ItemType: Codable> {
+ private class MonomorphicGetItemsRetriable<AttributesType: PrimaryKeyAttributes, ItemType: Sendable & Codable> {
  typealias OutputType = [CompositePrimaryKey<AttributesType>: TypedDatabaseItem<AttributesType, ItemType>]
 
  let dynamodb: AWSDynamoDB.DynamoDBClient

Sources/DynamoDBTables/CompositePrimaryKey.swift

@@ -26,7 +26,7 @@
 
 import Foundation
 
-public protocol PrimaryKeyAttributes {
+public protocol PrimaryKeyAttributes: Sendable {
  static var partitionKeyAttributeName: String { get }
  static var sortKeyAttributeName: String { get }
  static var indexName: String? { get }
@@ -66,7 +66,7 @@ struct DynamoDBAttributesTypeCodingKey: CodingKey {
  }
 }
 
-public struct CompositePrimaryKey<AttributesType: PrimaryKeyAttributes>: Codable, CustomStringConvertible, Hashable {
+public struct CompositePrimaryKey<AttributesType: PrimaryKeyAttributes>: Sendable, Codable, CustomStringConvertible, Hashable {
  public var description: String {
  "CompositePrimaryKey(partitionKey: \(self.partitionKey), sortKey: \(self.sortKey))"
  }

Sources/DynamoDBTables/DynamoDBCompositePrimaryKeyTable+clobberVersionedItemWithHistoricalRow.swift

@@ -44,7 +44,7 @@ public extension DynamoDBCompositePrimaryKeyTable {
  version number.
  - completion: completion handler providing an error that was thrown or nil
  */
- func clobberVersionedItemWithHistoricalRow<AttributesType: PrimaryKeyAttributes, ItemType: Codable>(
+ func clobberVersionedItemWithHistoricalRow<AttributesType: PrimaryKeyAttributes, ItemType: Sendable & Codable>(
  forPrimaryKey partitionKey: String,
  andHistoricalKey historicalKey: String,
  item: ItemType,

Sources/DynamoDBTables/DynamoDBCompositePrimaryKeyTable+conditionallyUpdateItem.swift

@@ -43,7 +43,7 @@ public extension DynamoDBCompositePrimaryKeyTable {
  withRetries: the number of times to attempt to retry the update before failing.
  updatedPayloadProvider: the provider that will return updated payloads.
  */
- func conditionallyUpdateItem<AttributesType, ItemType: Codable>(
+ func conditionallyUpdateItem<AttributesType, ItemType: Sendable & Codable>(
  forKey key: CompositePrimaryKey<AttributesType>,
  withRetries retries: Int = 10,
  updatedPayloadProvider: @escaping (ItemType) async throws -> ItemType) async throws
@@ -60,7 +60,7 @@ public extension DynamoDBCompositePrimaryKeyTable {
 
  // Explicitly specify an overload with sync updatedPayloadProvider
  // to avoid the compiler matching a call site with such a provider with the EventLoopFuture-returning overload.
- func conditionallyUpdateItem<AttributesType, ItemType: Codable>(
+ func conditionallyUpdateItem<AttributesType, ItemType: Sendable & Codable>(
  forKey key: CompositePrimaryKey<AttributesType>,
  withRetries retries: Int = 10,
  updatedPayloadProvider: @escaping (ItemType) throws -> ItemType) async throws

Sources/DynamoDBTables/DynamoDBCompositePrimaryKeyTable.swift

@@ -70,7 +70,7 @@ public extension Swift.Error {
 /**
  Enumeration of the types of conditions that can be specified for an attribute.
  */
-public enum AttributeCondition {
+public enum AttributeCondition: Sendable {
  case equals(String)
  case lessThan(String)
  case lessThanOrEqual(String)
@@ -80,7 +80,7 @@ public enum AttributeCondition {
  case beginsWith(String)
 }
 
-public enum WriteEntry<AttributesType: PrimaryKeyAttributes, ItemType: Codable> {
+public enum WriteEntry<AttributesType: PrimaryKeyAttributes, ItemType: Sendable & Codable>: Sendable {
  case update(new: TypedDatabaseItem<AttributesType, ItemType>, existing: TypedDatabaseItem<AttributesType, ItemType>)
  case insert(new: TypedDatabaseItem<AttributesType, ItemType>)
  case deleteAtKey(key: CompositePrimaryKey<AttributesType>)

Sources/DynamoDBTables/InMemoryDynamoDBCompositePrimaryKeyTable.swift

@@ -25,10 +25,10 @@
 // DynamoDBTables
 //
 
-import AWSDynamoDB
+@preconcurrency import AWSDynamoDB
 import Foundation
 
-public protocol PolymorphicOperationReturnTypeConvertable {
+public protocol PolymorphicOperationReturnTypeConvertable: Sendable {
  var createDate: Foundation.Date { get }
  var rowStatus: RowStatus { get }
 
@@ -41,7 +41,7 @@ extension TypedDatabaseItem: PolymorphicOperationReturnTypeConvertable {
  }
 }
 
-public typealias ExecuteItemFilterType = (String, String, String, PolymorphicOperationReturnTypeConvertable)
+public typealias ExecuteItemFilterType = @Sendable (String, String, String, PolymorphicOperationReturnTypeConvertable)
  -> Bool
 
 public protocol InMemoryTransactionDelegate {

Sources/DynamoDBTables/InMemoryDynamoDBCompositePrimaryKeysProjection.swift

@@ -31,15 +31,15 @@ import Foundation
 public struct InMemoryDynamoDBCompositePrimaryKeysProjection: DynamoDBCompositePrimaryKeysProjection {
  let keysWrapper: InMemoryDynamoDBCompositePrimaryKeysProjectionStore
 
- public init(keys: [Any] = []) {
+ public init(keys: [Sendable] = []) {
  self.keysWrapper = InMemoryDynamoDBCompositePrimaryKeysProjectionStore(keys: keys)
  }
 
  init(keysWrapper: InMemoryDynamoDBCompositePrimaryKeysProjectionStore) {
  self.keysWrapper = keysWrapper
  }
 
- public var keys: [Any] {
+ public var keys: [Sendable] {
  get async {
  await self.keysWrapper.keys
  }

Sources/DynamoDBTables/InMemoryDynamoDBCompositePrimaryKeysProjectionStore.swift

@@ -31,9 +31,9 @@ import Foundation
 // MARK: - Store implementation
 
 actor InMemoryDynamoDBCompositePrimaryKeysProjectionStore {
- public var keys: [Any] = []
+ public var keys: [Sendable] = []
 
- public init(keys: [Any] = []) {
+ public init(keys: [Sendable] = []) {
  self.keys = keys
  }
 

Sources/DynamoDBTables/PolymorphicOperationReturnType.swift

@@ -33,25 +33,27 @@ public protocol BatchCapableReturnType {
  func getItemKey() -> CompositePrimaryKey<AttributesType>
 }
 
-public protocol PolymorphicOperationReturnType {
+public protocol PolymorphicOperationReturnType: Sendable {
  associatedtype AttributesType: PrimaryKeyAttributes
 
  static var types: [(Codable.Type, PolymorphicOperationReturnOption<AttributesType, Self>)] { get }
 }
 
-public struct PolymorphicOperationReturnOption<AttributesType: PrimaryKeyAttributes, ReturnType> {
- private let decodingPayloadHandler: (Decoder) throws -> ReturnType
- private let typeConvertingPayloadHander: (Any) throws -> ReturnType
+public struct PolymorphicOperationReturnOption<AttributesType: PrimaryKeyAttributes, ReturnType>: Sendable {
+ private let decodingPayloadHandler: @Sendable (Decoder) throws -> ReturnType
+ private let typeConvertingPayloadHander: @Sendable (Any) throws -> ReturnType
 
  public init<RowType: Codable>(
- _ payloadHandler: @escaping (TypedDatabaseItem<AttributesType, RowType>) -> ReturnType)
+ _ payloadHandler: @escaping @Sendable (TypedDatabaseItem<AttributesType, RowType>) -> ReturnType)
  {
+ @Sendable
  func newDecodingPayloadHandler(decoder: Decoder) throws -> ReturnType {
  let typedDatabaseItem: TypedDatabaseItem<AttributesType, RowType> = try TypedDatabaseItem(from: decoder)
 
  return payloadHandler(typedDatabaseItem)
  }
 
+ @Sendable
  func newTypeConvertingPayloadHandler(input: Any) throws -> ReturnType {
  guard let typedDatabaseItem = input as? TypedDatabaseItem<AttributesType, RowType> else {
  let description = "Expected to use item type \(TypedDatabaseItem<AttributesType, RowType>.self)."