IOS-4312 :: Feature internal :: Use async-await on the sample app (mobilejazz#52)

Author: franmontiel

Example/Harmony/Core/Features/Item/Data/ItemNetworkDataSource.swift

@@ -33,7 +33,7 @@ class ItemNetworkDataSource : GetDataSource  {
         case let query as IdQuery<String>:
             return getById(query.id)
         default:
-            query.fatalError(.get, self)
+            return Future(CoreError.QueryNotSupported())
         }
     }
 
@@ -44,7 +44,7 @@ class ItemNetworkDataSource : GetDataSource  {
         case is SearchItemsQuery:
             return searchItems((query as! SearchItemsQuery).text)
         default:
-            query.fatalError(.getAll, self)
+            return Future(CoreError.QueryNotSupported())
         }
     }
 }

Example/Harmony/Core/Features/Item/Domain/Interactors/GetAllItemsInteractor.swift

@@ -9,13 +9,10 @@
 import Harmony
 
 struct GetAllItemsInteractor {
-    let executor: Executor
-    let getItems: Interactor.GetAllByQuery<Item>
+    let getItems: AsyncGetAllInteractor<Item>
 
-    func execute(_ operation: Harmony.Operation = DefaultOperation()) -> Future<[Item]> {
-        return executor.submit { r in
-            let items = try self.getItems.execute(AllItemsQuery(), operation, in: DirectExecutor()).result.get()
-            r.set(items)
-        }
+    func execute(_ operation: Harmony.Operation = DefaultOperation()) async throws -> [Item] {
+        return try await self.getItems.execute(AllItemsQuery(), operation)
+
     }
 }

Example/Harmony/Core/Features/Item/Domain/Presenters/ItemListPresenter.swift

@@ -33,12 +33,19 @@ class ItemListDefaultPresenter: ItemListPresenter {
 
     func onEventLoadList() {
         view?.onDisplayProgressHud(show: true)
-        getItems.execute().then { items in
-            self.view?.onDisplayProgressHud(show: false)
-            self.view?.onDisplayItems(items)
-        }.fail { error in
-            self.view?.onDisplayProgressHud(show: false)
-            self.view?.onDisplayFailedToFetchItems(error)
+        Task {
+            do {
+                let items = try await self.getItems.execute()
+                Task { @MainActor in
+                    self.view?.onDisplayProgressHud(show: false)
+                    self.view?.onDisplayItems(items)
+                }
+            } catch {
+                Task { @MainActor in
+                    self.view?.onDisplayProgressHud(show: false)
+                    self.view?.onDisplayFailedToFetchItems(error)
+                }
+            }
         }
     }
 
@@ -48,12 +55,21 @@ class ItemListDefaultPresenter: ItemListPresenter {
 
     func onActionReloadList() {
         view?.onDisplayProgressHud(show: true)
-        self.getItems.execute(MainSyncOperation()).then { items in
-            self.view?.onDisplayProgressHud(show: false)
-            self.view?.onDisplayItems(items)
-        }.fail { error in
-            self.view?.onDisplayProgressHud(show: false)
-            self.view?.onDisplayFailedToFetchItems(error)
+        Task {
+            do {
+                let items = try await self.getItems.execute(MainSyncOperation())
+                Task { @MainActor in
+                    self.view?.onDisplayProgressHud(show: false)
+                    self.view?.onDisplayItems(items)
+                }
+            } catch {
+                Task { @MainActor in
+                    self.view?.onDisplayProgressHud(show: false)
+                    self.view?.onDisplayFailedToFetchItems(error)
+                }
+            }
         }
+        
     }
 }
+

Example/Harmony/Core/Features/Item/ItemProvider.swift

@@ -63,10 +63,14 @@ class ItemDefaultModule: ItemComponent {
                                 toOutMapper: EncodableToDecodableMapper<ItemEntity, Item>())
         )
     }()
+
+    private lazy var asyncRepository: AsyncAnyGetRepository<Item> = {
+        let asyncRepositoryWrapper: AsyncGetRepositoryWrapper = AsyncGetRepositoryWrapper(repository)
+        return AsyncAnyGetRepository(asyncRepositoryWrapper)
+    }()
 
     private func getAllItemsInteractor() -> GetAllItemsInteractor {
-        return GetAllItemsInteractor(executor: self.executor,
-                                     getItems: Interactor.GetAllByQuery(DirectExecutor(), self.repository))
+        return GetAllItemsInteractor(getItems: AsyncGetAllInteractor(asyncRepository))
     }
 
     func itemListPresenter(view: ItemListPresenterView) -> ItemListPresenter {