Making append backwards compatible with earlier clients

Cratis · Aug 28, 2023 · 83e9db5 · 83e9db5
1 parent 2d509fe
commit 83e9db5
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 15 deletions.
diff --git a/Source/Kernel/Domain/EventSequences/AppendEvent.cs b/Source/Kernel/Domain/EventSequences/AppendEvent.cs
@@ -23,6 +23,6 @@ public record AppendEvent(
     EventSourceId EventSourceId,
     EventType EventType,
     JsonObject Content,
-    IEnumerable<Causation> Causation,
-    Identity CausedBy,
+    IEnumerable<Causation>? Causation,
+    Identity? CausedBy,
     DateTimeOffset? ValidFrom);
diff --git a/Source/Kernel/Domain/EventSequences/AppendManyEvents.cs b/Source/Kernel/Domain/EventSequences/AppendManyEvents.cs
@@ -19,5 +19,5 @@ namespace Aksio.Cratis.Kernel.Domain.EventSequences;
 public record AppendManyEvents(
     EventSourceId EventSourceId,
     IEnumerable<EventToAppend> Events,
-    IEnumerable<Causation> Causation,
-    Identity CausedBy);
+    IEnumerable<Causation>? Causation,
+    Identity? CausedBy);
diff --git a/Source/Kernel/Domain/EventSequences/EventSequence.cs b/Source/Kernel/Domain/EventSequences/EventSequence.cs
@@ -67,14 +67,17 @@ public async Task Append(
         [FromRoute] TenantId tenantId,
         [FromBody] AppendEvent eventToAppend)
     {
+        var causation = eventToAppend.Causation ?? _causationManager.GetCurrentChain();
+        var causedBy = eventToAppend.CausedBy ?? _identityProvider.GetCurrent();
+
         _executionContextManager.Establish(tenantId, _executionContextManager.Current.CorrelationId, microserviceId);
         var eventSequence = GetEventSequence(microserviceId, eventSequenceId, tenantId);
         await eventSequence.Append(
             eventToAppend.EventSourceId,
             eventToAppend.EventType,
             eventToAppend.Content,
-            eventToAppend.Causation,
-            eventToAppend.CausedBy,
+            causation,
+            causedBy,
             eventToAppend.ValidFrom);
     }
 
@@ -93,10 +96,13 @@ public async Task AppendMany(
         [FromRoute] TenantId tenantId,
         [FromBody] AppendManyEvents eventsToAppend)
     {
+        var causation = eventsToAppend.Causation ?? _causationManager.GetCurrentChain();
+        var causedBy = eventsToAppend.CausedBy ?? _identityProvider.GetCurrent();
+
         _executionContextManager.Establish(tenantId, _executionContextManager.Current.CorrelationId, microserviceId);
         var eventSequence = GetEventSequence(microserviceId, eventSequenceId, tenantId);
         var events = eventsToAppend.Events.Select(_ => new Grains.EventSequences.EventToAppend(eventsToAppend.EventSourceId, _.EventType, _.Content, _.ValidFrom)).ToArray();
-        await eventSequence.AppendMany(events, eventsToAppend.Causation, eventsToAppend.CausedBy);
+        await eventSequence.AppendMany(events, causation, causedBy);
     }
 
     /// <summary>

diff --git a/Source/Workbench/API/events/store/sequence/Append.ts b/Source/Workbench/API/events/store/sequence/Append.ts
@@ -18,7 +18,7 @@ export interface IAppend {
     eventSourceId?: string;
     eventType?: EventType;
     content?: any;
-    causation?: Causation[];
+    causation?: Causation;
     causedBy?: Identity;
     validFrom?: Date;
 }
@@ -48,7 +48,7 @@ export class Append extends Command<IAppend> implements IAppend {
     private _eventSourceId!: string;
     private _eventType!: EventType;
     private _content!: any;
-    private _causation!: Causation[];
+    private _causation!: Causation;
     private _causedBy!: Identity;
     private _validFrom!: Date;
 
@@ -126,11 +126,11 @@ export class Append extends Command<IAppend> implements IAppend {
         this._content = value;
         this.propertyChanged('content');
     }
-    get causation(): Causation[] {
+    get causation(): Causation {
         return this._causation;
     }
 
-    set causation(value: Causation[]) {
+    set causation(value: Causation) {
         this._causation = value;
         this.propertyChanged('causation');
     }

diff --git a/Source/Workbench/API/events/store/sequence/AppendMany.ts b/Source/Workbench/API/events/store/sequence/AppendMany.ts
@@ -17,7 +17,7 @@ export interface IAppendMany {
     tenantId?: string;
     eventSourceId?: string;
     events?: EventToAppend[];
-    causation?: Causation[];
+    causation?: Causation;
     causedBy?: Identity;
 }
 
@@ -43,7 +43,7 @@ export class AppendMany extends Command<IAppendMany> implements IAppendMany {
     private _tenantId!: string;
     private _eventSourceId!: string;
     private _events!: EventToAppend[];
-    private _causation!: Causation[];
+    private _causation!: Causation;
     private _causedBy!: Identity;
 
     constructor() {
@@ -110,11 +110,11 @@ export class AppendMany extends Command<IAppendMany> implements IAppendMany {
         this._events = value;
         this.propertyChanged('events');
     }
-    get causation(): Causation[] {
+    get causation(): Causation {
         return this._causation;
     }
 
-    set causation(value: Causation[]) {
+    set causation(value: Causation) {
         this._causation = value;
         this.propertyChanged('causation');
     }