#99: add exception mapper

SwiftParcel.ExternalAPI.Lecturer/src/SwiftParcel.ExternalAPI.Lecturer.Application/SwiftParcel.ExternalAPI.Lecturer.Application/Events/Rejected/AddParcelRejected.cs

@@ -0,0 +1,16 @@
+namespace SwiftParcel.ExternalAPI.Lecturer.Application.Events.Rejected
+{
+    public class AddParcelRejected
+    {
+        public Guid ParcelId { get; }
+        public string Reason { get; }
+        public string Code { get; }
+
+        public AddParcelRejected(Guid parcelId, string reason, string code)
+        {
+            ParcelId = parcelId;
+            Reason = reason;
+            Code = code;
+        }
+    }
+}

SwiftParcel.ExternalAPI.Lecturer/src/SwiftParcel.ExternalAPI.Lecturer.Application/SwiftParcel.ExternalAPI.Lecturer.Application/Events/Rejected/CancelOrderRejected.cs

@@ -0,0 +1,18 @@
+using Convey.CQRS.Events;
+
+namespace SwiftParcel.ExternalAPI.Lecturer.Application.Events.Rejected
+{
+    public class CancelOrderRejected : IRejectedEvent
+    {
+        public Guid OrderId { get; }
+        public string Reason { get; }
+        public string Code { get; }
+
+        public CancelOrderRejected(Guid orderId, string reason, string code)
+        {
+            OrderId = orderId;
+            Reason = reason;
+            Code = code;
+        }
+    }
+}

SwiftParcel.ExternalAPI.Lecturer/src/SwiftParcel.ExternalAPI.Lecturer.Application/SwiftParcel.ExternalAPI.Lecturer.Application/Events/Rejected/ConfirmOrderRejected.cs

@@ -0,0 +1,18 @@
+using Convey.CQRS.Events;
+
+namespace SwiftParcel.ExternalAPI.Lecturer.Application.Events.Rejected
+{
+    public class ConfirmOrderRejected : IRejectedEvent
+    {
+        public Guid OrderId { get; }
+        public string Reason { get; }
+        public string Code { get; }
+
+        public ConfirmOrderRejected (Guid orderId, string reason, string code)
+        {
+            OrderId = orderId;
+            Reason = reason;
+            Code = code;
+        }
+    }
+}

SwiftParcel.ExternalAPI.Lecturer/src/SwiftParcel.ExternalAPI.Lecturer.Application/SwiftParcel.ExternalAPI.Lecturer.Application/Events/Rejected/CreateOrderRejected.cs

@@ -0,0 +1,22 @@
+using Convey.CQRS.Events;
+
+namespace SwiftParcel.ExternalAPI.Lecturer.Application.Events.Rejected
+{
+    public class CreateOrderRejected : IRejectedEvent
+    {
+        public Guid OrderId { get; }
+        public Guid CustomerId { get; }
+        public Guid ParcelId { get; }
+        public string Reason { get; }
+        public string Code { get; }
+
+        public CreateOrderRejected(Guid orderId, Guid customerId, Guid parcelId, string reason, string code)
+        {
+            OrderId = orderId;
+            CustomerId = customerId;
+            ParcelId = parcelId;
+            Reason = reason;
+            Code = code;
+        }
+    }
+}

SwiftParcel.ExternalAPI.Lecturer/src/SwiftParcel.ExternalAPI.Lecturer.Infrastructure/SwiftParcel.ExternalAPI.Lecturer.Infrastructure/Exceptions/ExceptionToMessageMapper.cs

@@ -0,0 +1,46 @@
+using Convey.MessageBrokers.RabbitMQ;
+using SwiftParcel.ExternalAPI.Lecturer.Application.Exceptions;
+using SwiftParcel.ExternalAPI.Lecturer.Application.Commands;
+using SwiftParcel.ExternalAPI.Lecturer.Application.Events.Rejected;
+
+namespace SwiftParcel.ExternalAPI.Lecturer.Infrastructure.Exceptions
+{
+    public class ExceptionToMessageMapper : IExceptionToMessageMapper
+    {
+        public object Map(Exception exception, object message)
+            => exception switch
+            {
+                InquiresServiceConnectionException ex => message switch
+                {
+                    AddParcel m => new AddParcelRejected(m.ParcelId, ex.Message, ex.Code),
+                    _ => null
+                },
+                InquiresServiceException ex => message switch
+                {
+                    AddParcel m => new AddParcelRejected(m.ParcelId, ex.Message, ex.Code),
+                    _ => null
+                },
+                OffersServiceConnectionException ex => message switch
+                {
+                    CreateOrder m => new CreateOrderRejected(m.OrderId, m.CustomerId, m.ParcelId, ex.Message, ex.Code),
+                    ConfirmOrder m => new ConfirmOrderRejected(m.OrderId, ex.Message, ex.Code),
+                    CancelOrder m => new CancelOrderRejected(m.OrderId, ex.Message, ex.Code),
+                    _ => null
+                },
+                OffersServiceException ex => message switch
+                {
+                    CreateOrder m => new CreateOrderRejected(m.OrderId, m.CustomerId, m.ParcelId, ex.Message, ex.Code),
+                    ConfirmOrder m => new ConfirmOrderRejected(m.OrderId, ex.Message, ex.Code),
+                    CancelOrder m => new CancelOrderRejected(m.OrderId, ex.Message, ex.Code),
+                    _ => null
+                },
+                OfferNotFoundException ex => message switch
+                {
+                    ConfirmOrder m => new ConfirmOrderRejected(m.OrderId, ex.Message, ex.Code),
+                    CancelOrder m => new CancelOrderRejected(m.OrderId, ex.Message, ex.Code),
+                    _ => null
+                },
+                _ => null
+            };
+    }
+}

SwiftParcel.ExternalAPI.Lecturer/src/SwiftParcel.ExternalAPI.Lecturer.Infrastructure/SwiftParcel.ExternalAPI.Lecturer.Infrastructure/Extensions.cs

@@ -69,7 +69,7 @@ public static IConveyBuilder AddInfrastructure(this IConveyBuilder builder)
                 .AddFabio()
                 .AddRabbitMq(plugins: p => p.AddJaegerRabbitMqPlugin())
                 .AddMessageOutbox(o => o.AddMongo())
-                //.AddExceptionToMessageMapper<ExceptionToMessageMapper>()
+                .AddExceptionToMessageMapper<ExceptionToMessageMapper>()
                 .AddMongo()
                 .AddRedis()
                 .AddMetrics()
@@ -92,9 +92,9 @@ public static IApplicationBuilder UseInfrastructure(this IApplicationBuilder app
                 .UseMetrics()
                 .UseRabbitMq()
                 .SubscribeCommand<AddParcel>()
-                .SubscribeCommand<CreateOrder>();
-                //.SubscribeCommand<DeleteParcel>()
-                //.SubscribeEvent<CustomerCreated>();
+                .SubscribeCommand<CreateOrder>()
+                .SubscribeCommand<ConfirmOrder>()
+                .SubscribeCommand<CancelOrder>();
 
             return app;
         }