try adding onExpired listener on ApiObserver.kt

Author: yzzzd

.idea/gradle.xml

@@ -14,5 +14,14 @@ class ApiCode {
         const val STATUS = "status"
         const val MESSAGE = "message"
         const val DATA = "data"
+        const val ERROR_MESSAGE = "error"
+
+        const val NOT_FOUND = "not_found" //url tidak ada
+        const val BAD_REQUEST = "bad_request" //request tidak sesuai
+        const val INVALID_TOKEN = "invalid_token" //token salah
+        const val EXPIRED_TOKEN = "expired_token" //token expired
+        const val UNAUTHORIZED = "unauthorized" //token tidak dikirim
+        const val FORBIDDEN = "forbidden" //forbidden
+        const val INVALID_LOGIN = "invalid_login" //credential login tidak sesuai
     }
 }

core/src/main/java/com/crocodic/core/api/ApiCode.kt

@@ -8,23 +8,18 @@ import org.json.JSONObject
  * Created by @yzzzd on 4/22/18.
  */
 
-class ApiObserver(
-    block: suspend () -> String,
-    dispatcher: CoroutineDispatcher,
-    toast: Boolean = false,
-    responseListener: ResponseListener
-) {
+class ApiObserver(block: suspend () -> String, dispatcher: CoroutineDispatcher, toast: Boolean = false, responseListener: ResponseListener) {
 
-    constructor(
-        block: suspend () -> String,
-        toast: Boolean = false,
-        responseListener: ResponseListener
-    ) : this(block, Dispatchers.IO, toast, responseListener)
+    constructor(block: suspend () -> String, toast: Boolean = false, responseListener: ResponseListener) : this(block, Dispatchers.IO, toast, responseListener)
 
     init {
         val exception = CoroutineExceptionHandler { coroutineContext, throwable ->
             val response = ApiResponse(isToast = toast).responseError(throwable)
-            responseListener.onError(response)
+            if (response.isTokenExpired) {
+                responseListener.onExpired(response)
+            } else {
+                responseListener.onError(response)
+            }
         }
 
         CoroutineScope(exception + dispatcher).launch {
@@ -40,37 +35,34 @@ class ApiObserver(
         fun onError(response: ApiResponse) {
             EventBus.getDefault().post(response)
         }
-    }
-}
 
-/**
- * @param block suspend function
- * @param dispatcher Default [Dispatchers.IO]
- * @param toast Default false
- * @param listener Anonymus class to handle response
- */
-suspend fun apiObserver(
-    block: suspend () -> String,
-    dispatcher: CoroutineDispatcher = Dispatchers.IO,
-    toast: Boolean = false,
-    listener: ResponseListener
-) {
-    try {
-        val responseJSON = withContext(dispatcher) {
-            val response = block.invoke()
-            JSONObject(response)
+        fun onExpired(response: ApiResponse) {
+            EventBus.getDefault().post(response)
         }
-        listener.onSuccess(responseJSON)
-    } catch (t: Throwable) {
-        val response = ApiResponse(isToast = toast).responseError(t)
-        listener.onError(response)
     }
-}
-
-interface ResponseListener {
-    suspend fun onSuccess(response: JSONObject)
 
-    suspend fun onError(response: ApiResponse) {
-        EventBus.getDefault().post(response)
+    companion object {
+        /**
+         * @param block suspend function
+         * @param dispatcher Default [Dispatchers.IO]
+         * @param toast Default false
+         * @param listener Anonymous class to handle response
+         */
+        suspend fun apiObserver(block: suspend () -> String, dispatcher: CoroutineDispatcher = Dispatchers.IO, toast: Boolean = false, listener: ResponseListener) {
+            try {
+                val responseJSON = withContext(dispatcher) {
+                    val response = block.invoke()
+                    JSONObject(response)
+                }
+                listener.onSuccess(responseJSON)
+            } catch (t: Throwable) {
+                val response = ApiResponse(isToast = toast).responseError(t)
+                if (response.isTokenExpired) {
+                    listener.onExpired(response)
+                } else {
+                    listener.onError(response)
+                }
+            }
+        }
     }
 }

core/src/main/java/com/crocodic/core/api/ApiObserver.kt

@@ -27,7 +27,15 @@ open class ApiResponse(
             rawResponse?.let { errorBody ->
                 message = try {
                     val responseJson = JSONObject(errorBody)
-                    responseJson.getString("message")
+
+                    val status = responseJson.extractInt(ApiCode.STATUS)
+
+                    if (status == ApiCode.EXPIRED) {
+                        val errorMessage = responseJson.extractString(ApiCode.ERROR_MESSAGE)
+                        this.isTokenExpired = errorMessage?.contains(ApiCode.EXPIRED_TOKEN) == true
+                    }
+
+                    responseJson.extractString(ApiCode.MESSAGE)
                 } catch (e: JSONException) {
                     e.printStackTrace()
                     e.message
@@ -73,4 +81,20 @@ open class ApiResponse(
             null
         }
     }
+
+    fun JSONObject.extractInt(key: String): Int? {
+        return if (this.has(key)) {
+            this.getInt(key)
+        } else {
+            null
+        }
+    }
+
+    fun JSONObject.extractString(key: String): String? {
+        return if (this.has(key)) {
+            this.getString(key)
+        } else {
+            null
+        }
+    }
 }