Consumer API: Use StatusChanged instead of RelationshipCreated DomainEvent when establishing a new Relationship

Modules/Quotas/src/Quotas.Application/Extensions/IEventBusExtensions.cs

@@ -3,7 +3,6 @@
 using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.IdentityCreated;
 using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.MessageCreated;
 using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.QuotaCreatedForTier;
-using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.RelationshipCreated;
 using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.RelationshipStatusChanged;
 using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.RelationshipTemplateCreated;
 using Backbone.Modules.Quotas.Application.DomainEvents.Incoming.TierCreated;
@@ -14,7 +13,6 @@
 using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.FileUploaded;
 using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.IdentityCreated;
 using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.MessageCreated;
-using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.RelationshipCreated;
 using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.RelationshipStatusChanged;
 using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.RelationshipTemplateCreated;
 using Backbone.Modules.Quotas.Domain.DomainEvents.Incoming.TierCreated;
@@ -41,7 +39,6 @@ private static void SubscribeToSynchronizationEvents(IEventBus eventBus)
         eventBus.Subscribe<MessageCreatedDomainEvent, MessageCreatedDomainEventHandler>();
         eventBus.Subscribe<TierQuotaDefinitionDeletedDomainEvent, TierQuotaDefinitionDeletedDomainEventHandler>();
         eventBus.Subscribe<FileUploadedDomainEvent, FileUploadedDomainEventHandler>();
-        eventBus.Subscribe<RelationshipCreatedDomainEvent, RelationshipCreatedDomainEventHandler>();
         eventBus.Subscribe<RelationshipStatusChangedDomainEvent, RelationshipStatusChangedDomainEventHandler>();
         eventBus.Subscribe<RelationshipTemplateCreatedDomainEvent, RelationshipTemplateCreatedDomainEventHandler>();
         eventBus.Subscribe<TokenCreatedDomainEvent, TokenCreatedDomainEventHandler>();

Modules/Relationships/src/Relationships.Application/Relationships/Commands/CreateRelationship/Handler.cs

@@ -2,10 +2,10 @@
 using Backbone.BuildingBlocks.Application.Abstractions.Infrastructure.EventBus;
 using Backbone.BuildingBlocks.Application.Abstractions.Infrastructure.UserContext;
 using Backbone.DevelopmentKit.Identity.ValueObjects;
-using Backbone.Modules.Relationships.Application.DomainEvents.Outgoing;
 using Backbone.Modules.Relationships.Application.Infrastructure.Persistence.Repository;
 using Backbone.Modules.Relationships.Domain.Aggregates.Relationships;
 using Backbone.Modules.Relationships.Domain.Aggregates.RelationshipTemplates;
+using Backbone.Modules.Relationships.Domain.DomainEvents.Outgoing;
 using MediatR;
 
 namespace Backbone.Modules.Relationships.Application.Relationships.Commands.CreateRelationship;
@@ -78,6 +78,6 @@ private async Task CreateAndSaveRelationship()
 
     private void PublishDomainEvent()
     {
-        _eventBus.Publish(new RelationshipCreatedDomainEvent(_relationship));
+        _eventBus.Publish(new RelationshipStatusChangedDomainEvent(_relationship));
     }
 }

Modules/Relationships/test/Relationships.Application.Tests/Tests/Relationships/Commands/CreateRelationship/HandlerTests.cs

@@ -2,11 +2,11 @@
 using Backbone.BuildingBlocks.Application.Abstractions.Infrastructure.EventBus;
 using Backbone.BuildingBlocks.Application.Abstractions.Infrastructure.UserContext;
 using Backbone.DevelopmentKit.Identity.ValueObjects;
-using Backbone.Modules.Relationships.Application.DomainEvents.Outgoing;
 using Backbone.Modules.Relationships.Application.Infrastructure.Persistence.Repository;
 using Backbone.Modules.Relationships.Application.Relationships.Commands.CreateRelationship;
 using Backbone.Modules.Relationships.Domain.Aggregates.Relationships;
 using Backbone.Modules.Relationships.Domain.Aggregates.RelationshipTemplates;
+using Backbone.Modules.Relationships.Domain.DomainEvents.Outgoing;
 using Backbone.Tooling;
 using Backbone.UnitTestTools.Data;
 using Backbone.UnitTestTools.Extensions;
@@ -153,7 +153,7 @@ await handler.Handle(new CreateRelationshipCommand
         }, CancellationToken.None);
 
         // Assert
-        A.CallTo(() => mockEventBus.Publish(A<RelationshipCreatedDomainEvent>.That.Matches(e => e.From == activeIdentity, relationshipTemplate.CreatedBy))).MustHaveHappenedOnceExactly();
+        A.CallTo(() => mockEventBus.Publish(A<RelationshipStatusChangedDomainEvent>.That.Matches(e => e.Initiator == activeIdentity, relationshipTemplate.CreatedBy))).MustHaveHappenedOnceExactly();
     }
 
     private static Handler CreateHandler(IRelationshipTemplatesRepository relationshipTemplatesRepository)

Modules/Synchronization/src/Synchronization.Application/Extensions/IEventBusExtensions.cs

@@ -2,12 +2,10 @@
 using Backbone.Modules.Synchronization.Application.DomainEvents.Incoming.IdentityDeletionProcessStarted;
 using Backbone.Modules.Synchronization.Application.DomainEvents.Incoming.IdentityDeletionProcessStatusChanged;
 using Backbone.Modules.Synchronization.Application.DomainEvents.Incoming.MessageCreated;
-using Backbone.Modules.Synchronization.Application.DomainEvents.Incoming.RelationshipCreated;
 using Backbone.Modules.Synchronization.Application.DomainEvents.Incoming.RelationshipStatusChanged;
 using Backbone.Modules.Synchronization.Domain.DomainEvents.Incoming.IdentityDeletionProcessStarted;
 using Backbone.Modules.Synchronization.Domain.DomainEvents.Incoming.IdentityDeletionProcessStatusChanged;
 using Backbone.Modules.Synchronization.Domain.DomainEvents.Incoming.MessageCreated;
-using Backbone.Modules.Synchronization.Domain.DomainEvents.Incoming.RelationshipCreated;
 using Backbone.Modules.Synchronization.Domain.DomainEvents.Incoming.RelationshipStatusChanged;
 
 namespace Backbone.Modules.Synchronization.Application.Extensions;
@@ -32,7 +30,6 @@ private static void SubscribeToMessagesEvents(IEventBus eventBus)
 
     private static void SubscribeToRelationshipsEvents(IEventBus eventBus)
     {
-        eventBus.Subscribe<RelationshipCreatedDomainEvent, RelationshipCreatedDomainEventHandler>();
         eventBus.Subscribe<RelationshipStatusChangedDomainEvent, RelationshipStatusChangedDomainEventHandler>();
     }
 }