feat: don't create an external event in case the deletion process sta…

…tus was changed by the owner of the identity
nmshd · May 6, 2024 · 6ca02e7 · 6ca02e7
1 parent a95bc5c
commit 6ca02e7
Show file tree

Hide file tree

Showing 7 changed files with 57 additions and 18 deletions.
diff --git a/...vices/src/Devices.Application/Identities/Commands/CancelDeletionProcessAsOwner/Handler.cs b/...vices/src/Devices.Application/Identities/Commands/CancelDeletionProcessAsOwner/Handler.cs
@@ -41,7 +41,7 @@ public async Task<CancelDeletionProcessAsOwnerResponse> Handle(CancelDeletionPro
         var newTierId = identity.TierId;
 
         _eventBus.Publish(new TierOfIdentityChangedDomainEvent(identity, oldTierId, newTierId));
-        _eventBus.Publish(new IdentityDeletionProcessStatusChangedDomainEvent(identity.Address, deletionProcess.Id));
+        _eventBus.Publish(new IdentityDeletionProcessStatusChangedDomainEvent(identity.Address, deletionProcess.Id, _userContext.GetAddress()));
 
         return new CancelDeletionProcessAsOwnerResponse(deletionProcess);
     }

diff --git a/...ces/src/Devices.Application/Identities/Commands/CancelDeletionProcessAsSupport/Handler.cs b/...ces/src/Devices.Application/Identities/Commands/CancelDeletionProcessAsSupport/Handler.cs
@@ -37,7 +37,7 @@ public async Task<CancelDeletionAsSupportResponse> Handle(CancelDeletionAsSuppor
         var newTierId = identity.TierId;
 
         _eventBus.Publish(new TierOfIdentityChangedDomainEvent(identity, oldTierId, newTierId));
-        _eventBus.Publish(new IdentityDeletionProcessStatusChangedDomainEvent(identity.Address, deletionProcess.Id));
+        _eventBus.Publish(new IdentityDeletionProcessStatusChangedDomainEvent(identity.Address, deletionProcess.Id, null));
 
         return new CancelDeletionAsSupportResponse(deletionProcess);
     }

diff --git a/...c/Devices.Application/Identities/Commands/CancelStaleIdentityDeletionProcesses/Handler.cs b/...c/Devices.Application/Identities/Commands/CancelStaleIdentityDeletionProcesses/Handler.cs
@@ -34,7 +34,7 @@ public async Task<CancelStaleIdentityDeletionProcessesResponse> Handle(CancelSta
 
             await _identityRepository.Update(identity, cancellationToken);
 
-            _eventBus.Publish(new IdentityDeletionProcessStatusChangedDomainEvent(identity.Address, deletionProcess.Value.Id));
+            _eventBus.Publish(new IdentityDeletionProcessStatusChangedDomainEvent(identity.Address, deletionProcess.Value.Id, null));
         }
 
         return new CancelStaleIdentityDeletionProcessesResponse(idsOfCancelledDeletionProcesses);

diff --git a/...c/Devices.Domain/DomainEvents/Outgoing/IdentityDeletionProcessStatusChangedDomainEvent.cs b/...c/Devices.Domain/DomainEvents/Outgoing/IdentityDeletionProcessStatusChangedDomainEvent.cs
@@ -4,13 +4,15 @@ namespace Backbone.Modules.Devices.Domain.DomainEvents.Outgoing;
 
 public class IdentityDeletionProcessStatusChangedDomainEvent : DomainEvent
 {
-    public IdentityDeletionProcessStatusChangedDomainEvent(string identityAddress, string deletionProcessId)
+    public IdentityDeletionProcessStatusChangedDomainEvent(string identityAddress, string deletionProcessId, string? initiator)
         : base($"{identityAddress}/IdentityDeletionProcessStatusChanged/{deletionProcessId}")
     {
         Address = identityAddress;
         DeletionProcessId = deletionProcessId;
+        Initiator = initiator;
     }
 
     public string Address { get; }
     public string DeletionProcessId { get; }
+    public string? Initiator { get; }
 }
diff --git a/...ityDeletionProcessStatusChanged/IdentityDeletionProcessStatusChangedDomainEventHandler.cs b/...ityDeletionProcessStatusChanged/IdentityDeletionProcessStatusChangedDomainEventHandler.cs
@@ -25,6 +25,10 @@ public IdentityDeletionProcessStatusChangedDomainEventHandler(ISynchronizationDb
 
     public async Task Handle(IdentityDeletionProcessStatusChangedDomainEvent @event)
     {
+        // No need to create an external event if the action that triggered the event was initiated by the owner of the deletion process (in that case it's not "external").
+        if (@event.Initiator == @event.Address)
+            return;
+
 #pragma warning disable IDE0037
         var payload = new { DeletionProcessId = @event.DeletionProcessId };
 #pragma warning restore IDE0037

diff --git a/...g/IdentityDeletionProcessStatusChanged/IdentityDeletionProcessStatusChangedDomainEvent.cs b/...g/IdentityDeletionProcessStatusChanged/IdentityDeletionProcessStatusChangedDomainEvent.cs
@@ -4,12 +4,14 @@ namespace Backbone.Modules.Synchronization.Domain.DomainEvents.Incoming.Identity
 
 public class IdentityDeletionProcessStatusChangedDomainEvent : DomainEvent
 {
-    public IdentityDeletionProcessStatusChangedDomainEvent(string address, string deletionProcessId)
+    public IdentityDeletionProcessStatusChangedDomainEvent(string address, string deletionProcessId, string? initiator)
     {
         Address = address;
         DeletionProcessId = deletionProcessId;
+        Initiator = initiator;
     }
 
     public string Address { get; }
     public string DeletionProcessId { get; }
+    public string? Initiator { get; }
 }
diff --git a/...n.Tests/Tests/DomainEvents/IdentityDeletionProcessStatusChangedDomainEventHandlerTests.cs b/...n.Tests/Tests/DomainEvents/IdentityDeletionProcessStatusChangedDomainEventHandlerTests.cs
@@ -14,19 +14,19 @@ namespace Backbone.Modules.Synchronization.Application.Tests.Tests.DomainEvents;
 public class IdentityDeletionProcessStatusChangedDomainEventHandlerTests
 {
     [Fact]
-    public async Task Creates_an_external_event()
+    public async Task Creates_an_external_event_if_initiator_is_someone_else()
     {
         // Arrange
-        var identityAddress = TestDataGenerator.CreateRandomIdentityAddress();
-        var identityDeletionProcessStatusChangedDomainEvent = new IdentityDeletionProcessStatusChangedDomainEvent(identityAddress, "someDeletionProcessId");
+        var deletionProcessOwner = TestDataGenerator.CreateRandomIdentityAddress();
+        var identityDeletionProcessStatusChangedDomainEvent = new IdentityDeletionProcessStatusChangedDomainEvent(deletionProcessOwner, "someDeletionProcessId", null);
 
         var mockDbContext = A.Fake<ISynchronizationDbContext>();
 
-        var externalEvent = new ExternalEvent(ExternalEventType.IdentityDeletionProcessStatusChanged, IdentityAddress.Parse(identityAddress), 1,
+        var externalEvent = new ExternalEvent(ExternalEventType.IdentityDeletionProcessStatusChanged, IdentityAddress.Parse(deletionProcessOwner), 1,
             new { identityDeletionProcessStatusChangedDomainEvent.DeletionProcessId });
 
         A.CallTo(() => mockDbContext.CreateExternalEvent(
-            identityAddress,
+            deletionProcessOwner,
             ExternalEventType.IdentityDeletionProcessStatusChanged,
             A<object>._)
         ).Returns(externalEvent);
@@ -38,26 +38,26 @@ public async Task Creates_an_external_event()
         // Act
         await handler.Handle(identityDeletionProcessStatusChangedDomainEvent);
 
-        // Handle
-        A.CallTo(() => mockDbContext.CreateExternalEvent(identityAddress, ExternalEventType.IdentityDeletionProcessStatusChanged, A<object>._))
+        // Assert
+        A.CallTo(() => mockDbContext.CreateExternalEvent(deletionProcessOwner, ExternalEventType.IdentityDeletionProcessStatusChanged, A<object>._))
             .MustHaveHappenedOnceExactly();
     }
 
     [Fact]
-    public async Task Publishes_an_external_event()
+    public async Task Publishes_a_domain_event_after_creating_an_external_event()
     {
         // Arrange
-        var identityAddress = TestDataGenerator.CreateRandomIdentityAddress();
-        var identityDeletionProcessStatusChangedDomainEvent = new IdentityDeletionProcessStatusChangedDomainEvent(identityAddress, "someDeletionProcessId");
+        var deletionProcessOwner = TestDataGenerator.CreateRandomIdentityAddress();
+        var identityDeletionProcessStatusChangedDomainEvent = new IdentityDeletionProcessStatusChangedDomainEvent(deletionProcessOwner, "someDeletionProcessId", null);
 
         var fakeDbContext = A.Fake<ISynchronizationDbContext>();
         var mockEventBus = A.Fake<IEventBus>();
 
-        var externalEvent = new ExternalEvent(ExternalEventType.IdentityDeletionProcessStatusChanged, IdentityAddress.Parse(identityAddress), 1,
+        var externalEvent = new ExternalEvent(ExternalEventType.IdentityDeletionProcessStatusChanged, IdentityAddress.Parse(deletionProcessOwner), 1,
             new { identityDeletionProcessStatusChangedDomainEvent.DeletionProcessId });
 
         A.CallTo(() => fakeDbContext.CreateExternalEvent(
-            identityAddress,
+            deletionProcessOwner,
             ExternalEventType.IdentityDeletionProcessStatusChanged,
             A<object>._)
         ).Returns(externalEvent);
@@ -69,9 +69,40 @@ public async Task Publishes_an_external_event()
         // Act
         await handler.Handle(identityDeletionProcessStatusChangedDomainEvent);
 
-        // Handle
+        // Assert
         A.CallTo(() => mockEventBus.Publish(
             A<ExternalEventCreatedDomainEvent>.That.Matches(e => e.Owner == externalEvent.Owner && e.EventId == externalEvent.Id))
         ).MustHaveHappenedOnceExactly();
     }
+
+    [Fact]
+    public async Task Does_nothing_if_initiator_is_deletion_process_owner()
+    {
+        // Arrange
+        var deletionProcessOwner = TestDataGenerator.CreateRandomIdentityAddress();
+        var identityDeletionProcessStatusChangedDomainEvent = new IdentityDeletionProcessStatusChangedDomainEvent(deletionProcessOwner, "someDeletionProcessId", deletionProcessOwner);
+
+        var mockDbContext = A.Fake<ISynchronizationDbContext>();
+        var mockEventBus = A.Fake<IEventBus>();
+
+        var externalEvent = new ExternalEvent(ExternalEventType.IdentityDeletionProcessStatusChanged, IdentityAddress.Parse(deletionProcessOwner), 1,
+            new { identityDeletionProcessStatusChangedDomainEvent.DeletionProcessId });
+
+        A.CallTo(() => mockDbContext.CreateExternalEvent(
+            deletionProcessOwner,
+            ExternalEventType.IdentityDeletionProcessStatusChanged,
+            A<object>._)
+        ).Returns(externalEvent);
+
+        var handler = new IdentityDeletionProcessStatusChangedDomainEventHandler(mockDbContext,
+            mockEventBus,
+            A.Fake<ILogger<IdentityDeletionProcessStatusChangedDomainEventHandler>>());
+
+        // Act
+        await handler.Handle(identityDeletionProcessStatusChangedDomainEvent);
+
+        // Assert
+        A.CallTo(() => mockDbContext.CreateExternalEvent(A<IdentityAddress>._, A<ExternalEventType>._, A<object>._)).MustNotHaveHappened();
+        A.CallTo(() => mockEventBus.Publish(A<IdentityDeletionProcessStatusChangedDomainEvent>._)).MustNotHaveHappened();
+    }
 }