ECommerce samples alignment

Core.EventStoreDB/Events/StreamEventExtensions.cs → Core.EventStoreDB/Events/EventEnvelopeExtensions.cs

@@ -4,9 +4,9 @@
 
 namespace Core.EventStoreDB.Events;
 
-public static class StreamEventExtensions
+public static class EventEnvelopeExtensions
 {
-    public static EventEnvelope? ToStreamEvent(this ResolvedEvent resolvedEvent)
+    public static EventEnvelope? ToEventEnvelope(this ResolvedEvent resolvedEvent)
     {
         var eventData = resolvedEvent.Deserialize();
         var eventMetadata = resolvedEvent.DeserializeMetadata();

Core.EventStoreDB/Subscriptions/EventStoreDBSubscriptionToAll.cs

@@ -77,7 +77,7 @@ private async Task HandleEvent(StreamSubscription subscription, ResolvedEvent re
         {
             if (IsEventWithEmptyData(resolvedEvent) || IsCheckpointEvent(resolvedEvent)) return;
 
-            var streamEvent = resolvedEvent.ToStreamEvent();
+            var streamEvent = resolvedEvent.ToEventEnvelope();
 
             if (streamEvent == null)
             {

Core.Marten/Config.cs

@@ -79,14 +79,14 @@ private static StoreOptions SetStoreOptions(
             "MartenSubscription"
         );
 
-        configureOptions?.Invoke(options);
-
         if (config.UseMetadata)
         {
             options.Events.MetadataConfig.CausationIdEnabled = true;
             options.Events.MetadataConfig.CorrelationIdEnabled = true;
         }
 
+        configureOptions?.Invoke(options);
+
         return options;
     }
 }

Core.WebApi/Middlewares/ExceptionHandling/ExceptionHandlingMiddleware.cs

@@ -36,7 +36,10 @@ public async Task Invoke(HttpContext context /* other scoped dependencies */)
     private Task HandleExceptionAsync(HttpContext context, Exception exception)
     {
         logger.LogError(exception, exception.Message);
-        Console.WriteLine(exception.Message);
+        Console.WriteLine("ERROR:" + exception.Message + exception.StackTrace);
+
+        if(exception.InnerException != null)
+            Console.WriteLine("INNER DETAILS:" + exception.InnerException.Message + exception.InnerException.StackTrace);
 
         var codeInfo = ExceptionToHttpStatusMapper.Map(exception);
 
@@ -70,4 +73,4 @@ public static IApplicationBuilder UseExceptionHandlingMiddleware(
         ExceptionToHttpStatusMapper.CustomMap = customMap;
         return app.UseMiddleware<ExceptionHandlingMiddleware>();
     }
-}
+}

Sample/ECommerce/Carts/Carts.Api.Tests/ShoppingCarts/AddingProduct/AddProductTests.cs

@@ -23,10 +23,10 @@ public class AddProductFixture: ApiWithEventsFixture<Startup>
 
     public override async Task InitializeAsync()
     {
-        var initializeResponse = await Post(new InitializeShoppingCartRequest(ClientId));
-        initializeResponse.EnsureSuccessStatusCode();
+        var openResponse = await Post(new OpenShoppingCartRequest(ClientId));
+        openResponse.EnsureSuccessStatusCode();
 
-        ShoppingCartId = await initializeResponse.GetResultFromJson<Guid>();
+        ShoppingCartId = await openResponse.GetResultFromJson<Guid>();
 
         CommandResponse = await Post(
             $"{ShoppingCartId}/products",

Sample/ECommerce/Carts/Carts.Api.Tests/ShoppingCarts/Canceling/CancelShoppingCartTests.cs

@@ -0,0 +1,78 @@
+using System.Net;
+using Carts.Api.Requests.Carts;
+using Carts.ShoppingCarts;
+using Carts.ShoppingCarts.FinalizingCart;
+using Carts.ShoppingCarts.GettingCartById;
+using Core.Api.Testing;
+using Core.Testing;
+using FluentAssertions;
+using Xunit;
+
+namespace Carts.Api.Tests.ShoppingCarts.Canceling;
+
+public class ConfirmShoppingCartFixture: ApiWithEventsFixture<Startup>
+{
+    protected override string ApiUrl => "/api/ShoppingCarts";
+
+    public Guid ShoppingCartId { get; private set; }
+
+    public readonly Guid ClientId = Guid.NewGuid();
+
+    public HttpResponseMessage CommandResponse = default!;
+
+    public override async Task InitializeAsync()
+    {
+        var openResponse = await Post(new OpenShoppingCartRequest(ClientId));
+        openResponse.EnsureSuccessStatusCode();
+
+        ShoppingCartId = await openResponse.GetResultFromJson<Guid>();
+
+        CommandResponse = await Delete(
+            $"{ShoppingCartId}",
+            new RequestOptions { IfMatch = 1.ToString() }
+        );
+    }
+}
+
+public class ConfirmShoppingCartTests: IClassFixture<ConfirmShoppingCartFixture>
+{
+    private readonly ConfirmShoppingCartFixture fixture;
+
+    public ConfirmShoppingCartTests(ConfirmShoppingCartFixture fixture)
+    {
+        this.fixture = fixture;
+    }
+
+    [Fact]
+    [Trait("Category", "Acceptance")]
+    public Task Put_Should_Return_OK()
+    {
+        var commandResponse = fixture.CommandResponse.EnsureSuccessStatusCode();
+        commandResponse.StatusCode.Should().Be(HttpStatusCode.OK);
+
+        return Task.CompletedTask;
+    }
+
+    [Fact]
+    [Trait("Category", "Acceptance")]
+    public async Task Put_Should_Confirm_ShoppingCart()
+    {
+        // prepare query
+        var query = $"{fixture.ShoppingCartId}";
+
+        //send query
+        var queryResponse = await fixture.Get(query, 30,
+            check: async response => (await response.GetResultFromJson<ShoppingCartDetails>()).Version == 2);
+
+        queryResponse.EnsureSuccessStatusCode();
+
+        var cartDetails = await queryResponse.GetResultFromJson<ShoppingCartDetails>();
+        cartDetails.Should().NotBeNull();
+        cartDetails.Id.Should().Be(fixture.ShoppingCartId);
+        cartDetails.Status.Should().Be(ShoppingCartStatus.Canceled);
+        cartDetails.ClientId.Should().Be(fixture.ClientId);
+        cartDetails.Version.Should().Be(2);
+
+        fixture.PublishedExternalEventsOfType<CartFinalized>();
+    }
+}

Sample/ECommerce/Carts/Carts.Api.Tests/ShoppingCarts/Confirming/ConfirmShoppingCartTests.cs

@@ -22,10 +22,10 @@ public class ConfirmShoppingCartFixture: ApiWithEventsFixture<Startup>
 
     public override async Task InitializeAsync()
     {
-        var initializeResponse = await Post(new InitializeShoppingCartRequest(ClientId));
-        initializeResponse.EnsureSuccessStatusCode();
+        var openResponse = await Post(new OpenShoppingCartRequest(ClientId));
+        openResponse.EnsureSuccessStatusCode();
 
-        ShoppingCartId = await initializeResponse.GetResultFromJson<Guid>();
+        ShoppingCartId = await openResponse.GetResultFromJson<Guid>();
 
         CommandResponse = await Put(
             $"{ShoppingCartId}/confirmation",

Sample/ECommerce/Carts/Carts.Api.Tests/ShoppingCarts/Initializing/InitializeShoppingCartTests.cs → Sample/ECommerce/Carts/Carts.Api.Tests/ShoppingCarts/Opening/OpenShoppingCartTests.cs

@@ -7,9 +7,9 @@
 using FluentAssertions;
 using Xunit;
 
-namespace Carts.Api.Tests.ShoppingCarts.Initializing;
+namespace Carts.Api.Tests.ShoppingCarts.Opening;
 
-public class InitializeShoppingCartFixture: ApiWithEventsFixture<Startup>
+public class OpenShoppingCartFixture: ApiWithEventsFixture<Startup>
 {
     protected override string ApiUrl => "/api/ShoppingCarts";
 
@@ -19,15 +19,15 @@ public class InitializeShoppingCartFixture: ApiWithEventsFixture<Startup>
 
     public override async Task InitializeAsync()
     {
-        CommandResponse = await Post(new InitializeShoppingCartRequest(ClientId));
+        CommandResponse = await Post(new OpenShoppingCartRequest(ClientId));
     }
 }
 
-public class InitializeShoppingCartTests: IClassFixture<InitializeShoppingCartFixture>
+public class OpenShoppingCartTests: IClassFixture<OpenShoppingCartFixture>
 {
-    private readonly InitializeShoppingCartFixture fixture;
+    private readonly OpenShoppingCartFixture fixture;
 
-    public InitializeShoppingCartTests(InitializeShoppingCartFixture fixture)
+    public OpenShoppingCartTests(OpenShoppingCartFixture fixture)
     {
         this.fixture = fixture;
     }

Sample/ECommerce/Carts/Carts.Api.Tests/ShoppingCarts/RemovingProduct/RemoveProductTests.cs

@@ -25,10 +25,10 @@ public class RemoveProductFixture: ApiWithEventsFixture<Startup>
 
     public override async Task InitializeAsync()
     {
-        var initializeResponse = await Post(new InitializeShoppingCartRequest(ClientId));
-        initializeResponse.EnsureSuccessStatusCode();
+        var openResponse = await Post(new OpenShoppingCartRequest(ClientId));
+        openResponse.EnsureSuccessStatusCode();
 
-        ShoppingCartId = await initializeResponse.GetResultFromJson<Guid>();
+        ShoppingCartId = await openResponse.GetResultFromJson<Guid>();
 
         var addResponse  = await Post(
             $"{ShoppingCartId}/products",

Sample/ECommerce/Carts/Carts.Api/Controllers/ShoppingCartsController.cs

@@ -1,10 +1,11 @@
 using Carts.Api.Requests.Carts;
+using Carts.ShoppingCarts.CancelingCart;
 using Carts.ShoppingCarts.ConfirmingCart;
 using Carts.ShoppingCarts.GettingCartAtVersion;
 using Carts.ShoppingCarts.GettingCartById;
 using Carts.ShoppingCarts.GettingCartHistory;
 using Carts.ShoppingCarts.GettingCarts;
-using Carts.ShoppingCarts.InitializingCart;
+using Carts.ShoppingCarts.OpeningCart;
 using Carts.ShoppingCarts.Products;
 using Microsoft.AspNetCore.Mvc;
 using Core.Commands;
@@ -35,11 +36,11 @@ public ShoppingCartsController(
     }
 
     [HttpPost]
-    public async Task<IActionResult> InitializeCart([FromBody] InitializeShoppingCartRequest? request)
+    public async Task<IActionResult> OpenCart([FromBody] OpenShoppingCartRequest? request)
     {
         var cartId = idGenerator.New();
 
-        var command = InitializeShoppingCart.Create(
+        var command = OpenShoppingCart.Create(
             cartId,
             request?.ClientId
         );
@@ -102,6 +103,20 @@ public async Task<IActionResult> ConfirmCart(Guid id)
         return Ok();
     }
 
+
+
+    [HttpDelete("{id}")]
+    public async Task<IActionResult> CancelCart(Guid id)
+    {
+        var command = CancelShoppingCart.Create(
+            id
+        );
+
+        await commandBus.Send(command);
+
+        return Ok();
+    }
+
     [HttpGet("{id}")]
     public async Task<ShoppingCartDetails> Get(Guid id)
     {

Sample/ECommerce/Carts/Carts.Api/Requests/Carts/ShoppingCartsRequests.cs

@@ -1,6 +1,6 @@
 namespace Carts.Api.Requests.Carts;
 
-public record InitializeShoppingCartRequest(
+public record OpenShoppingCartRequest(
     Guid? ClientId
 );
 

Sample/ECommerce/Carts/Carts.Tests/Builders/CartBuilder.cs

@@ -7,13 +7,13 @@ internal class CartBuilder
 {
     private Func<ShoppingCart> build  = () => new ShoppingCart();
 
-    public CartBuilder Initialized()
+    public CartBuilder Opened()
     {
         var cartId = Guid.NewGuid();
         var clientId = Guid.NewGuid();
 
         // When
-        var cart = ShoppingCart.Initialize(
+        var cart = ShoppingCart.Open(
             cartId,
             clientId
         );
@@ -31,4 +31,4 @@ public ShoppingCart Build()
         ((IAggregate)cart).DequeueUncommittedEvents();
         return cart;
     }
-}
+}

Sample/ECommerce/Carts/Carts.Tests/Carts/ConfirmingCart/ConfirmCartTests.cs

@@ -15,7 +15,7 @@ public void ForTentativeCart_ShouldSucceed()
         // Given
         var cart = CartBuilder
             .Create()
-            .Initialized()
+            .Opened()
             .Build();
 
         // When

Sample/ECommerce/Carts/Carts.Tests/Carts/InitializingCart/InitializeCartTests.cs

@@ -14,19 +14,19 @@ public void ForValidParams_ShouldCreateCartWithPendingStatus()
         var clientId = Guid.NewGuid();
 
         // When
-        var cart = ShoppingCart.Initialize(
+        var cart = ShoppingCart.Open(
             cartId,
             clientId
         );
 
         // Then
 
         cart
-            .IsInitializedCartWith(
+            .IsOpenedCartWith(
                 cartId,
                 clientId
             )
-            .HasCartInitializedEventWith(
+            .HasCartOpenedEventWith(
                 cartId,
                 clientId
             );

Sample/ECommerce/Carts/Carts.Tests/Carts/InitializingCart/InitializeCardCommandHandlerTests.cs → Sample/ECommerce/Carts/Carts.Tests/Carts/InitializingCart/OpenShoppingCardCommandHandlerTests.cs

@@ -1,5 +1,5 @@
 using Carts.ShoppingCarts;
-using Carts.ShoppingCarts.InitializingCart;
+using Carts.ShoppingCarts.OpeningCart;
 using Carts.Tests.Extensions.Reservations;
 using Carts.Tests.Stubs.Events;
 using Carts.Tests.Stubs.Repositories;
@@ -8,7 +8,7 @@
 
 namespace Carts.Tests.Carts.InitializingCart;
 
-public class InitializeCardCommandHandlerTests
+public class OpenShoppingCardCommandHandlerTests
 {
     [Fact]
     public async Task ForInitCardCommand_ShouldAddNewCart()
@@ -17,12 +17,12 @@ public async Task ForInitCardCommand_ShouldAddNewCart()
         var repository = new FakeRepository<ShoppingCart>();
         var scope = new DummyMartenAppendScope();
 
-        var commandHandler = new HandleInitializeCart(
+        var commandHandler = new HandleOpenShoppingCart(
             repository,
             scope
         );
 
-        var command = InitializeShoppingCart.Create(Guid.NewGuid(), Guid.NewGuid());
+        var command = OpenShoppingCart.Create(Guid.NewGuid(), Guid.NewGuid());
 
         // When
         await commandHandler.Handle(command, CancellationToken.None);
@@ -33,11 +33,11 @@ public async Task ForInitCardCommand_ShouldAddNewCart()
         var cart = repository.Aggregates.Values.Single();
 
         cart
-            .IsInitializedCartWith(
+            .IsOpenedCartWith(
                 command.CartId,
                 command.ClientId
             )
-            .HasCartInitializedEventWith(
+            .HasCartOpenedEventWith(
                 command.CartId,
                 command.ClientId
             );