handle span equipment merged event

DAXGRID · Apr 16, 2024 · 606b4fe · 606b4fe
1 parent 9294af4
commit 606b4fe
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/OpenFTTH.RelationalProjector/RelationalDatabaseProjection.cs b/OpenFTTH.RelationalProjector/RelationalDatabaseProjection.cs
@@ -51,6 +51,7 @@ public RelationalDatabaseProjection(ILogger<RelationalDatabaseProjection> logger
             ProjectEventAsync<SpanEquipmentAffixedToParent>(Project);
             ProjectEventAsync<SpanEquipmentDetachedFromParent>(Project);
             ProjectEventAsync<SpanEquipmentAddressInfoChanged>(Project);
+            ProjectEventAsync<SpanEquipmentMerged>(Project);
 
             // Span equipment specification events
             ProjectEventAsync<SpanEquipmentSpecificationAdded>(Project);
@@ -150,6 +151,10 @@ private Task Project(IEventEnvelope eventEnvelope)
                     ApplyStateChanges(_state.ProcessSpanEquipmentDetachedFromParent(@event));
                     break;
 
+                case (SpanEquipmentMerged @event):
+                    ApplyStateChanges(_state.ProcessSpanEquipmentMerged(@event));
+                    break;
+
 
                 // Span equipment specification events
                 case (SpanEquipmentSpecificationAdded @event):

diff --git a/OpenFTTH.RelationalProjector/State/ProjektorState.cs b/OpenFTTH.RelationalProjector/State/ProjektorState.cs
@@ -190,6 +190,14 @@ public List<ObjectState> ProcessSpanEquipmentMoved(SpanEquipmentMoved @event)
             return stateChanges;
         }
 
+        public List<ObjectState> ProcessSpanEquipmentMerged(SpanEquipmentMerged @event)
+        {
+            // The logic should be applied as with move
+            return ProcessSpanEquipmentMoved(
+                new SpanEquipmentMoved(@event.SpanEquipmentId, @event.NodesOfInterestIds)
+            );
+        }
+
         public List<ObjectState> ProcessSpanEquipmentRemoved(Guid spanEquipmentId)
         {
             List<ObjectState> stateChanges = new List<ObjectState>();