module Eventful.ProcessManager
( ProcessManager (..)
, ProcessManagerCommand (..)
, applyProcessManagerCommandsAndEvents
) where
import Control.Monad (forM_, void)
import Eventful.Aggregate
import Eventful.Projection
import Eventful.Store.Class
import Eventful.UUID
data ProcessManager state event command
= ProcessManager
{ processManagerProjection :: Projection state (ProjectionEvent event)
, processManagerPendingCommands :: state -> [ProcessManagerCommand event command]
, processManagerPendingEvents :: state -> [ProjectionEvent event]
}
data ProcessManagerCommand event command
= forall state. ProcessManagerCommand
{ processManagerCommandAggregateId :: UUID
, processManagerCommandAggregate :: Aggregate state event command
, processManagerCommandCommand :: command
}
instance (Show command, Show event) => Show (ProcessManagerCommand event command) where
show (ProcessManagerCommand uuid _ command) =
"ProcessManagerCommand{processManagerCommandAggregateId = " ++ show uuid ++
", processManagerCommandCommand = " ++ show command ++ "}"
applyProcessManagerCommandsAndEvents
:: (Monad m)
=> ProcessManager state event command
-> EventStore event m
-> state
-> m ()
applyProcessManagerCommandsAndEvents ProcessManager{..} store state = do
forM_ (processManagerPendingCommands state) $ \(ProcessManagerCommand aggregateId aggregate command) ->
void $ commandStoredAggregate store aggregate aggregateId command
forM_ (processManagerPendingEvents state) $ \(ProjectionEvent projectionId event) ->
storeEvents store AnyVersion projectionId [event]