Used Minimal APIs builders instead of custom one in Warehouse CQRS example

Author: oskardudycz

Sample/Warehouse/Warehouse.Api.Tests/Products/GettingProductDetails/GetProductDetailsTests.cs

@@ -63,15 +63,15 @@ public async Task ValidRequest_With_NoParams_ShouldReturn_200()
     [Theory]
     [InlineData(12)]
     [InlineData("not-a-guid")]
-    public async Task InvalidGuidId_ShouldReturn_400(object invalidId)
+    public async Task InvalidGuidId_ShouldReturn_404(object invalidId)
     {
         // Given
 
         // When
         var response = await fixture.Get($"{invalidId}");
 
         // Then
-        response.StatusCode.Should().Be(HttpStatusCode.BadRequest);
+        response.StatusCode.Should().Be(HttpStatusCode.NotFound);
     }
 
     [Fact]
@@ -86,4 +86,4 @@ public async Task NotExistingId_ShouldReturn_404()
         // Then
         response.StatusCode.Should().Be(HttpStatusCode.NotFound);
     }
-}
+}

Sample/Warehouse/Warehouse.Api/Program.cs

@@ -8,7 +8,9 @@
             .ConfigureServices(services =>
             {
                 services.AddRouting()
-                    .AddWarehouseServices();
+                    .AddWarehouseServices()
+                    .AddEndpointsApiExplorer()
+                    .AddSwaggerGen();
             })
             .Configure(app =>
             {
@@ -18,7 +20,9 @@
                     {
                         endpoints.UseWarehouseEndpoints();
                     })
-                    .ConfigureWarehouse();
+                    .ConfigureWarehouse()
+                    .UseSwagger()
+                    .UseSwaggerUI();
             });
     })
     .Build();

Sample/Warehouse/Warehouse/Configuration.cs

@@ -24,7 +24,7 @@ public static IApplicationBuilder ConfigureWarehouse(this IApplicationBuilder ap
 
         if (environment == "Development")
         {
-            app.ApplicationServices.GetRequiredService<WarehouseDBContext>().Database.Migrate();
+            app.ApplicationServices.CreateScope().ServiceProvider.GetRequiredService<WarehouseDBContext>().Database.Migrate();
         }
 
         return app;

Sample/Warehouse/Warehouse/Core/Extensions/HttpExtensions.cs

@@ -1,33 +1,24 @@
 using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Routing;
-using Warehouse.Core.Extensions;
 using Warehouse.Core.Queries;
+using static Microsoft.AspNetCore.Http.Results;
 
 namespace Warehouse.Products.GettingProductDetails;
 
 public static class Route
 {
     internal static IEndpointRouteBuilder UseGetProductDetailsEndpoint(this IEndpointRouteBuilder endpoints)
     {
-        endpoints.MapGet("/api/products/{id}", async context =>
+        endpoints.MapGet("/api/products/{id:guid}", async (HttpContext context, Guid id) =>
         {
-            // var dbContext = WarehouseDBContextFactory.Create();
-            // var handler = new HandleGetProductDetails(dbContext.Set<Product>().AsQueryable());
-
-            var productId = context.FromRoute<Guid>("id");
-            var query = GetProductDetails.Create(productId);
+            var query = GetProductDetails.Create(id);
 
             var result = await context
                 .SendQuery<GetProductDetails, ProductDetails?>(query);
 
-            if (result == null)
-            {
-                context.NotFound();
-                return;
-            }
-
-            await context.OK(result);
+            return result != null ? Ok(result) : NotFound();
         });
         return endpoints;
     }
-}
+}

Sample/Warehouse/Warehouse/Products/GettingProductDetails/Route.cs

@@ -1,30 +1,25 @@
 using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Routing;
-using Warehouse.Core.Extensions;
 using Warehouse.Core.Queries;
+using static Microsoft.AspNetCore.Http.Results;
 
 namespace Warehouse.Products.GettingProducts;
 
 public static class Route
 {
     internal static IEndpointRouteBuilder UseGetProductsEndpoint(this IEndpointRouteBuilder endpoints)
     {
-        endpoints.MapGet("/api/products", async context =>
+        endpoints.MapGet("/api/products", async (HttpContext context, [FromQuery]string? filter, [FromQuery]int? page, [FromQuery]int? pageSize) =>
         {
-            // var dbContext = WarehouseDBContextFactory.Create();
-            // var handler = new HandleGetProducts(dbContext.Set<Product>().AsQueryable());
-
-            var filter = context.FromQuery("filter");
-            var page = context.FromQuery<int>("page");
-            var pageSize = context.FromQuery<int>("pageSize");
-
             var query = GetProducts.Create(filter, page, pageSize);
 
             var result = await context
                 .SendQuery<GetProducts, IReadOnlyList<ProductListItem>>(query);
 
-            await context.OK(result);
+            return Ok(result);
         });
         return endpoints;
     }
-}
+}

Sample/Warehouse/Warehouse/Products/GettingProducts/Route.cs

@@ -1,7 +1,9 @@
-using Microsoft.AspNetCore.Builder;
+using System.Net;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Routing;
 using Warehouse.Core.Commands;
-using Warehouse.Core.Extensions;
+using static Microsoft.AspNetCore.Http.Results;
 
 namespace Warehouse.Products.RegisteringProduct;
 
@@ -15,18 +17,19 @@ internal static class Route
 {
     internal static IEndpointRouteBuilder UseRegisterProductEndpoint(this IEndpointRouteBuilder endpoints)
     {
-        endpoints.MapPost("api/products/", async context =>
+        endpoints.MapPost("api/products/", async (HttpContext context, RegisterProductRequest request) =>
         {
-            var (sku, name, description) = await context.FromBody<RegisterProductRequest>();
+            var (sku, name, description) = request;
             var productId = Guid.NewGuid();
 
             var command = RegisterProduct.Create(productId, sku, name, description);
 
             await context.SendCommand(command);
 
-            await context.Created(productId);
+            return Created($"/api/products/{productId}", productId);
         });
 
+
         return endpoints;
     }
-}
+}