Fixes setting of correlation ID in AggregateRoot ctor (#133)

joshkempner · web-flow · commit a7cb7a57557d · 2023-02-07T15:57:48.000-05:00
When using a root message as the correlation source in the ctor of AggregateRoot, the correlation ID would not be set correctly.
diff --git a/src/ReactiveDomain.Foundation/Domain/AggregateRoot.cs b/src/ReactiveDomain.Foundation/Domain/AggregateRoot.cs
@@ -14,8 +14,7 @@ protected AggregateRoot() { }
         protected AggregateRoot(ICorrelatedMessage source = null)
         {
             if (source == null) { return; }
-            _correlationId = source.CorrelationId;
-            _causationId = source.MsgId;
+            Source = source;
         }
 
         internal void RegisterChild(ChildEntity childAggregate, out Action<object> raise, out EventRouter router)
@@ -27,7 +26,7 @@ internal void RegisterChild(ChildEntity childAggregate, out Action<object> raise
 
         private Guid _correlationId;
         private Guid _causationId;
-        ICorrelatedMessage ICorrelatedEventSource.Source
+        public ICorrelatedMessage Source
         {
             get
             {

Original file line number	Diff line number	Diff line change
`@@ -14,8 +14,7 @@ protected AggregateRoot() { }`
`14`	`14`	`protected AggregateRoot(ICorrelatedMessage source = null)`
`15`	`15`	`{`
`16`	`16`	`if (source == null) { return; }`
`17`		`- _correlationId = source.CorrelationId;`
`18`		`- _causationId = source.MsgId;`
	`17`	`+ Source = source;`
`19`	`18`	`}`
`20`	`19`
`21`	`20`	`internal void RegisterChild(ChildEntity childAggregate, out Action<object> raise, out EventRouter router)`
`@@ -27,7 +26,7 @@ internal void RegisterChild(ChildEntity childAggregate, out Action<object> raise`
`27`	`26`
`28`	`27`	`private Guid _correlationId;`
`29`	`28`	`private Guid _causationId;`
`30`		`- ICorrelatedMessage ICorrelatedEventSource.Source`
	`29`	`+ public ICorrelatedMessage Source`
`31`	`30`	`{`
`32`	`31`	`get`
`33`	`32`	`{`