/** * 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/http4s_0_22 */ package nm.joglog.api.v0 { import cats.effect._ import cats.implicits._ import io.circe.syntax._ 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/http4s_0_22" val Version = "0.0.1-dev" val VersionMajor = 0 } class Client[F[_]: Sync]( val baseUrl: org.http4s.Uri = org.http4s.Uri.unsafeFromString("http://localhost:8081"), auth: scala.Option[nm.joglog.api.v0.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, httpClient: org.http4s.client.Client[F] ) extends interfaces.Client[F] { import org.http4s.Response import nm.joglog.api.v0.models.json._ def times: Times[F] = Times def users: Users[F] = Users object Times extends Times[F] { override def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] = { val urlPath = Seq("times") val (payload, formPayload) = (Some(minimal), None) _executeRequest[.models.Minimal, nm.joglog.api.v0.models.Time]("POST", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 201 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.Time]("nm.joglog.api.v0.models.Time", r) case r if r.status.code == 400 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 201, 400, 403")) } } override def get( requestHeaders: Seq[(String, String)] = Nil ): F[Seq[nm.joglog.api.v0.models.Time]] = { val urlPath = Seq("times") _executeRequest[Unit, Seq[nm.joglog.api.v0.models.Time]]("GET", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, Seq[nm.joglog.api.v0.models.Time]]("Seq[nm.joglog.api.v0.models.Time]", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403")) } } override def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] = { val urlPath = Seq("times", id.toString) _executeRequest[Unit, nm.joglog.api.v0.models.Time]("GET", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.Time]("nm.joglog.api.v0.models.Time", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r if r.status.code == 404 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403, 404")) } } override def patch( entries: Seq[time.models.Entry], requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] = { val urlPath = Seq("times") val (payload, formPayload) = (Some(entries), None) _executeRequest[Seq[time.models.Entry], nm.joglog.api.v0.models.Time]("PATCH", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.Time]("nm.joglog.api.v0.models.Time", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403")) } } override def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] = { val urlPath = Seq("times", id.toString) _executeRequest[Unit, nm.joglog.api.v0.models.Time]("DELETE", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.Time]("nm.joglog.api.v0.models.Time", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r if r.status.code == 404 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403, 404")) } } } object Users extends Users[F] { override def postAuthenticate( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil ): F[String] = { val urlPath = Seq("users", "authenticate") val (payload, formPayload) = (Some(minimal), None) _executeRequest[.models.Minimal, String]("POST", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 201 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 201, 403")) } } override def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] = { val urlPath = Seq("users") val (payload, formPayload) = (Some(minimal), None) _executeRequest[.models.Minimal, nm.joglog.api.v0.models.User]("POST", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 201 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.User]("nm.joglog.api.v0.models.User", r) case r if r.status.code == 400 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 201, 400, 403")) } } override def get( requestHeaders: Seq[(String, String)] = Nil ): F[Seq[nm.joglog.api.v0.models.User]] = { val urlPath = Seq("users") _executeRequest[Unit, Seq[nm.joglog.api.v0.models.User]]("GET", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, Seq[nm.joglog.api.v0.models.User]]("Seq[nm.joglog.api.v0.models.User]", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403")) } } override def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] = { val urlPath = Seq("users", id.toString) _executeRequest[Unit, nm.joglog.api.v0.models.User]("GET", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.User]("nm.joglog.api.v0.models.User", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r if r.status.code == 404 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403, 404")) } } override def patch( entries: Seq[user.models.Entry], requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] = { val urlPath = Seq("users") val (payload, formPayload) = (Some(entries), None) _executeRequest[Seq[user.models.Entry], nm.joglog.api.v0.models.User]("PATCH", path = urlPath, body = payload, formBody = formPayload, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.User]("nm.joglog.api.v0.models.User", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403")) } } override def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] = { val urlPath = Seq("users", id.toString) _executeRequest[Unit, nm.joglog.api.v0.models.User]("DELETE", path = urlPath, requestHeaders = requestHeaders) { case r if r.status.code == 200 => _root_.nm.joglog.api.v0.Client.parseJson[F, nm.joglog.api.v0.models.User]("nm.joglog.api.v0.models.User", r) case r if r.status.code == 403 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r if r.status.code == 404 => _root_.nm.joglog.api.v0.Client.parseJson[F, String]("String", r).flatMap(body => Sync[F].raiseError(new nm.joglog.api.v0.errors.ValueResponse(r.headers, r.status.code, None, body))) case r => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Unsupported response code[${r.status.code}]. Expected: 200, 403, 404")) } } } private lazy val defaultApiHeaders = Seq( ("User-Agent", Constants.UserAgent), ("X-Apidoc-Version", Constants.Version), ("X-Apidoc-Version-Major", Constants.VersionMajor.toString) ) def apiHeaders: Seq[(String, String)] = defaultApiHeaders def modifyRequest(request: org.http4s.Request[F]): org.http4s.Request[F] = request implicit def circeJsonEncoder[F[_]: Sync, A](implicit encoder: io.circe.Encoder[A]) = org.http4s.circe.jsonEncoderOf[F, A] def _executeRequest[T, U]( method: String, path: Seq[String], queryParameters: Seq[(String, String)] = Nil, requestHeaders: Seq[(String, String)] = Nil, body: Option[T] = None, formBody : Option[org.http4s.UrlForm] = None )(handler: org.http4s.Response[F] => F[U] )(implicit encoder: io.circe.Encoder[T]): F[U] = { import org.http4s.QueryParamEncoder._ val m = org.http4s.Method.fromString(method) match { case Right(m) => m case Left(e) => sys.error(e.toString) } val headers = org.http4s.Headers(( apiHeaders ++ defaultHeaders ++ requestHeaders ).groupBy(_._1).map { case (k, l) => org.http4s.Header.Raw(org.typelevel.ci.CIString(k), l.last._2) }.toList) val queryMap = queryParameters.groupBy(_._1).map { case (k, v) => k -> v.map(_._2) } val uri = path.foldLeft(baseUrl){ case (uri, segment) => uri / segment }.setQueryParams(queryMap) val request = org.http4s.Request[F](method = m, uri = uri, headers = headers) val reqAndMaybeAuth = auth.fold(request) { case Authorization.Basic(username, passwordOpt) => { val userpass = s"$username:${passwordOpt.getOrElse("")}" val token = java.util.Base64.getEncoder.encodeToString(userpass.getBytes(java.nio.charset.StandardCharsets.ISO_8859_1)) request.putHeaders(org.http4s.Header.Raw(org.typelevel.ci.CIString("Authorization"), s"Basic $token")) } case a => sys.error("Invalid authorization scheme[" + a.getClass + "]") } val reqAndMaybeAuthAndBody = if (formBody.nonEmpty) formBody.fold(reqAndMaybeAuth)(reqAndMaybeAuth.withEntity) else body.fold(reqAndMaybeAuth)(reqAndMaybeAuth.withEntity) httpClient.fetch(modifyRequest(reqAndMaybeAuthAndBody))(handler) } } object Client { import cats.effect._ implicit def circeJsonDecoder[F[_]: Sync, A](implicit decoder: io.circe.Decoder[A]) = org.http4s.circe.jsonOf[F, A] def parseJson[F[_]: Sync, T]( className: String, r: org.http4s.Response[F] )(implicit decoder: io.circe.Decoder[T]): F[T] = r.attemptAs[T].value.flatMap { case Right(value) => Sync[F].pure(value) case Left(error) => Sync[F].raiseError(new nm.joglog.api.v0.errors.FailedRequest(r.status.code, s"Invalid json for class[" + className + "]", None, error)) } } sealed trait Authorization extends _root_.scala.Product with _root_.scala.Serializable object Authorization { final case class Basic(username: String, password: Option[String] = None) extends Authorization } package interfaces { trait Client[F[_]] { def baseUrl: org.http4s.Uri def times: nm.joglog.api.v0.Times[F] def users: nm.joglog.api.v0.Users[F] } } trait Times[F[_]] { /** * Create a time entry */ def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] /** * List all times */ def get( requestHeaders: Seq[(String, String)] = Nil ): F[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 ): F[nm.joglog.api.v0.models.Time] /** * Patch a time entry */ def patch( entries: Seq[time.models.Entry], requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] /** * Remove a specific time entry * * @param id Time ID */ def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.Time] } trait Users[F[_]] { /** * Authentication */ def postAuthenticate( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil ): F[String] /** * Create a user */ def post( minimal: .models.Minimal, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] /** * List all users */ def get( requestHeaders: Seq[(String, String)] = Nil ): F[Seq[nm.joglog.api.v0.models.User]] /** * Get a specific user * * @param id User ID */ def getById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] /** * Patch a user */ def patch( entries: Seq[user.models.Entry], requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] /** * Remove a specific user * * @param id User ID */ def deleteById( id: Int, requestHeaders: Seq[(String, String)] = Nil ): F[nm.joglog.api.v0.models.User] } package errors { final case class ValueResponse( headers: org.http4s.Headers, status: Int, message: Option[String] = None, body: String ) extends Exception(s"HTTP $status${message.fold("")(m => s": $m")}"){ lazy val value = body } final case class FailedRequest(responseCode: Int, message: String, requestUri: Option[_root_.java.net.URI] = None, parent: Exception = null) extends _root_.java.lang.Exception(s"HTTP $responseCode: $message", parent) } }