/** * Generated by API Builder - https://www.apibuilder.io * Service version: 0.0.1-dev * User agent: apibuilder app.apibuilder.io/nicolai-moraru/joglog-api/0.0.1-dev/ning_1_9_client */ package nm.joglog.api.v0.models { /** * Time entry * * @param id Unique time id * @param distance Distance in meters * @param time Time in seconds * @param createdAt Creation date-time * @param updatedAt Last update date-time */ final case class Time( id: Int, distance: Int, time: Int, createdAt: _root_.org.joda.time.DateTime, updatedAt: _root_.org.joda.time.DateTime ) /** * Time entry * * @param distance Distance in meters * @param time Time in seconds */ final case class TimeMinimal( distance: Int, time: Int ) /** * Time patch entry */ final case class TimePatchEntry( op: .models.Operation, path: time.models.Path, value: Int ) /** * User * * @param id Unique user id * @param username Username * @param role User Role * @param createdAt Creation date-time * @param updatedAt Last update date-time */ final case class User( id: Int, username: String, role: .models.Role, createdAt: _root_.org.joda.time.DateTime, updatedAt: _root_.org.joda.time.DateTime ) /** * User * * @param username Username * @param password Password */ final case class UserMinimal( username: String, password: String ) /** * User patch entry */ final case class UserPatchEntry( op: .models.Operation, path: user.models.Path, value: nm.joglog.api.v0.models.StringOrInteger ) /** * Patch operation */ sealed trait PatchOperation extends _root_.scala.Product with _root_.scala.Serializable object PatchOperation { case object Test extends PatchOperation { override def toString = "test" } case object Replace extends PatchOperation { override def toString = "replace" } /** * 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 PatchOperation /** * 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[PatchOperation] = scala.List(Test, Replace) private val byName: Map[String, PatchOperation] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): PatchOperation = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[PatchOperation] = byName.get(value.toLowerCase) } /** * Integer for ID or string for any other */ sealed trait StringOrInteger extends _root_.scala.Product with _root_.scala.Serializable object StringOrInteger { case object String extends StringOrInteger { override def toString = "string" } case object Integer extends StringOrInteger { override def toString = "integer" } /** * 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 StringOrInteger /** * 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[StringOrInteger] = scala.List(String, Integer) private val byName: Map[String, StringOrInteger] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): StringOrInteger = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[StringOrInteger] = byName.get(value.toLowerCase) } /** * Time patch field path (id only for test) */ sealed trait TimePatchPath extends _root_.scala.Product with _root_.scala.Serializable object TimePatchPath { case object Distance extends TimePatchPath { override def toString = "distance" } case object Time extends TimePatchPath { override def toString = "time" } case object Id extends TimePatchPath { override def toString = "id" } /** * 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 TimePatchPath /** * 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[TimePatchPath] = scala.List(Distance, Time, Id) private val byName: Map[String, TimePatchPath] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): TimePatchPath = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[TimePatchPath] = byName.get(value.toLowerCase) } /** * User patch field path (id only for test) */ sealed trait UserPatchPath extends _root_.scala.Product with _root_.scala.Serializable object UserPatchPath { case object Username extends UserPatchPath { override def toString = "username" } case object Password extends UserPatchPath { override def toString = "password" } case object Role extends UserPatchPath { override def toString = "role" } case object Id extends UserPatchPath { override def toString = "id" } /** * 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 UserPatchPath /** * 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[UserPatchPath] = scala.List(Username, Password, Role, Id) private val byName: Map[String, UserPatchPath] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): UserPatchPath = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[UserPatchPath] = byName.get(value.toLowerCase) } /** * User Role */ sealed trait UserRole extends _root_.scala.Product with _root_.scala.Serializable object UserRole { /** * Regular user */ case object User extends UserRole { override def toString = "user" } /** * User manager */ case object Manager extends UserRole { override def toString = "manager" } /** * The God himself */ case object Admin extends UserRole { override def toString = "admin" } /** * 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 UserRole /** * 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[UserRole] = scala.List(User, Manager, Admin) private val byName: Map[String, UserRole] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): UserRole = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[UserRole] = byName.get(value.toLowerCase) } } package nm.joglog.api.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 nm.joglog.api.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 jsonReadsJoglogApiPatchOperation: play.api.libs.json.Reads[nm.joglog.api.v0.models.PatchOperation] = new play.api.libs.json.Reads[nm.joglog.api.v0.models.PatchOperation] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[nm.joglog.api.v0.models.PatchOperation] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.PatchOperation(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.PatchOperation(v)) case _: play.api.libs.json.JsError => (js \ "patch.operation").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.PatchOperation(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesJoglogApiPatchOperation(obj: nm.joglog.api.v0.models.PatchOperation) = { play.api.libs.json.JsString(obj.toString) } def jsObjectPatchOperation(obj: nm.joglog.api.v0.models.PatchOperation) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesJoglogApiPatchOperation: play.api.libs.json.Writes[PatchOperation] = { (obj: nm.joglog.api.v0.models.PatchOperation) => { nm.joglog.api.v0.models.json.jsonWritesJoglogApiPatchOperation(obj) } } implicit val jsonReadsJoglogApiStringOrInteger: play.api.libs.json.Reads[nm.joglog.api.v0.models.StringOrInteger] = new play.api.libs.json.Reads[nm.joglog.api.v0.models.StringOrInteger] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[nm.joglog.api.v0.models.StringOrInteger] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.StringOrInteger(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.StringOrInteger(v)) case _: play.api.libs.json.JsError => (js \ "stringOrInteger").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.StringOrInteger(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesJoglogApiStringOrInteger(obj: nm.joglog.api.v0.models.StringOrInteger) = { play.api.libs.json.JsString(obj.toString) } def jsObjectStringOrInteger(obj: nm.joglog.api.v0.models.StringOrInteger) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesJoglogApiStringOrInteger: play.api.libs.json.Writes[StringOrInteger] = { (obj: nm.joglog.api.v0.models.StringOrInteger) => { nm.joglog.api.v0.models.json.jsonWritesJoglogApiStringOrInteger(obj) } } implicit val jsonReadsJoglogApiTimePatchPath: play.api.libs.json.Reads[nm.joglog.api.v0.models.TimePatchPath] = new play.api.libs.json.Reads[nm.joglog.api.v0.models.TimePatchPath] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[nm.joglog.api.v0.models.TimePatchPath] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.TimePatchPath(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.TimePatchPath(v)) case _: play.api.libs.json.JsError => (js \ "time.patch.path").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.TimePatchPath(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesJoglogApiTimePatchPath(obj: nm.joglog.api.v0.models.TimePatchPath) = { play.api.libs.json.JsString(obj.toString) } def jsObjectTimePatchPath(obj: nm.joglog.api.v0.models.TimePatchPath) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesJoglogApiTimePatchPath: play.api.libs.json.Writes[TimePatchPath] = { (obj: nm.joglog.api.v0.models.TimePatchPath) => { nm.joglog.api.v0.models.json.jsonWritesJoglogApiTimePatchPath(obj) } } implicit val jsonReadsJoglogApiUserPatchPath: play.api.libs.json.Reads[nm.joglog.api.v0.models.UserPatchPath] = new play.api.libs.json.Reads[nm.joglog.api.v0.models.UserPatchPath] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[nm.joglog.api.v0.models.UserPatchPath] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.UserPatchPath(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.UserPatchPath(v)) case _: play.api.libs.json.JsError => (js \ "user.patch.path").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.UserPatchPath(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesJoglogApiUserPatchPath(obj: nm.joglog.api.v0.models.UserPatchPath) = { play.api.libs.json.JsString(obj.toString) } def jsObjectUserPatchPath(obj: nm.joglog.api.v0.models.UserPatchPath) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesJoglogApiUserPatchPath: play.api.libs.json.Writes[UserPatchPath] = { (obj: nm.joglog.api.v0.models.UserPatchPath) => { nm.joglog.api.v0.models.json.jsonWritesJoglogApiUserPatchPath(obj) } } implicit val jsonReadsJoglogApiUserRole: play.api.libs.json.Reads[nm.joglog.api.v0.models.UserRole] = new play.api.libs.json.Reads[nm.joglog.api.v0.models.UserRole] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[nm.joglog.api.v0.models.UserRole] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.UserRole(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.UserRole(v)) case _: play.api.libs.json.JsError => (js \ "user.role").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(nm.joglog.api.v0.models.UserRole(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesJoglogApiUserRole(obj: nm.joglog.api.v0.models.UserRole) = { play.api.libs.json.JsString(obj.toString) } def jsObjectUserRole(obj: nm.joglog.api.v0.models.UserRole) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesJoglogApiUserRole: play.api.libs.json.Writes[UserRole] = { (obj: nm.joglog.api.v0.models.UserRole) => { nm.joglog.api.v0.models.json.jsonWritesJoglogApiUserRole(obj) } } implicit def jsonReadsJoglogApiTime: play.api.libs.json.Reads[nm.joglog.api.v0.models.Time] = { for { id <- (__ \ "id").read[Int] distance <- (__ \ "distance").read[Int] time <- (__ \ "time").read[Int] createdAt <- (__ \ "createdAt").read[_root_.org.joda.time.DateTime] updatedAt <- (__ \ "updatedAt").read[_root_.org.joda.time.DateTime] } yield Time(id, distance, time, createdAt, updatedAt) } def jsObjectTime(obj: nm.joglog.api.v0.models.Time): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "id" -> play.api.libs.json.JsNumber(obj.id), "distance" -> play.api.libs.json.JsNumber(obj.distance), "time" -> play.api.libs.json.JsNumber(obj.time), "createdAt" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.createdAt)), "updatedAt" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.updatedAt)) ) } implicit def jsonWritesJoglogApiTime: play.api.libs.json.Writes[Time] = { (obj: nm.joglog.api.v0.models.Time) => { nm.joglog.api.v0.models.json.jsObjectTime(obj) } } implicit def jsonReadsJoglogApiTimeMinimal: play.api.libs.json.Reads[nm.joglog.api.v0.models.TimeMinimal] = { for { distance <- (__ \ "distance").read[Int] time <- (__ \ "time").read[Int] } yield TimeMinimal(distance, time) } def jsObjectTimeMinimal(obj: nm.joglog.api.v0.models.TimeMinimal): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "distance" -> play.api.libs.json.JsNumber(obj.distance), "time" -> play.api.libs.json.JsNumber(obj.time) ) } implicit def jsonWritesJoglogApiTimeMinimal: play.api.libs.json.Writes[TimeMinimal] = { (obj: nm.joglog.api.v0.models.TimeMinimal) => { nm.joglog.api.v0.models.json.jsObjectTimeMinimal(obj) } } implicit def jsonReadsJoglogApiTimePatchEntry: play.api.libs.json.Reads[nm.joglog.api.v0.models.TimePatchEntry] = { for { op <- (__ \ "op").read[.models.Operation] path <- (__ \ "path").read[time.models.Path] value <- (__ \ "value").read[Int] } yield TimePatchEntry(op, path, value) } def jsObjectTimePatchEntry(obj: nm.joglog.api.v0.models.TimePatchEntry): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "op" -> play.api.libs.json.JsString(obj.op.toString), "path" -> play.api.libs.json.JsString(obj.path.toString), "value" -> play.api.libs.json.JsNumber(obj.value) ) } implicit def jsonWritesJoglogApiTimePatchEntry: play.api.libs.json.Writes[TimePatchEntry] = { (obj: nm.joglog.api.v0.models.TimePatchEntry) => { nm.joglog.api.v0.models.json.jsObjectTimePatchEntry(obj) } } implicit def jsonReadsJoglogApiUser: play.api.libs.json.Reads[nm.joglog.api.v0.models.User] = { for { id <- (__ \ "id").read[Int] username <- (__ \ "username").read[String] role <- (__ \ "role").read[.models.Role] createdAt <- (__ \ "createdAt").read[_root_.org.joda.time.DateTime] updatedAt <- (__ \ "updatedAt").read[_root_.org.joda.time.DateTime] } yield User(id, username, role, createdAt, updatedAt) } def jsObjectUser(obj: nm.joglog.api.v0.models.User): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "id" -> play.api.libs.json.JsNumber(obj.id), "username" -> play.api.libs.json.JsString(obj.username), "role" -> play.api.libs.json.JsString(obj.role.toString), "createdAt" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.createdAt)), "updatedAt" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.updatedAt)) ) } implicit def jsonWritesJoglogApiUser: play.api.libs.json.Writes[User] = { (obj: nm.joglog.api.v0.models.User) => { nm.joglog.api.v0.models.json.jsObjectUser(obj) } } implicit def jsonReadsJoglogApiUserMinimal: play.api.libs.json.Reads[nm.joglog.api.v0.models.UserMinimal] = { for { username <- (__ \ "username").read[String] password <- (__ \ "password").read[String] } yield UserMinimal(username, password) } def jsObjectUserMinimal(obj: nm.joglog.api.v0.models.UserMinimal): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "username" -> play.api.libs.json.JsString(obj.username), "password" -> play.api.libs.json.JsString(obj.password) ) } implicit def jsonWritesJoglogApiUserMinimal: play.api.libs.json.Writes[UserMinimal] = { (obj: nm.joglog.api.v0.models.UserMinimal) => { nm.joglog.api.v0.models.json.jsObjectUserMinimal(obj) } } implicit def jsonReadsJoglogApiUserPatchEntry: play.api.libs.json.Reads[nm.joglog.api.v0.models.UserPatchEntry] = { for { op <- (__ \ "op").read[.models.Operation] path <- (__ \ "path").read[user.models.Path] value <- (__ \ "value").read[nm.joglog.api.v0.models.StringOrInteger] } yield UserPatchEntry(op, path, value) } def jsObjectUserPatchEntry(obj: nm.joglog.api.v0.models.UserPatchEntry): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "op" -> play.api.libs.json.JsString(obj.op.toString), "path" -> play.api.libs.json.JsString(obj.path.toString), "value" -> play.api.libs.json.JsString(obj.value.toString) ) } implicit def jsonWritesJoglogApiUserPatchEntry: play.api.libs.json.Writes[UserPatchEntry] = { (obj: nm.joglog.api.v0.models.UserPatchEntry) => { nm.joglog.api.v0.models.json.jsObjectUserPatchEntry(obj) } } } } package nm.joglog.api.v0 { import com.ning.http.client.{AsyncCompletionHandler, AsyncHttpClient, Realm, Request, RequestBuilder, Response, AsyncHttpClientConfig} object Constants { val BaseUrl = "http://localhost:8081" val Namespace = "nm.joglog.api.v0" val UserAgent = "apibuilder app.apibuilder.io/nicolai-moraru/joglog-api/0.0.1-dev/ning_1_9_client" val Version = "0.0.1-dev" val VersionMajor = 0 } class Client( val baseUrl: String = "http://localhost:8081", auth: scala.Option[nm.joglog.api.v0.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, asyncHttpClient: AsyncHttpClient = Client.defaultAsyncHttpClient ) extends interfaces.Client { import org.slf4j.{Logger, LoggerFactory} import nm.joglog.api.v0.models.json._ def closeAsyncHttpClient(): Unit = { asyncHttpClient.close() } val logger = LoggerFactory.getLogger(getClass) def times: Times = Times def users: Users = Users object Times extends Times { override def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] = { val payload = play.api.libs.json.Json.toJson(minimal) _executeRequest("POST", s"/times", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 201 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.Time", r, _.validate[nm.joglog.api.v0.models.Time]) case r if r.getStatusCode == 400 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201, 400, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[nm.joglog.api.v0.models.Time]] = { _executeRequest("GET", s"/times", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("Seq[nm.joglog.api.v0.models.Time]", r, _.validate[Seq[nm.joglog.api.v0.models.Time]]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] = { _executeRequest("GET", s"/times/${id}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.Time", r, _.validate[nm.joglog.api.v0.models.Time]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r if r.getStatusCode == 404 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403, 404", requestUri = Some(r.getUri.toJavaNetURI)) } } override def patch( entries: Seq[time.models.Entry], requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] = { val payload = play.api.libs.json.Json.toJson(entries) _executeRequest("PATCH", s"/times", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.Time", r, _.validate[nm.joglog.api.v0.models.Time]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] = { _executeRequest("DELETE", s"/times/${id}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.Time", r, _.validate[nm.joglog.api.v0.models.Time]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r if r.getStatusCode == 404 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403, 404", requestUri = Some(r.getUri.toJavaNetURI)) } } } object Users extends Users { override def postAuthenticate( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[String] = { val payload = play.api.libs.json.Json.toJson(minimal) _executeRequest("POST", s"/users/authenticate", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 201 => _root_.nm.joglog.api.v0.Client.parseJson("String", r, _.validate[String]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] = { val payload = play.api.libs.json.Json.toJson(minimal) _executeRequest("POST", s"/users", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 201 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.User", r, _.validate[nm.joglog.api.v0.models.User]) case r if r.getStatusCode == 400 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201, 400, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[nm.joglog.api.v0.models.User]] = { _executeRequest("GET", s"/users", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("Seq[nm.joglog.api.v0.models.User]", r, _.validate[Seq[nm.joglog.api.v0.models.User]]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] = { _executeRequest("GET", s"/users/${id}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.User", r, _.validate[nm.joglog.api.v0.models.User]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r if r.getStatusCode == 404 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403, 404", requestUri = Some(r.getUri.toJavaNetURI)) } } override def patch( entries: Seq[user.models.Entry], requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] = { val payload = play.api.libs.json.Json.toJson(entries) _executeRequest("PATCH", s"/users", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.User", r, _.validate[nm.joglog.api.v0.models.User]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403", requestUri = Some(r.getUri.toJavaNetURI)) } } override def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] = { _executeRequest("DELETE", s"/users/${id}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.nm.joglog.api.v0.Client.parseJson("nm.joglog.api.v0.models.User", r, _.validate[nm.joglog.api.v0.models.User]) case r if r.getStatusCode == 403 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r if r.getStatusCode == 404 => throw nm.joglog.api.v0.errors.ValueResponse(r) case r => throw nm.joglog.api.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 403, 404", 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("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.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[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 nm.joglog.api.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 times: nm.joglog.api.v0.Times def users: nm.joglog.api.v0.Users } } trait Times { /** * Create a time entry */ def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] /** * List all times */ def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[nm.joglog.api.v0.models.Time]] /** * Get a specific time entry * * @param id Time entry ID */ def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] /** * Patch a time entry */ def patch( entries: Seq[time.models.Entry], requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] /** * Remove a specific time entry * * @param id Time ID */ def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.Time] } trait Users { /** * Authentication */ def postAuthenticate( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[String] /** * Create a user */ def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] /** * List all users */ def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[nm.joglog.api.v0.models.User]] /** * Get a specific user * * @param id User ID */ def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] /** * Patch a user */ def patch( entries: Seq[user.models.Entry], requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] /** * Remove a specific user * * @param id User ID */ def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[nm.joglog.api.v0.models.User] } package errors { import nm.joglog.api.v0.models.json._ final case class ValueResponse( response: _root_.com.ning.http.client.Response, message: Option[String] = None ) extends Exception(message.getOrElse(s"${response.getStatusCode}: ${response.getResponseBody("UTF-8")}")) { lazy val value = _root_.nm.joglog.api.v0.Client.parseJson("String", response, _.validate[String]) } 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 } } }