upickle akka-http

upickleakkahttp.scala

import akka.http.marshalling._
import akka.http.model._
import akka.http.unmarshalling.{FromResponseUnmarshaller, FromRequestUnmarshaller, Unmarshaller}
import akka.stream.FlowMaterializer
import upickle.{Writer, Reader}
import scala.concurrent.duration._
import scala.concurrent.{ExecutionContext, Future}
import scala.language.implicitConversions


trait BaseUPickleSupport {

  implicit def upickleFromRequestUnmarshaller[T: Reader](implicit fm:FlowMaterializer, ex:ExecutionContext):FromRequestUnmarshaller[T] =
    new Unmarshaller[HttpRequest,T] {
      def apply(req: HttpRequest): Future[T] = {
        req.entity.withContentType(ContentTypes.`application/json`).toStrict(1.second)
          .map(_.data.toArray).map(x => upickle.read[T](new String(x)))
      }
    }

  implicit def upickleFromResponseUnmarshaller[T: Reader](implicit fm:FlowMaterializer, ex:ExecutionContext):FromResponseUnmarshaller[T] =
    new Unmarshaller[HttpResponse,T] {
      def apply(res: HttpResponse): Future[T] = {
        res.entity.withContentType(ContentTypes.`application/json`).toStrict(1.second).map(_.data.toArray).map(x => upickle.read[T](new String(x)))
      }
    }

  implicit def upickleToEntityMarshaller[T:Writer]:ToEntityMarshaller[T] =
    Marshaller.withFixedCharset[T, MessageEntity](MediaTypes.`application/json`,HttpCharset.custom("*"))( tp =>
      HttpEntity(upickle.write[T](tp)))