玩2.2 EssentialAction与期货 [英] Play 2.2 EssentialAction With Futures
问题描述
我正在尝试实现类似于此示例的身份验证机制:
I'm trying to implement an authentication mechanism similar to this example:
def HasToken(action: String => EssentialAction): EssentialAction = EssentialAction { requestHeader =>
val maybeToken = requestHeader.headers.get("X-SECRET-TOKEN")
maybeToken map { token =>
action(token)(requestHeader) // apply requestHeader to EssentialAction produces the Iteratee[Array[Byte], SimpleResult]
} getOrElse {
Done(Unauthorized("401 No Security Token\n")) // 'Done' means the Iteratee has completed its computations
}
}
但是,在我的情况下,我正在将随机令牌值映射到存储在Mongodb中的服务器端的会话.目的是使用户能够随意终止其所有其他会话.
However, in my case I'm mapping a random token value to a session on the server side stored in Mongodb. The goal was to be able to let a user terminate all his other sessions at will.
但是,我从ReactiveMongo获得的数据将被包装在Future中.
However, the data I get from ReactiveMongo is going to be wrapped in a Future.
我想要这样的东西:
def HasToken(action: String => EssentialAction): EssentialAction = EssentialAction { requestHeader =>
val maybeToken = requestHeader.headers.get("session")
maybeToken map { token =>
//This returns a future..
Session.find(session).map { result =>
result match
case Some(session) => action(session)(requestHeader)
case None => Done(Unauthorized())
}
} getOrElse {
Done(Unauthorized("401 No Security Token\n")) // 'Done' means the Iteratee has completed its computations
}
}
EssentialAction是否可能?
Is this possible with EssentialAction?
推荐答案
Iteratee.flatten
来自Future[Iteratee[A, E]] => Iteratee[A, E]
,因此您可以这样做:
Iteratee.flatten
goes from Future[Iteratee[A, E]] => Iteratee[A, E]
so you could do it like this:
def HasToken(action: String => EssentialAction): EssentialAction = EssentialAction { requestHeader =>
val maybeToken = requestHeader.headers.get("session")
val futureIteratee: Future[Iteratee[Array[Byte], SimpleResult]] = maybeToken map { token =>
//This returns a future..
Session.find(token).map {
case Some(session) => action(session)(requestHeader)
case None => Done[Array[Byte], SimpleResult](Unauthorized("Invalid token"))
}
} getOrElse {
Future.successful(Done[Array[Byte], SimpleResult](Unauthorized("401 No Security Token\n")))
}
Iteratee.flatten(futureIteratee)
}
这篇关于玩2.2 EssentialAction与期货的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!