|
6 | 6 | //
|
7 | 7 |
|
8 | 8 | import Foundation
|
| 9 | + |
9 | 10 | import Moya
|
| 11 | +import RxMoya |
| 12 | +import RxSwift |
10 | 13 |
|
11 | 14 | /// 부서 관련 API 요청을 처리하는 서비스 클래스입니다.
|
12 | 15 | ///
|
13 | 16 | /// 이 클래스는 사용자 부서 관련 API 요청을 수행하며, 부서 추가 기능을 제공합니다.
|
14 |
| -/// MoyaProvider를 사용하여 API 요청을 처리하며, 인증 토큰은 RealmService를 통해 가져옵니다. |
| 17 | +/// RxMoyaProvider를 사용하여 API 요청을 처리하며, 인증 토큰은 RealmService를 통해 가져옵니다. |
15 | 18 | final class UserDepartmentService {
|
16 | 19 | /// MoyaProvider 인스턴스
|
17 | 20 | private let provider: MoyaProvider<UserDepartmentRouter>
|
| 21 | + private let decoder: JSONDecoder |
18 | 22 |
|
19 | 23 | /// 초기화 메서드
|
20 | 24 | ///
|
21 | 25 | /// - Parameter provider: 기본값은 `MoyaProvider<UserDepartmentRouter>()`입니다.
|
22 |
| - init(provider: MoyaProvider<UserDepartmentRouter> = MoyaProvider<UserDepartmentRouter>()) { |
| 26 | + /// - Parameter decoder: 기본값은 `JSONDecoder()`입니다. |
| 27 | + init( |
| 28 | + provider: MoyaProvider<UserDepartmentRouter> = MoyaProvider<UserDepartmentRouter>(), |
| 29 | + decoder: JSONDecoder = JSONDecoder() |
| 30 | + ) { |
23 | 31 | self.provider = provider
|
| 32 | + self.decoder = decoder |
| 33 | + } |
| 34 | + |
| 35 | + /// 공통 디코딩 로직을 처리하는 private 메서드 |
| 36 | + private func decode<T: Decodable>(_ type: T.Type, from response: Response) -> Single<T> { |
| 37 | + Single.create { single in |
| 38 | + do { |
| 39 | + let decodedData = try self.decoder.decode(type, from: response.data) |
| 40 | + single(.success(decodedData)) |
| 41 | + } catch { |
| 42 | + single(.failure(error)) |
| 43 | + } |
| 44 | + return Disposables.create() |
| 45 | + } |
24 | 46 | }
|
25 | 47 |
|
26 | 48 | /// 부서 추가 API 요청을 수행합니다.
|
27 | 49 | ///
|
28 |
| - /// - Parameters: |
29 |
| - /// - departmentName: 추가할 부서의 이름 |
30 |
| - /// - completion: 요청 완료 후 호출되는 클로저. |
31 |
| - /// 성공 시 서버의 응답 문자열을 반환하고, 실패 시 에러를 반환합니다. |
32 |
| - func addDepartment(departmentName: String, completion: @escaping (Result<String, Error>) -> Void) { |
33 |
| - provider.request(.addDepartment(departmentName: departmentName)) { result in |
34 |
| - switch result { |
35 |
| - case let .success(response): |
36 |
| - do { |
37 |
| - // 서버 응답을 문자열 형태로 매핑합니다. |
38 |
| - let decodedData = try JSONDecoder().decode(BaseResponseWithoutResult.self, from: response.data) |
39 |
| - if decodedData.isSuccess { |
40 |
| - completion(.success(decodedData.message)) |
41 |
| - } else { |
42 |
| - // 서버에서 전달한 메시지를 포함한 에러 반환 |
43 |
| - let error = NSError( |
44 |
| - domain: "UserDepartmentService", |
45 |
| - code: -1, |
46 |
| - userInfo: [NSLocalizedDescriptionKey: decodedData.message] |
47 |
| - ) |
48 |
| - completion(.failure(error)) |
49 |
| - } |
50 |
| - } catch { |
51 |
| - completion(.failure(error)) |
52 |
| - } |
53 |
| - case let .failure(error): |
54 |
| - completion(.failure(error)) |
| 50 | + /// - Parameter departmentName: 추가할 부서의 이름 |
| 51 | + /// - Returns: 성공 시 서버의 응답 메시지를 포함한 BaseResponseWithoutResult를 반환하는 Single |
| 52 | + /// - Note: 부서 추가에 실패할 경우 에러를 반환합니다. |
| 53 | + func addDepartment(departmentName: String) -> Single<BaseResponseWithoutResult> { |
| 54 | + provider.rx.request(.addDepartment(departmentName: departmentName)) |
| 55 | + .flatMap { [weak self] response in |
| 56 | + guard let self else { return .error(ServiceError.instanceDeallocated) } |
| 57 | + return decode(BaseResponseWithoutResult.self, from: response) |
55 | 58 | }
|
56 |
| - } |
57 | 59 | }
|
58 | 60 |
|
59 | 61 | /// 부서 이름 검증 API 요청을 수행합니다.
|
60 | 62 | ///
|
61 |
| - /// - Parameter completion: 요청 완료 후 호출되는 클로저. |
62 |
| - /// 성공 시 서버의 응답 문자열을 반환하고, 실패 시 에러를 반환합니다. |
63 |
| - func validateDepartment(completion: @escaping (Result<Bool, Error>) -> Void) { |
64 |
| - provider.request(.validateDepartment) { result in |
65 |
| - switch result { |
66 |
| - case let .success(response): |
67 |
| - do { |
68 |
| - let decodedData = try JSONDecoder().decode(BaseResponse<Bool>.self, from: response.data) |
69 |
| - if decodedData.isSuccess { |
70 |
| - completion(.success(decodedData.result)) |
71 |
| - } else { |
72 |
| - let error = NSError( |
73 |
| - domain: "UserDepartmentService", |
74 |
| - code: -1, |
75 |
| - userInfo: [NSLocalizedDescriptionKey: decodedData.message] |
76 |
| - ) |
77 |
| - completion(.failure(error)) |
78 |
| - } |
79 |
| - } catch { |
80 |
| - completion(.failure(error)) |
81 |
| - } |
82 |
| - case let .failure(error): |
83 |
| - completion(.failure(error)) |
| 63 | + /// - Returns: 성공 시 검증 결과를 포함한 BaseResponse<Bool>을 반환하는 Single |
| 64 | + /// - Note: 검증에 실패할 경우 에러를 반환합니다. |
| 65 | + func validateDepartment() -> Single<BaseResponse<Bool>> { |
| 66 | + provider.rx.request(.validateDepartment) |
| 67 | + .flatMap { [weak self] response in |
| 68 | + guard let self else { return .error(ServiceError.instanceDeallocated) } |
| 69 | + return decode(BaseResponse<Bool>.self, from: response) |
84 | 70 | }
|
85 |
| - } |
86 | 71 | }
|
87 | 72 |
|
88 | 73 | /// 사용자 단과대의 제휴업체 목록을 요청합니다.
|
89 | 74 | ///
|
90 |
| - /// - Parameter completion: 요청 완료 후 호출되는 클로저. |
91 |
| - /// 성공 시 제휴업체 목록을 반환하고, 실패 시 에러를 반환합니다. |
92 |
| - func getUserPartnership(completion: @escaping (Result<[PartnershipResponse], Error>) -> Void) { |
93 |
| - provider.request(.getUserPartnership) { result in |
94 |
| - switch result { |
95 |
| - case let .success(response): |
96 |
| - do { |
97 |
| - let decodedData = try JSONDecoder().decode(BaseResponse<[PartnershipResponse]>.self, from: response.data) |
98 |
| - if decodedData.isSuccess { |
99 |
| - completion(.success(decodedData.result)) |
100 |
| - } else { |
101 |
| - let error = NSError( |
102 |
| - domain: "UserDepartmentService", |
103 |
| - code: -1, |
104 |
| - userInfo: [NSLocalizedDescriptionKey: decodedData.message] |
105 |
| - ) |
106 |
| - completion(.failure(error)) |
107 |
| - } |
108 |
| - } catch { |
109 |
| - completion(.failure(error)) |
110 |
| - } |
111 |
| - case let .failure(error): |
112 |
| - completion(.failure(error)) |
| 75 | + /// - Returns: 성공 시 제휴업체 목록을 포함한 BaseResponse<[PartnershipResponse]>를 반환하는 Single |
| 76 | + /// - Note: 목록 조회에 실패할 경우 에러를 반환합니다. |
| 77 | + func getUserPartnership() -> Single<BaseResponse<[PartnershipResponse]>> { |
| 78 | + provider.rx.request(.getUserPartnership) |
| 79 | + .flatMap { [weak self] response in |
| 80 | + guard let self else { return .error(ServiceError.instanceDeallocated) } |
| 81 | + return decode(BaseResponse<[PartnershipResponse]>.self, from: response) |
113 | 82 | }
|
114 |
| - } |
115 | 83 | }
|
116 | 84 | }
|
| 85 | + |
| 86 | +/// 서비스 계층에서 발생할 수 있는 에러 정의 |
| 87 | +enum ServiceError: Error { |
| 88 | + case instanceDeallocated |
| 89 | + // 필요한 다른 에러 케이스들을 추가할 수 있습니다. |
| 90 | +} |
0 commit comments