Updated OrderingIntegrationEvent svc

Author: Ramón Tomás

src/Services/Ordering/Ordering.API/Application/IntegrationEvents/OrderingIntegrationEventService.cs

@@ -9,6 +9,7 @@
 using System;
 using System.Data.Common;
 using System.Diagnostics;
+using System.Linq;
 using System.Threading.Tasks;
 
 namespace Ordering.API.Application.IntegrationEvents
@@ -35,15 +36,21 @@ public OrderingIntegrationEventService(IEventBus eventBus,
 
         public async Task PublishThroughEventBusAsync(IntegrationEvent evt)
         {
-            await SaveEventAndOrderingContextChangesAsync(evt);
+            await SaveEventAsync(evt);
             _eventBus.Publish(evt);
             await _eventLogService.MarkEventAsPublishedAsync(evt);
         }
 
-        private async Task SaveEventAndOrderingContextChangesAsync(IntegrationEvent evt)
+        private async Task SaveEventAsync(IntegrationEvent evt)
         {
-            await _orderingContext.SaveChangesAsync();
-            await _eventLogContext.SaveChangesAsync();
+            var strategy = _orderingContext.Database.CreateExecutionStrategy();
+            await strategy.ExecuteAsync(async () =>
+            {
+                await _orderingContext.BeginTransactionAsync();
+                await _eventLogService.SaveEventAsync(evt, _orderingContext.GetCurrentTransaction.GetDbTransaction());
+                await _orderingContext.CommitTransactionAsync();
+            });
+            
         }
     }
 }

src/Services/Ordering/Ordering.Infrastructure/OrderingContext.cs

@@ -29,6 +29,8 @@ public class OrderingContext : DbContext, IUnitOfWork
 
         private OrderingContext(DbContextOptions<OrderingContext> options) : base (options) { }
 
+        public IDbContextTransaction GetCurrentTransaction => _currentTransaction;
+
         public OrderingContext(DbContextOptions<OrderingContext> options, IMediator mediator) : base(options)
         {
             _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));