Fast-android-networking: Kotlin Coroutine Support

[GulajavaMinistudio]

Fast Android Networking have been support RxJava for beginning. And can you add support for Kotlin Coroutine in this library ?

Or any tips and tricks about how to use Fast Android Networking with Kotlin Coroutine ?

[Pfuster12]

If I'm not mistaken, you can create a synchronous request, so you can wrap it in a coroutine scope.

CoroutineScope(Dispatcher.Main).launch { synchronousRequest() }

[heskadon]

Is there anyone has an example of how to implement Fast Android Networking with Kotlin Coroutine?

[yogeshpaliyal]

I hope this will help
```kotlin
/*
CREATED BY : yogesh ON 07/08/20 10:58 AM
*/

open class BaseCaller {

val params: HashMap<String, String> by lazy {
    HashMap<String, String>()
}

val files: HashMap<String, File?> by lazy {
    HashMap<String, File?>()
}

suspend fun hitApiGet(
    api: String,
    params: HashMap<String, String>? = null, checkAuthentication: Boolean = true
): Resource<BaseApiModel> {
    return hitApiGet(api, params, BaseApiModel::class.java,checkAuthentication)
}

suspend fun <T> hitApiGet(
    api: String,
    params: HashMap<String, String>? = null,
    objectType: Class<T>, checkAuthentication: Boolean = true
): Resource<T> {
    val request = AndroidNetworking.get(api)
        .addQueryParameter(params)
        .addHeaders(getHeader())
        .build()

    return request.fetch(objectType,checkAuthentication)
}

suspend fun hitApiUpload(
    api: String,
    params: HashMap<String, String>? = null,
    files: HashMap<String, File?>? = null, checkAuthentication: Boolean = true
): Resource<BaseApiModel> {
    return hitApiUpload(api, params, files, BaseApiModel::class.java, checkAuthentication)
}

suspend fun <T> hitApiUpload(
    api: String,
    params: HashMap<String, String>? = null,
    files: HashMap<String, File?>? = null,
    objectType: Class<T>, checkAuthentication: Boolean = true
): Resource<T> {
    val request = AndroidNetworking.upload(api)
        .addMultipartParameter(params)
        .addMultipartFile(files)
        .setOkHttpClient(OkHttpClient())
        .addHeaders(getHeader())
        .build()

    return request.fetch(objectType,checkAuthentication)
}

private suspend fun <T> ANRequest<*>.fetch(objectType: Class<T>,checkAuthentication: Boolean): Resource<T> = withContext(Dispatchers.IO){
    val response = executeForObject(BaseApiModel::class.java)
    try {
        if (response.isSuccess) {
            if (response.result is BaseApiModel) {
                val baseApiModel = response.result as BaseApiModel
                if (baseApiModel.code == 200) {
                    if (objectType.isAssignableFrom(BaseApiModel::class.java))
                        return@withContext Resource.success<T>(baseApiModel as T, baseApiModel.message)
                    val formatted = Gson().fromJson(baseApiModel.data, objectType)
                    return@withContext  Resource.success<T>(formatted, baseApiModel.message)
                } else {
                    return@withContext  onGettingError(ANError().apply {
                        errorCode = baseApiModel.code
                        this.errorBody = Gson().toJson(baseApiModel).toString()
                    },checkAuthentication)
                }
            } else {
                return@withContext  Resource.error<T>("Some error occurred")
            }
        }
    }catch (e:Exception){
        e.printStackTrace()
        return@withContext  Resource.error<T>("Some error occurred")
    }
    return@withContext  onGettingError(response.error,checkAuthentication)
}

suspend fun hitApi(
    api: String,
    params: HashMap<String, String>? = null, checkAuthentication: Boolean = true,headers: HashMap<String, String>? = null
): Resource<BaseApiModel> {
    return hitApi(api, params, BaseApiModel::class.java, checkAuthentication,headers)
}

suspend fun <T> hitApi(
    api: String,
    params: HashMap<String, String>? = null,
    objectType: Class<T>, checkAuthentication: Boolean = true, headers: HashMap<String, String>? = null
): Resource<T> {

    val request = AndroidNetworking.post(api)
        .addBodyParameter(params)
        .addHeaders(getHeader())
        .addHeaders(headers)
        .build()

    return request.fetch(objectType,checkAuthentication)
}


private fun <T> onGettingError(anError: ANError, checkAuthentication: Boolean): Resource<T> {
     if (anError.errorCode == 401) {
         if (checkAuthentication)
             MyApplication.getInstance().logout()
         return Resource.error<T>("User Logout")
     } else if (anError.errorCode != 0) {
        // received error from server
        // error.getErrorCode() - the error code from server
        // error.getErrorBody() - the error body from server
        // error.getErrorDetail() - just an error detail
        //Log.d(TAG, "onError errorCode : " + anError.getErrorCode());
        //Log.d(TAG, "onError errorBody : " + anError.getErrorBody());
        //Log.d(TAG, "onError errorDetail : " + anError.getErrorDetail());
        // get parsed error object (If ApiError is your class)
        try {
            LogHelper.logD("Error",anError.errorBody)
            val apiError = anError.getErrorAsObject(BaseApiModel::class.java)
            return Resource.error<T>(apiError.message)
        } catch (e: Exception) {
            return Resource.error<T>("Parsing Error")
            e.printStackTrace()
        }
    } else {
        // error.getErrorDetail() : connectionError, parseError, requestCancelledError
        //Log.d(TAG, "onError errorDetail : " + anError.getErrorDetail());
        return when (anError.errorDetail) {
            ANConstants.REQUEST_CANCELLED_ERROR -> Resource.error<T>("Request Cancelled")
            ANConstants.CONNECTION_ERROR -> Resource.error<T>("No internet connected")
            else -> Resource.error<T>("Some Error occurred")
        }
    }
}


protected fun getHeader(): HashMap<String, String> {
    val map = HashMap<String, String>()
    map.put("platform", "A")
    map.put("os_version", Build.VERSION.SDK_INT.toString())
   // map["device_id"] = getDeviceId()
   // map["X-localization"] = PreferenceLocaleStore(MyApplication.getInstance(), Locale(Languages.ENGLISH)).getLocale().language
    map["app_version"] = BuildConfig.VERSION_NAME
    map["time"] = System.currentTimeMillis().toString()
    map["timezone"] = TimeZone.getDefault().id
    map["Accept"] = "application/json"
    val token = MyApplication.getInstance().getLoginToken()
    if (!token.trim().isBlank())
        map["Authorization"] = "Bearer $token"
    return map
}

}`