IOS-1320 :: Feature :: Missing Async DataSource and Repository Wrapper (mobilejazz#53)

Author: vilanovi

Sources/Harmony/Data/DataSource/Async/AsyncDataSourceWrapper.swift

@@ -64,3 +64,35 @@ public class AsyncDeleteDataSourceWrapper<D>: AsyncDeleteDataSource where D: Del
         try await dataSource.delete(query).async()
     }
 }
+
+// swiftlint:disable line_length
+@available(iOS 13.0.0, *)
+public class AsyncDataSourceWrapper<D, T>: AsyncGetDataSource, AsyncPutDataSource, AsyncDeleteDataSource where D: GetDataSource, D: PutDataSource, D: DeleteDataSource, D.T == T {
+    private let dataSource: D
+
+    public init(_ dataSource: D) {
+        self.dataSource = dataSource
+    }
+
+    public func get(_ query: Query) async throws -> T {
+        try await dataSource.get(query).async()
+    }
+
+    public func getAll(_ query: Query) async throws -> [T] {
+        try await dataSource.getAll(query).async()
+    }
+
+    @discardableResult
+    public func put(_ value: T?, in query: Query) async throws -> T {
+        try await dataSource.put(value, in: query).async()
+    }
+
+    @discardableResult
+    public func putAll(_ array: [T], in query: Query) async throws -> [T] {
+        try await dataSource.putAll(array, in: query).async()
+    }
+
+    public func delete(_ query: Query) async throws {
+        try await dataSource.delete(query).async()
+    }
+}

Sources/Harmony/Data/Repository/Async/AsyncRepositoryWrapper.swift

@@ -64,3 +64,35 @@ public class AsyncDeleteRepositoryWrapper<R, T>: AsyncDeleteRepository where R:
         try await repository.delete(query, operation: operation).async()
     }
 }
+
+@available(iOS 13.0.0, *)
+// swiftlint:disable line_length
+public class AsyncRepositoryWrapper<R, T>: AsyncGetRepository, AsyncPutRepository, AsyncDeleteRepository where R: GetRepository, R: PutRepository, R: DeleteRepository, R.T == T {
+    private let repository: R
+
+    public init(_ repository: R) {
+        self.repository = repository
+    }
+
+    public func get(_ query: Query, operation: Operation) async throws -> T {
+        try await repository.get(query, operation: operation).async()
+    }
+
+    public func getAll(_ query: Query, operation: Operation) async throws -> [T] {
+        try await repository.getAll(query, operation: operation).async()
+    }
+
+    @discardableResult
+    public func put(_ value: T?, in query: Query, operation: Operation) async throws -> T {
+        try await repository.put(value, in: query, operation: operation).async()
+    }
+
+    @discardableResult
+    public func putAll(_ array: [T], in query: Query, operation: Operation) async throws -> [T] {
+        try await repository.putAll(array, in: query, operation: operation).async()
+    }
+
+    public func delete(_ query: Query, operation: Operation) async throws {
+        try await repository.delete(query, operation: operation).async()
+    }
+}