#22 - configurando tratamento de erro no API

Author: rviannaoliveira

core-networking/src/main/java/com/codandotv/streamplayerapp/core_networking/handleError/Failure.kt

@@ -6,26 +6,26 @@ package com.codandotv.streamplayerapp.core_networking.handleError
 sealed class Failure(val code: Int? = -1, val errorMessage: String) : java.lang.Exception() {
     data class NoDataContent(val codeStatus: Int? = null) : Failure(codeStatus, "No data content")
     data class ServerError(val codeStatus: Int? = null) : Failure(codeStatus, "Server error!")
-    data class GenericError(val codeStatus: Int? = -1100,
+    data class GenericError(val codeStatus: Int? = -12,
                             private val msg: String? = null) : Failure(codeStatus, msg
             ?: MSG_DEFAULT)
 
-    data class NetworkError(val codeStatus: Int? = -1200,
+    data class NetworkError(val codeStatus: Int? = -13,
                             private val throwable: Throwable) : Failure(codeStatus, "Sem conexão. Verifique o wifi ou dados móveis e tente novamente em alguns instantes.")
 
     data class UnknownError(val codeStatus: Int? = null,
                             private val throwable: Throwable? = Exception()) : Failure(codeStatus, throwable?.message
             ?: MSG_DEFAULT)
 
-    data class UnexpectedApiException(val codeStatus: Int? = -1011,
+    data class UnexpectedApiException(val codeStatus: Int? = -14,
                                       private val throwable: Throwable? = Exception()) : Failure(codeStatus, throwable?.message
             ?: MSG_DEFAULT)
 
-    data class ClientException(val codeStatus: Int? = -1011,
+    data class ClientException(val codeStatus: Int? = -15,
                                private val throwable: Throwable? = Exception()) : Failure(codeStatus, throwable?.message
             ?: MSG_DEFAULT)
 
-    data class UnparsableResponseException(val codeStatus: Int? = -1012,
+    data class UnparsableResponseException(val codeStatus: Int? = -16,
                                            private val throwable: Throwable? = Exception()) : Failure(codeStatus, throwable?.message
             ?: MSG_DEFAULT)
 

core-networking/src/main/java/com/codandotv/streamplayerapp/core_networking/handleError/NetworkResponse.kt

@@ -1,5 +1,8 @@
 package com.codandotv.streamplayerapp.core_networking.handleError
 
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flow
+
 sealed class NetworkResponse<out T> {
     data class Success<out T>(
         val value: T
@@ -20,4 +23,18 @@ fun <T> NetworkResponse<T>.toResult(): Result<T> =
         is NetworkResponse.Error -> {
             Result.failure(this.exception ?: Failure.GenericError())
         }
-    }
+    }
+
+fun <T> NetworkResponse<T>.toFlow(): Flow<T> {
+    val networkResponse = this
+    return flow {
+        when (networkResponse) {
+            is NetworkResponse.Success -> {
+                emit(networkResponse.value)
+            }
+            is NetworkResponse.Error -> {
+                throw networkResponse.exception ?: Failure.GenericError()
+            }
+        }
+    }
+}

core-networking/src/main/java/com/codandotv/streamplayerapp/core_networking/handleError/ResultExtensions.kt

@@ -1,9 +1,21 @@
-
 package com.codandotv.streamplayerapp.core_networking.handleError
 
-inline fun <T> Result<T>.onError(action: (exception: Failure) -> Unit) {
-    if (isFailure && exceptionOrNull() is Failure) {
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.catch
+
+inline fun <T> Result<T>.onError(action: (exception: Failure) -> Unit): Result<T> {
+    if(isFailure && exceptionOrNull() is Failure){
         val error = exceptionOrNull() as Failure
         action(error)
     }
+    return this
 }
+
+fun <T> Flow<T>.catchFailure(action: suspend kotlinx.coroutines.flow.FlowCollector<T>.(Failure) -> Unit): Flow<T> =
+    catch {
+        if(it is Failure){
+            action(it)
+        }else{
+            action(Failure.GenericError())
+        }
+    }

core-networking/src/main/java/com/codandotv/streamplayerapp/core_networking/handleError/flow/FlowCallAdapter.kt

@@ -1,22 +1,24 @@
 package com.codandotv.streamplayerapp.feature_list_streams.data
 
+import com.codandotv.streamplayerapp.core_networking.handleError.toFlow
 import com.codandotv.streamplayerapp.core_networking.handleError.toResult
 import com.codandotv.streamplayerapp.feature_list_streams.domain.model.ListStream
 import com.codandotv.streamplayerapp.feature_list_streams.domain.toListStream
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
 
 interface ListStreamRepository {
-    suspend fun getMovies(): Result<ListStream>
+    suspend fun getMovies(): Flow<ListStream>
 }
 
 class ListStreamRepositoryImpl(
     private val service: ListStreamService
 ) : ListStreamRepository {
 
-    override suspend fun getMovies(): Result<ListStream> =
+    override suspend fun getMovies(): Flow<ListStream> =
         service.getMovies()
-            .toResult()
+            .toFlow()
             .map {
                 it.toListStream()
             }
-
 }

core-networking/src/main/java/com/codandotv/streamplayerapp/core_networking/handleError/flow/FlowCallAdapterFactory.kt

@@ -6,5 +6,5 @@ import retrofit2.http.GET
 
 interface ListStreamService {
     @GET("codandotv")
-    suspend fun getMovies() :  NetworkResponse<ListStreamResponse>
+    suspend fun getMovies() : NetworkResponse<ListStreamResponse>
 }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/data/ListStreamRepository.kt

@@ -7,7 +7,7 @@ import com.codandotv.streamplayerapp.feature_list_streams.domain.ListStreamAnaly
 import com.codandotv.streamplayerapp.feature_list_streams.domain.ListStreamAnalyticsImpl
 import com.codandotv.streamplayerapp.feature_list_streams.domain.ListStreamUseCase
 import com.codandotv.streamplayerapp.feature_list_streams.domain.ListStreamUseCaseImpl
-import com.codandotv.streamplayerapp.feature_list_streams.presentation.ListMovieViewModel
+import com.codandotv.streamplayerapp.feature_list_streams.presentation.ListStreamViewModel
 import com.codandotv.streamplayerapp.feature_list_streams.presentation.ListStreamUiModelImpl
 import com.codandotv.streamplayerapp.feature_list_streams.presentation.ListStreamUimodel
 import org.koin.androidx.viewmodel.dsl.viewModel
@@ -17,7 +17,7 @@ import retrofit2.Retrofit
 object ListStreamModule {
     val module = module {
         viewModel {
-            ListMovieViewModel(
+            ListStreamViewModel(
                 uiModel = get(),
                 useCase = get(),
                 analytics = get()

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/data/ListStreamService.kt

@@ -2,15 +2,16 @@ package com.codandotv.streamplayerapp.feature_list_streams.domain
 
 import com.codandotv.streamplayerapp.feature_list_streams.data.ListStreamRepository
 import com.codandotv.streamplayerapp.feature_list_streams.domain.model.ListStream
+import kotlinx.coroutines.flow.Flow
 
 interface ListStreamUseCase {
-    suspend fun getMovies() : Result<ListStream>
+    suspend fun getMovies() : Flow<ListStream>
 }
 
 class ListStreamUseCaseImpl(
     private val repository: ListStreamRepository
 ) : ListStreamUseCase {
-    override suspend fun getMovies(): Result<ListStream> {
+    override suspend fun getMovies(): Flow<ListStream> {
         println(">>>>>>> Curta o video!!!")
         return repository.getMovies()
     }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/di/ListStreamModule.kt

@@ -9,7 +9,7 @@ import org.koin.core.context.loadKoinModules
 import org.koin.core.context.unloadKoinModules
 
 class ListStreamActivity  : AppCompatActivity() {
-    private val viewModel : ListMovieViewModel by viewModel()
+    private val viewModel : ListStreamViewModel by viewModel()
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
         setContentView(R.layout.activity_list_stream)