rabbit listener error

Author: mehmetozkaya

src/Ordering/Ordering.API/Controllers/OrderController.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Logging;
+using Ordering.Application.Commands;
 using Ordering.Application.Queries;
 using Ordering.Application.Responses;
 using System;
@@ -31,5 +32,14 @@ public async Task<ActionResult<IEnumerable<OrderResponse>>> GetOrdersByUserName(
             var orders = await _mediator.Send(query);
             return Ok(orders);
         }
+
+        //Added for testing purpose
+        [HttpPost]
+        [ProducesResponseType(typeof(OrderResponse), (int)HttpStatusCode.OK)]
+        public async Task<IActionResult> CheckoutOrder([FromBody] CheckoutOrderCommand command)
+        {
+            var result = await _mediator.Send(command);
+            return Ok(result);
+        }
     }
 }

src/Ordering/Ordering.API/RabbitMQ/EventBusRabbitMQConsumer.cs

@@ -38,16 +38,18 @@ public void Consume()
             channel.BasicConsume(queue: EventBusConstants.BasketCheckoutQueue, autoAck: true, consumer: consumer);
         }
 
-        private void ReceivedEvent(object sender, BasicDeliverEventArgs e)
+        private async void ReceivedEvent(object sender, BasicDeliverEventArgs e)
         {
             if (e.RoutingKey == EventBusConstants.BasketCheckoutQueue)
             {
                 var message = Encoding.UTF8.GetString(e.Body);
                 var basketCheckoutEvent = JsonConvert.DeserializeObject<BasketCheckoutEvent>(message);
 
+
                 // Internal Checkout Operation Call
                 var command = _mapper.Map<CheckoutOrderCommand>(basketCheckoutEvent);
-                var result = _mediator.Send(command);
+                var result = await _mediator.Send(command); // ERROR : CANT RESOLVE SUB OBJECTS FROM THIS CALL
+
             }
         }
 

src/Ordering/Ordering.API/Startup.cs

@@ -8,8 +8,10 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.OpenApi.Models;
+using Ordering.API.Extentions;
 using Ordering.API.RabbitMQ;
 using Ordering.Application.Handlers;
+using Ordering.Application.PipelineBehaviours;
 using Ordering.Core.Repositories;
 using Ordering.Core.Repositories.Base;
 using Ordering.Infrastructure.Data;
@@ -50,7 +52,7 @@ public void ConfigureServices(IServiceCollection services)
 
             // Add Infrastructure Layer
             services.AddScoped(typeof(IRepository<>), typeof(Repository<>));
-            services.AddScoped(typeof(IOrderRepository), typeof(OrderRepository));
+            services.AddScoped(typeof(IOrderRepository), typeof(OrderRepository));            
             services.AddScoped<IOrderRepository, OrderRepository>();
 
             // Add AutoMapper
@@ -59,6 +61,9 @@ public void ConfigureServices(IServiceCollection services)
             // Add MediatR
             services.AddMediatR(typeof(CheckoutOrderHandler).GetTypeInfo().Assembly);
 
+            //Domain Level Validation
+            services.AddTransient(typeof(IPipelineBehavior<,>), typeof(ValidationBehaviour<,>));
+
             #endregion
 
             #region RabbitMQ Dependencies
@@ -114,8 +119,8 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
                 endpoints.MapControllers();
             });
 
-            ////Initilize Rabbit Listener in ApplicationBuilderExtentions
-            //app.UseRabbitListener();
+            //Initilize Rabbit Listener in ApplicationBuilderExtentions
+            app.UseRabbitListener();
 
             app.UseSwagger();
             app.UseSwaggerUI(c =>

src/Ordering/Ordering.Application/PipelineBehaviours/ValidationBehaviour.cs

@@ -0,0 +1,39 @@
+using FluentValidation;
+using MediatR;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Ordering.Application.PipelineBehaviours
+{
+    public class ValidationBehaviour<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : IRequest<TResponse>
+    {
+        private readonly IEnumerable<IValidator<TRequest>> _validators;
+
+        public ValidationBehaviour(IEnumerable<IValidator<TRequest>> validators)
+        {
+            _validators = validators;
+        }
+
+        public Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken, RequestHandlerDelegate<TResponse> next)
+        {
+            var context = new ValidationContext(request);
+            var failures = _validators
+                .Select(x => x.Validate(context))
+                .SelectMany(x => x.Errors)
+                .Where(x => x != null)
+                .ToList();
+
+            // TODO: add context to which command/query is throwing the exception and its origination
+
+            if (failures.Any())
+            {
+                throw new ValidationException(failures);
+            }
+
+            return next();
+        }
+    }
+}