Compare commits

...
Sign in to create a new pull request.

1 commit

Author SHA1 Message Date
Paul-Henri Froidmont
868f44e90e
Move reducer 2025-11-04 18:23:30 +01:00
3 changed files with 12 additions and 23 deletions

11
.envrc
View file

@ -1,10 +1 @@
if ! has nix_direnv_version || ! nix_direnv_version 2.2.1; then
source_url "https://raw.githubusercontent.com/nix-community/nix-direnv/2.2.1/direnvrc" "sha256-zelF0vLbEl5uaqrfIzbgNzJWGmLzCmYAkInj/LNxvKs="
fi
watch_file flake.nix
watch_file flake.lock
if ! use flake . --no-pure-eval
then
echo "devenv could not be built. The devenv environment was not loaded. Make the necessary changes to devenv.nix and hit enter to try again." >&2
fi
use flake . --no-pure-eval

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))

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))