FuelOkHttpClientForHttpPatch sample using OkHttpClient

FuelOkHttpClientForHttpPatch.kt

package com.rcgonzalezf.example.common.network

import com.github.kittinunf.fuel.core.Client
import com.github.kittinunf.fuel.core.FuelError
import com.github.kittinunf.fuel.core.Request
import com.github.kittinunf.fuel.core.Response
import okhttp3.MediaType
import okhttp3.OkHttpClient
import okhttp3.RequestBody
import java.io.ByteArrayInputStream
import java.io.ByteArrayOutputStream
import java.io.IOException
import java.util.zip.GZIPInputStream

/**
 * Create just to support simple patch operations f
 */
class FuelOkHttpClientForHttpPatch : Client {

    override fun executeRequest(request: Request): Response {
        val body = RequestBody.create(MediaType.parse("application/json; charset=utf-8"),
                ByteArrayOutputStream().apply {
                    request.bodyCallback?.invoke(request, this, 0)
                }.toByteArray())

        val okHttpRequestBuilder = okhttp3.Request
                .Builder()
                .url(request.url)
                .patch(body)
        request.headers.entries.map { okHttpRequestBuilder.header(it.key, it.value) }


        try {
            val okHttpRequest: okhttp3.Request = okHttpRequestBuilder.build()
            val okHttpResponse = OkHttpClient().newCall(okHttpRequest).execute()

            val responseBody = okHttpResponse.body()
            if (responseBody != null) {
                val contentEncoding = responseBody.contentType()?.toString() ?: ""
                return Response(
                        url = request.url,
                        headers = okHttpResponse.headers().toMultimap(),
                        contentLength = responseBody.contentLength(),
                        statusCode = okHttpResponse.code(),
                        responseMessage = okHttpResponse.message(),
                        dataStream = try {
                            val stream = responseBody.byteStream()
                            if (contentEncoding.compareTo("gzip", true) == 0)
                                GZIPInputStream(stream)
                            else stream
                        } catch (exception: IOException) {
                            try {
                                responseBody.byteStream().close()
                            } catch (exception: IOException) {
                            }
                            ByteArrayInputStream(ByteArray(0))
                        }
                )
            } else {
                throw FuelError(Exception("Failed to sign up"), ByteArray(0), Response(request.url))
            }

        } catch (exception: Exception) {
            throw FuelError(exception, ByteArray(0), Response(request.url))
        }
    }
}