web-services - 在Scala中使用分派(dispatch)访问Rdio oauth API时出错

我正在尝试使用scala调度来访问Rdio API，如下所示：

import dispatch.url
import dispatch.Http
import dispatch.Defaults.executor
import dispatch._
import com.ning.http.client.oauth.ConsumerKey
import dispatch.oauth._

val consumer = new ConsumerKey("my key", "my secret")
val params = Map("method" -> "get", "keys" -> id, "extras" -> "-*,playCount")
val request = url("http://api.rdio.com/1/").POST <@ consumer << params <:< Map("Accept" -> "application/json")
val response = Http(request OK as.String)

我收到错误403。

怎么了？我确定我的钥匙是正确的。

最佳答案

我分析了rdio页面上的python示例与Scala所做的区别。

我认为确实有两个问题。


首先是您需要获取访问令牌。
第二个问题是，显然调度库的sign方法使rdio感到不满意。它将删除尾部的斜杠，从而使签名不匹配。


第一个问题很容易解决-您只需要使用Exchange类，它将为您完成大部分工作。

第二个问题非常棘手，我只复制了原始的sign方法并更改了该部分，即删除了斜杠。

代码如下。

val ck = new ConsumerKey("YOUR_CONSUMER_KEY", "YOUR_CONSUMER_TOKEN")

// declare exchange to obtain an access token
val exchange = new Exchange with SomeHttp with SomeCallback with SomeConsumer with SomeEndpoints {

  override def http: HttpExecutor = Http

  override def callback: String = "oob"

  override def consumer: ConsumerKey = ck

  override def accessToken: String = "http://api.rdio.com/oauth/access_token"

  override def authorize: String = "http://api.rdio.com/oauth/authorize"

  override def requestToken: String = "http://api.rdio.com/oauth/request_token"
}

/// we change the default method of the dispatch
def sign(request: Req, consumer: ConsumerKey, token: RequestToken): Req = {
  val calc = new OAuthSignatureCalculator(consumer, token)
  request underlying { r =>
    val req = r.build
    //!!! here we make change so the trailing slash is not removed
    val baseurl = req.getURI.toString.takeWhile(_ != '?').mkString("")
    calc.calculateAndAddSignature(baseurl, req, r)
    r
  }
}

val response = exchange.fetchRequestToken.right.flatMap { rt =>

  // point your browser to this URL with the given oauth token, we'll get PIN back
  println(s"Go to https://www.rdio.com/oauth/authorize/?oauth_callback=oob&oauth_token=${rt.getKey}")
  print("Enter PIN:")
  val pin = readLine()

  exchange.fetchAccessToken(rt, pin)
}.right.flatMap { at =>
  // now we can call API using the consumer key and the access token
  val request = sign(url("http://api.rdio.com/1/").POST << Map("method" -> "currentUser"), ck, at)
  val response = Http(request > as.String)
  response.map(Right(_))
}

response.map { responseOrError =>
  responseOrError.fold(err => println(s"Error $err"), suc => println(s"Response: $suc"))
  Http.shutdown()
}