fix: fire CreatedEvent/DeletedEvent for

UpdateChannelEnvironmentVariablesCommand Signed-off-by: Matthew Fisher <[email protected]>
deislabs · Jun 13, 2022 · fe229ec · fe229ec
1 parent a5a62b1
commit fe229ec
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/Application/EnvironmentVariables/Commands/UpdateChannelEnvironmentVariablesCommand.cs b/src/Application/EnvironmentVariables/Commands/UpdateChannelEnvironmentVariablesCommand.cs
@@ -36,6 +36,11 @@ public async Task<Unit> Handle(UpdateChannelEnvironmentVariablesCommand request,
         var envVariablesToBeUpdated = EnvironmentVariablesToBeUpdated(existingVariables, request.EnvironmentVariables);
         var envVariablesToBeDeleted = EnvironmentVariablesToBeRemoved(existingVariables, request.EnvironmentVariables);
 
+        foreach (var entity in envVariablesToBeAdded)
+        {
+            entity.AddDomainEvent(new CreatedEvent<EnvironmentVariable>(entity));
+        }
+
         _context.EnvironmentVariables.AddRange(envVariablesToBeAdded);
 
         if (existingVariables.Count > 0)
@@ -55,6 +60,11 @@ public async Task<Unit> Handle(UpdateChannelEnvironmentVariablesCommand request,
             }
         }
 
+        foreach (var entity in envVariablesToBeDeleted)
+        {
+            entity.AddDomainEvent(new DeletedEvent<EnvironmentVariable>(entity));
+        }
+
         _context.EnvironmentVariables.RemoveRange(envVariablesToBeDeleted);
 
         await _context.SaveChangesAsync(cancellationToken);