Add RxJava error handler

Author: enginebai

base/src/main/java/com/enginebai/base/di/UtilsModule.kt

@@ -1,11 +1,13 @@
 package com.enginebai.base.di
 
 import com.enginebai.base.BuildConfig
+import com.enginebai.base.utils.RxErrorHandler
 import com.enginebai.base.utils.logging.TimberLoggerDebugTree
 import com.google.gson.Gson
 import com.orhanobut.logger.AndroidLogAdapter
 import com.orhanobut.logger.FormatStrategy
 import com.orhanobut.logger.PrettyFormatStrategy
+import org.koin.android.ext.koin.androidApplication
 import org.koin.dsl.module
 import timber.log.Timber
 
@@ -31,4 +33,8 @@ val loggingModule = module {
 
 val gsonModule = module {
     single { Gson() }
+}
+
+val errorHandleModule = module {
+    single(createdAtStart = true) { RxErrorHandler(androidApplication()) }
 }

base/src/main/java/com/enginebai/base/utils/RxErrorHandler.kt

@@ -0,0 +1,52 @@
+package com.enginebai.base.utils
+
+import android.app.Application
+import com.enginebai.base.R
+import io.reactivex.exceptions.OnErrorNotImplementedException
+import io.reactivex.exceptions.UndeliverableException
+import io.reactivex.functions.Consumer
+import io.reactivex.plugins.RxJavaPlugins
+import io.reactivex.subjects.PublishSubject
+import retrofit2.HttpException
+import timber.log.Timber
+import java.net.ConnectException
+import java.net.SocketException
+import java.net.SocketTimeoutException
+import java.net.UnknownHostException
+
+class RxErrorHandler(private val application: Application) : Consumer<Throwable> {
+
+    val errorMessageToDisplay = PublishSubject.create<String>()
+
+    init {
+        RxJavaPlugins.setErrorHandler(this)
+    }
+
+    override fun accept(t: Throwable) {
+        when (val cause = parseCause(t)) {
+            is SocketTimeoutException, is ConnectException, is UnknownHostException, is SocketException -> {
+                Timber.w("Network fail: $cause")
+                errorMessageToDisplay.onNext(application.getString(R.string.error_network_fail))
+            }
+            is HttpException -> {
+                val url = cause.response()?.raw()?.request?.url
+                errorMessageToDisplay.onNext("HTTP ${cause.code()} of $url")
+            }
+            else -> {
+                Timber.e(cause)
+                throw cause
+            }
+        }
+    }
+
+    private fun parseCause(t: Throwable): Throwable {
+        when (t) {
+            is OnErrorNotImplementedException, is UndeliverableException, is RuntimeException -> {
+                t.cause?.run { return this } ?: throw ParseCauseFailException(t)
+            }
+        }
+        return t
+    }
+}
+
+class ParseCauseFailException(t: Throwable) : RuntimeException(t)

base/src/main/res/values/strings.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <string name="error_network_fail">Looks like your are offline.</string>
+</resources>