[FEAT] : 레포지토리 적용 #54

Author: lsakee

data/src/main/java/com/velogm/data/repositoryimpl/TagRepositoryImpl.kt

@@ -1,24 +1,30 @@
 package com.velogm.data.repositoryimpl
 
 import com.velogm.data.datasource.TagDataSource
+import com.velogm.domain.OutResult
 import com.velogm.domain.model.PostList
 import com.velogm.domain.model.Tag
 import com.velogm.domain.repository.TagRepository
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flow
+import retrofit2.HttpException
+import java.lang.RuntimeException
 import javax.inject.Inject
 
 class TagRepositoryImpl @Inject constructor(
     private val dataSource: TagDataSource
 ) : TagRepository {
 
-    override suspend fun getTag(): Flow<List<Tag>> {
-        return flow {
-            val result = kotlin.runCatching {
-                dataSource.getTag().map { Tag(it) }
-            }
-            emit(result.getOrDefault(emptyList()))
+    override suspend fun getTag(): Flow<OutResult<List<Tag>>> = flow {
+        val result = runCatching {
+            val tag = dataSource.getTag().map { Tag(it) }
+            OutResult.Success(tag)
+        }
+        val outcome = result.getOrElse {
+            val errorCode = (it as? HttpException)?.code() ?: -1
+            OutResult.Failure(error = VelogHttpException(errorCode, "$errorCode"))
         }
+        emit(outcome)
     }
 
     override suspend fun getPopularTag(): Flow<List<Tag>> {
@@ -56,4 +62,9 @@ class TagRepositoryImpl @Inject constructor(
             emit(result.getOrDefault(PostList(emptyList())))
         }
     }
-}
+}
+
+class VelogHttpException(
+    val httpCode: Int,
+    override val message: String,
+) : RuntimeException()

domain/src/main/java/com/velogm/domain/repository/TagRepository.kt

@@ -1,11 +1,12 @@
 package com.velogm.domain.repository
 
+import com.velogm.domain.OutResult
 import com.velogm.domain.model.PostList
 import com.velogm.domain.model.Tag
 import kotlinx.coroutines.flow.Flow
 
 interface TagRepository {
-    suspend fun getTag(): Flow<List<Tag>>
+    suspend fun getTag(): Flow<OutResult<List<Tag>>>
     suspend fun getPopularTag():Flow<List<Tag>>
     suspend fun deleteTag(tag:String):Flow<String>
     suspend fun addTag(tag:String):Flow<String>