Spray client - обрабатывать ответ с неожиданным типом контента как application/json?

Question

Когда я пытаюсь получить данные Amazon удостоверения, как этот

val pipeline: HttpRequest => Future[IdentityData] = sendReceive ~> unmarshal[IdentityData] 
pipeline(Get("http://169.254.169.254/latest/dynamic/instance-identity/document")) 

с соответствующим классом случая и форматировщиком, я получаю следующее исключение

UnsupportedContentType (ожидаемый 'применение/JSON')

потому что амазонки отметьте их ответ как текст/простой тип контента. Они также не заботятся о параметре заголовка Accept. Есть ли простой способ сказать спрей-json игнорировать это на unmarshalling?

Answer 1

Если вы хотите извлечь некоторую IdentityData (который является примером класса с определенным jsonFormat) от амазонки ответа, который является действительным JSON, но с text/plain типа контекста, вы можете просто извлечь текстовые данные, анализировать его в JSON и конвертировать в ваших данных, например:

entity.asString.parseJson.convertTo(identityDataJsonFormat) 

Answer 2

После копания в распылительную списке писем я написал функцию, которая работает

def mapTextPlainToApplicationJson: HttpResponse => HttpResponse = { 
    case r@ HttpResponse(_, entity, _, _) => 
    r.withEntity(entity.flatMap(amazonEntity => HttpEntity(ContentType(MediaTypes.`application/json`), amazonEntity.data))) 
    case x => x 
} 

и использовали его в трубопроводе

val pipeline: HttpRequest => Future[IdentityData] = sendReceive ~> mapTextPlainToApplicationJson ~> unmarshal[IdentityData] 
pipeline(Get("http://169.254.169.254/latest/dynamic/instance-identity/document")) 

Отличная вещь здесь вы можете перехватить & изменить любой HttpResponse, если ваша функция перехвата имеет соответствующую подпись.

Answer 3

Я придумал более простое/более чистое решение @ yevgeniy-mordovkin.

def setContentType(mediaType: MediaType)(r: HttpResponse): HttpResponse = { 
    r.withEntity(HttpEntity(ContentType(mediaType), r.entity.data)) 
} 

Использование:

val pipeline: HttpRequest => Future[IdentityData] = (
     sendReceive 
    ~> setContentType(MediaTypes.`application/json`) 
    ~> unmarshal[IdentityData] 
) 
pipeline(Get("http://169.254.169.254/latest/dynamic/instance-identity/document"))