using MediatR; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using Microsoft.eShopOnContainers.Services.Ordering.API.Application.Commands; using Microsoft.eShopOnContainers.Services.Ordering.API.Application.Queries; using Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.Services; using System; using System.Collections.Generic; using System.Threading.Tasks; namespace Microsoft.eShopOnContainers.Services.Ordering.API.Controllers { [Route("api/v1/[controller]")] [Authorize] public class OrdersController : Controller { private readonly IMediator _mediator; private readonly IOrderQueries _orderQueries; private readonly IIdentityService _identityService; public OrdersController(IMediator mediator, IOrderQueries orderQueries, IIdentityService identityService) { _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator)); _orderQueries = orderQueries ?? throw new ArgumentNullException(nameof(orderQueries)); _identityService = identityService ?? throw new ArgumentNullException(nameof(identityService)); } [Route("new")] [HttpPost] public async Task CreateOrder([FromBody]CreateOrderCommand command, [FromHeader(Name = "x-requestid")] string requestId) { bool commandResult = false; if (Guid.TryParse(requestId, out Guid guid) && guid != Guid.Empty) { var requestCreateOrder = new IdentifiedCommand(command, guid); commandResult = await _mediator.SendAsync(requestCreateOrder); } else { // If no x-requestid header is found we process the order anyway. This is just temporary to not break existing clients // that aren't still updated. When all clients were updated this could be removed. commandResult = await _mediator.SendAsync(command); } return commandResult ? (IActionResult)Ok() : (IActionResult)BadRequest(); } [Route("{orderId:int}")] [HttpGet] public async Task GetOrder(int orderId) { try { var order = await _orderQueries .GetOrderAsync(orderId); return Ok(order); } catch (KeyNotFoundException) { return NotFound(); } } [Route("")] [HttpGet] public async Task GetOrders() { var orderTask = _orderQueries.GetOrdersAsync(); var orders = await orderTask; return Ok(orders); } [Route("cardtypes")] [HttpGet] public async Task GetCardTypes() { var cardTypes = await _orderQueries .GetCardTypesAsync(); return Ok(cardTypes); } } }