nbarnwell / regalo Goto Github PK

Current implementations of process managers are up to the consumer of the library. It would be helpful if process managers were actually implemented in Regalo, particularly if Regalo could handle the situation where certain aggregate instances (i.e. by type and ID) could subscribe to certain "external" events emitted by other aggregate instances.

This would remove the need for dedicated event handlers just to tell one aggregate about events that happened in another.

What is included and what's not (i.e. I've not given you the read side because I don't know what yours should be)

When using the Repository.Get(Id, Version) overload, new events generated on that aggregate will have their parent versions starting from the version loaded. Need some sort of "rebase" command that can re-set all the parent versionson a successful save.

Calling Get() multiple times on a repository for the same ID should always return the same actual object.

We have checks in the RavenEventStore.Load(Guid, Guid) method to ensure that when a specific version is requested, it exists in the EventStream. Consider making the EventStream a higher-level concept that encapsulates this kind of logic.

Basic implementations of ICommandBus and IEventBus.

First stab at conflict detection:

var common = getcommonancestorevents()
var left = common.Clone()
var right = common.Clone()

left.apply(myevents, Options.BypassInvariants)
left.apply(theirevents, Options.BypassInvariants)
right.apply(theirevents, Options.BypassInvariants)
right.apply(myevents, Options.BypassInvariants)

if (!left.Equals(right)) throw RealConcurrencyException

try {
    right.apply(myevents, Options.CheckInvariants)
} catch {
    throw RealConcurrencyException
}

return true