/** * Generated by API Builder - https://www.apibuilder.io * Service version: 0.0.2 * User agent: apibuilder app.apibuilder.io/bml/bml-gen-test-application/0.0.2/async_http_2_5_client */ package org.bml.bml.gen.test.application.v0.models { /** * This is the top level in the system. It represents a specific client. * * @param id The Universally Unique Identifier. See RFC 4122. * @param awsAccount Test param for a pattern restricted string. * @param name A unique human readable string name. * @param enabled Adds the ability to enable / disable this resource. */ final case class Account( id: _root_.java.util.UUID, awsAccount: String, name: String, enabled: Boolean ) /** * A form used for creating an Account resource. * * @param name A unique human readable string name. * @param enabled Adds the ability to enable / disable this resource. */ final case class AccountForm( name: String, enabled: Boolean ) /** * A model client for testing generation. * * @param accounts test field to make sure non empty lists are non empty in generated mock * factories. */ final case class Client( accounts: Seq[org.bml.bml.gen.test.application.v0.models.Account] ) /** * A response model for the standard health check resource. * * @param status A general status string. */ final case class Healthcheck( status: String ) /** * Test Enumeration provides a useful test for enumeration based code generation. */ sealed trait TestEnumeration extends _root_.scala.Product with _root_.scala.Serializable object TestEnumeration { /** * A foo enumeration entry. */ case object Foo extends TestEnumeration { override def toString = "foo" } /** * A bar enumeration entry. */ case object Bar extends TestEnumeration { override def toString = "bar" } /** * 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 TestEnumeration /** * 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[TestEnumeration] = scala.List(Foo, Bar) private val byName: Map[String, TestEnumeration] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): TestEnumeration = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[TestEnumeration] = byName.get(value.toLowerCase) } } package org.bml.bml.gen.test.application.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 org.bml.annotation.v0.models.json._ import org.bml.bml.gen.test.application.v0.models.json._ import org.bml.validation.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 jsonReadsBmlGenTestApplicationTestEnumeration: play.api.libs.json.Reads[org.bml.bml.gen.test.application.v0.models.TestEnumeration] = new play.api.libs.json.Reads[org.bml.bml.gen.test.application.v0.models.TestEnumeration] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[org.bml.bml.gen.test.application.v0.models.TestEnumeration] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(org.bml.bml.gen.test.application.v0.models.TestEnumeration(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(org.bml.bml.gen.test.application.v0.models.TestEnumeration(v)) case _: play.api.libs.json.JsError => (js \ "test_enumeration").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(org.bml.bml.gen.test.application.v0.models.TestEnumeration(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesBmlGenTestApplicationTestEnumeration(obj: org.bml.bml.gen.test.application.v0.models.TestEnumeration) = { play.api.libs.json.JsString(obj.toString) } def jsObjectTestEnumeration(obj: org.bml.bml.gen.test.application.v0.models.TestEnumeration) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesBmlGenTestApplicationTestEnumeration: play.api.libs.json.Writes[TestEnumeration] = { (obj: org.bml.bml.gen.test.application.v0.models.TestEnumeration) => { org.bml.bml.gen.test.application.v0.models.json.jsonWritesBmlGenTestApplicationTestEnumeration(obj) } } implicit def jsonReadsBmlGenTestApplicationAccount: play.api.libs.json.Reads[org.bml.bml.gen.test.application.v0.models.Account] = { for { id <- (__ \ "id").read[_root_.java.util.UUID] awsAccount <- (__ \ "awsAccount").read[String] name <- (__ \ "name").read[String] enabled <- (__ \ "enabled").read[Boolean] } yield Account(id, awsAccount, name, enabled) } def jsObjectAccount(obj: org.bml.bml.gen.test.application.v0.models.Account): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "id" -> play.api.libs.json.JsString(obj.id.toString), "awsAccount" -> play.api.libs.json.JsString(obj.awsAccount), "name" -> play.api.libs.json.JsString(obj.name), "enabled" -> play.api.libs.json.JsBoolean(obj.enabled) ) } implicit def jsonWritesBmlGenTestApplicationAccount: play.api.libs.json.Writes[Account] = { (obj: org.bml.bml.gen.test.application.v0.models.Account) => { org.bml.bml.gen.test.application.v0.models.json.jsObjectAccount(obj) } } implicit def jsonReadsBmlGenTestApplicationAccountForm: play.api.libs.json.Reads[org.bml.bml.gen.test.application.v0.models.AccountForm] = { for { name <- (__ \ "name").read[String] enabled <- (__ \ "enabled").read[Boolean] } yield AccountForm(name, enabled) } def jsObjectAccountForm(obj: org.bml.bml.gen.test.application.v0.models.AccountForm): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "name" -> play.api.libs.json.JsString(obj.name), "enabled" -> play.api.libs.json.JsBoolean(obj.enabled) ) } implicit def jsonWritesBmlGenTestApplicationAccountForm: play.api.libs.json.Writes[AccountForm] = { (obj: org.bml.bml.gen.test.application.v0.models.AccountForm) => { org.bml.bml.gen.test.application.v0.models.json.jsObjectAccountForm(obj) } } implicit def jsonReadsBmlGenTestApplicationClient: play.api.libs.json.Reads[org.bml.bml.gen.test.application.v0.models.Client] = { (__ \ "accounts").read[Seq[org.bml.bml.gen.test.application.v0.models.Account]].map { x => Client(accounts = x) } } def jsObjectClient(obj: org.bml.bml.gen.test.application.v0.models.Client): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "accounts" -> play.api.libs.json.Json.toJson(obj.accounts) ) } implicit def jsonWritesBmlGenTestApplicationClient: play.api.libs.json.Writes[Client] = { (obj: org.bml.bml.gen.test.application.v0.models.Client) => { org.bml.bml.gen.test.application.v0.models.json.jsObjectClient(obj) } } implicit def jsonReadsBmlGenTestApplicationHealthcheck: play.api.libs.json.Reads[org.bml.bml.gen.test.application.v0.models.Healthcheck] = { (__ \ "status").read[String].map { x => Healthcheck(status = x) } } def jsObjectHealthcheck(obj: org.bml.bml.gen.test.application.v0.models.Healthcheck): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "status" -> play.api.libs.json.JsString(obj.status) ) } implicit def jsonWritesBmlGenTestApplicationHealthcheck: play.api.libs.json.Writes[Healthcheck] = { (obj: org.bml.bml.gen.test.application.v0.models.Healthcheck) => { org.bml.bml.gen.test.application.v0.models.json.jsObjectHealthcheck(obj) } } } } package org.bml.bml.gen.test.application.v0 { import org.asynchttpclient.{AsyncCompletionHandler, AsyncHttpClient, Realm, Request, RequestBuilder, Response, DefaultAsyncHttpClient, DefaultAsyncHttpClientConfig} object Constants { val Namespace = "org.bml.bml.gen.test.application.v0" val UserAgent = "apibuilder app.apibuilder.io/bml/bml-gen-test-application/0.0.2/async_http_2_5_client" val Version = "0.0.2" val VersionMajor = 0 } class Client( val baseUrl: String, auth: scala.Option[org.bml.bml.gen.test.application.v0.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, asyncHttpClient: AsyncHttpClient = Client.defaultAsyncHttpClient ) extends interfaces.Client { import org.slf4j.{Logger, LoggerFactory} import org.bml.annotation.v0.models.json._ import org.bml.bml.gen.test.application.v0.models.json._ import org.bml.validation.v0.models.json._ def closeAsyncHttpClient(): Unit = { asyncHttpClient.close() } val logger = LoggerFactory.getLogger(getClass) def accounts: Accounts = Accounts object Accounts extends Accounts { override def post( testDefault: Boolean = false, accountForm: org.bml.bml.gen.test.application.v0.models.AccountForm, authorization: String, test: _root_.scala.Option[Boolean] = None, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.bml.bml.gen.test.application.v0.models.Account] = { val payload = play.api.libs.json.Json.toJson(accountForm) val queryParameters = Seq( test.map("test" -> _.toString), Some("testDefault" -> testDefault.toString) ).flatten val headerParameters = Seq( Some("Authorization" -> authorization) ).flatten _executeRequest("POST", s"/accounts", body = Some(payload), queryParameters = queryParameters, requestHeaders = (requestHeaders ++ headerParameters)).map { case r if r.getStatusCode == 201 => _root_.org.bml.bml.gen.test.application.v0.Client.parseJson("org.bml.bml.gen.test.application.v0.models.Account", r, _.validate[org.bml.bml.gen.test.application.v0.models.Account]) case r if r.getStatusCode == 400 => throw org.bml.bml.gen.test.application.v0.errors.FieldValidationResponseResponse(r) case r if r.getStatusCode == 401 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r if r.getStatusCode == 409 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r => throw org.bml.bml.gen.test.application.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 201, 400, 401, 409", requestUri = Some(r.getUri.toJavaNetURI)) } } override def getById( id: _root_.java.util.UUID, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.bml.bml.gen.test.application.v0.models.Account] = { val headerParameters = Seq( Some("Authorization" -> authorization) ).flatten _executeRequest("GET", s"/accounts/${id}", requestHeaders = (requestHeaders ++ headerParameters)).map { case r if r.getStatusCode == 200 => _root_.org.bml.bml.gen.test.application.v0.Client.parseJson("org.bml.bml.gen.test.application.v0.models.Account", r, _.validate[org.bml.bml.gen.test.application.v0.models.Account]) case r if r.getStatusCode == 400 => throw org.bml.bml.gen.test.application.v0.errors.FieldValidationResponseResponse(r) case r if r.getStatusCode == 401 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r if r.getStatusCode == 404 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r => throw org.bml.bml.gen.test.application.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 400, 401, 404", requestUri = Some(r.getUri.toJavaNetURI)) } } override def getFooById( id: _root_.java.util.UUID, name: _root_.scala.Option[String] = None, page: Int = 0, count: Int = 100, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[org.bml.bml.gen.test.application.v0.models.Account]] = { val queryParameters = Seq( name.map("name" -> _), Some("page" -> page.toString), Some("count" -> count.toString) ).flatten val headerParameters = Seq( Some("Authorization" -> authorization) ).flatten _executeRequest("GET", s"/accounts/${id}/foo", queryParameters = queryParameters, requestHeaders = (requestHeaders ++ headerParameters)).map { case r if r.getStatusCode == 200 => _root_.org.bml.bml.gen.test.application.v0.Client.parseJson("Seq[org.bml.bml.gen.test.application.v0.models.Account]", r, _.validate[Seq[org.bml.bml.gen.test.application.v0.models.Account]]) case r if r.getStatusCode == 400 => throw org.bml.bml.gen.test.application.v0.errors.FieldValidationResponseResponse(r) case r if r.getStatusCode == 401 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r if r.getStatusCode == 404 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r => throw org.bml.bml.gen.test.application.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 400, 401, 404", requestUri = Some(r.getUri.toJavaNetURI)) } } override def get( name: _root_.scala.Option[String] = None, page: Int = 0, count: Int = 100, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[org.bml.bml.gen.test.application.v0.models.Account]] = { val queryParameters = Seq( name.map("name" -> _), Some("page" -> page.toString), Some("count" -> count.toString) ).flatten val headerParameters = Seq( Some("Authorization" -> authorization) ).flatten _executeRequest("GET", s"/accounts", queryParameters = queryParameters, requestHeaders = (requestHeaders ++ headerParameters)).map { case r if r.getStatusCode == 200 => _root_.org.bml.bml.gen.test.application.v0.Client.parseJson("Seq[org.bml.bml.gen.test.application.v0.models.Account]", r, _.validate[Seq[org.bml.bml.gen.test.application.v0.models.Account]]) case r if r.getStatusCode == 400 => throw org.bml.bml.gen.test.application.v0.errors.FieldValidationResponseResponse(r) case r if r.getStatusCode == 401 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r if r.getStatusCode == 404 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r => throw org.bml.bml.gen.test.application.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 400, 401, 404", requestUri = Some(r.getUri.toJavaNetURI)) } } override def deleteById( id: _root_.java.util.UUID, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.bml.bml.gen.test.application.v0.models.Account] = { val headerParameters = Seq( Some("Authorization" -> authorization) ).flatten _executeRequest("DELETE", s"/accounts/${id}", requestHeaders = (requestHeaders ++ headerParameters)).map { case r if r.getStatusCode == 200 => _root_.org.bml.bml.gen.test.application.v0.Client.parseJson("org.bml.bml.gen.test.application.v0.models.Account", r, _.validate[org.bml.bml.gen.test.application.v0.models.Account]) case r if r.getStatusCode == 400 => throw org.bml.bml.gen.test.application.v0.errors.FieldValidationResponseResponse(r) case r if r.getStatusCode == 401 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r if r.getStatusCode == 404 => throw org.bml.bml.gen.test.application.v0.errors.UnitResponse(r.getStatusCode) case r => throw org.bml.bml.gen.test.application.v0.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200, 400, 401, 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(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 org.bml.bml.gen.test.application.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 accounts: org.bml.bml.gen.test.application.v0.Accounts } } trait Accounts { /** * @param authorization Standard Auth header pass a JWT token. * @param test is this call a test * @param testDefault is this call a test */ def post( testDefault: Boolean = false, accountForm: org.bml.bml.gen.test.application.v0.models.AccountForm, authorization: String, test: _root_.scala.Option[Boolean] = None, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.bml.bml.gen.test.application.v0.models.Account] /** * @param id The Universally Unique Identifier for an existing account resource. See RFC 4122 * @param authorization Standard Auth header pass a JWT token. */ def getById( id: _root_.java.util.UUID, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.bml.bml.gen.test.application.v0.models.Account] /** * A mock to test returning a raw array. This is not a practical method to * implement in a production environment. In production you would return a page * object but here we want to test to ensure generators are handling raw array * return value. * * @param id The Universally Unique Identifier for an existing account resource. See RFC 4122 * @param authorization Standard Auth header pass a JWT token. * @param name An optional test query parameter. * @param page An optional test query parameter. * @param count An optional test query parameter. */ def getFooById( id: _root_.java.util.UUID, name: _root_.scala.Option[String] = None, page: Int = 0, count: Int = 100, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[org.bml.bml.gen.test.application.v0.models.Account]] /** * A mock to test returning a raw array. This is not a practical method to * implement in a production environment. In production you would return a page * object but here we want to test to ensure generators are handling raw array * return value. * * @param authorization Standard Auth header pass a JWT token. * @param name An optional test query parameter. * @param page An optional test query parameter. * @param count An optional test query parameter. */ def get( name: _root_.scala.Option[String] = None, page: Int = 0, count: Int = 100, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[org.bml.bml.gen.test.application.v0.models.Account]] /** * Delete an Account resource by id. * * @param id The Universally Unique Identifier for an existing account resource. See RFC 4122 * @param authorization Standard Auth header pass a JWT token. */ def deleteById( id: _root_.java.util.UUID, authorization: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[org.bml.bml.gen.test.application.v0.models.Account] } package errors { import org.bml.annotation.v0.models.json._ import org.bml.bml.gen.test.application.v0.models.json._ import org.bml.validation.v0.models.json._ final case class FieldValidationResponseResponse( response: _root_.org.asynchttpclient.Response, message: Option[String] = None ) extends Exception(message.getOrElse(s"${response.getStatusCode}: ${response.getResponseBody(java.nio.charset.Charset.forName("UTF-8"))}")) { lazy val fieldValidationResponse = _root_.org.bml.bml.gen.test.application.v0.Client.parseJson("org.bml.validation.v0.models.FieldValidationResponse", response, _.validate[org.bml.validation.v0.models.FieldValidationResponse]) } final case class UnitResponse(status: Int) extends Exception(s"HTTP $status") 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 } } }