package com.afrosoft.apibuilder.api.v0.models import com.fasterxml.jackson.core.type.TypeReference 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.String import kotlin.Throwable import kotlin.Unit import kotlin.collections.List import retrofit2.Response import retrofit2.http.Body import retrofit2.http.DELETE import retrofit2.http.POST import retrofit2.http.Path /** * This code was generated by [models.generator.kotlin.KotlinGenerator] */ interface DomainsClient { /** * Add a domain to this organization */ @POST(value="domains/{orgKey}") fun postDomainsOrgKey(@Path(value="orgKey") orgKey: String, @Body domain: Domain): Single> /** * Remove this domain from this organization */ @DELETE(value="domains/{orgKey}/{name}") fun deleteDomainsOrgKeyName(@Path(value="orgKey") orgKey: String, @Path(value="name") name: String): Single> object PostDomainsOrgKeyCall { val toError: (Throwable) -> EitherCallOrCommonNetworkError = { t -> when (t) { is HttpException -> { val body: String? = t.response().errorBody()?.string() when (t.code()) { 409 -> body?.let { CallError(ErrorResponses.Error409(com.afrosoft.apibuilder.api.v0.models.JacksonObjectMapperFactory.create().readValue(body, ErrorListTypeReference ))) } ?: CommonNetworkError(UnknownNetworkError(409, "No Body")) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda( client: DomainsClient, orgKey: String, domain: Domain ) = ApiNetworkCallResponse( client.postDomainsOrgKey(orgKey,domain) .map{ response -> if(response.isSuccessful) response.body()?.let { body -> Pair(body, response.code())} else throw HttpException(response)} .map{it} , toError) object ErrorListTypeReference : TypeReference>() /** * Error Responses for postDomainsOrgKey - Add a domain to this organization */ sealed class ErrorResponses { data class Error409( val data: List ) : ErrorResponses() } } object DeleteDomainsOrgKeyNameCall { val toError: (Throwable) -> EitherCallOrCommonNetworkError = { t -> when (t) { is HttpException -> { val body: String? = t.response().errorBody()?.string() when (t.code()) { 401 -> CallError (ErrorResponses.Error401) 404 -> CallError (ErrorResponses.Error404) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda( client: DomainsClient, orgKey: String, name: String ) = ApiNetworkCallResponse( client.deleteDomainsOrgKeyName(orgKey,name) .map{ response -> if(response.isSuccessful) Pair(Unit, response.code()) else throw HttpException(response)} .map{it} , toError) /** * Error Responses for deleteDomainsOrgKeyName - Remove this domain from this organization */ sealed class ErrorResponses { object Error401 : ErrorResponses() object Error404 : ErrorResponses() } } }