/** * Generated by API Builder - https://www.apibuilder.io * Service version: 0.0.6-dev * User agent: apibuilder app.apibuilder.io/danitest/competition-api/0.0.6-dev/http4s_0_15 */ package namespace.models { /** * A competition is a race game for the competitors to collect more vote points. * * @param guid Internal unique identifier for this competition. */ final case class Competition( guid: _root_.java.util.UUID, name: String, status: namespace.models.CompetitionStatus, startAt: _root_.java.time.Instant, endAt: _root_.java.time.Instant, createdAt: _root_.java.time.Instant, updatedAt: _root_.java.time.Instant ) /** * The competition participant is a competitor who is playing in a specific * competition and he/she be able to win that. * * @param guid Internal unique identifier for this competition_participant. */ final case class CompetitionParticipant( guid: _root_.java.util.UUID, competitionId: _root_.java.util.UUID, competitorId: _root_.java.util.UUID ) /** * The competitor can who can participate in a competition. * * @param guid Internal unique identifier for this competitor. */ final case class Competitor( guid: _root_.java.util.UUID, name: String ) /** * The vote is created by voter and it concern for a competition_participant * * @param guid Internal unique identifier for this voter. */ final case class Vote( guid: _root_.java.util.UUID, competitionParticipantId: _root_.java.util.UUID, voterId: _root_.java.util.UUID, `type`: String, points: Int ) /** * The voter can vote for competition_participant. * * @param guid Internal unique identifier for this voter. */ final case class Voter( guid: _root_.java.util.UUID, name: String, asdf: String ) sealed trait AppSortBy extends _root_.scala.Product with _root_.scala.Serializable object AppSortBy { case object Name extends AppSortBy { override def toString = "name" } case object CreatedAt extends AppSortBy { override def toString = "created_at" } case object UpdatedAt extends AppSortBy { override def toString = "updated_at" } case object CompetitionStatus extends AppSortBy { override def toString = "competition_status" } /** * UNDEFINED captures values that are sent either in error or * that were added by the server after this library was * generated. We want to make it easy and obvious for users of * this library to handle this case gracefully. * * We use all CAPS for the variable name to avoid collisions * with the camel cased values above. */ final case class UNDEFINED(override val toString: String) extends AppSortBy /** * all returns a list of all the valid, known values. We use * lower case to avoid collisions with the camel cased values * above. */ val all: scala.List[AppSortBy] = scala.List(Name, CreatedAt, UpdatedAt, CompetitionStatus) private val byName: Map[String, AppSortBy] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): AppSortBy = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[AppSortBy] = byName.get(value.toLowerCase) } /** * The actual status of the competition. */ sealed trait CompetitionStatus extends _root_.scala.Product with _root_.scala.Serializable object CompetitionStatus { /** * Prepared competition, waiting for start. */ case object Pending extends CompetitionStatus { override def toString = "pending" } /** * Currently active(running) competition. */ case object Active extends CompetitionStatus { override def toString = "active" } /** * Already closed competition. */ case object Closed extends CompetitionStatus { override def toString = "closed" } /** * UNDEFINED captures values that are sent either in error or * that were added by the server after this library was * generated. We want to make it easy and obvious for users of * this library to handle this case gracefully. * * We use all CAPS for the variable name to avoid collisions * with the camel cased values above. */ final case class UNDEFINED(override val toString: String) extends CompetitionStatus /** * all returns a list of all the valid, known values. We use * lower case to avoid collisions with the camel cased values * above. */ val all: scala.List[CompetitionStatus] = scala.List(Pending, Active, Closed) private val byName: Map[String, CompetitionStatus] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): CompetitionStatus = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[CompetitionStatus] = byName.get(value.toLowerCase) } sealed trait SortOrder extends _root_.scala.Product with _root_.scala.Serializable object SortOrder { case object Asc extends SortOrder { override def toString = "asc" } case object Desc extends SortOrder { override def toString = "desc" } /** * UNDEFINED captures values that are sent either in error or * that were added by the server after this library was * generated. We want to make it easy and obvious for users of * this library to handle this case gracefully. * * We use all CAPS for the variable name to avoid collisions * with the camel cased values above. */ final case class UNDEFINED(override val toString: String) extends SortOrder /** * all returns a list of all the valid, known values. We use * lower case to avoid collisions with the camel cased values * above. */ val all: scala.List[SortOrder] = scala.List(Asc, Desc) private val byName: Map[String, SortOrder] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): SortOrder = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[SortOrder] = byName.get(value.toLowerCase) } /** * The actual status of the competition. */ sealed trait VoteType extends _root_.scala.Product with _root_.scala.Serializable object VoteType { /** * Basic vote. */ case object Basic extends VoteType { override def toString = "basic" } /** * Premium vote. */ case object Premium extends VoteType { override def toString = "premium" } /** * UNDEFINED captures values that are sent either in error or * that were added by the server after this library was * generated. We want to make it easy and obvious for users of * this library to handle this case gracefully. * * We use all CAPS for the variable name to avoid collisions * with the camel cased values above. */ final case class UNDEFINED(override val toString: String) extends VoteType /** * all returns a list of all the valid, known values. We use * lower case to avoid collisions with the camel cased values * above. */ val all: scala.List[VoteType] = scala.List(Basic, Premium) private val byName: Map[String, VoteType] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): VoteType = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[VoteType] = byName.get(value.toLowerCase) } } package namespace.models { package object json { import io.circe.Decoder._ import io.circe.Encoder._ import scala.language.implicitConversions // See below - Make Scala 2.11 Either monadic import scala.util.Try import io.circe.{Json, JsonObject, Encoder, Decoder, DecodingFailure} import io.circe.syntax._ import namespace.models.json._ // Make Scala 2.11 Either monadic private[namespace] implicit def eitherOps[A,B](e: Either[A,B]) = cats.implicits.catsSyntaxEither(e) private[namespace] implicit val decodeUUID: Decoder[_root_.java.util.UUID] = Decoder.decodeString.emapTry(str => Try(_root_.java.util.UUID.fromString(str))) private[namespace] implicit val encodeUUID: Encoder[_root_.java.util.UUID] = Encoder.encodeString.contramap[_root_.java.util.UUID](uuid => uuid.toString) private[namespace] implicit val decodeInstant: Decoder[_root_.java.time.Instant] = Decoder.decodeString.emapTry(str => Try(_root_.java.time.OffsetDateTime.parse(str).toInstant)) private[namespace] implicit val encodeInstant: Encoder[_root_.java.time.Instant] = Encoder.encodeString.contramap[_root_.java.time.Instant](_.toString) private[namespace] implicit val decodeLocalDate: Decoder[_root_.java.time.LocalDate] = Decoder.decodeString.emapTry(str => Try(_root_.java.time.LocalDate.parse(str))) private[namespace] implicit val encodeLocalDate: Encoder[_root_.java.time.LocalDate] = Encoder.encodeString.contramap[_root_.java.time.LocalDate](_.toString) implicit val jsonDecoderCompetitionAPIAppSortBy: Decoder[namespace.models.AppSortBy] = Decoder.decodeString.map(namespace.models.AppSortBy(_)) implicit val jsonEncoderCompetitionAPIAppSortBy: Encoder[namespace.models.AppSortBy] = Encoder.encodeString.contramap[namespace.models.AppSortBy](_.toString) implicit val jsonDecoderCompetitionAPICompetitionStatus: Decoder[namespace.models.CompetitionStatus] = Decoder.decodeString.map(namespace.models.CompetitionStatus(_)) implicit val jsonEncoderCompetitionAPICompetitionStatus: Encoder[namespace.models.CompetitionStatus] = Encoder.encodeString.contramap[namespace.models.CompetitionStatus](_.toString) implicit val jsonDecoderCompetitionAPISortOrder: Decoder[namespace.models.SortOrder] = Decoder.decodeString.map(namespace.models.SortOrder(_)) implicit val jsonEncoderCompetitionAPISortOrder: Encoder[namespace.models.SortOrder] = Encoder.encodeString.contramap[namespace.models.SortOrder](_.toString) implicit val jsonDecoderCompetitionAPIVoteType: Decoder[namespace.models.VoteType] = Decoder.decodeString.map(namespace.models.VoteType(_)) implicit val jsonEncoderCompetitionAPIVoteType: Encoder[namespace.models.VoteType] = Encoder.encodeString.contramap[namespace.models.VoteType](_.toString) implicit def decodeCompetitionAPICompetition: Decoder[Competition] = Decoder.instance { c => for { guid <- c.downField("guid").as[_root_.java.util.UUID] name <- c.downField("name").as[String] status <- c.downField("status").as[namespace.models.CompetitionStatus] startAt <- c.downField("start_at").as[_root_.java.time.Instant] endAt <- c.downField("end_at").as[_root_.java.time.Instant] createdAt <- c.downField("created_at").as[_root_.java.time.Instant] updatedAt <- c.downField("updated_at").as[_root_.java.time.Instant] } yield { Competition( guid = guid, name = name, status = status, startAt = startAt, endAt = endAt, createdAt = createdAt, updatedAt = updatedAt ) } } implicit def encodeCompetitionAPICompetition: Encoder[Competition] = Encoder.instance { t => Json.fromFields(Seq( Some("guid" -> t.guid.asJson), Some("name" -> t.name.asJson), Some("status" -> t.status.asJson), Some("start_at" -> t.startAt.asJson), Some("end_at" -> t.endAt.asJson), Some("created_at" -> t.createdAt.asJson), Some("updated_at" -> t.updatedAt.asJson) ).flatten) } implicit def decodeCompetitionAPICompetitionParticipant: Decoder[CompetitionParticipant] = Decoder.instance { c => for { guid <- c.downField("guid").as[_root_.java.util.UUID] competitionId <- c.downField("competition_id").as[_root_.java.util.UUID] competitorId <- c.downField("competitor_id").as[_root_.java.util.UUID] } yield { CompetitionParticipant( guid = guid, competitionId = competitionId, competitorId = competitorId ) } } implicit def encodeCompetitionAPICompetitionParticipant: Encoder[CompetitionParticipant] = Encoder.instance { t => Json.fromFields(Seq( Some("guid" -> t.guid.asJson), Some("competition_id" -> t.competitionId.asJson), Some("competitor_id" -> t.competitorId.asJson) ).flatten) } implicit def decodeCompetitionAPICompetitor: Decoder[Competitor] = Decoder.instance { c => for { guid <- c.downField("guid").as[_root_.java.util.UUID] name <- c.downField("name").as[String] } yield { Competitor( guid = guid, name = name ) } } implicit def encodeCompetitionAPICompetitor: Encoder[Competitor] = Encoder.instance { t => Json.fromFields(Seq( Some("guid" -> t.guid.asJson), Some("name" -> t.name.asJson) ).flatten) } implicit def decodeCompetitionAPIVote: Decoder[Vote] = Decoder.instance { c => for { guid <- c.downField("guid").as[_root_.java.util.UUID] competitionParticipantId <- c.downField("competition_participant_id").as[_root_.java.util.UUID] voterId <- c.downField("voter_id").as[_root_.java.util.UUID] __type__ <- c.downField("type").as[String] points <- c.downField("points").as[Int] } yield { Vote( guid = guid, competitionParticipantId = competitionParticipantId, voterId = voterId, `type` = __type__, points = points ) } } implicit def encodeCompetitionAPIVote: Encoder[Vote] = Encoder.instance { t => Json.fromFields(Seq( Some("guid" -> t.guid.asJson), Some("competition_participant_id" -> t.competitionParticipantId.asJson), Some("voter_id" -> t.voterId.asJson), Some("type" -> t.`type`.asJson), Some("points" -> t.points.asJson) ).flatten) } implicit def decodeCompetitionAPIVoter: Decoder[Voter] = Decoder.instance { c => for { guid <- c.downField("guid").as[_root_.java.util.UUID] name <- c.downField("name").as[String] asdf <- c.downField("asdf").as[String] } yield { Voter( guid = guid, name = name, asdf = asdf ) } } implicit def encodeCompetitionAPIVoter: Encoder[Voter] = Encoder.instance { t => Json.fromFields(Seq( Some("guid" -> t.guid.asJson), Some("name" -> t.name.asJson), Some("asdf" -> t.asdf.asJson) ).flatten) } } } package namespace { import org.http4s.client.blaze._ import io.circe.syntax._ object Constants { val BaseUrl = "competition-api.product-domain.com" val Namespace = "namespace" val UserAgent = "apibuilder app.apibuilder.io/danitest/competition-api/0.0.6-dev/http4s_0_15" val Version = "0.0.6-dev" val VersionMajor = 0 } class Client( val baseUrl: org.http4s.Uri = org.http4s.Uri.unsafeFromString("competition-api.product-domain.com"), auth: scala.Option[namespace.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, asyncHttpClient: org.http4s.client.Client = Client.defaultAsyncHttpClient ) extends interfaces.Client { import org.http4s.Response import namespace.models.json._ def closeAsyncHttpClient(): Unit = { asyncHttpClient.shutdownNow() } def competitions: Competitions = Competitions def competitors: Competitors = Competitors object Competitions extends Competitions { override def post( competition: namespace.models.Competition, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competition] = { val urlPath = Seq("competitions") val (payload, formPayload) = (Some(competition), None) _executeRequest[namespace.models.Competition, namespace.models.Competition]("POST", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 201 => _root_.namespace.Client.parseJson[namespace.models.Competition]("namespace.models.Competition", r) case r => scalaz.concurrent.Task.fail(new namespace.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 201")) } } override def getById( id: String, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competition] = { val urlPath = Seq("competitions", id) _executeRequest[Unit, namespace.models.Competition]("GET", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.namespace.Client.parseJson[namespace.models.Competition]("namespace.models.Competition", r) case r => scalaz.concurrent.Task.fail(new namespace.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200")) } } } object Competitors extends Competitors { override def post( competitor: namespace.models.Competitor, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competitor] = { val urlPath = Seq("competitors") val (payload, formPayload) = (Some(competitor), None) _executeRequest[namespace.models.Competitor, namespace.models.Competitor]("POST", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 201 => _root_.namespace.Client.parseJson[namespace.models.Competitor]("namespace.models.Competitor", r) case r => scalaz.concurrent.Task.fail(new namespace.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 201")) } } override def getById( id: String, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competitor] = { val urlPath = Seq("competitors", id) _executeRequest[Unit, namespace.models.Competitor]("GET", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.namespace.Client.parseJson[namespace.models.Competitor]("namespace.models.Competitor", r) case r => scalaz.concurrent.Task.fail(new namespace.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200")) } } } private lazy val defaultApiHeaders = Seq( ("User-Agent", Constants.UserAgent), ("X-Apidoc-Version", Constants.Version), ("X-Apidoc-Version-Major", Constants.VersionMajor.toString) ) def apiHeaders: Seq[(String, String)] = defaultApiHeaders def modifyRequest(request: scalaz.concurrent.Task[org.http4s.Request]): scalaz.concurrent.Task[org.http4s.Request] = request implicit def circeJsonEncoder[A](implicit encoder: io.circe.Encoder[A]) = org.http4s.circe.jsonEncoderOf[A] def _executeRequest[T, U]( method: String, path: Seq[String], queryParameters: Seq[(String, String)] = Nil, requestHeaders: Seq[(String, String)] = Nil, body: Option[T] = None, formBody : Option[org.http4s.UrlForm] = None )(handler: org.http4s.Response => scalaz.concurrent.Task[U] )(implicit encoder: io.circe.Encoder[T]): scalaz.concurrent.Task[U] = { import org.http4s.QueryParamEncoder._ val m = org.http4s.Method.fromString(method) match { case scalaz.\/-(m) => m case scalaz.-\/(e) => sys.error(e.toString) } val headers = org.http4s.Headers(( apiHeaders ++ defaultHeaders ++ requestHeaders ).groupBy(_._1).map { case (k, l) => org.http4s.Header(k, l.last._2) }.toList) val queryMap = queryParameters.groupBy(_._1).map { case (k, v) => k -> v.map(_._2) } val uri = path.foldLeft(baseUrl){ case (uri, segment) => uri / segment }.setQueryParams(queryMap) val request = org.http4s.Request(method = m, uri = uri, headers = headers) val reqAndMaybeAuth = auth.fold(request) { case Authorization.Basic(username, passwordOpt) => { val userpass = s"$username:${passwordOpt.getOrElse("")}" val token = java.util.Base64.getEncoder.encodeToString(userpass.getBytes(java.nio.charset.StandardCharsets.ISO_8859_1)) request.putHeaders(org.http4s.Header("Authorization", s"Basic $token")) } case a => sys.error("Invalid authorization scheme[" + a.getClass + "]") } val reqAndMaybeAuthAndBody = if (formBody.nonEmpty) formBody.fold(scalaz.concurrent.Task.now(reqAndMaybeAuth))(reqAndMaybeAuth.withBody) else body.fold(scalaz.concurrent.Task.now(reqAndMaybeAuth))(reqAndMaybeAuth.withBody) asyncHttpClient.fetch(modifyRequest(reqAndMaybeAuthAndBody))(handler) } } object Client { implicit def circeJsonDecoder[A](implicit decoder: io.circe.Decoder[A]) = org.http4s.circe.jsonOf[A] private lazy val defaultAsyncHttpClient = PooledHttp1Client() def parseJson[T]( className: String, r: org.http4s.Response )(implicit decoder: io.circe.Decoder[T]): scalaz.concurrent.Task[T] = r.attemptAs[T].run.flatMap { case scalaz.\/-(value) => scalaz.concurrent.Task.now(value) case scalaz.-\/(error) => scalaz.concurrent.Task.fail(new namespace.errors.FailedRequest(r.status.code, s"Invalid json for class[" + className + "]", None, error)) } } sealed trait Authorization extends _root_.scala.Product with _root_.scala.Serializable object Authorization { final case class Basic(username: String, password: Option[String] = None) extends Authorization } package interfaces { trait Client { def baseUrl: org.http4s.Uri def competitions: namespace.Competitions def competitors: namespace.Competitors } } trait Competitions { def post( competition: namespace.models.Competition, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competition] def getById( id: String, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competition] } trait Competitors { def post( competitor: namespace.models.Competitor, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competitor] def getById( id: String, requestHeaders: Seq[(String, String)] = Nil ): scalaz.concurrent.Task[namespace.models.Competitor] } package errors { final case class FailedRequest(responseCode: Int, message: String, requestUri: Option[_root_.java.net.URI] = None, parent: Exception = null) extends _root_.java.lang.Exception(s"HTTP $responseCode: $message", parent) } }