バックエンドの定義

BalanceSheetApp.scala

object BalanceSheetApp {
  given BackendCodec[BsEvent] = CirceCodec.json
  given BackendCodec[BsNotification] = CirceCodec.json
  given BackendCodec[BalanceSheet] = CirceCodec.json

  def backend[F[_]: Async](pool: Resource[F, Session[F]]) = Backend
    .builder(BalanceSheetService)
    .use(SkunkDriver("edomata_kakeibo", pool))
    .build

  def apply[F[_]: Async](pool: Resource[F, Session[F]]) =
    backend(pool).map(s =>
      new BalanceSheetApp(s, s.compile(BalanceSheetService[F]))
    )
}

final case class BalanceSheetApp[F[_]](
    storage: eventsourcing.Backend[
      F,
      BalanceSheet,
      BsEvent,
      BsRejection,
      BsNotification
    ],
    service: BalanceSheetService.Handler[F]
)