Finished first iteration over ordering.data

Author: unaizorrilla

src/Services/Ordering/Ordering.API/Controllers/OrdersController.cs

@@ -4,6 +4,7 @@
     using Application.Queries;
     using MediatR;
     using Microsoft.AspNetCore.Mvc;
+    using Models;
     using System;
     using System.Threading.Tasks;
 
@@ -13,7 +14,7 @@ public class OrdersController : Controller
         private readonly IMediator _mediator;
         private readonly IOrderQueries _orderQueries;
 
-        public OrdersController(IMediator mediator,IOrderQueries orderQueries)
+        public OrdersController(IMediator mediator, IOrderQueries orderQueries)
         {
             if (mediator == null)
             {
@@ -31,9 +32,21 @@ public OrdersController(IMediator mediator,IOrderQueries orderQueries)
 
         [Route("new")]
         [HttpPost]
-        public async Task<IActionResult> AddOrder()
+        public async Task<IActionResult> AddOrder([FromBody]NewOrderViewModel order)
         {
-            var newOrderRequest = new NewOrderRequest();
+            var newOrderRequest = new NewOrderRequest()
+            {
+                Buyer =GetUserName(), //TODO
+                CardTypeId = 1, //TODO
+                CardHolderName = order.CardHolderName,
+                CardNumber = order.CardNumber,
+                CardExpiration = order.CardExpiration,
+                CardSecurityNumber = order.CardSecurityNumber,
+                State = order.ShippingState,
+                City = order.ShippingCity,
+                Country = order.ShippingCountry,
+                Street = order.ShippingStreet
+            };
 
             var added = await _mediator.SendAsync(newOrderRequest);
 
@@ -45,50 +58,38 @@ public async Task<IActionResult> AddOrder()
             return BadRequest();
         }
 
-
-        [Route("cancel/{orderId:int}")]
-        [HttpPost]
-        public async Task<IActionResult> CancelOrder(int orderId)
+        [Route("{orderId:int}")]
+        [HttpGet]
+        public async Task<IActionResult> GetOrder(int orderId)
         {
-            var cancelOrderRequest = new CancelOrderRequest(orderId);
-
-            var cancelled = await _mediator.SendAsync(cancelOrderRequest);
-
-            if (cancelled)
-            {
-                return Ok();
-            }
+            var order = await _orderQueries.GetOrder(orderId);
 
-            return BadRequest();
+            
+            return Ok(order);
         }
 
-
-        [Route("{orderId:int}")]
+        [Route("")]
         [HttpGet]
-        public async Task<IActionResult> GetOrder(int orderId)
+        public async Task<IActionResult> GetOrders()
         {
-            var order = await _orderQueries.GetOrder(orderId);
+            var orders = await _orderQueries.GetOrders();
 
-            if ( order != null)
-            {
-                Ok(order);
-            }
 
-            return NotFound();
+            return Ok(orders);
         }
 
-        [Route("pending")]
+        [Route("cardtypes")]
         [HttpGet]
-        public async Task<IActionResult> GetPendingOrders(int orderId)
+        public async Task<IActionResult> GetCardTypes()
         {
-            var orders = await _orderQueries.GetPendingOrders();
+            var cardTypes = await _orderQueries.GetCardTypes();
 
-            if (orders.Any())
-            {
-                Ok(orders);
-            }
+            return Ok(cardTypes);
+        }
 
-            return NoContent();
+        string GetUserName()
+        {
+            return "MOCK";
         }
     }
 

src/Services/Ordering/Ordering.API/Infrastructure/ActionResults/InternalServerErrorObjectResult.cs

@@ -0,0 +1,14 @@
+namespace Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.ActionResults
+{
+    using AspNetCore.Http;
+    using Microsoft.AspNetCore.Mvc;
+
+    public class InternalServerErrorObjectResult : ObjectResult
+    {
+        public InternalServerErrorObjectResult(object error)
+            : base(error)
+        {
+            StatusCode = StatusCodes.Status500InternalServerError;
+        }
+    }
+}

src/Services/Ordering/Ordering.API/Infrastructure/AutofacModules/ApplicationModule.cs

@@ -0,0 +1,28 @@
+
+
+namespace Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.AutofacModules
+{
+    using Application.Queries;
+    using Autofac;
+    using Domain.Repositories;
+    using Ordering.Infrastructure.Repositories;
+
+    public class ApplicationModule
+        :Autofac.Module
+    {
+        protected override void Load(ContainerBuilder builder)
+        {
+            builder.RegisterType<OrderQueries>()
+                .As<IOrderQueries>()
+                .InstancePerLifetimeScope();
+
+            builder.RegisterType<BuyerRepository>()
+                .As<IBuyerRepository>()
+                .InstancePerLifetimeScope();
+
+            builder.RegisterType<OrderRepository>()
+                .As<IOrderRepository>()
+                .InstancePerLifetimeScope();
+        }
+    }
+}

src/Services/Ordering/Ordering.API/Infrastructure/AutofacModules/MediatorModule.cs

@@ -0,0 +1,43 @@
+namespace Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.AutofacModules
+{
+    using Application.Commands;
+    using Application.Decorators;
+    using Autofac;
+    using Autofac.Core;
+    using MediatR;
+    using System.Collections.Generic;
+    using System.Linq;
+    using System.Reflection;
+
+    public class MediatorModule : Autofac.Module
+    {
+        protected override void Load(ContainerBuilder builder)
+        {
+            builder.RegisterAssemblyTypes(typeof(IMediator).GetTypeInfo().Assembly)
+                .AsImplementedInterfaces();
+
+            builder.RegisterAssemblyTypes(typeof(NewOrderRequest).GetTypeInfo().Assembly)
+                .As(o => o.GetInterfaces()
+                    .Where(i => i.IsClosedTypeOf(typeof(IAsyncRequestHandler<,>)))
+                    .Select(i => new KeyedService("IAsyncRequestHandler", i)));
+
+            builder.Register<SingleInstanceFactory>(context =>
+            {
+                var componentContext = context.Resolve<IComponentContext>();
+
+                return t => componentContext.Resolve(t);
+            });
+
+            builder.Register<MultiInstanceFactory>(context =>
+            {
+                var componentContext = context.Resolve<IComponentContext>();
+
+                return t => (IEnumerable<object>)componentContext.Resolve(typeof(IEnumerable<>).MakeGenericType(t));
+            });
+
+            builder.RegisterGenericDecorator(typeof(LogDecorator<,>),
+                    typeof(IAsyncRequestHandler<,>),
+                    "IAsyncRequestHandler");
+        }
+    }
+}

src/Services/Ordering/Ordering.API/Infrastructure/Filters/HttpGlobalExceptionFilter.cs

@@ -0,0 +1,45 @@
+namespace Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.Filters
+{
+    using Microsoft.AspNetCore.Hosting;
+    using Microsoft.AspNetCore.Mvc.Filters;
+    using Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.ActionResults;
+    using Microsoft.Extensions.Logging;
+
+    public class HttpGlobalExceptionFilter : IExceptionFilter
+    {
+        private readonly IHostingEnvironment env;
+        private readonly ILogger<HttpGlobalExceptionFilter> logger;
+
+        public HttpGlobalExceptionFilter(IHostingEnvironment env, ILogger<HttpGlobalExceptionFilter> logger)
+        {
+            this.env = env;
+            this.logger = logger;
+        }
+
+        public void OnException(ExceptionContext context)
+        {
+            logger.LogError(new EventId(context.Exception.HResult),
+                context.Exception,
+                context.Exception.Message);
+
+            var json = new JsonErrorResponse
+            {
+                Messages = new[] { "An error ocurr.Try it again." }
+            };
+
+            if (env.IsDevelopment())
+            {
+                json.DeveloperMeesage = context.Exception;
+            }
+
+            context.Result = new InternalServerErrorObjectResult(json);
+        }
+
+        private class JsonErrorResponse
+        {
+            public string[] Messages { get; set; }
+
+            public object DeveloperMeesage { get; set; }
+        }
+    }
+}