refact :: [#118] SchoolMeal Combine refact

Author: leejh08

Projects/Domain/SchoolMealDomain/Interface/Repository/SchoolMealRepository.swift

@@ -1,5 +1,6 @@
 import Foundation
+import Combine
 
 public protocol SchoolMealRepository {
-    func fetchSchoolMeal(date: String) async throws -> SchoolMealEntity
+    func fetchSchoolMeal(date: String) -> AnyPublisher<SchoolMealEntity, Error>
 }

Projects/Domain/SchoolMealDomain/Interface/UseCase/FetchSchoolMealUseCase.swift

@@ -1,5 +1,6 @@
 import Foundation
+import Combine
 
 public protocol FetchSchoolMealUseCaseProtocol {
-    func execute(date: String) async throws -> SchoolMealEntity
+    func execute(date: String) -> AnyPublisher<SchoolMealEntity, Error>
 }

Projects/Domain/SchoolMealDomain/Sources/DataSource/SchoolMealDataSource.swift

@@ -2,5 +2,5 @@ import Foundation
 import Combine
 
 public protocol SchoolMealRemoteDataSource {
-    func fetchSchoolMeal(date: String) async throws -> SchoolMealDTO
+    func fetchSchoolMeal(date: String) -> AnyPublisher<SchoolMealDTO, Error>
 }

Projects/Domain/SchoolMealDomain/Sources/DataSource/SchoolMealRemoteDataSourceImpl.swift

@@ -1,34 +1,15 @@
 import Foundation
-import Moya
-import CombineMoya
 import Combine
 import BaseDomain
 import Core
 
-public final class SchoolMealRemoteDataSourceImpl: SchoolMealRemoteDataSource {
-    private let keychain: any Keychain
-    private let provider: MoyaProvider<SchoolMealAPI>
-    
-    public init(keychain: any Keychain) {
-        self.keychain = keychain
-        self.provider = MoyaProvider<SchoolMealAPI>(plugins: [MoyaLoggingPlugin()])
-    }
-    
-    public func fetchSchoolMeal(date: String) async throws -> SchoolMealDTO {
-        return try await withCheckedThrowingContinuation { continuation in
-            provider.request(.fetchSchoolMeal(date: date)) { result in
-                switch result {
-                case .success(let response):
-                    do {
-                        let dto = try response.map(SchoolMealDTO.self)
-                        continuation.resume(returning: dto)
-                    } catch {
-                        continuation.resume(throwing: error)
-                    }
-                case .failure(let error):
-                    continuation.resume(throwing: error)
-                }
+public final class SchoolMealRemoteDataSourceImpl: BaseRemoteDataSource<SchoolMealAPI>, SchoolMealRemoteDataSource {
+
+    public func fetchSchoolMeal(date: String) -> AnyPublisher<SchoolMealDTO, Error> {
+        request(.fetchSchoolMeal(date: date))
+            .tryMap { response in
+                try response.map(SchoolMealDTO.self)
             }
-        }
+            .eraseToAnyPublisher()
     }
 }

Projects/Domain/SchoolMealDomain/Sources/Repository/SchoolMealRepositoryImpl.swift

@@ -1,15 +1,17 @@
 import Foundation
+import Combine
 import SchoolMealDomainInterface
 
 public final class SchoolMealRepositoryImpl: SchoolMealRepository {
     private let remoteDataSource: SchoolMealRemoteDataSource
-    
+
     public init(remoteDataSource: SchoolMealRemoteDataSource) {
         self.remoteDataSource = remoteDataSource
     }
-    
-    public func fetchSchoolMeal(date: String) async throws -> SchoolMealEntity {
-        let dto = try await remoteDataSource.fetchSchoolMeal(date: date)
-        return dto.toDomain()
+
+    public func fetchSchoolMeal(date: String) -> AnyPublisher<SchoolMealEntity, Error> {
+        remoteDataSource.fetchSchoolMeal(date: date)
+            .map { $0.toDomain() }
+            .eraseToAnyPublisher()
     }
 }

Projects/Domain/SchoolMealDomain/Sources/UseCase/FetchSchoolMealUseCase.swift

@@ -1,14 +1,15 @@
 import Foundation
+import Combine
 import SchoolMealDomainInterface
 
 public struct FetchSchoolMealUseCase: FetchSchoolMealUseCaseProtocol {
     private let repository: SchoolMealRepository
-    
+
     public init(repository: SchoolMealRepository) {
         self.repository = repository
     }
-    
-    public func execute(date: String) async throws -> SchoolMealEntity {
-        return try await repository.fetchSchoolMeal(date: date)
+
+    public func execute(date: String) -> AnyPublisher<SchoolMealEntity, Error> {
+        repository.fetchSchoolMeal(date: date)
     }
 }

Projects/Feature/SchoolMealFeature/Sources/SchoolMealReducer.swift

@@ -42,13 +42,11 @@ public struct SchoolMealReducer: Reducer {
             case .fetchMeal(let dateString):
                 state.isLoading = true
                 state.errorMessage = nil
-                return .run { send in
-                    do {
-                        let mealEntity = try await fetchSchoolMealsUseCase.execute(date: dateString)
-                        await send(.mealFetched(mealEntity))
-                    } catch {
-                        await send(.fetchFailed(error.localizedDescription))
-                    }
+                return .publisher {
+                    fetchSchoolMealsUseCase.execute(date: dateString)
+                        .mapError { $0 as Error }
+                        .map { Action.mealFetched($0) }
+                        .catch { Just(Action.fetchFailed($0.localizedDescription)) }
                 }
 
             case .mealFetched(let mealEntity):