Merge branch 'compose' into feature/311-home-repository

Author: hegunhee

core/data/src/main/java/com/youthtalk/repository/PolicyRepositoryImpl.kt

@@ -3,49 +3,22 @@ package com.youthtalk.repository
 import com.core.dataapi.repository.PolicyRepository
 import com.core.exception.NoDataException
 import com.youthtalk.data.PolicyService
-import com.youthtalk.dto.PolicyDetailResponse
-import com.youthtalk.dto.policy.PolicyResponse
 import com.youthtalk.mapper.toData
 import com.youthtalk.mapper.toDomain
 import com.youthtalk.model.policy.Policy
 import com.youthtalk.model.policy.PolicyDetail
-import com.youthtalk.utils.ErrorUtils.throwableError
+import com.youthtalk.utils.ErrorUtils.createResult
 import javax.inject.Inject
-import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.flow
-import timber.log.Timber
 
 class PolicyRepositoryImpl @Inject constructor(
     private val policyService: PolicyService
 ) : PolicyRepository {
 
-    override fun getPolicyDetail(policyId: Long): Flow<PolicyDetail> = flow {
-        runCatching {
-            policyService.getPolicyDetail(policyId)
-        }
-            .onSuccess { response ->
-                response.data?.let {
-                    emit(it.toData())
-                } ?: throw NoDataException("no Data")
-            }
-            .onFailure {
-                Timber.e("getPolicyDetail $it")
-                throwableError<PolicyDetailResponse>(it)
-            }
+    override suspend fun getPolicyDetail(policyId: Long): Result<PolicyDetail> = createResult {
+        policyService.getPolicyDetail(policyId).data?.toData() ?: throw NoDataException()
     }
 
-    override fun getRecentlyViewPolicies(): Flow<List<Policy>> = flow {
-        runCatching {
-            policyService.getRecentlyViewPolicies()
-        }
-            .onSuccess { response ->
-                response.data?.let { data ->
-                    emit(data.map { it.toDomain() })
-                } ?: throw NoDataException("no Data")
-            }
-            .onFailure {
-                Timber.e("PolicyRepositoryImpl getRecentlyViewPolicies error $it")
-                throwableError<PolicyResponse>(it)
-            }
+    override suspend fun getRecentlyViewPolicies(): Result<List<Policy>> = createResult {
+        policyService.getRecentlyViewPolicies().data?.map { it.toDomain() } ?: throw NoDataException()
     }
 }

core/data/src/test/java/com/youthtalk/repository/PolicyRepositoryTest.kt

@@ -0,0 +1,68 @@
+package com.youthtalk.repository
+
+import com.core.dataapi.repository.PolicyRepository
+import com.youthtalk.data.PolicyService
+import com.youthtalk.dto.CommonResponse
+import com.youthtalk.dto.PolicyDetailResponse
+import com.youthtalk.mapper.toData
+import com.youthtalk.model.policy.Policy
+import kotlinx.coroutines.test.runTest
+import org.junit.Assert.assertEquals
+import org.junit.Before
+import org.junit.Test
+import org.junit.runner.RunWith
+import org.mockito.Mock
+import org.mockito.junit.MockitoJUnitRunner
+import org.mockito.kotlin.verify
+import org.mockito.kotlin.whenever
+
+@RunWith(MockitoJUnitRunner::class)
+class PolicyRepositoryTest {
+
+    private lateinit var sut: PolicyRepository
+
+    @Mock
+    private lateinit var policyService: PolicyService
+
+    @Before
+    fun setUp() {
+        sut = PolicyRepositoryImpl(policyService)
+    }
+
+    @Test
+    fun givenPolicyId_whenGetPolicyDetail_thenReturnsPolicy() {
+        runTest {
+            // given
+            val policyId = 3L
+            val policyDetailResponse = createPolicyDetailResponse()
+
+            whenever(policyService.getPolicyDetail(policyId)).thenReturn(CommonResponse(200, "정책 조회에 성공하였습니다.", "S04", policyDetailResponse))
+
+            // when
+            val result = sut.getPolicyDetail(policyId).getOrThrow()
+
+            // then
+            assertEquals(policyDetailResponse.toData(), result)
+            verify(policyService).getPolicyDetail(policyId)
+        }
+    }
+
+    @Test
+    fun given_whenGetRecentViewPolicy_thenReturnsPolicy() {
+        runTest {
+            // given
+            whenever(policyService.getRecentlyViewPolicies()).thenReturn(CommonResponse(200, "요청에 성공하였습니다.", "S01", listOf()))
+
+            // when
+            val result = sut.getRecentlyViewPolicies().getOrThrow()
+
+            // then
+            assertEquals(listOf<Policy>(), result)
+            verify(policyService).getRecentlyViewPolicies()
+        }
+    }
+
+    private fun createPolicyDetailResponse(): PolicyDetailResponse {
+        return PolicyDetailResponse("", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", "", true, "", "")
+    }
+}

core/dataApi/src/main/java/com/core/dataapi/repository/PolicyRepository.kt

@@ -2,9 +2,8 @@ package com.core.dataapi.repository
 
 import com.youthtalk.model.policy.Policy
 import com.youthtalk.model.policy.PolicyDetail
-import kotlinx.coroutines.flow.Flow
 
 interface PolicyRepository {
-    fun getPolicyDetail(policyId: Long): Flow<PolicyDetail>
-    fun getRecentlyViewPolicies(): Flow<List<Policy>>
+    suspend fun getPolicyDetail(policyId: Long): Result<PolicyDetail>
+    suspend fun getRecentlyViewPolicies(): Result<List<Policy>>
 }

core/domain/src/main/java/com/core/domain/usercase/policydetail/GetPolicyDetailUseCase.kt

@@ -3,10 +3,9 @@ package com.core.domain.usercase.policydetail
 import com.core.dataapi.repository.PolicyRepository
 import com.youthtalk.model.policy.PolicyDetail
 import javax.inject.Inject
-import kotlinx.coroutines.flow.Flow
 
 class GetPolicyDetailUseCase @Inject constructor(
     private val policyRepository: PolicyRepository
 ) {
-    operator fun invoke(policyId: Long): Flow<PolicyDetail> = policyRepository.getPolicyDetail(policyId)
+    suspend operator fun invoke(policyId: Long): Result<PolicyDetail> = policyRepository.getPolicyDetail(policyId)
 }

feature/home/src/main/java/com/core/home/viewmodel/NewPolicyViewModel.kt

@@ -62,10 +62,7 @@ class NewPolicyViewModel @Inject constructor(
         viewModelScope.launch {
             state.value.policyId?.let { policyId ->
                 getPolicyDetailUseCase(policyId)
-                    .catch {
-                        Timber.e("NewPolicyViewModel refresh error $it")
-                    }
-                    .collectLatest { policyDetail ->
+                    .onSuccess { policyDetail ->
                         setState {
                             copy(
                                 newPolicies = newPolicies.copy(