Skip to content

Instantly share code, notes, and snippets.

@mattroberts297

mattroberts297/CirceSupport.scala

Created August 2, 2017 19:51
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save mattroberts297/c531a4e9e525d6a18cbf8889ab5f3dec to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save mattroberts297/c531a4e9e525d6a18cbf8889ab5f3dec to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. mattroberts297 created this gist Aug 2, 2017.
    35 changes: 35 additions & 0 deletions CirceSupport.scala
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,35 @@
    import io.circe._
    import io.circe.parser._
    import io.circe.syntax._

    import akka.http.scaladsl.marshalling.{Marshaller, ToEntityMarshaller}
    import akka.http.scaladsl.model.{ContentTypeRange, HttpEntity}
    import akka.http.scaladsl.model.MediaTypes.`application/json`
    import akka.http.scaladsl.unmarshalling.{FromEntityUnmarshaller, Unmarshaller}

    import scala.concurrent.Future

    /**
    * To use circe for json marshalling and unmarshalling:
    *
    * import CirceSupport._
    * import io.circe.generic.auto._
    */
    object CirceSupport {
    private def jsonContentTypes: List[ContentTypeRange] =
    List(`application/json`)

    implicit final def unmarshaller[A: Decoder]: FromEntityUnmarshaller[A] = {
    Unmarshaller.stringUnmarshaller
    .forContentTypes(jsonContentTypes: _*)
    .flatMap { ctx => mat => json =>
    decode[A](json).fold(Future.failed, Future.successful)
    }
    }

    implicit final def marshaller[A: Encoder]: ToEntityMarshaller[A] = {
    Marshaller.withFixedContentType(`application/json`) { a =>
    HttpEntity(`application/json`, a.asJson.noSpaces)
    }
    }
    }