Как получить код ответа при использовании пользовательского объекта вместо HTTPResponse

Question

Когда я использую

val pipeline: HttpRequest => Future[HttpResponse] = addHeader(.......) ~> sendReceive ~>  unmarshal[HttpResponse]   

то я могу получить код состояния как это объект HttpResponse с помощью

val futureResponse = pipeline(Post(url, body)) futureResponse.map(_.status) 

Однако, когда Я использую пользовательский unmarshaller как:

val pipeline: HttpRequest => Future[MyResponse] = addHeader(.......) ~> sendReceive ~>  unmarshal[MyResponse] 

использованием

val myfutureResponse = pipeline(Post(url, body)) 
myutureResponse.map(_.status) 

не компилируется, поскольку он не может найти статус. Как получить код статуса здесь? Мне нужно использовать настраиваемый unmarshaller, чтобы иметь возможность десериализовать мой json-результат.

Answer 1

Наконец, я нашел ответ на основе вашего предложения

private def unmarshal[T: Unmarshaller](response: HttpResponse): T = { 
response.entity.as[T] match { 
    case Right(value) => value 
    case Left(error) ⇒ throw new PipelineException(error.toString) 
} 

}

Я изменил мой метод трубопроводного быть

val pipeline: HttpRequest => HttpResponse = addHeader(.......) ~> sendReceive 
val searchResponse = pipeline(Post(urlwithpath, queryString)).map { 
    response => response.status match { 
    case StatusCodes.OK => 
     Some(unmarshal[MyResponse](response)) 
    case StatusCodes.NotFound => print(StatusCodes.NotFound) 
    } 
} 

Теперь, когда я получил это из пути, Я правильно изучу API

Answer 2

Если вы жестко запрограммируете немаршаллер в конвейере, вы не сможете получить код состояния. Вы все равно получите код сбоя, поскольку они будут частью исключения, которое приведет к сбою Future.

Если вы действительно хотите сохранить эту информацию и использовать маркированный маршаллер в вашем трубопроводе вам нужно будет написать свой собственный ип-маршаллер, который может предоставить вам ответ такого рода:

case class Wrapper[T](response: T, status: StatusCode) 

val pipeline: HttpRequest => Future[Wrapper[MyResponse]] = addHeader(.......) ~> sendReceive ~> myUnmarshall[MyResponse] 

Этих может стать довольно сложной задачей, если вы не знаете внутренних органов. Другой вариант - не жестко закодировать бит unmarshall в вашем конвейере и вручную обработать JSON.