/** * 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/ning_1_8_client */ 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_.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, 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 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 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 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) } 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 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 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 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 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 play.api.libs.json.__ import play.api.libs.json.JsString import play.api.libs.json.Writes import play.api.libs.functional.syntax._ import namespace.models.json._ private[namespace] implicit val jsonReadsUUID: play.api.libs.json.Reads[_root_.java.util.UUID] = __.read[String].map { str => _root_.java.util.UUID.fromString(str) } private[namespace] 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[namespace] 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[namespace] 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[namespace] 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[namespace] 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 jsonReadsCompetitionAPIAppSortBy: play.api.libs.json.Reads[namespace.models.AppSortBy] = new play.api.libs.json.Reads[namespace.models.AppSortBy] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[namespace.models.AppSortBy] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(namespace.models.AppSortBy(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.AppSortBy(v)) case _: play.api.libs.json.JsError => (js \ "app_sort_by").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.AppSortBy(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesCompetitionAPIAppSortBy(obj: namespace.models.AppSortBy) = { play.api.libs.json.JsString(obj.toString) } def jsObjectAppSortBy(obj: namespace.models.AppSortBy) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesCompetitionAPIAppSortBy: play.api.libs.json.Writes[AppSortBy] = { (obj: namespace.models.AppSortBy) => { namespace.models.json.jsonWritesCompetitionAPIAppSortBy(obj) } } implicit val jsonReadsCompetitionAPICompetitionStatus: play.api.libs.json.Reads[namespace.models.CompetitionStatus] = new play.api.libs.json.Reads[namespace.models.CompetitionStatus] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[namespace.models.CompetitionStatus] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(namespace.models.CompetitionStatus(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.CompetitionStatus(v)) case _: play.api.libs.json.JsError => (js \ "competition_status").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.CompetitionStatus(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesCompetitionAPICompetitionStatus(obj: namespace.models.CompetitionStatus) = { play.api.libs.json.JsString(obj.toString) } def jsObjectCompetitionStatus(obj: namespace.models.CompetitionStatus) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesCompetitionAPICompetitionStatus: play.api.libs.json.Writes[CompetitionStatus] = { (obj: namespace.models.CompetitionStatus) => { namespace.models.json.jsonWritesCompetitionAPICompetitionStatus(obj) } } implicit val jsonReadsCompetitionAPISortOrder: play.api.libs.json.Reads[namespace.models.SortOrder] = new play.api.libs.json.Reads[namespace.models.SortOrder] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[namespace.models.SortOrder] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(namespace.models.SortOrder(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.SortOrder(v)) case _: play.api.libs.json.JsError => (js \ "sort_order").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.SortOrder(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesCompetitionAPISortOrder(obj: namespace.models.SortOrder) = { play.api.libs.json.JsString(obj.toString) } def jsObjectSortOrder(obj: namespace.models.SortOrder) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesCompetitionAPISortOrder: play.api.libs.json.Writes[SortOrder] = { (obj: namespace.models.SortOrder) => { namespace.models.json.jsonWritesCompetitionAPISortOrder(obj) } } implicit val jsonReadsCompetitionAPIVoteType: play.api.libs.json.Reads[namespace.models.VoteType] = new play.api.libs.json.Reads[namespace.models.VoteType] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[namespace.models.VoteType] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(namespace.models.VoteType(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.VoteType(v)) case _: play.api.libs.json.JsError => (js \ "vote_type").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(namespace.models.VoteType(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesCompetitionAPIVoteType(obj: namespace.models.VoteType) = { play.api.libs.json.JsString(obj.toString) } def jsObjectVoteType(obj: namespace.models.VoteType) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesCompetitionAPIVoteType: play.api.libs.json.Writes[VoteType] = { (obj: namespace.models.VoteType) => { namespace.models.json.jsonWritesCompetitionAPIVoteType(obj) } } implicit def jsonReadsCompetitionAPICompetition: play.api.libs.json.Reads[namespace.models.Competition] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] name <- (__ \ "name").read[String] status <- (__ \ "status").read[namespace.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: namespace.models.Competition): 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), "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)) ) } implicit def jsonWritesCompetitionAPICompetition: play.api.libs.json.Writes[Competition] = { (obj: namespace.models.Competition) => { namespace.models.json.jsObjectCompetition(obj) } } implicit def jsonReadsCompetitionAPICompetitionParticipant: play.api.libs.json.Reads[namespace.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: namespace.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 jsonWritesCompetitionAPICompetitionParticipant: play.api.libs.json.Writes[CompetitionParticipant] = { (obj: namespace.models.CompetitionParticipant) => { namespace.models.json.jsObjectCompetitionParticipant(obj) } } implicit def jsonReadsCompetitionAPICompetitor: play.api.libs.json.Reads[namespace.models.Competitor] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] name <- (__ \ "name").read[String] } yield Competitor(guid, name) } def jsObjectCompetitor(obj: namespace.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 jsonWritesCompetitionAPICompetitor: play.api.libs.json.Writes[Competitor] = { (obj: namespace.models.Competitor) => { namespace.models.json.jsObjectCompetitor(obj) } } implicit def jsonReadsCompetitionAPIVote: play.api.libs.json.Reads[namespace.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: namespace.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 jsonWritesCompetitionAPIVote: play.api.libs.json.Writes[Vote] = { (obj: namespace.models.Vote) => { namespace.models.json.jsObjectVote(obj) } } implicit def jsonReadsCompetitionAPIVoter: play.api.libs.json.Reads[namespace.models.Voter] = { for { guid <- (__ \ "guid").read[_root_.java.util.UUID] name <- (__ \ "name").read[String] asdf <- (__ \ "asdf").read[String] } yield Voter(guid, name, asdf) } def jsObjectVoter(obj: namespace.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), "asdf" -> play.api.libs.json.JsString(obj.asdf) ) } implicit def jsonWritesCompetitionAPIVoter: play.api.libs.json.Writes[Voter] = { (obj: namespace.models.Voter) => { namespace.models.json.jsObjectVoter(obj) } } } } package namespace { import com.ning.http.client.{AsyncCompletionHandler, AsyncHttpClient, Realm, Request, RequestBuilder, Response, AsyncHttpClientConfig} 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/ning_1_8_client" val Version = "0.0.6-dev" val VersionMajor = 0 } class Client( val baseUrl: String = "competition-api.product-domain.com", auth: scala.Option[namespace.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, asyncHttpClient: AsyncHttpClient = Client.defaultAsyncHttpClient ) extends interfaces.Client { import org.slf4j.{Logger, LoggerFactory} import namespace.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: namespace.models.Competition, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.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_.namespace.Client.parseJson("namespace.models.Competition", r, _.validate[namespace.models.Competition]) case r => throw namespace.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201", requestUri = Some(r.getUri)) } } override def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.models.Competition] = { _executeRequest("GET", s"/competitions/${_root_.namespace.PathSegment.encode(id, "UTF-8")}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.namespace.Client.parseJson("namespace.models.Competition", r, _.validate[namespace.models.Competition]) case r => throw namespace.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri)) } } } object Competitors extends Competitors { override def post( competitor: namespace.models.Competitor, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.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_.namespace.Client.parseJson("namespace.models.Competitor", r, _.validate[namespace.models.Competitor]) case r => throw namespace.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201", requestUri = Some(r.getUri)) } } override def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.models.Competitor] = { _executeRequest("GET", s"/competitors/${_root_.namespace.PathSegment.encode(id, "UTF-8")}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.namespace.Client.parseJson("namespace.models.Competitor", r, _.validate[namespace.models.Competitor]) case r => throw namespace.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri)) } } } 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("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.RealmBuilder() .setPrincipal(username) .setPassword(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[com.ning.http.client.Response] = { val allHeaders = body match { case None => requestHeaders case Some(_) => _withJsonContentType(requestHeaders) } val request = _requestBuilder(method, path, allHeaders) queryParameters.foreach { pair => request.addQueryParameter(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[com.ning.http.client.Response]() asyncHttpClient.executeRequest(finalRequest, new AsyncCompletionHandler[Unit]() { override def onCompleted(r: com.ning.http.client.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 AsyncHttpClient( new AsyncHttpClientConfig.Builder() .setExecutorService(java.util.concurrent.Executors.newCachedThreadPool()) .build() ) } def parseJson[T]( className: String, r: _root_.com.ning.http.client.Response, f: (play.api.libs.json.JsValue => play.api.libs.json.JsResult[T]) ): T = { f(play.api.libs.json.Json.parse(r.getResponseBody("UTF-8"))) match { case play.api.libs.json.JsSuccess(x, _) => x case play.api.libs.json.JsError(errors) => { throw namespace.errors.FailedRequest(r.getStatusCode, s"Invalid json for class[" + className + "]: " + errors.mkString(" "), requestUri = Some(r.getUri)) } } } } 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: namespace.Competitions def competitors: namespace.Competitors } } trait Competitions { def post( competition: namespace.models.Competition, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.models.Competition] def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.models.Competition] } trait Competitors { def post( competitor: namespace.models.Competitor, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.models.Competitor] def getById( id: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[namespace.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 } } }