🔀 :: (#431) 액세스 토큰 자동 재발급 로직 추가

Projects/Domains/BaseDomain/Sources/DataSource/BaseRemoteDataSource.swift

@@ -15,6 +15,7 @@ import RxSwift
 open class BaseRemoteDataSource<API: WMAPI> {
     private let keychain: any Keychain
     private let provider: MoyaProvider<API>
+    private var refreshProvider: MoyaProvider<TokenRefreshAPI>?
     private let decoder = JSONDecoder()
     private let maxRetryCount = 2
 
@@ -34,12 +35,21 @@ open class BaseRemoteDataSource<API: WMAPI> {
     public func request(_ api: API) -> Single<Response> {
         return Single<Response>.create { single in
             var disposabels = [Disposable]()
-            disposabels.append(
-                self.defaultRequest(api).subscribe(
-                    onSuccess: { single(.success($0)) },
-                    onFailure: { single(.failure($0)) }
+            if self.checkIsApiNeedsAuthorization(api) {
+                disposabels.append(
+                    self.authorizedRequest(api).subscribe(
+                        onSuccess: { single(.success($0)) },
+                        onFailure: { single(.failure($0)) }
+                    )
                 )
-            )
+            } else {
+                disposabels.append(
+                    self.defaultRequest(api).subscribe(
+                        onSuccess: { single(.success($0)) },
+                        onFailure: { single(.failure($0)) }
+                    )
+                )
+            }
             return Disposables.create(disposabels)
         }
     }
@@ -60,7 +70,33 @@ private extension BaseRemoteDataSource {
             }
     }
 
+    func authorizedRequest(_ api: API) -> Single<Response> {
+        if checkAccessTokenIsValid() {
+            return defaultRequest(api)
+        } else {
+            return reissueToken()
+                .andThen(defaultRequest(api))
+                .retry(maxRetryCount)
+        }
+    }
+
     func checkIsApiNeedsAuthorization(_ api: API) -> Bool {
         api.jwtTokenType == .accessToken
     }
+
+    func checkAccessTokenIsValid() -> Bool {
+        let accessToken = keychain.load(type: .accessToken)
+        return !accessToken.isEmpty
+    }
+
+    func reissueToken() -> Completable {
+        let refreshAPI = TokenRefreshAPI.refresh
+        let provider = refreshProvider ?? MoyaProvider(plugins: [JwtPlugin(keychain: keychain), CustomLoggingPlugin()])
+        if refreshProvider == nil {
+            refreshProvider = provider
+        }
+
+        return provider.rx.request(.refresh)
+            .asCompletable()
+    }
 }

Projects/Domains/BaseDomain/Sources/DataSource/TokenRefreshAPI.swift

@@ -0,0 +1,28 @@
+import ErrorModule
+import Moya
+
+enum TokenRefreshAPI {
+    case refresh
+}
+
+extension TokenRefreshAPI: WMAPI {
+    var domain: WMDomain { .auth }
+
+    var urlPath: String { "/token" }
+
+    var method: Moya.Method { .post }
+
+    var task: Moya.Task { .requestPlain }
+
+    var jwtTokenType: JwtTokenType { .refreshToken }
+
+    var errorMap: [Int: WMError] {
+        [
+            400: .badRequest,
+            401: .tokenExpired,
+            404: .notFound,
+            429: .tooManyRequest,
+            500: .internalServerError
+        ]
+    }
+}