Compensation instead of TransactionScope

ModularMonolith/Order/Shop.Order.UseCases/Orders/Commands/CreateOrder/CreateOrderRequestHandler.cs

@@ -38,7 +38,19 @@ public async Task<int> Handle(CreateOrderRequest request, CancellationToken canc
 
             await _dbContext.SaveChangesAsync(cancellationToken);
 
-            await _publisher.Publish(new OrderCreatedNotification(order.Id, _currentUserService.Id, _currentUserService.Email), cancellationToken);
+            try
+            {
+                await _publisher.Publish(new OrderCreatedNotification(order.Id, _currentUserService.Id, _currentUserService.Email), cancellationToken);
+            }
+            catch (Exception e) //Compensation
+            {
+                //log exception
+
+                _dbContext.Orders.Remove(order);
+                await _dbContext.SaveChangesAsync(cancellationToken);
+
+                throw;
+            }
 
             return order.Id;
         }

ModularMonolith/Shop.Tests.Unit/WorkflowTests.cs

@@ -148,8 +148,6 @@ private ServiceCollection CreateServiceProvider(IConfiguration configuration)
             services.AddMediatR(assemblies);
             services.AddAutoMapper(assemblies);
 
-            services.AddScoped(typeof(IPipelineBehavior<,>), typeof(TransactionScopePipelineBehavior<,>));
-
             services.RegisterModule<OrderDataAccessModule>(configuration);
 
             services.RegisterModule<FrameworkModule>(configuration);

ModularMonolith/Shop.Web/Startup.cs

@@ -1,7 +1,4 @@
-using System.IO;
-using System.Linq;
-using System.Reflection;
-using System.Runtime.Loader;
+using System.Linq;
 using AutoMapper;
 using MediatR;
 using Microsoft.AspNetCore.Builder;
@@ -54,8 +51,6 @@ public void ConfigureServices(IServiceCollection services)
             services.RegisterModule<OrderContractModule>(Configuration);
             services.RegisterModule<OrderUseCasesModule>(Configuration);
 
-            services.AddScoped(typeof(IPipelineBehavior<,>), typeof(TransactionScopePipelineBehavior<,>));
-
             var sp = services.BuildServiceProvider();
 
             var requests = sp.GetServices<IBaseRequest>();