Module.scala

class Module(createSchema: Boolean = true, cfg: Config = ConfigFactory.load())(
  implicit system: ActorSystem,
  executionContext: ExecutionContext
) extends StrictLogging {

  val db = Database.forConfig("storage", cfg)
  val dao = new TripDao(db)
  val service = new TripService(dao)
  val routes: Route = concat(QueryRoutes.routes(service), CommandRoutes.routes(service))

  if (createSchema) _createSchema()

  private def _createSchema(): Unit =
    dao.createSchema().failed.foreach(t => logger.error(s"Failed to create schema: $t"))

  def close(): Unit = db.close()
}