Акка HTTP POST маршрут JSON десериализация - PullRequest
Новая
       60

Акка HTTP POST маршрут JSON десериализация

0 голосов
/ 18 мая 2019

Я новичок в Scala Akka httpd и пытаюсь создать почтовый маршрут, который может принимать данные JSON для сериализации и возвращать другой ответ JSON.Пока что я создал приведенный ниже код, но в нем есть какая-то ошибка, и я не могу ее решить.

Я также загружаю проект в github: https://github.com/devawal/akka-http-bidder

// This class will take POST JSON data and process for internal matching
case class BidRequest(id: String, imp: Option[List[Impression]], site: Site, user: Option[User], device: Option[Device])


// BidResponse protocol:
// This will return as HTTP JSON response
case class BidResponse(id: String, bidRequestId: String, price: Double, adid: Option[String], banner: Option[Banner])


trait ServiceJsonProtoocol extends DefaultJsonProtocol {
  implicit val customerProtocol = jsonFormat5(BidResponse)
}

object Bidder extends App with ServiceJsonProtoocol{
  implicit val system = ActorSystem("bid_request")
  implicit val meterializer = ActorMaterializer()
  import system.dispatcher
  import akka.http.scaladsl.server.Directives._

  // Define common HTTP entity
  def toHttpEntity(payload: String) = HttpEntity(ContentTypes.`application/json`, payload)

  //implicit val timeOut = Timeout(2 seconds)


  // Server code
  val httpServerRoute =
   pathPrefix("api" / "bid-request") {
     post {
       entity(as[requestData]){ request =>

       }
     }
  }

  Http().bindAndHandle(httpServerRoute, "localhost", 8080)
}

Мой запрос JSONis: 

{"id":"XN2zZQABxJsKK0jU4QnIzw","imp":[{"id":"1","banner":{"w":300,"h":250,"pos":3,"format":[{"w":300,"h":250}]},"displaymanager":"GOOGLE","tagid":"4254117042","bidfloor":0.19,"bidfloorcur":"USD","secure":1,"metric":[{"type":"click_through_rate","value":0,"vendor":"EXCHANGE"},{"type":"viewability","value":0.80000000000000004,"vendor":"EXCHANGE"},{"type":"session_depth","value":13,"vendor":"EXCHANGE"}],"ext":{"billing_id":["71151605235"],"publisher_settings_list_id":["18260683268513888323","2151365641960790044"],"allowed_vendor_type":[79,138,144,237,238,331,342,414,445,474,485,489,523,550,566,698,704,743,745,767,776,780,785,797,828,4374,4513,4648,4651,4680,4697],"ampad":3}}],"site":{"page":"http://jobs.bdjobs.com/jobsearch.asp","publisher":{"id":"pub-5130888087776673","ext":{"country":"BD"}},"content":{"contentrating":"DV-G","language":"en"},"ext":{"amp":0}},"device":{"ua":"Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:66.0) Gecko/20100101 Firefox/66.0","ip":"103.219.170.0","geo":{"lat":23.818607330322266,"lon":90.433006286621094,"country":"BGD","utcoffset":360},"os":"Windows","devicetype":2,"pxratio":1},"user":{"id":"CAESEGTB3gVLV019BLOZ9saadwo","data":[{"id":"DetectedVerticals","name":"DoubleClick","segment":[{"id":"5076","value":"0.8"},{"id":"960","value":"1"},{"id":"61","value":"0"},{"id":"330","value":"0.1"},{"id":"959","value":"0.1"}]}]},"at":2,"tmax":122,"cur":["USD"],"ext":{"google_query_id":"ANy-zJH36AVK9h5uCf4Z0xfyWjrBZU6M7mxGfgQE9A_qw_HahXk9khANxU7o1KDEIsfldK0DAw"}}

Как я могу обработать ввод JSON и отправить ответ?

Update

Я обновил свой маршрут до точки с классом дела, но получил ошибку в консоли 

val httpServerRoute =
     post {
       path("bid-request")
       entity(implicitly[FromRequestUnmarshaller[requestData]]) { request =>
         complete((dataBiddermap ? getBidderData(request)).map(
           _ => StatusCodes.OK
         ))
       }
     }

Сообщение об ошибке: 

Error:(95, 25) could not find implicit value for parameter e: akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller[bidder.requestData]
   entity(implicitly[FromRequestUnmarshaller[requestData]]) { request =>
Error:(95, 25) not enough arguments for method implicitly: (implicit e: akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller[bidder.requestData])akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller[bidder.requestData].Unspecified value parameter e.
   entity(implicitly[FromRequestUnmarshaller[requestData]]) { request =>

1 Ответ

1 голос
/ 20 мая 2019

Я использую этот шаблон для post запросов на моем сервере, надеюсь, это поможет: 

post {
  decodeRequest {
    entity(as[BidRequest]) { bidRequest =>
      val response: BidResponse = process(bidRequest)

      complete(response)
    }
  }
}

Маршалеры для типов запросов и ответов находятся в области действия.

...