AsyncAuthenticatedBuilder.scala

package models.auth

import play.api.mvc.Results.Unauthorized
import play.api.mvc.Security.AuthenticatedRequest
import play.api.mvc._
import scala.concurrent.{ExecutionContext, Future}
import scala.language.reflectiveCalls

class AsyncAuthenticatedBuilder[U](
    userinfo: RequestHeader => Future[U], // Future[U] against Option[U]
    defaultParser: BodyParser[AnyContent],
    onUnauthorized: (RequestHeader, Throwable) => Result = _ => Unauthorized(views.html.defaultpages.unauthorized()))(implicit val executionContext: ExecutionContext) extends ActionBuilder[({ type R[A] = AuthenticatedRequest[A, U] })#R, AnyContent] {

  lazy val parser = defaultParser

  def invokeBlock[A](request: Request[A], block: (AuthenticatedRequest[A, U]) => Future[Result]) =
    authenticate(request, block)

  /**
    * Authenticate the block
    */
  def authenticate[A](request: Request[A], block: (AuthenticatedRequest[A, U]) => Future[Result]) = {
    userinfo(request).flatMap { user =>
      block(new AuthenticatedRequest(user, request))
    } recoverWith {
      case t: Throwable => Future.successful[Result](onUnauthorized(request, t))
    }
  }
}