akka-HTTP

Question

내가 외부 API를 호출하고 내가 OK과 다른 상태 코드의 경우 사용자에게 "있는 그대로"결과를 반환하려는 실패한 경우 보내는 응답 응답 :

val connectionFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] = 
    Http().outgoingConnection("akka.io") 
def responseFuture: Future[HttpResponse] = 
    Source.single(HttpRequest(uri = "/")) 
    .via(connectionFlow) 
    .runWith(Sink.head) 

val fooRoutes = path("foo"){ 
get { 
complete(
responseFuture.flatMap{ response => 
case OK => 
Unmarshal(response.entity.withContentType(ContentTypes.`application/json`)).to[Foo] 
case _ => response //fails 
})}} 

방법을 내가 하나가 onComplete 지시어를 사용 할 수있는이 문제를 해결하는 다른 유효한 방법이있을 수 있습니다 생각한다

Unmarshal(response.entity).to[String].flatMap { body => 
Future.failed(new IOException(s"The response status is ${response.status} response body is $body"))} 

Answer 1

: 내가 좋아하는 일을하지 않고 OK 이외의 상태 코드의 경우 "있는 그대로"응답을 반환 할 수

val fooRoutes = path("foo"){ 
    get { 
     onComplete(responseFuture) { 
     case Success(response) if response.status == OK => 
      complete(Unmarshal(response.entity.withContentType(ContentTypes.`application/json`)).to[Foo]) 

     case Success(response) => complete(response) 
     case Failure(ex) => complete((InternalServerError, s"An error occurred: ${ex.getMessage}")) 
     } 
    } 
    }