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.String
import kotlin.Throwable
import kotlin.collections.List
import retrofit2.Response
import retrofit2.http.Body
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 UsersClient {
  /**
   * Search for a specific user. You must specify at least 1 parameter - either a id or email - and
   * will receive back either 0 or 1 users.
   */
  @GET(value="users")
  fun getUsers(
    @Query(value="id") id: String?,
    @Query(value="email") email: String?,
    @Query(value="identifier") identifier: String?
  ): Single<Response<List<io.flow.common.v0.models.User>>>

  /**
   * Returns information about the user with this id.
   */
  @GET(value="users/{id}")
  fun getUsersId(@Path(value="id") id: String): Single<Response<io.flow.common.v0.models.User>>

  /**
   * Returns the latest identifier for this user. The basic use case is to enable things like
   * unsubscribe w/out  login (and thus once you have an identifier, you can GET
   * /users?identifier=xxx). Identifiers are rotated regularly with last n identifiers being valid
   * (allowing eventual expiration).
   */
  @GET(value="users/{id}/identifier")
  fun getUsersIdIdentifier(@Path(value="id") id: String): Single<Response<UserIdentifier>>

  /**
   * Create a new user.
   */
  @POST(value="users")
  fun postUsers(@Body userForm: UserForm): Single<Response<io.flow.common.v0.models.User>>

  object GetUsersCall {
    val toError: (Throwable) -> EitherCallOrCommonNetworkError<ErrorResponses> = {
    t ->
                    when (t) {
                        is HttpException -> {
                            val body: String? = t.response().errorBody()?.string()
                                when (t.code()) {
                                401 -> CallError<ErrorResponses> (ErrorResponses.Error401)
                                422 -> body?.let {
        CallError<ErrorResponses>(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: UsersClient,
      id: String?,
      email: String?,
      identifier: String?
    ) = ApiNetworkCallResponse(
       client.getUsers(id,email,identifier)
         .map{ response -> 
             if(response.isSuccessful)
               response.body()?.let { body -> Pair(body, response.code())}
             else
               throw HttpException(response)}
         .map{it}
    , toError)

    /**
     * Error Responses for getUsers - Search for a specific user. You must specify at least 1
     * parameter - either a id or email - and will receive back either 0 or 1 users.
     */
    sealed class ErrorResponses {
      object Error401 : ErrorResponses()

      data class Error422(
        val data: io.flow.error.v0.models.GenericError
      ) : ErrorResponses()
    }
  }

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


    fun getCallAndErrorLambda(client: UsersClient, id: String) = ApiNetworkCallResponse(
       client.getUsersId(id)
         .map{ response -> 
             if(response.isSuccessful)
               response.body()?.let { body -> Pair(body, response.code())}
             else
               throw HttpException(response)}
         .map{it}
    , toError)

    /**
     * Error Responses for getUsersId - Returns information about the user with this id.
     */
    sealed class ErrorResponses {
      object Error401 : ErrorResponses()

      object Error404 : ErrorResponses()
    }
  }

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


    fun getCallAndErrorLambda(client: UsersClient, id: String) = ApiNetworkCallResponse(
       client.getUsersIdIdentifier(id)
         .map{ response -> 
             if(response.isSuccessful)
               response.body()?.let { body -> Pair(body, response.code())}
             else
               throw HttpException(response)}
         .map{it}
    , toError)

    /**
     * Error Responses for getUsersIdIdentifier - Returns the latest identifier for this user. The
     * basic use case is to enable things like unsubscribe w/out  login (and thus once you have an
     * identifier, you can GET /users?identifier=xxx). Identifiers are rotated regularly with last n
     * identifiers being valid (allowing eventual expiration).
     */
    sealed class ErrorResponses {
      object Error401 : ErrorResponses()

      object Error404 : ErrorResponses()
    }
  }

  object PostUsersCall {
    val toError: (Throwable) -> EitherCallOrCommonNetworkError<ErrorResponses> = {
    t ->
                    when (t) {
                        is HttpException -> {
                            val body: String? = t.response().errorBody()?.string()
                                when (t.code()) {
                                422 -> body?.let {
        CallError<ErrorResponses>(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: UsersClient, userForm: UserForm) = ApiNetworkCallResponse(
       client.postUsers(userForm)
         .map{ response -> 
             if(response.isSuccessful)
               response.body()?.let { body -> Pair(body, response.code())}
             else
               throw HttpException(response)}
         .map{it}
    , toError)

    /**
     * Error Responses for postUsers - Create a new user.
     */
    sealed class ErrorResponses {
      data class Error422(
        val data: io.flow.error.v0.models.GenericError
      ) : ErrorResponses()
    }
  }
}