jczuchnowski

val zioResult: ZIO[Any, Exception, PortfolioStatus] = 
  ApplicationService.getPortfolio(portfolioId).provide(env)
val runtime = new DefaultRuntime() {}
runtime.unsafeRun(zioResult)

jczuchnowski

class LiveEnv 
    extends SlickAssetRepository 
    with SlickPortfolioAssetRepository 
    with LiveDatabaseProvider

val env = new LiveEnv()

jczuchnowski

object ApplicationService {
  def getPortfolio(portfolioId: PortfolioId): ZIO[AssetRepository with PortfolioAssetRepository, Exception, PortfolioStatus] = ...
}

jczuchnowski

def fromStreamingDBIO[T](dbio: StreamingDBIO[_, T]): ZIO[DatabaseProvider, Throwable, ZStream[Any, Throwable, T]] =
  for {
    db <- ZIO.accessM[DatabaseProvider](_.databaseProvider.db)
    r  <- ZIO.effect(db.stream(dbio).toStream())
  } yield r

jczuchnowski

def fromDBIO[R](dbio: DBIO[R]): ZIO[DatabaseProvider, Throwable, R] =
  for {
    db <- ZIO.accessM[DatabaseProvider](_.databaseProvider.db)
    r  <- ZIO.fromFuture(ec => db.run(dbio))
  } yield r

jczuchnowski

result <- ZIO.fromFuture(ec => db.run(dbio))

jczuchnowski

db.run(action)

jczuchnowski

db <- ZIO.accessM[DatabaseProvider](_.databaseProvider.db)

jczuchnowski

trait PortfolioAssetRepository {
  def portfolioAssetRepository: PortfolioAssetRepository.Service
}

object PortfolioAssetRepository {
  trait Service {
  
    def add(name: String, price: BigDecimal): IO[RepositoryException, AssetId]
    
    def getById(id: AssetId): IO[RepositoryException, Option[Asset]]

jczuchnowski

trait LiveDatabaseProvider extends DatabaseProvider {
  override val databaseProvider = new DatabaseProvider.Service {
    override val db = ZIO.effectTotal(Database.forURL(url = "jdbc:h2:prod"))
  }
}