/** * Generated by API Builder - https://www.apibuilder.io * Service version: 1.0.1 * User agent: apibuilder app.apibuilder.io/catalystsquad/catalyst-squad-hello-world-example-api/1.0.1/http4s_0_17 */ package com.catalystsquad.catalyst.squad.hello.world.example.api.v1.server import org.http4s.dsl._ import com.catalystsquad.catalyst.squad.hello.world.example.api.v1.models.json._ private[server] object Matchers { implicit lazy val queryParamDecodeBigDecimal: org.http4s.QueryParamDecoder[BigDecimal] = org.http4s.QueryParamDecoder.fromUnsafeCast[BigDecimal](p => BigDecimal(p.value))("BigDecimal") implicit lazy val queryParamDecodeInstant: org.http4s.QueryParamDecoder[_root_.java.time.Instant] = org.http4s.QueryParamDecoder.fromUnsafeCast[_root_.java.time.Instant](p => _root_.java.time.OffsetDateTime.parse(p.value).toInstant)("_root_.java.time.Instant") implicit lazy val queryParamDecodeLocalDate: org.http4s.QueryParamDecoder[_root_.java.time.LocalDate] = org.http4s.QueryParamDecoder.fromUnsafeCast[_root_.java.time.LocalDate](p => _root_.java.time.LocalDate.parse(p.value))("_root_.java.time.LocalDate") implicit lazy val queryParamDecodeUUID: org.http4s.QueryParamDecoder[_root_.java.util.UUID] = org.http4s.QueryParamDecoder.fromUnsafeCast[_root_.java.util.UUID](p => _root_.java.util.UUID.fromString(p.value))("_root_.java.util.UUID") object ApiVersion { val ApiVersionMajor = { "X-Apidoc-Version-Major".ci } def apply(req: org.http4s.Message): Boolean = req.headers.get(ApiVersionMajor) match { case Some(v) if v.value == "1" => true case _ => false } } } trait HelloRoutes { import Matchers._ implicit def circeJsonDecoder[A](implicit decoder: _root_.io.circe.Decoder[A]) = org.http4s.circe.jsonOf[A] implicit def circeJsonEncoder[A](implicit encoder: _root_.io.circe.Encoder[A]) = org.http4s.circe.jsonEncoderOf[A] sealed trait GetResponse object GetResponse { case class HTTP200(value: com.catalystsquad.catalyst.squad.hello.world.example.api.v1.models.Hello, headers: Seq[org.http4s.Header] = Nil) extends GetResponse case class HTTP404(headers: Seq[org.http4s.Header] = Nil) extends GetResponse case class UndocumentedResponse(response: fs2.Task[org.http4s.Response]) extends GetResponse } def get( _req: org.http4s.Request ): fs2.Task[GetResponse] sealed trait PostResponse object PostResponse { case class HTTP200(value: com.catalystsquad.catalyst.squad.hello.world.example.api.v1.models.Hello, headers: Seq[org.http4s.Header] = Nil) extends PostResponse case class HTTP401(value: String, challenge: org.http4s.Challenge, challenges: Seq[org.http4s.Challenge] = Nil, headers: Seq[org.http4s.Header] = Nil) extends PostResponse case class UndocumentedResponse(response: fs2.Task[org.http4s.Response]) extends PostResponse } def post( _req: org.http4s.Request ): fs2.Task[PostResponse] def apiVersionMatch(req: org.http4s.Message): Boolean = ApiVersion(req) def service() = org.http4s.HttpService { case _req @ GET -> Root / "helloes" if apiVersionMatch(_req) => get(_req).flatMap { case GetResponse.HTTP200(value, headers) => Ok(value).putHeaders(headers: _*) case GetResponse.HTTP404(headers) => NotFound().putHeaders(headers: _*) case GetResponse.UndocumentedResponse(response) => response } case _req @ GET -> Root / "helloes" if !_req.headers.get(ApiVersion.ApiVersionMajor).isDefined => BadRequest(s"Missing required request header: ${ApiVersion.ApiVersionMajor}.") case _req @ POST -> Root / "helloes" if apiVersionMatch(_req) => post(_req).flatMap { case PostResponse.HTTP200(value, headers) => Ok(value).putHeaders(headers: _*) case PostResponse.HTTP401(value, challenge, challenges, headers) => Unauthorized(challenge, challenges: _*).putHeaders(headers: _*) case PostResponse.UndocumentedResponse(response) => response } case _req @ POST -> Root / "helloes" if !_req.headers.get(ApiVersion.ApiVersionMajor).isDefined => BadRequest(s"Missing required request header: ${ApiVersion.ApiVersionMajor}.") } }