Jak rozpakować `text/plain` jako JSON w Akka HTTP

Question

Pracuję ze starszym API HTTP (którego nie mogę zmienić), który reaguje z JSON w ciele, ale daje nagłówek Content-Type: text/plain; charset=utf-8.

Ja próbuje wycofać to ciało HTTP jako JSON, ale pojawia się następujący wyjątek: akka.http.scaladsl.unmarshalling.Unmarshaller$UnsupportedContentTypeException: Unsupported Content-Type, supported: application/json

Mój kod wygląda następująco:

import spray.json.DefaultJsonProtocol 
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._ 
import akka.http.scaladsl.unmarshalling._ 

case class ResponseBody(status: String, error_msg: String) 

object ResponseBodyJsonProtocol extends DefaultJsonProtocol { 
    implicit val responseBodyFormat = jsonFormat2(ResponseBody) 
} 

def parse(entity: HttpEntity): Future[ResponseBody] = { 
    implicit val materializer: Materializer = ActorMaterializer() 
    import ResponseBodyJsonProtocol._ 
    Unmarshal[HttpEntity](entity).to[ResponseBody] 
} 

Odpowiedź próbka HTTP wygląda następująco:

HTTP/1.1 200 OK 
Cache-Control: private 
Content-Encoding: gzip 
Content-Length: 161 
Content-Type: text/plain; charset=utf-8 
Date: Wed, 16 Dec 2015 18:15:14 GMT 
Server: Microsoft-IIS/7.5 
Vary: Accept-Encoding 
X-AspNet-Version: 4.0.30319 
X-Powered-By: ASP.NET 

{"status":"1","error_msg":"Missing parameter"} 

Co mogę zrobić, aby zignorować wartość Content-Type w odpowiedzi HTTP i przeanalizować jako JSON?

Answer 1

Jeden obejście znalazłem tylko ręcznie ustawić Content-Type na HttpEntity przed unmarshalling go:

def parse(entity: HttpEntity): Future[ResponseBody] = { 
    implicit val materializer: Materializer = ActorMaterializer() 
    import ResponseBodyJsonProtocol._ 
    Unmarshal[HttpEntity](entity.withContentType(ContentTypes.`application/json`)).to[ResponseBody] 
} 

wydaje się działać OK, ale jestem otwarty na inne pomysły ...

Answer 2

I użyje dyrektywy map.... Wygląda krótko i elegancko.

val routes = (decodeRequest & encodeResponse) { 
    mapResponseEntity(_.withContentType(ContentTypes.`application/json`)) { 
    nakedRoutes ~ authenticatedRoutes 
    } 
}