Moved orders queries to controller

Added also some questions to rethink the design by viewers

Core.EventStoreDB/Subscriptions/EventStoreDBSubscriptionToAll.cs

@@ -78,7 +78,7 @@ await foreach (var @event in subscription)
         }
         catch (Exception ex)
         {
-            logger.LogWarning("Subscription was dropped: {ex}", ex);
+            logger.LogWarning("Subscription was dropped: {Exception}", ex);
 
             // Sleep between reconnections to not flood the database or not kill the CPU with infinite loop
             // Randomness added to reduce the chance of multiple subscriptions trying to reconnect at the same time

Core/Commands/InMemoryCommandBus.cs

@@ -40,8 +40,10 @@ public async Task Send<TCommand>(TCommand command, CancellationToken ct = defaul
 
 public static class EventBusExtensions
 {
-    public static IServiceCollection AddInMemoryCommandBus(this IServiceCollection services,
-        AsyncPolicy? asyncPolicy = null)
+    public static IServiceCollection AddInMemoryCommandBus(
+        this IServiceCollection services,
+        AsyncPolicy? asyncPolicy = null
+    )
     {
         services.AddSingleton<CommandHandlerMetrics>();
         services.AddSingleton<CommandHandlerActivity>();

Sample/ECommerce/Orders/Orders.Api/Controllers/CartsController.cs

@@ -2,9 +2,13 @@
 using Core.Commands;
 using Core.Ids;
 using Core.Queries;
+using Marten;
+using Marten.AspNetCore;
+using Marten.Pagination;
 using Orders.Api.Requests.Carts;
 using Orders.Orders.CompletingOrder;
 using Orders.Orders.GettingOrderStatus;
+using Orders.Orders.GettingPending;
 using Orders.Orders.InitializingOrder;
 using Orders.Products;
 
@@ -13,12 +17,11 @@ namespace Orders.Api.Controllers;
 [Route("api/[controller]")]
 public class OrdersController(
     ICommandBus commandBus,
-    IQueryBus queryBus,
-    IIdGenerator idGenerator)
+    IQuerySession querySession,
+    IIdGenerator idGenerator
+)
     : Controller
 {
-    private readonly IQueryBus queryBus = queryBus;
-
     [HttpPost]
     public async Task<IActionResult> InitOrder([FromBody] InitOrderRequest? request)
     {
@@ -28,7 +31,7 @@ public async Task<IActionResult> InitOrder([FromBody] InitOrderRequest? request)
             orderId,
             request?.ClientId,
             request?.ProductItems?.Select(
-                pi => PricedProductItem.Create(pi.ProductId, pi.Quantity,pi.UnitPrice)).ToList(),
+                pi => PricedProductItem.Create(pi.ProductId, pi.Quantity, pi.UnitPrice)).ToList(),
             request?.TotalPrice
         );
 
@@ -77,11 +80,14 @@ public async Task<IActionResult> ConfirmOrder(Guid id)
     }
 
     [HttpGet("{id}")]
-    public async Task<IActionResult> GetStatus(Guid id)
-    {
-        var query = GetOrderStatus.For(id);
-
-        return await queryBus.Query<GetOrderStatus, OrderDetails?>(query) is {} details ?
-                Ok(details) : NotFound();
-    }
+    public Task GetStatus(Guid id) =>
+        querySession.Json.WriteById<OrderDetails>(id, HttpContext);
+
+    [HttpGet]
+    public Task<IPagedList<PendingOrder>> GetPending(
+        [FromQuery] int? pageNumber,
+        [FromQuery] int? pageSize,
+        CancellationToken ct
+    ) =>
+        querySession.Query<PendingOrder>().ToPagedListAsync(pageNumber ?? 1, pageSize ?? 10, ct);
 }

Sample/ECommerce/Orders/Orders.Api/Orders.Api.csproj

@@ -5,6 +5,7 @@
     </PropertyGroup>
 
     <ItemGroup>
+        <PackageReference Include="Marten.AspNetCore" Version="7.10.1" />
         <PackageReference Include="Npgsql.OpenTelemetry" Version="8.0.2" />
         <PackageReference Include="OpenTelemetry.Exporter.Jaeger" Version="1.5.1" />
         <PackageReference Include="Aspire.Confluent.Kafka" Version="8.0.0-preview.7.24251.11"/>

Sample/ECommerce/Orders/Orders/Orders/CancellingOrder/CancelOrder.cs

@@ -3,6 +3,7 @@
 using Core.Marten.Repository;
 using Marten;
 using Orders.Orders.GettingOrderStatus;
+using Orders.Orders.GettingPending;
 
 namespace Orders.Orders.CancellingOrder;
 

Sample/ECommerce/Orders/Orders/Orders/Config.cs

@@ -8,6 +8,7 @@
 using Orders.Orders.CancellingOrder;
 using Orders.Orders.CompletingOrder;
 using Orders.Orders.GettingOrderStatus;
+using Orders.Orders.GettingPending;
 using Orders.Orders.InitializingOrder;
 using Orders.Orders.RecordingOrderPayment;
 using Orders.Payments.FinalizingPayment;
@@ -24,7 +25,6 @@ internal static class OrdersConfig
         services
             .AddMartenRepository<Order>()
             .AddCommandHandlers()
-            .AddQueryHandlers()
             .AddEventHandlers();
 
     private static IServiceCollection AddCommandHandlers(this IServiceCollection services) =>
@@ -33,9 +33,6 @@ internal static class OrdersConfig
             .AddCommandHandler<CompleteOrder, HandleCompleteOrder>()
             .AddCommandHandler<CancelOrder, HandleCancelOrder>();
 
-    private static IServiceCollection AddQueryHandlers(this IServiceCollection services) =>
-        services.AddQueryHandler<GetOrderStatus, OrderDetails?, HandleGetOrderStatus>();
-
     private static IServiceCollection AddEventHandlers(this IServiceCollection services) =>
         services.AddEventHandler<CartFinalized, OrderSaga>()
             .AddEventHandler<OrderInitiated, OrderSaga>()

Sample/ECommerce/Orders/Orders/Orders/CancellingOrder/PendingOrder.cs → Sample/ECommerce/Orders/Orders/Orders/GettingPendingOrders/PendingOrder.cs

@@ -1,8 +1,6 @@
 using Marten.Events.Aggregation;
-using Orders.Orders.CompletingOrder;
-using Orders.Orders.InitializingOrder;
 
-namespace Orders.Orders.CancellingOrder;
+namespace Orders.Orders.GettingPending;
 using static OrderEvent;
 
 public class PendingOrder

Sample/ECommerce/Orders/Orders/Orders/Order.cs

@@ -77,12 +77,13 @@ public void Complete(DateTimeOffset now)
 
     public void Cancel(OrderCancellationReason cancellationReason, DateTimeOffset now)
     {
+        // QUESTION TO THE READER: Is throwing Exception here fine or not?
         if (OrderStatus.Closed.HasFlag(Status))
             throw new InvalidOperationException("Cannot cancel a closed order.");
 
-        var @event = OrderCancelled.Create(Id, PaymentId, cancellationReason, now);
-
-        Enqueue(@event);
+        Enqueue(
+            OrderCancelled.Create(Id, PaymentId, cancellationReason, now)
+        );
     }
 
     public override void Apply(OrderEvent @event)

Sample/ECommerce/Orders/Orders/Orders/OrderEvent.cs

@@ -82,5 +82,7 @@ DateTimeOffset cancelledAt
             new(orderId.NotEmpty(), paymentId.NotEmpty(), orderCancellationReason.NotEmpty(), cancelledAt.NotEmpty());
     }
 
+    // QUESTION TO THE READER: How to split OrderCancelled into OrderCancelled and OrderTimedOut
+
     private OrderEvent() { }
 }

Sample/Helpdesk.Wolverine/Helpdesk.Api/Program.cs

@@ -110,13 +110,10 @@
 
 return await app.RunOaktonCommands(args);
 
-namespace Helpdesk.Api
+public class IncidentsHub: Hub
 {
-    public class IncidentsHub: Hub
-    {
-    }
+}
 
-    public partial class Program
-    {
-    }
+public partial class Program
+{
 }