package io.gimbalabs.hilltop.api.v0.models import com.jakewharton.retrofit2.adapter.rxjava2.HttpException import io.apibuilder.app.ApiNetworkCallResponse import io.apibuilder.app.CommonNetworkErrors import io.apibuilder.app.CommonNetworkErrors.UnknownNetworkError import io.apibuilder.app.EitherCallOrCommonNetworkError import io.apibuilder.app.EitherCallOrCommonNetworkError.CallError import io.apibuilder.app.EitherCallOrCommonNetworkError.CommonNetworkError import io.reactivex.Single import kotlin.Long import kotlin.Throwable import org.threeten.bp.LocalDate import retrofit2.Response import retrofit2.http.GET import retrofit2.http.Path import retrofit2.http.Query /** * This code was generated by [models.generator.kotlin.KotlinGenerator] */ interface BlocksClient { @GET(value="blocks/blocks_in_day") fun getBlocksBlocksInDay(@Query(value="date") date: LocalDate): Single> @GET(value="blocks/{block_number}") fun getBlocksBlockNumber(@Path(value="block_number") blockNumber: Long): Single> object GetBlocksBlocksInDayCall { val toError: (Throwable) -> EitherCallOrCommonNetworkError = { t -> when (t) { is HttpException -> { val body: String? = t.response().errorBody()?.string() when (t.code()) { 404 -> body?.let { CallError(ErrorResponses.Error404(GenericError.parseJson(body))) } ?: CommonNetworkError(UnknownNetworkError(404, "No Body")) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda(client: BlocksClient, date: LocalDate) = ApiNetworkCallResponse( client.getBlocksBlocksInDay(date) .map{ response -> if(response.isSuccessful) response.body()?.let { body -> Pair(body, response.code())} else throw HttpException(response)} .map{it} , toError) sealed class ErrorResponses { data class Error404( val data: GenericError ) : ErrorResponses() } } object GetBlocksBlockNumberCall { val toError: (Throwable) -> EitherCallOrCommonNetworkError = { t -> when (t) { is HttpException -> { val body: String? = t.response().errorBody()?.string() when (t.code()) { 404 -> body?.let { CallError(ErrorResponses.Error404(GenericError.parseJson(body))) } ?: CommonNetworkError(UnknownNetworkError(404, "No Body")) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda(client: BlocksClient, blockNumber: Long) = ApiNetworkCallResponse( client.getBlocksBlockNumber(blockNumber) .map{ response -> if(response.isSuccessful) response.body()?.let { body -> Pair(body, response.code())} else throw HttpException(response)} .map{it} , toError) sealed class ErrorResponses { data class Error404( val data: GenericError ) : ErrorResponses() } } }