phfroidmont/foyer-dsi-assure-2035
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Move reducer

Browse source
This commit is contained in:
Paul-Henri Froidmont 2025-11-04 17:57:44 +01:00
parent 4bd2a1518b
commit 868f44e90e
Signed by: phfroidmont
GPG key ID: BE948AFD7E7873BE
3 changed files with 12 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

13
core/src/lu/foyer/EventSourcing.scala
View file

@ -1,9 +1,6 @@
package lu.foyer
import zio.*
import zio.schema.Schema
import lu.foyer.auth.UserInfo
final case class Entity[T](entityId: String, data: T, version: Long)
final case class Event[T](entityId: String, data: T, eventId: String)
@ -12,13 +9,3 @@ trait StateRepository[Data] extends Repository[Entity[Data], String]
trait EventRepository[Data] extends Repository[Event[Data], String]:
def fetchOne(entityId: String, eventId: String): Task[Option[Event[Data]]]
def fetchMany(entityId: String, page: Page): Task[Paged[Event[Data]]]
trait Reducer[Event, State]:
def fromEmpty: PartialFunction[Event, State]
def fromState: PartialFunction[(State, Event), State]
def reduce(event: Event): Option[State] =
fromEmpty.lift(event)
def reduce(state: State, event: Event): Option[State] =
fromState.lift((state, event))

11
core/src/lu/foyer/Reducer.scala Normal file
View file

@ -0,0 +1,11 @@
package lu.foyer
trait Reducer[Event, State]:
def fromEmpty: PartialFunction[Event, State]
def fromState: PartialFunction[(State, Event), State]
def reduce(event: Event): Option[State] =
fromEmpty.lift(event)
def reduce(state: State, event: Event): Option[State] =
fromState.lift((state, event))