Transactor

transactor.scala

import doobie.h2.H2Transactor
import scala.concurrent.ExecutionContext
import zio.Task
import zio.interop.catz._

object DoobiePersistenceService {

def mkTransactor(
    conf: DbConfig,
    connectEC: ExecutionContext,
    transactEC: ExecutionContext
): Managed[Throwable, Transactor[Task]] = {
  H2Transactor
    .newH2Transactor[Task](conf.url, conf.user, conf.password, connectEC, Blocker.liftExecutionContext(transactEC))
    .toManagedZIO
}