0

喷雾和 scala 的新手。这几天一直在努力让它正确。

我正在尝试将 facebook oauth2 登录 + 用户登录详细信息合并到数据库中，以防同一用户通过不同方式（用户/密码或 fb 登录）登录。

粘贴在喷雾路由片段下方。

  path("facebook") {
    post{
      entity(as[JObject]) { json =>
        val fb: FacebookAuthModel = json.extract[FacebookAuthModel]
        complete {

          //Get user details from fb oauth2
          val fbUser = fbAuth.getIdentity(fb) match {
            case Right(user: User) => user
            case Left(error: Failure) => throw new FailureException(error)
          }

          //Check if user is already present either by fb id or email
          val userFuture = userRepo(FetchUserByFacebook(fbUser.facebook.get,fbUser.email))

          userFuture.map {
            case u: User => {

              //user present but fb id not attached yet
              if (u.facebook.isEmpty) {
                //update fb id for the user - fire to actor and forget, i.e no callback to sender
                userRepo(UpdateFacebookId(u.id.get, fbUser.facebook.get))
              }

              //complete request with a token - request(1)
              AuthToken(token=jwt.createToken(u))
            }
            case None => {

              //first time user using fb login
              userRepo(CreateUser(fbUser)).map {

                //complete request with the token - request(2)
                case createdUser: User => AuthToken(token=jwt.createToken(createdUser))

                case None => throw new FailureException(Failure("Not able to CreateUser", FailureType.Unauthorized))
              }
            }
          }
        }  
      }
    }
  }

一切正常，除非是第一次使用 fb 登录的用户（请参阅 request(2)）。
在嵌套未来完成之前，请求以空响应完成。

我尝试对来自 userFuture 的结果进行 flatMapping，然后在其上使用 onComplete 以给出适当的响应，但它不起作用。

知道如何使用令牌成功完成请求（请求（2））吗？

4

1 回答 1

1

如果您的代码执行路径中的两个分支之一可能导致 a Future，那么您在处理时必须将此编码为最低公分母userFuture。这意味着在您没有明确的秒数要处理的情况下flatMap打开userFuture和使用。沿着这条线的东西：Future.successfulFuture

def handleUserResult(a:Any):Future[AuthToken] = a match{
  case u:User =>              
    if (u.facebook.isEmpty) {                
      userRepo(UpdateFacebookId(u.id.get, fbUser.facebook.get))
    }              
    Future.successful(AuthToken(token=jwt.createToken(u)))

  case None =>              
    userRepo(CreateUser(fbUser)).map {
      case createdUser: User =>
        AuthToken(token=jwt.createToken(createdUser))

      case None => 
        throw new FailureException(Failure("Not able to CreateUser", FailureType.Unauthorized))
    }
}

定义该方法后，您可以userResult按如下方式使用它：

userResult.flatMap(handleUserResult)

我没有检查此代码是否存在编译问题。我更想展示flatMap用于处理两种情况的一般方法，一种产生另一种情况，另Future一种没有。

于 2015-02-01T17:40:02.157 回答