Refactoring Integration Events so they cannot be confused with Domain Events

Author: CESARDELATORRE

…dling/ProductPriceChangedEventHandler.cs …ctPriceChangedIntegrationEventHandler.cssrc/Services/Basket/Basket.API/IntegrationEvents/EventHandling/ProductPriceChangedEventHandler.cs renamed to src/Services/Basket/Basket.API/IntegrationEvents/EventHandling/ProductPriceChangedIntegrationEventHandler.cs src/Services/Basket/Basket.API/IntegrationEvents/EventHandling/ProductPriceChangedEventHandler.cs renamed to src/Services/Basket/Basket.API/IntegrationEvents/EventHandling/ProductPriceChangedIntegrationEventHandler.cs

@@ -6,15 +6,15 @@
 
 namespace Microsoft.eShopOnContainers.Services.Basket.API.IntegrationEvents.EventHandling
 {
-    public class ProductPriceChangedEventHandler : IIntegrationEventHandler<ProductPriceChangedEvent>
+    public class ProductPriceChangedIntegrationEventHandler : IIntegrationEventHandler<ProductPriceChangedIntegrationEvent>
     {
         private readonly IBasketRepository _repository;
-        public ProductPriceChangedEventHandler(IBasketRepository repository)
+        public ProductPriceChangedIntegrationEventHandler(IBasketRepository repository)
         {
             _repository = repository;
         }
 
-        public async Task Handle(ProductPriceChangedEvent @event)
+        public async Task Handle(ProductPriceChangedIntegrationEvent @event)
         {
             var userIds = await _repository.GetUsers();
             foreach (var id in userIds)

…vents/Events/ProductPriceChangedEvent.cs …s/ProductPriceChangedIntegrationEvent.cssrc/Services/Basket/Basket.API/IntegrationEvents/Events/ProductPriceChangedEvent.cs renamed to src/Services/Basket/Basket.API/IntegrationEvents/Events/ProductPriceChangedIntegrationEvent.cs src/Services/Basket/Basket.API/IntegrationEvents/Events/ProductPriceChangedEvent.cs renamed to src/Services/Basket/Basket.API/IntegrationEvents/Events/ProductPriceChangedIntegrationEvent.cs

@@ -8,15 +8,15 @@ namespace Microsoft.eShopOnContainers.Services.Basket.API.IntegrationEvents.Even
     // Integration Events notes: 
     // An Event is “something that has happened in the past”, therefore its name has to be   
     // An Integration Event is an event that can cause side effects to other microsrvices, Bounded-Contexts or external systems.
-    public class ProductPriceChangedEvent : IntegrationEvent
+    public class ProductPriceChangedIntegrationEvent : IntegrationEvent
     {        
         public int ProductId { get; private set; }
 
         public decimal NewPrice { get; private set; }
 
         public decimal OldPrice { get; private set; }
 
-        public ProductPriceChangedEvent(int productId, decimal newPrice, decimal oldPrice)
+        public ProductPriceChangedIntegrationEvent(int productId, decimal newPrice, decimal oldPrice)
         {
             ProductId = productId;
             NewPrice = newPrice;

src/Services/Basket/Basket.API/Startup.cs

@@ -76,16 +76,16 @@ public void ConfigureServices(IServiceCollection services)
             });
 
             services.AddTransient<IBasketRepository, RedisBasketRepository>();
-            services.AddTransient<IIntegrationEventHandler<ProductPriceChangedEvent>, ProductPriceChangedEventHandler>();
+            services.AddTransient<IIntegrationEventHandler<ProductPriceChangedIntegrationEvent>, ProductPriceChangedIntegrationEventHandler>();
 
             var serviceProvider = services.BuildServiceProvider();
             var configuration = serviceProvider.GetRequiredService<IOptionsSnapshot<BasketSettings>>().Value;
             var eventBus = new EventBusRabbitMQ(configuration.EventBusConnection);
             services.AddSingleton<IEventBus>(eventBus);
 
 
-            var catalogPriceHandler = serviceProvider.GetService<IIntegrationEventHandler<ProductPriceChangedEvent>>();
-            eventBus.Subscribe<ProductPriceChangedEvent>(catalogPriceHandler);
+            var catalogPriceHandler = serviceProvider.GetService<IIntegrationEventHandler<ProductPriceChangedIntegrationEvent>>();
+            eventBus.Subscribe<ProductPriceChangedIntegrationEvent>(catalogPriceHandler);
 
         }
 

src/Services/Catalog/Catalog.API/Catalog.API.csproj

@@ -22,7 +22,7 @@
       <CopyToPublishDirectory>PreserveNewest</CopyToPublishDirectory>
     </Content>
     <Compile Include="IntegrationEvents\EventHandling\AnyFutureIntegrationEventHandler.cs.txt" />
-    <Compile Include="IntegrationEvents\Events\ProductPriceChangedEvent.cs.txt" />
+    <Compile Include="IntegrationEvents\Events\ProductPriceChangedIntegrationEvent.cs.txt" />
     <Content Update="web.config;">
       <CopyToPublishDirectory>PreserveNewest</CopyToPublishDirectory>
     </Content>

src/Services/Catalog/Catalog.API/Controllers/CatalogController.cs

@@ -146,7 +146,7 @@ public async Task<IActionResult> Post([FromBody]CatalogItem value)
                 item.Price = value.Price;
                 _context.CatalogItems.Update(item);
 
-                var @event = new ProductPriceChangedEvent(item.Id, item.Price, oldPrice);
+                var @event = new ProductPriceChangedIntegrationEvent(item.Id, item.Price, oldPrice);
                 var eventLogEntry = new IntegrationEventLogEntry(@event);                
                 _context.IntegrationEventLog.Add(eventLogEntry);                
 

src/Services/Catalog/Catalog.API/IntegrationEvents/Events/ProductPriceChangedEvent.cs.txt

@@ -8,15 +8,15 @@ namespace Microsoft.eShopOnContainers.Services.Catalog.API.IntegrationEvents.Eve
     // Integration Events notes: 
     // An Event is “something that has happened in the past”, therefore its name has to be   
     // An Integration Event is an event that can cause side effects to other microsrvices, Bounded-Contexts or external systems.
-    public class ProductPriceChangedEvent : IntegrationEvent
+    public class ProductPriceChangedIntegrationEvent : IntegrationEvent
     {        
         public int ProductId { get; private set; }
 
         public decimal NewPrice { get; private set; }
 
         public decimal OldPrice { get; private set; }
 
-        public ProductPriceChangedEvent(int productId, decimal newPrice, decimal oldPrice)
+        public ProductPriceChangedIntegrationEvent(int productId, decimal newPrice, decimal oldPrice)
         {
             ProductId = productId;
             NewPrice = newPrice;