Как определить сервер http4s как ZIO ZLayer, который будет внедряться и извлекаться в основном?

Помогите мне определить http4s с помощью ZLayers. Я учусь и запутался. Я хотел бы выделить http-сервер как компонент. Но я не знаю, как скомпоновать ZManageds и ZLayers, чтобы они скомпилировались.

Также имеет смысл создавать слой, требующий Runtime[ZEnv]? Или имеет смысл создать слой, требующий ZEnv, и сгенерировать для него среду выполнения.

object HttpServer {

  def createHttp4Server: ZManaged[Runtime[ZEnv], Throwable, Server] = 
      ZManaged.accessManaged { implicit runtime: Runtime[ZEnv] =>
        BlazeServerBuilder[Task](runtime.platform.executor.asEC)
          .bindHttp(8080, "localhost")
          .withHttpApp(Routes.helloWorldService)
          .resource
          .toManagedZIO
      }


  def createHttp4Layer: ZLayer[RuntimeLayer, Throwable, Http4ServerLayer] =
    ZLayer.succeed(createHttp4Server)

}

object Routes {
  val helloWorldService = ...
}

package object simple {
  type Http4ServerLayer = Has[ZManaged[Runtime[ZEnv], Throwable, Server]]
  type RuntimeLayer = Has[Runtime[ZEnv]]
}

Я не знаю, как получить доступ к ZManaged[..., ..., Server] из Layer здесь в основном. Я не совсем понимаю access методы.

object ItsAren extends App {

  def run(args: List[String]): URIO[ZEnv, ExitCode] = {

    val toProvide: ZIO[Http4ServerLayer, Nothing, ExitCode] =
      ZIO
        .accessM[Http4ServerLayer](_.get.useForever) //compile error
        .as(ExitCode.success)
        .catchAll(ZIO.succeed(ExitCode.failure))

    val runtimeLayer: ZLayer[Any, Nothing, RuntimeLayer]              = ZLayer.succeed(Runtime.default)
    val http4Layer: ZLayer[RuntimeLayer, Throwable, Http4ServerLayer] = HttpServer.createHttp4Layer
    val fullLayer: ZLayer[Any, Throwable, Http4ServerLayer]           = runtimeLayer >>> http4Layer

    val provided = toProvide.provideCustomLayer(fullLayer)

    provided //compile error
  }

}

type mismatch
 found   : ZIO[Runtime[ZEnv], Throwable, Nothing]
 required: ZIO[Http4ServerLayer, ?, ?]

также внизу, но это меньшее значение

 found   : ZIO[ZEnv, Throwable, ExitCode]
 required: URIO[ZEnv, ExitCode]

То же самое в PR, не стесняйтесь комментировать https://github.com/kovacshuni/itsaren/pull/1


scala cats-effect http4s zio
person Hunor Kovács    schedule 07.10.2020    source источник
comment
Решено, скоро выкладываю результат.   -  person Hunor Kovács    schedule 07.10.2020

Ответы (1)


arrow_upward
0
arrow_downward

Решение состоит в том, что ZLayer при наличии Managed сам является управляемым. Поэтому, когда что-то работает на таком слое, все это время будет использоваться включенный Managed. Таким образом, если вы запустите ZIO.never на слое, сервер останется в живых.

Создание самого слоя было еще одной уловкой с использованием fromManaged. И createHttp4Server требует только ZEnv, я признаю, что теперь нет смысла требовать Runtime. ZManaged.runtime - это еще одна уловка, которую они используют, чтобы не использовать ZManaged.accessManaged { implicit runtime: Runtime[ZEnv] =>.

Полное решение https://github.com/kovacshuni/zio-http4s-zlayer-example < / а>

object Main extends App {

  def run(args: List[String]): URIO[ZEnv, ExitCode] = {

    val program: ZIO[Has[Server] with Console, Nothing, Nothing] =
      ZIO.never

    val httpServerLayer: ZLayer[ZEnv, Throwable, Http4Server] = Http4Server.createHttp4sLayer

    program
      .provideLayer(httpServerLayer ++ Console.live)
      .exitCode
  }

}

import zio._
import zio.interop.catz._
import zio.interop.catz.implicits._

import org.http4s.server.Server
import org.http4s.server.blaze.BlazeServerBuilder

object Http4Server {

  type Http4Server = Has[Server]

  def createHttp4Server: ZManaged[ZEnv, Throwable, Server] =
    ZManaged.runtime[ZEnv].flatMap { implicit runtime: Runtime[ZEnv] =>
      BlazeServerBuilder[Task](runtime.platform.executor.asEC)
        .bindHttp(8080, "localhost")
        .withHttpApp(Routes.helloWorldService)
        .resource
        .toManagedZIO
    }

  def createHttp4sLayer: ZLayer[ZEnv, Throwable, Http4Server] =
    ZLayer.fromManaged(createHttp4Server)

}
person Hunor Kovács    schedule 07.10.2020