Remove PaymentIntegrationEventService and remove integration command to integration event

Author: christian147

src/Services/Payment/Payment.API/IntegrationCommands/CommandHandlers/PayOrderCommandHandler.cs

@@ -0,0 +1,37 @@
+namespace Payment.API.IntegrationEvents.EventHandling
+{
+    using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions;
+    using System.Threading.Tasks;
+    using Payment.API.IntegrationEvents.Events;
+    using Microsoft.Extensions.Options;
+    using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events;
+
+    public class OrderStatusChangedToStockConfirmedIntegrationEventHandler : 
+        IIntegrationEventHandler<OrderStatusChangedToStockConfirmedIntegrationEvent>
+    {
+        private readonly IEventBus _eventBus;
+        private readonly PaymentSettings _settings;
+
+        public OrderStatusChangedToStockConfirmedIntegrationEventHandler(IEventBus eventBus, 
+            IOptionsSnapshot<PaymentSettings> settings)
+        {
+            _eventBus = eventBus;
+            _settings = settings.Value;
+        }         
+
+        public async Task Handle(OrderStatusChangedToStockConfirmedIntegrationEvent @event)
+        {
+            IntegrationEvent orderPaymentIntegrationEvent;
+            if(_settings.SuccessPayment)
+            {
+                orderPaymentIntegrationEvent = new OrderPaymentSuccededIntegrationEvent(@event.OrderId);
+            }
+            else
+            {
+                orderPaymentIntegrationEvent = new OrderPaymentFailedIntegrationEvent(@event.OrderId);
+            }
+
+            _eventBus.Publish(orderPaymentIntegrationEvent);
+        }
+    }
+}

src/Services/Payment/Payment.API/IntegrationCommands/Commands/PayOrderCommand.cs

@@ -0,0 +1,12 @@
+namespace Payment.API.IntegrationEvents.Events
+{
+    using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events;
+
+    public class OrderStatusChangedToStockConfirmedIntegrationEvent : IntegrationEvent
+    {
+        public int OrderId { get; }
+
+        public OrderStatusChangedToStockConfirmedIntegrationEvent(int orderId)
+            => OrderId = orderId;
+    }
+}

src/Services/Payment/Payment.API/IntegrationEvents/EventHandling/OrderStatusChangedToStockConfirmedIntegrationEventHandler.cs

@@ -0,0 +1,8 @@
+namespace Payment.API
+{
+    public class PaymentSettings
+    {
+        public bool SuccessPayment { get; set; }
+        public string EventBusConnection { get; set; }
+    }
+}

src/Services/Payment/Payment.API/IntegrationEvents/Events/OrderStatusChangedToStockConfirmedIntegrationEvent.cs

@@ -7,12 +7,11 @@
 using Microsoft.Extensions.Logging;
 using System;
 using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions;
-using Payment.API.IntegrationCommands.Commands;
 using Microsoft.eShopOnContainers.BuildingBlocks.EventBusRabbitMQ;
 using RabbitMQ.Client;
 using Microsoft.eShopOnContainers.BuildingBlocks.EventBus;
-using Payment.API.IntegrationEvents;
-using Payment.API.IntegrationCommands.CommandHandlers;
+using Payment.API.IntegrationEvents.Events;
+using Payment.API.IntegrationEvents.EventHandling;
 
 namespace Payment.API
 {
@@ -35,8 +34,7 @@ public IServiceProvider ConfigureServices(IServiceCollection services)
         {
             // Add framework services.
             services.AddMvc();
-
-            services.AddTransient<IPaymentIntegrationEventService, PaymentIntegrationEventService>();
+            services.Configure<PaymentSettings>(Configuration);
             services.AddSingleton<IRabbitMQPersistentConnection>(sp =>
             {
                 var logger = sp.GetRequiredService<ILogger<DefaultRabbitMQPersistentConnection>>();
@@ -88,13 +86,15 @@ private void RegisterServiceBus(IServiceCollection services)
             services.AddSingleton<IEventBus, EventBusRabbitMQ>();
             services.AddSingleton<IEventBusSubscriptionsManager, InMemoryEventBusSubscriptionsManager>();
 
-            services.AddTransient<IIntegrationEventHandler<PayOrderCommand>, PayOrderCommandHandler>();
+            services.AddTransient<IIntegrationEventHandler<OrderStatusChangedToStockConfirmedIntegrationEvent>, 
+                OrderStatusChangedToStockConfirmedIntegrationEventHandler>();
         }
 
         private void ConfigureEventBus(IApplicationBuilder app)
         {
             var eventBus = app.ApplicationServices.GetRequiredService<IEventBus>();
-            eventBus.Subscribe<PayOrderCommand, IIntegrationEventHandler<PayOrderCommand>>();
+            eventBus.Subscribe<OrderStatusChangedToStockConfirmedIntegrationEvent, 
+                IIntegrationEventHandler<OrderStatusChangedToStockConfirmedIntegrationEvent>>();
         }
     }
-}
+}

src/Services/Payment/Payment.API/IntegrationEvents/IPaymentIntegrationEventService.cs

@@ -4,5 +4,6 @@
     "LogLevel": {
       "Default": "Warning"
     }
-  }
+  },
+  "SuccessPayment": "true"
 }