Merge pull request #115 from THT-Team/feature/TOP-90_refresh_token

TOP-90 feature Http Code가 500일 때 error 필드값에 따라서 토큰 만료, Internal Server Errro 구분

data/src/main/java/com/tht/tht/data/di/retrofit/OkHttpInterceptorModule.kt

@@ -1,17 +1,16 @@
 package com.tht.tht.data.di.retrofit
 
+import com.google.gson.Gson
 import com.tht.tht.data.BuildConfig
+import com.tht.tht.data.remote.retrofit.ThtHeaderInterceptor
 import com.tht.tht.data.remote.retrofit.TokenRefreshAuthenticator
-import com.tht.tht.data.remote.retrofit.header.HttpHeaderKey
-import com.tht.tht.domain.token.model.TokenException
 import com.tht.tht.domain.token.token.FetchThtAccessTokenUseCase
 import com.tht.tht.domain.token.token.RefreshThtAccessTokenUseCase
 import dagger.Lazy
 import dagger.Module
 import dagger.Provides
 import dagger.hilt.InstallIn
 import dagger.hilt.components.SingletonComponent
-import kotlinx.coroutines.runBlocking
 import okhttp3.Interceptor
 import okhttp3.logging.HttpLoggingInterceptor
 
@@ -21,23 +20,9 @@ object OkHttpInterceptorModule {
 
     @Provides
     fun provideHeaderInterceptor(
+        gson: Gson,
         fetchThtAccessTokenUseCase: Lazy<FetchThtAccessTokenUseCase>
-    ): Interceptor = Interceptor { chain ->
-        val requestBuilder = chain.request().newBuilder()
-            .header(HttpHeaderKey.CONTENT_TYPE_HEADER_KEY, HttpHeaderKey.CONTENT_TYPE_HEADER_VALUE)
-        val accessToken = runBlocking { fetchThtAccessTokenUseCase.get().invoke().getOrNull() }
-        if (accessToken != null) {
-            requestBuilder.header(
-                HttpHeaderKey.AUTHORIZATION_HEADER_KEY,
-                "${HttpHeaderKey.BEARER_PREFIX} $accessToken"
-            )
-        }
-        chain.proceed(requestBuilder.build()).also { response ->
-            when (response.code) {
-                500 -> throw TokenException.RefreshTokenExpiredException()
-            }
-        }
-    }
+    ): Interceptor = ThtHeaderInterceptor(gson, fetchThtAccessTokenUseCase)
 
     @Provides
     fun provideHttpLoggingInterceptor(): HttpLoggingInterceptor =

data/src/main/java/com/tht/tht/data/remote/retrofit/ThtHeaderInterceptor.kt

@@ -0,0 +1,64 @@
+package com.tht.tht.data.remote.retrofit
+
+import com.google.gson.Gson
+import com.tht.tht.data.remote.response.base.ErrorResponse
+import com.tht.tht.data.remote.retrofit.header.HttpHeaderKey
+import com.tht.tht.domain.token.model.TokenException
+import com.tht.tht.domain.token.token.FetchThtAccessTokenUseCase
+import dagger.Lazy
+import kotlinx.coroutines.runBlocking
+import okhttp3.Interceptor
+import okhttp3.Response
+import okhttp3.ResponseBody
+import javax.inject.Inject
+
+class ThtHeaderInterceptor @Inject constructor(
+    private val gson: Gson,
+    private val fetchThtAccessTokenUseCase: Lazy<FetchThtAccessTokenUseCase>
+) : Interceptor {
+
+    override fun intercept(chain: Interceptor.Chain): Response {
+        val requestBuilder = chain.request().newBuilder()
+            .header(HttpHeaderKey.CONTENT_TYPE_HEADER_KEY, HttpHeaderKey.CONTENT_TYPE_HEADER_VALUE)
+        val accessToken = runBlocking { fetchThtAccessTokenUseCase.get().invoke().getOrNull() }
+        if (accessToken != null) {
+            requestBuilder.header(
+                HttpHeaderKey.AUTHORIZATION_HEADER_KEY,
+                "${HttpHeaderKey.BEARER_PREFIX} $accessToken"
+            )
+        }
+
+        val response = chain.proceed(requestBuilder.build())
+        return response.body?.string()?.let {
+            checkTokenExpiredException(response, parseErrorResponse(it))
+            //response 는 한 번 밖에 읽지 못함
+            response.newBuilder()
+                .body(ResponseBody.create(response.body!!.contentType(), it))
+                .build()
+        } ?: kotlin.run {
+            checkTokenExpiredException(response, null)
+            response
+        }
+    }
+
+    private fun parseErrorResponse(errorJson: String): ErrorResponse? {
+        return try {
+            gson.fromJson(errorJson, ErrorResponse::class.java)
+        } catch (e: Exception) {
+            e.printStackTrace()
+            null
+        }
+    }
+
+    private fun checkTokenExpiredException(
+        response: Response,
+        errorResponse: ErrorResponse?
+    ) {
+        when {
+            errorResponse?.error == "refresh_token_expired" &&
+                response.code == 500 -> {
+                throw TokenException.RefreshTokenExpiredException()
+            }
+        }
+    }
+}