Merge pull request #24 from FoundatioFx/cross-project

Add support for using interceptors with handlers in referenced projects

Author: ejsmith

AGENTS.md

@@ -17,13 +17,13 @@ Build project (triggers source generators): `dotnet build`
 Run tests (validate work): `dotnet test`
 Run benchmarks: `cd benchmarks/Foundatio.Mediator.Benchmarks; dotnet run -c Release`
 Run samples: `cd samples/ConsoleSample; dotnet run`
+Clean (removes source generated files): `dotnet clean`
 
 ## Code Conventions
 
 ### Coding Standards
 
 - Follow `.editorconfig` settings strictly
-- See [.github/instructions/general.instructions.md](.github/instructions/general.instructions.md) for complete guidelines
 - Keep comments minimal - only for complex logic or non-obvious intent
 
 ### Source Generator Code Style

samples/ModularMonolithSample/src/Orders.Module/Api/OrdersApi.cs

@@ -64,7 +64,7 @@ public static void MapOrdersEndpoints(this IEndpointRouteBuilder endpoints)
             var result = await mediator.InvokeAsync<Result<Order>>(command);
             return result.ToCreatedResult($"/api/orders/{result.Value?.Id}");
         })
-        .WithName("EntityAction")
+        .WithName("OrderEntityAction")
         .WithSummary("Perform an action on an order");
     }
 }

samples/ModularMonolithSample/src/Products.Module/Api/ProductApi.cs

@@ -64,7 +64,7 @@ public static void MapProductEndpoints(this IEndpointRouteBuilder endpoints)
             var result = await mediator.InvokeAsync<Result<Product>>(command);
             return result.ToCreatedResult($"/api/products/{result.Value?.Id}");
         })
-        .WithName("EntityAction")
+        .WithName("ProductEntityAction")
         .WithSummary("Perform an action on a product");
     }
 }

samples/ModularMonolithSample/src/WebApp/Api/DashboardApi.cs

@@ -0,0 +1,70 @@
+using Foundatio.Mediator;
+using Orders.Module.Messages;
+using Products.Module.Messages;
+
+namespace WebApp.Api;
+
+public static class DashboardApi
+{
+    public static void MapDashboardEndpoints(this IEndpointRouteBuilder endpoints)
+    {
+        var group = endpoints.MapGroup("/api/dashboard")
+            .WithTags("Dashboard");
+
+        group.MapGet("/", async (IMediator mediator) =>
+        {
+            var ordersTask = mediator.InvokeAsync<Result<List<Order>>>(new GetOrders());
+            var productsTask = mediator.InvokeAsync<Result<List<Product>>>(new GetProducts());
+
+            await Task.WhenAll(ordersTask.AsTask(), productsTask.AsTask());
+
+            var orders = ordersTask.Result;
+            var products = productsTask.Result;
+
+            return Results.Ok(new DashboardResponse(
+                TotalOrders: orders.IsSuccess ? orders.Value?.Count ?? 0 : 0,
+                TotalProducts: products.IsSuccess ? products.Value?.Count ?? 0 : 0,
+                TotalRevenue: orders.IsSuccess ? orders.Value?.Sum(o => o.Amount) ?? 0 : 0,
+                RecentOrders: orders.IsSuccess ? orders.Value?.OrderByDescending(o => o.CreatedAt).Take(5).ToList() ?? [] : [],
+                RecentProducts: products.IsSuccess ? products.Value?.OrderByDescending(p => p.CreatedAt).Take(5).ToList() ?? [] : []
+            ));
+        })
+        .WithName("GetDashboard")
+        .WithSummary("Get dashboard overview with orders and products summary");
+
+        group.MapPost("/quick-order", async (QuickOrderRequest request, IMediator mediator) =>
+        {
+            var command = new CreateOrder(request.CustomerId, request.Amount, request.Description ?? "Quick order");
+            var result = await mediator.InvokeAsync<Result<Order>>(command);
+
+            return result.IsSuccess
+                ? Results.Created($"/api/orders/{result.Value?.Id}", result.Value)
+                : Results.BadRequest(new { error = result.Message });
+        })
+        .WithName("QuickOrder")
+        .WithSummary("Create a quick order with minimal input");
+
+        group.MapPost("/quick-product", async (QuickProductRequest request, IMediator mediator) =>
+        {
+            var command = new CreateProduct(request.Name, request.Description ?? $"Product: {request.Name}", request.Price);
+            var result = await mediator.InvokeAsync<Result<Product>>(command);
+
+            return result.IsSuccess
+                ? Results.Created($"/api/products/{result.Value?.Id}", result.Value)
+                : Results.BadRequest(new { error = result.Message });
+        })
+        .WithName("QuickProduct")
+        .WithSummary("Create a quick product with minimal input");
+    }
+}
+
+// Request/Response DTOs
+public record QuickOrderRequest(string CustomerId, decimal Amount, string? Description = null);
+public record QuickProductRequest(string Name, decimal Price, string? Description = null);
+
+public record DashboardResponse(
+    int TotalOrders,
+    int TotalProducts,
+    decimal TotalRevenue,
+    List<Order> RecentOrders,
+    List<Product> RecentProducts);

samples/ModularMonolithSample/src/WebApp/Api/SearchApi.cs

@@ -0,0 +1,52 @@
+using Foundatio.Mediator;
+using Orders.Module.Messages;
+using Products.Module.Messages;
+
+namespace WebApp.Api;
+
+public static class SearchApi
+{
+    public static void MapSearchEndpoints(this IEndpointRouteBuilder endpoints)
+    {
+        endpoints.MapGet("/api/search", async (string? q, IMediator mediator) =>
+        {
+            var ordersTask = mediator.InvokeAsync<Result<List<Order>>>(new GetOrders());
+            var productsTask = mediator.InvokeAsync<Result<List<Product>>>(new GetProducts());
+
+            await Task.WhenAll(ordersTask.AsTask(), productsTask.AsTask());
+
+            var orders = ordersTask.Result;
+            var products = productsTask.Result;
+
+            var query = q?.ToLowerInvariant() ?? "";
+
+            var matchingOrders = orders.IsSuccess
+                ? orders.Value?.Where(o =>
+                    o.Description.Contains(query, StringComparison.OrdinalIgnoreCase) ||
+                    o.CustomerId.Contains(query, StringComparison.OrdinalIgnoreCase)).ToList() ?? []
+                : [];
+
+            var matchingProducts = products.IsSuccess
+                ? products.Value?.Where(p =>
+                    p.Name.Contains(query, StringComparison.OrdinalIgnoreCase) ||
+                    p.Description.Contains(query, StringComparison.OrdinalIgnoreCase)).ToList() ?? []
+                : [];
+
+            return Results.Ok(new SearchResponse(
+                Query: q,
+                Orders: matchingOrders,
+                Products: matchingProducts,
+                TotalResults: matchingOrders.Count + matchingProducts.Count
+            ));
+        })
+        .WithName("Search")
+        .WithTags("Search")
+        .WithSummary("Search across orders and products");
+    }
+}
+
+public record SearchResponse(
+    string? Query,
+    List<Order> Orders,
+    List<Product> Products,
+    int TotalResults);

samples/ModularMonolithSample/src/WebApp/Program.cs

@@ -6,6 +6,7 @@
 using Products.Module;
 using Products.Module.Api;
 using Products.Module.Messages;
+using WebApp.Api;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -40,4 +41,8 @@
     .WithName("Home")
     .WithSummary("Home endpoint");
 
+// Map WebApp endpoints (these call handlers in other modules via cross-assembly interception)
+app.MapDashboardEndpoints();
+app.MapSearchEndpoints();
+
 app.Run();