package de.nccloud.common.v0.models

import com.jakewharton.retrofit2.adapter.rxjava2.HttpException
import io.apibuilder.app.ApiNetworkCallResponse
import io.apibuilder.app.CommonNetworkErrors
import io.apibuilder.app.EitherCallOrCommonNetworkError
import io.apibuilder.app.EitherCallOrCommonNetworkError.CallError
import io.apibuilder.app.EitherCallOrCommonNetworkError.CommonNetworkError
import io.reactivex.Single
import kotlin.Throwable
import kotlin.Unit
import retrofit2.Response
import retrofit2.http.GET

/**
 * This code was generated by [models.generator.kotlin.KotlinGenerator]
 */
interface HealthChecksClient {
  /**
   * Get the current health of the service.
   */
  @GET(value="_internal_/healthcheck")
  fun getInternalHealthcheck(): Single<Response<HealthCheck>>

  /**
   * Endpoint for readiness probe.
   */
  @GET(value="_internal_/probe/ready")
  fun getInternalProbeReady(): Single<Response<Unit>>

  /**
   * Endpoint for liveliness probe.
   */
  @GET(value="_internal_/probe/live")
  fun getInternalProbeLive(): Single<Response<Unit>>

  object GetInternalProbeReadyCall {
    val toError: (Throwable) -> EitherCallOrCommonNetworkError<ErrorResponses> = {
    t ->
                    when (t) {
                        is HttpException -> {
                            val body: String? = t.response().errorBody()?.string()
                                when (t.code()) {
                                400 -> CallError<ErrorResponses> (ErrorResponses.Error400)
                            else ->
        CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t))
                            }
                        }
                        else -> CommonNetworkError(CommonNetworkErrors.processCommonNetworkError(t))
                    }
                }


    fun getCallAndErrorLambda(client: HealthChecksClient) = ApiNetworkCallResponse(
       client.getInternalProbeReady()
         .map{ response -> 
             if(response.isSuccessful)
               Pair(Unit, response.code())
             else
               throw HttpException(response)}
         .map{it}
    , toError)

    /**
     * Error Responses for getInternalProbeReady - Endpoint for readiness probe.
     */
    sealed class ErrorResponses {
      object Error400 : ErrorResponses()
    }
  }
}