5

Pusher API にポスト リクエストを送信しようとしていますが、正しいタイプを返すのに問題があります。タイプが一致しません。見つかった: scala.concurrent.Future[play.api.libs.ws.Response] 必須: play.api.libs.ws.Response

def trigger(channel:String, event:String, message:String): ws.Response = {
val domain = "api.pusherapp.com"
val url = "/apps/"+appId+"/channels/"+channel+"/events";
val body = message

val params = List( 
  ("auth_key", key),
  ("auth_timestamp", (new Date().getTime()/1000) toInt ),
  ("auth_version", "1.0"),
  ("name", event),
  ("body_md5", md5(body))
).sortWith((a,b) => a._1 < b._1 ).map( o => o._1+"="+URLEncoder.encode(o._2.toString)).mkString("&");

    val signature = sha256(List("POST", url, params).mkString("\n"), secret.get); 
    val signatureEncoded = URLEncoder.encode(signature, "UTF-8");
    implicit val timeout = Timeout(5 seconds)
    WS.url("http://"+domain+url+"?"+params+"&auth_signature="+signatureEncoded).post(body
}
4

3 に答える 3

4

あなたが行っているリクエストpostは非同期です。Responseその呼び出しはすぐに返されますが、オブジェクトは返されません。代わりに、http 要求が非同期で完了するとオブジェクトFuture[Response]を含むオブジェクトを返します。Response

リクエストが完了するまで実行をブロックするには、次のようにします。

val f = Ws.url(...).post(...)
Await.result(f)

先物についてはこちらをご覧ください。

于 2013-03-28T21:51:03.973 に答える
3

を追加するだけmapです：

WS.url("http://"+domain+url+"?"+params+"&auth_signature="+signatureEncoded).post(body).map(_)
于 2013-03-28T21:50:52.267 に答える
3

ブロッキング アプリを作成したくない場合、メソッドはFuture[ws.Response]. 先物を Controller にバブルアップさせて、 AsyncResultusingを返し、 Async { ... }Play に残りを処理させます。

コントローラ

def webServiceResult = Action { implicit request =>
  Async {
    // ... your logic
    trigger(channel, event, message).map { response =>
      // Do something with the response, e.g. convert to Json
    }
  }
}
于 2013-03-28T22:11:04.043 に答える