1

PLAYフレームワークにこのコードがあります

  def ws: WebSocket = WebSocket.acceptOrResult[JsValue, JsValue] { rh =>
    implicit val req = Request(rh, AnyContentAsEmpty)

    silhouette.SecuredRequestHandler { securedRequest =>
      Future.successful(HandlerResult(Ok, Some(securedRequest.identity)))
    }.map {
      case HandlerResult(_, Some(_)) => wsFutureFlow(rh).map { flow => Right(flow) }
      case HandlerResult(r, None) => Left(r)
    }

    //    wsFutureFlow(rh).map { flow =>
    //      Right(flow)
    //    }.recover {
    //      case e: Exception =>
    //        logger.error("Cannot create websocket", e)
    //        val jsError = Json.obj("error" -> "Cannot create websocket")
    //        val result = InternalServerError(jsError)
    //        Left(result)
    //    }
  }



private def wsFutureFlow(request: RequestHeader): Future[Flow[JsValue, JsValue, NotUsed]] = {
    // Use guice assisted injection to instantiate and configure the child actor.
    implicit val timeout = Timeout(1.second) // the first run in dev can take a while :-(
    val future: Future[Any] = userParentActor ? UserParentActor.Create(request.id.toString)
    val futureFlow: Future[Flow[JsValue, JsValue, NotUsed]] = future.mapTo[Flow[JsValue, JsValue, NotUsed]]
    futureFlow
  }

私はスカラの初心者であり、基本的に私がやろうとしているのは、wsエンドポイントへのリクエストを認証することです。認証Flow[JsValue, JsValue, None]されている場合は、WebSocket 接続として機能するように を渡します。それ以外の場合は、 を返す必要がありResultます。私が抱えている問題は、先物を正しく設計する方法がよくわからないことです。コンテキストとして、ドキュメントhttps://www.silhouette.rocks/docs/endpointsの認証済みエンドポイントの例を次に示します。

コンパイルされない行は次のとおりです。

  case HandlerResult(_, Some(_)) => wsFutureFlow(rh).map { flow => Right(flow) }

渡す関数はWebSocket.acceptOrResult[JsValue, JsValue]、 を返す必要がありFuture[Either[Result, Flow[In, Out, _]]]ます。コンパイルされていない行でわかるように、私はしようとしていますRight()がFlow、それはまったく正しくありません。ただし、コメントセクションはコンパイルされます。ここにコンパイルエラーがあります

[error] /home/julian/IdeaProjects/crypto-bloomberg-app/app-admin/src/main/scala/admin/controllers/HomeController.scala:32:62: type mismatch;
[error]  found   : scala.concurrent.Future[scala.util.Right[Nothing,akka.stream.scaladsl.Flow[play.api.libs.json.JsValue,play.api.libs.json.JsValue,akka.NotUsed]]]
[error]  required: Either[play.api.mvc.Result,akka.stream.scaladsl.Flow[play.api.libs.json.JsValue, play.api.libs.json.JsValue, _]]
[error]       case HandlerResult(_, Some(_)) => wsFutureFlow(rh).map { flow => Right(flow) }
[error]                                                              ^
[error] one error found
[error] (app-admin/compile:compileIncremental) Compilation failed
[error] Total time: 4 s, completed 21-Mar-2018 4:29:04 PM

ありがとう

4

1 に答える 1