package io.flow.dependency.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.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.GET import retrofit2.http.POST import retrofit2.http.Path import retrofit2.http.Query /** * This code was generated by [models.generator.kotlin.KotlinGenerator] */ interface LibrariesClient { /** * Search libraries. Results are paginated */ @GET(value="libraries") fun getLibraries( @Query(value="id") id: String?, @Query(value="ids") ids: List?, @Query(value="project_id") projectId: String?, @Query(value="group_id") groupId: String?, @Query(value="artifact_id") artifactId: String?, @Query(value="resolver_id") resolverId: String?, @Query(value="limit") limit: Long, @Query(value="offset") offset: Long ): Single>> /** * Returns information about the library with this id. */ @GET(value="libraries/{id}") fun getLibrariesId(@Path(value="id") id: String): Single> /** * Create a new library. */ @POST(value="libraries") fun postLibraries(@Body libraryForm: LibraryForm): Single> @DELETE(value="libraries/{id}") fun deleteLibrariesId(@Path(value="id") id: String): Single> object GetLibrariesCall { val toError: (Throwable) -> EitherCallOrCommonNetworkError = { t -> when (t) { is HttpException -> { val body: String? = t.response().errorBody()?.string() when (t.code()) { 401 -> CallError (ErrorResponses.Error401) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda( client: LibrariesClient, id: String?, ids: List?, projectId: String?, groupId: String?, artifactId: String?, resolverId: String?, limit: Long, offset: Long ) = ApiNetworkCallResponse( client.getLibraries(id,ids,projectId,groupId,artifactId,resolverId,limit,offset) .map{ response -> if(response.isSuccessful) response.body()?.let { body -> Pair(body, response.code())} else throw HttpException(response)} .map{it} , toError) /** * Error Responses for getLibraries - Search libraries. Results are paginated */ sealed class ErrorResponses { object Error401 : ErrorResponses() } } object GetLibrariesIdCall { 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: LibrariesClient, id: String) = ApiNetworkCallResponse( client.getLibrariesId(id) .map{ response -> if(response.isSuccessful) response.body()?.let { body -> Pair(body, response.code())} else throw HttpException(response)} .map{it} , toError) /** * Error Responses for getLibrariesId - Returns information about the library with this id. */ sealed class ErrorResponses { object Error401 : ErrorResponses() object Error404 : ErrorResponses() } } object PostLibrariesCall { val toError: (Throwable) -> EitherCallOrCommonNetworkError = { t -> when (t) { is HttpException -> { val body: String? = t.response().errorBody()?.string() when (t.code()) { 401 -> CallError (ErrorResponses.Error401) 422 -> body?.let { CallError(ErrorResponses.Error422(io.flow.error.v0.models.GenericError.parseJson(body))) } ?: CommonNetworkError(UnknownNetworkError(422, "No Body")) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda(client: LibrariesClient, libraryForm: LibraryForm) = ApiNetworkCallResponse( client.postLibraries(libraryForm) .map{ response -> if(response.isSuccessful) response.body()?.let { body -> Pair(body, response.code())} else throw HttpException(response)} .map{it} , toError) /** * Error Responses for postLibraries - Create a new library. */ sealed class ErrorResponses { object Error401 : ErrorResponses() data class Error422( val data: io.flow.error.v0.models.GenericError ) : ErrorResponses() } } object DeleteLibrariesIdCall { 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) 422 -> body?.let { CallError(ErrorResponses.Error422(io.flow.error.v0.models.GenericError.parseJson(body))) } ?: CommonNetworkError(UnknownNetworkError(422, "No Body")) else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t)) } } fun getCallAndErrorLambda(client: LibrariesClient, id: String) = ApiNetworkCallResponse( client.deleteLibrariesId(id) .map{ response -> if(response.isSuccessful) Pair(Unit, response.code()) else throw HttpException(response)} .map{it} , toError) sealed class ErrorResponses { object Error401 : ErrorResponses() object Error404 : ErrorResponses() data class Error422( val data: io.flow.error.v0.models.GenericError ) : ErrorResponses() } } }