Akka-http: Accepter et gérer le type de contenu

J'essaie à Akka-http et j'espère que quelqu'un peut jeter de la lumière sur les questions suivantes:

  1. Comment créer des itinéraires différents basés sur l'en-tête accept: dans la demande? Par exemple, je veux un chemin de code pour gérer les "json" et à manipuler "xml" demandes (par défaut à "json" si l'en-tête est manquante)
  2. Dans les cas où je ne veux pas le contentType être déduit, comment dois-je le préciser? Par exemple, dans le code ci-dessous j'essaie d'exécuter le json par compactPrint() mais cela change en une chaîne, d'où "text/plain". Je veux remplacer et de dire au client qu'il est toujours en json.

Mon code est quelque chose comme cela;

...
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
                }
              }
          }
        }
...

La réponse dans ce cas est text/plain, depuis compactPrint crée une chaîne de caractères.
critique très bienvenue. 😉

source d'informationauteur Will I Am

  1. 8

    Vous pouvez définir le Type de Contenu comme suit,

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

    Vous pouvez créer votre propre directive,

      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)) //
        }
    }
  }

    et l'utilisation de la directive sur la route comme

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

    Un potentiel de réponse à la question #1 semble être présent, mais je voudrais le faire par l'intermédiaire d'une coutume de directive ou de ou de quelque chose de plus élégant. Malheureusement la documentation pour Akka-Http personnalisé directives semble manquer. 

    //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.
                  }
              }
            }
    ...

    En espérant que quelqu'un peut apporter quelque chose de plus propre.

  3. 0

    Il semble que l'on a accepté la réponse ne fonctionne plus avec akka-http v10.0.3.

    Cela fonctionne bien :

    //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.
              }
          }
        }
...

    vous pouvez également faire de 

    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`)))
          }
      }
    }
}

    Espère que cette aide.