Akka-http: Kabul ve İçerik tipi işleme

Question

ben çalışıyorum Akka-http ve umarım birisi şu sorulara ışık tutabilir: birinciyi kabul dayalı farklı yolları oluşturmak nasıldır

1. : istekte başlık? Örneğin, "json" işlemek ve "xml" isteklerini işlemek için bir kod yolu istiyorum (başlık eksikse varsayılan olarak "json" için)

2. ContentType'ın istemesini istemediğim durumlarda ertelenir, nasıl belirleyebilirim? Örneğin, aşağıdaki kodda json'u compactPrint() ile çalıştırmaya çalışıyorum ancak bu onu bir dizgeye, dolayısıyla "text/plain" olarak değiştirir. Bunu geçersiz kılmak ve müşteriye hala json olduğunu söylemek istiyorum.

Benim kodum böyle bir şeydir;

... 
path("api") { 
      get { 
       complete { 
       getStuff.map[ToResponseMarshallable] { 
        case Right(r) if r.isEmpty => List[String]().toJson.compactPrint 
        case Right(r) => r.toJson.compactPrint 
        case Left(e) => BadRequest -> e 
       } 
       } 
      } 
     } 
... 

Bu durumda yanıt text/plain, çünkü compactPrint bir dize oluşturur. eleştiri çok hoş geldiniz. ;)

aşağıdaki gibi içerik türü tanımlayabilirsiniz

Answer 1

,

Sen olarak özel yönergesini oluşturabilir

complete { 
      HttpResponse(entity = HttpEntity(ContentType(MediaTypes.`application/json`), """{"id":"1"}""")) 
     } 

,

def handleReq(json: String) = { 
    (get & extract(_.request.acceptedMediaRanges)) { 
     r => 
     val encoding: MediaRange = 
      r.intersect(myEncodings).headOption 
      .getOrElse(MediaTypes.`application/json`) 
     complete { 
      // check conditions here 
     // HttpResponse(entity = HttpEntity(encoding.specimen, json)) // 
     } 
    } 
    } 

gibi rotada yönergesini kullanmak

val route = path("api"){ handleReq(json) } 

Answer 2

1. soru için olası bir cevap bu gibi görünüyor, ancak özel bir direktifle veya daha zarif bir şeyle yapmak istiyorum. Ne yazık ki, Akka-Http özel direktifleri için dokümantasyon eksik görünüyor.

// the encodings I want, in the order of preference 
val myEncodings = Seq(MediaRange(`application/xml`),MediaRange(`application/json`)) 

    ... 
    path("api") { 
       (get & extract(_.request.acceptedMediaRanges)){ 
        r => 
        val encoding = 
         r.intersect(myEncodings).headOption 
         .getOrElse(MediaRange(`application/json`)) 
        complete { 
         // check "encoding" here and make decision. 
        } 
       } 
      } 
    ... 

umuduyla birisi bir şey temizleyici sağlayabilir.

Answer 3

Kabul edilen cevap akka-http v10.0.3 ile artık çalışmıyor gibi görünüyor.

Bu olsa çalışır: Ayrıca bu yardımcı olur

val myEncodings = Seq(MediaRange(`application/xml`),MediaRange(`application/json`)) 

path("api") { 
     (get & extract(_.request.headers)){ requestHeaders => 
     complete { 
      val mediaTypeNegotiator = new MediaTypeNegotiator(requestHeaders) 
      if(mediaTypeNegotiator.accept(MediaTypes.`application/xml`)) { 
      // respond with xml 
      } else if(mediaTypeNegotiator.accept(MediaTypes.`application/json`)) { 
      // respond with json 
      } else { 
      // respond with json by default or reject properly : 
      reject(UnsupportedRequestContentTypeRejection(Set(MediaTypes.`application/xml`, MediaTypes.`application/json`))) 
      } 
     } 
    } 
} 

Umutlar yapabileceği

// the encodings I want, in the order of preference 
val myEncodings = Seq(MediaRange(`application/xml`),MediaRange(`application/json`)) 

... 
path("api") { 
      (get & extract(_.request.headers)){ requestHeaders => 
       val mediaTypeNegotiator = new MediaTypeNegotiator(requestHeaders) 
       val encoding = mediaTypeNegotiator 
        .acceptedMediaRanges 
        .intersect(myEncodings) 
        .headOption 
        .getOrElse(MediaRange(`application/json`)) 
       complete { 
        // check "encoding" here and make decision. 
       } 
      } 
     } 
... 

.