/** * Generated by API Builder - https://www.apibuilder.io * Service version: 0.0.1-swagger-public * User agent: apibuilder app.apibuilder.io/danitest/competition-api-from-swagger/0.0.1-swagger-public/async_http_2_5_client */ package DaniTest.competition.api.from.swagger.v0.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: _root_.scala.Option[String] = None, status: DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus, startAt: _root_.org.joda.time.DateTime, endAt: _root_.org.joda.time.DateTime, createdAt: _root_.org.joda.time.DateTime, updatedAt: _root_.org.joda.time.DateTime ) /** * 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 ) sealed trait CompetitionStatus extends _root_.scala.Product with _root_.scala.Serializable object CompetitionStatus { case object Pending extends CompetitionStatus { override def toString = "pending" } case object Active extends CompetitionStatus { override def toString = "active" } 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 to 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) } } package DaniTest.competition.api.from.swagger.v0.models { package object json { import play.api.libs.json.__ import play.api.libs.json.JsString import play.api.libs.json.Writes import play.api.libs.functional.syntax._ import DaniTest.competition.api.from.swagger.v0.models.json._ private[v0] implicit val jsonReadsUUID: play.api.libs.json.Reads[_root_.java.util.UUID] = __.read[String].map { str => _root_.java.util.UUID.fromString(str) } private[v0] implicit val jsonWritesUUID: play.api.libs.json.Writes[_root_.java.util.UUID] = (x: _root_.java.util.UUID) => play.api.libs.json.JsString(x.toString) private[v0] implicit val jsonReadsJodaDateTime: play.api.libs.json.Reads[_root_.org.joda.time.DateTime] = __.read[String].map { str => _root_.org.joda.time.format.ISODateTimeFormat.dateTimeParser.parseDateTime(str) } private[v0] implicit val jsonWritesJodaDateTime: play.api.libs.json.Writes[_root_.org.joda.time.DateTime] = (x: _root_.org.joda.time.DateTime) => { play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(x)) } private[v0] implicit val jsonReadsJodaLocalDate: play.api.libs.json.Reads[_root_.org.joda.time.LocalDate] = __.read[String].map { str => _root_.org.joda.time.format.ISODateTimeFormat.dateTimeParser.parseLocalDate(str) } private[v0] implicit val jsonWritesJodaLocalDate: play.api.libs.json.Writes[_root_.org.joda.time.LocalDate] = (x: _root_.org.joda.time.LocalDate) => { play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.date.print(x)) } implicit val jsonReadsCompetitionAPIFromSwaggerCompetitionStatus: play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus] = new play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus(v)) case _: play.api.libs.json.JsError => (js \ "CompetitionStatus").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesCompetitionAPIFromSwaggerCompetitionStatus(obj: DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus) = { play.api.libs.json.JsString(obj.toString) } def jsObjectCompetitionStatus(obj: DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesCompetitionAPIFromSwaggerCompetitionStatus: play.api.libs.json.Writes[CompetitionStatus] = { (obj: DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus) => { DaniTest.competition.api.from.swagger.v0.models.json.jsonWritesCompetitionAPIFromSwaggerCompetitionStatus(obj) } } implicit def jsonReadsCompetitionAPIFromSwaggerCompetition: play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.Competition] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] name <- (__ \ "name").readNullable[String] status <- (__ \ "status").read[DaniTest.competition.api.from.swagger.v0.models.CompetitionStatus] startAt <- (__ \ "start_at").read[_root_.org.joda.time.DateTime] endAt <- (__ \ "end_at").read[_root_.org.joda.time.DateTime] createdAt <- (__ \ "created_at").read[_root_.org.joda.time.DateTime] updatedAt <- (__ \ "updated_at").read[_root_.org.joda.time.DateTime] } yield Competition(guid, name, status, startAt, endAt, createdAt, updatedAt) } def jsObjectCompetition(obj: DaniTest.competition.api.from.swagger.v0.models.Competition): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "guid" -> play.api.libs.json.JsString(obj.guid.toString), "status" -> play.api.libs.json.JsString(obj.status.toString), "start_at" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.startAt)), "end_at" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.endAt)), "created_at" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.createdAt)), "updated_at" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.updatedAt)) ) ++ (obj.name match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("name" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesCompetitionAPIFromSwaggerCompetition: play.api.libs.json.Writes[Competition] = { (obj: DaniTest.competition.api.from.swagger.v0.models.Competition) => { DaniTest.competition.api.from.swagger.v0.models.json.jsObjectCompetition(obj) } } implicit def jsonReadsCompetitionAPIFromSwaggerCompetitionParticipant: play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.CompetitionParticipant] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] competitionId <- (__ \ "competition_id").read[_root_.java.util.UUID] competitorId <- (__ \ "competitor_id").read[_root_.java.util.UUID] } yield CompetitionParticipant(guid, competitionId, competitorId) } def jsObjectCompetitionParticipant(obj: DaniTest.competition.api.from.swagger.v0.models.CompetitionParticipant): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "guid" -> play.api.libs.json.JsString(obj.guid.toString), "competition_id" -> play.api.libs.json.JsString(obj.competitionId.toString), "competitor_id" -> play.api.libs.json.JsString(obj.competitorId.toString) ) } implicit def jsonWritesCompetitionAPIFromSwaggerCompetitionParticipant: play.api.libs.json.Writes[CompetitionParticipant] = { (obj: DaniTest.competition.api.from.swagger.v0.models.CompetitionParticipant) => { DaniTest.competition.api.from.swagger.v0.models.json.jsObjectCompetitionParticipant(obj) } } implicit def jsonReadsCompetitionAPIFromSwaggerCompetitor: play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.Competitor] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] name <- (__ \ "name").read[String] } yield Competitor(guid, name) } def jsObjectCompetitor(obj: DaniTest.competition.api.from.swagger.v0.models.Competitor): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "guid" -> play.api.libs.json.JsString(obj.guid.toString), "name" -> play.api.libs.json.JsString(obj.name) ) } implicit def jsonWritesCompetitionAPIFromSwaggerCompetitor: play.api.libs.json.Writes[Competitor] = { (obj: DaniTest.competition.api.from.swagger.v0.models.Competitor) => { DaniTest.competition.api.from.swagger.v0.models.json.jsObjectCompetitor(obj) } } implicit def jsonReadsCompetitionAPIFromSwaggerVote: play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.Vote] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] competitionParticipantId <- (__ \ "competition_participant_id").read[_root_.java.util.UUID] voterId <- (__ \ "voter_id").read[_root_.java.util.UUID] `type` <- (__ \ "type").read[String] points <- (__ \ "points").read[Int] } yield Vote(guid, competitionParticipantId, voterId, `type`, points) } def jsObjectVote(obj: DaniTest.competition.api.from.swagger.v0.models.Vote): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "guid" -> play.api.libs.json.JsString(obj.guid.toString), "competition_participant_id" -> play.api.libs.json.JsString(obj.competitionParticipantId.toString), "voter_id" -> play.api.libs.json.JsString(obj.voterId.toString), "type" -> play.api.libs.json.JsString(obj.`type`), "points" -> play.api.libs.json.JsNumber(obj.points) ) } implicit def jsonWritesCompetitionAPIFromSwaggerVote: play.api.libs.json.Writes[Vote] = { (obj: DaniTest.competition.api.from.swagger.v0.models.Vote) => { DaniTest.competition.api.from.swagger.v0.models.json.jsObjectVote(obj) } } implicit def jsonReadsCompetitionAPIFromSwaggerVoter: play.api.libs.json.Reads[DaniTest.competition.api.from.swagger.v0.models.Voter] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] name <- (__ \ "name").read[String] } yield Voter(guid, name) } def jsObjectVoter(obj: DaniTest.competition.api.from.swagger.v0.models.Voter): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "guid" -> play.api.libs.json.JsString(obj.guid.toString), "name" -> play.api.libs.json.JsString(obj.name) ) } implicit def jsonWritesCompetitionAPIFromSwaggerVoter: play.api.libs.json.Writes[Voter] = { (obj: DaniTest.competition.api.from.swagger.v0.models.Voter) => { DaniTest.competition.api.from.swagger.v0.models.json.jsObjectVoter(obj) } } } } package DaniTest.competition.api.from.swagger.v0 { import org.asynchttpclient.{AsyncCompletionHandler, AsyncHttpClient, Realm, Request, RequestBuilder, Response, DefaultAsyncHttpClient, DefaultAsyncHttpClientConfig} object Constants { val Namespace = "DaniTest.competition.api.from.swagger.v0" val UserAgent = "apibuilder app.apibuilder.io/danitest/competition-api-from-swagger/0.0.1-swagger-public/async_http_2_5_client" val Version = "0.0.1-swagger-public" val VersionMajor = 0 } class Client( val baseUrl: String, auth: scala.Option[DaniTest.competition.api.from.swagger.v0.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, asyncHttpClient: AsyncHttpClient = Client.defaultAsyncHttpClient ) extends interfaces.Client { import org.slf4j.{Logger, LoggerFactory} import DaniTest.competition.api.from.swagger.v0.models.json._ def closeAsyncHttpClient(): Unit = { asyncHttpClient.close() } val logger = LoggerFactory.getLogger(getClass) def competitions: Competitions = Competitions def competitors: Competitors = Competitors object Competitions extends Competitions { override def post( competition: DaniTest.competition.api.from.swagger.v0.models.Competition, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competition] = { val payload = play.api.libs.json.Json.toJson(competition) _executeRequest("POST", s"/competitions", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 201 => _root_.DaniTest.competition.api.from.swagger.v0.Client.parseJson("DaniTest.competition.api.from.swagger.v0.models.Competition", r, _.validate[DaniTest.competition.api.from.swagger.v0.models.Competition]) case r => throw DaniTest.competition.api.from.swagger.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201", requestUri = Some(r.getUri.toJavaNetURI)) } } override def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competition] = { _executeRequest("GET", s"/competitions/${_root_.DaniTest.competition.api.from.swagger.v0.PathSegment.encode(id, "UTF-8")}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.DaniTest.competition.api.from.swagger.v0.Client.parseJson("DaniTest.competition.api.from.swagger.v0.models.Competition", r, _.validate[DaniTest.competition.api.from.swagger.v0.models.Competition]) case r => throw DaniTest.competition.api.from.swagger.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } } object Competitors extends Competitors { override def post( competitor: DaniTest.competition.api.from.swagger.v0.models.Competitor, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competitor] = { val payload = play.api.libs.json.Json.toJson(competitor) _executeRequest("POST", s"/competitors", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 201 => _root_.DaniTest.competition.api.from.swagger.v0.Client.parseJson("DaniTest.competition.api.from.swagger.v0.models.Competitor", r, _.validate[DaniTest.competition.api.from.swagger.v0.models.Competitor]) case r => throw DaniTest.competition.api.from.swagger.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201", requestUri = Some(r.getUri.toJavaNetURI)) } } override def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competitor] = { _executeRequest("GET", s"/competitors/${_root_.DaniTest.competition.api.from.swagger.v0.PathSegment.encode(id, "UTF-8")}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.DaniTest.competition.api.from.swagger.v0.Client.parseJson("DaniTest.competition.api.from.swagger.v0.models.Competitor", r, _.validate[DaniTest.competition.api.from.swagger.v0.models.Competitor]) case r => throw DaniTest.competition.api.from.swagger.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } } def _logRequest(request: Request): Unit = { if (logger.isInfoEnabled) { logger.info("_logRequest: " + request) } } def _logResponse(response: Response): Unit = { if (logger.isInfoEnabled) { logger.info("_logResponse: status=" + response.getStatusCode + ", responseBody: " + response.getResponseBody(java.nio.charset.Charset.forName("UTF-8"))) } } def _requestBuilder(method: String, path: String, requestHeaders: Seq[(String, String)]): RequestBuilder = { val builder = new RequestBuilder(method) .setUrl(baseUrl + path) .addHeader("User-Agent", Constants.UserAgent) .addHeader("X-Apidoc-Version", Constants.Version) .addHeader("X-Apidoc-Version-Major", Constants.VersionMajor.toString) defaultHeaders.foreach { h => builder.addHeader(h._1, h._2) } requestHeaders.foreach { h => builder.addHeader(h._1, h._2) } auth.fold(builder) { case Authorization.Basic(username, passwordOpt) => { builder.setRealm( new Realm.Builder(username, passwordOpt.getOrElse("")) .setUsePreemptiveAuth(true) .setScheme(Realm.AuthScheme.BASIC) .build() ) } case a => sys.error("Invalid authorization scheme[" + a.getClass + "]") } } def _executeRequest( method: String, path: String, queryParameters: Seq[(String, String)] = Nil, requestHeaders: Seq[(String, String)] = Nil, body: Option[play.api.libs.json.JsValue] = None )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.asynchttpclient.Response] = { val allHeaders = body match { case None => requestHeaders case Some(_) => _withJsonContentType(requestHeaders) } val request = _requestBuilder(method, path, allHeaders) queryParameters.foreach { pair => request.addQueryParam(pair._1, pair._2) } val requestWithParamsAndBody = body.fold(request) { b => val serialized = play.api.libs.json.Json.stringify(b) request.setBody(serialized) } val finalRequest = requestWithParamsAndBody.build() _logRequest(finalRequest) val result = scala.concurrent.Promise[org.asynchttpclient.Response]() asyncHttpClient.executeRequest(finalRequest, new AsyncCompletionHandler[Unit]() { override def onCompleted(r: org.asynchttpclient.Response) = { _logResponse(r) result.success(r) } override def onThrowable(t: Throwable) = result.failure(t) } ) result.future } /** * Adds a Content-Type: application/json header unless the specified requestHeaders * already contain a Content-Type header */ def _withJsonContentType(headers: Seq[(String, String)]): Seq[(String, String)] = { headers.find { _._1.toUpperCase == "CONTENT-TYPE" } match { case None => headers ++ Seq(("Content-Type" -> "application/json; charset=UTF-8")) case Some(_) => headers } } } object Client { private lazy val defaultAsyncHttpClient = { new DefaultAsyncHttpClient( new DefaultAsyncHttpClientConfig.Builder().build() ) } def parseJson[T]( className: String, r: _root_.org.asynchttpclient.Response, f: (play.api.libs.json.JsValue => play.api.libs.json.JsResult[T]) ): T = { f(play.api.libs.json.Json.parse(r.getResponseBody(java.nio.charset.Charset.forName("UTF-8")))) match { case play.api.libs.json.JsSuccess(x, _) => x case play.api.libs.json.JsError(errors) => { throw DaniTest.competition.api.from.swagger.v0.errors.FailedRequest(r.getStatusCode, s"Invalid json for class[" + className + "]: " + errors.mkString(" "), requestUri = Some(r.getUri.toJavaNetURI)) } } } } 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: String def competitions: DaniTest.competition.api.from.swagger.v0.Competitions def competitors: DaniTest.competition.api.from.swagger.v0.Competitors } } trait Competitions { def post( competition: DaniTest.competition.api.from.swagger.v0.models.Competition, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competition] def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competition] } trait Competitors { def post( competitor: DaniTest.competition.api.from.swagger.v0.models.Competitor, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competitor] def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[DaniTest.competition.api.from.swagger.v0.models.Competitor] } package errors { final case class FailedRequest(responseCode: Int, message: String, requestUri: Option[_root_.java.net.URI] = None) extends _root_.java.lang.Exception(s"HTTP $responseCode: $message") } object PathSegment { // See https://github.com/playframework/playframework/blob/2.3.x/framework/src/play/src/main/scala/play/utils/UriEncoding.scala def encode(s: String, inputCharset: String): String = { val in = s.getBytes(inputCharset) val out = new java.io.ByteArrayOutputStream() for (b <- in) { val allowed = segmentChars.get(b & 0xFF) if (allowed) { out.write(b) } else { out.write('%') out.write(upperHex((b >> 4) & 0xF)) out.write(upperHex(b & 0xF)) } } out.toString("US-ASCII") } private def upperHex(x: Int): Int = { // Assume 0 <= x < 16 if (x < 10) (x + '0') else (x - 10 + 'A') } private val segmentChars: java.util.BitSet = membershipTable(pchar) private def pchar: Seq[Char] = { val alphaDigit = for ((min, max) <- Seq(('a', 'z'), ('A', 'Z'), ('0', '9')); c <- min to max) yield c val unreserved = alphaDigit ++ Seq('-', '.', '_', '~') val subDelims = Seq('!', '$', '&', '\'', '(', ')', '*', '+', ',', ';', '=') unreserved ++ subDelims ++ Seq(':', '@') } private def membershipTable(chars: Seq[Char]): java.util.BitSet = { val bits = new java.util.BitSet(256) for (c <- chars) { bits.set(c.toInt) } bits } } }