More tests

Author: ejsmith

samples/CleanArchitectureSample/README.md

@@ -369,16 +369,11 @@ You can create your own attributes following the same pattern — define an attr
 A streaming handler uses `IAsyncEnumerable<T>` to push domain events to clients in real time via Server-Sent Events. The mediator's built-in `SubscribeAsync<T>` yields events as they're published anywhere in the system:
 
 ```csharp
-[Handler]
 public class ClientEventStreamHandler(IMediator mediator)
 {
-    [HandlerEndpoint(
-        Route = "/events/stream",
-        Streaming = EndpointStreaming.ServerSentEvents,
-        Summary = "Subscribe to real-time domain events via Server-Sent Events")]
-    [HandlerAllowAnonymous]
+    [HandlerEndpoint(Streaming = EndpointStreaming.ServerSentEvents)]
     public async IAsyncEnumerable<ClientEvent> Handle(
-        SubscribeToClientEvents message,
+        GetEventStream message,
         [EnumeratorCancellation] CancellationToken cancellationToken)
     {
         await foreach (var evt in mediator.SubscribeAsync<IDispatchToClient>(cancellationToken: cancellationToken))

samples/CleanArchitectureSample/src/Api/Handlers/ClientEventStreamHandler.cs

@@ -13,22 +13,19 @@ public record ClientEvent(string EventType, object Data);
 /// <summary>
 /// Message to subscribe to real-time client events via SSE.
 /// </summary>
-public record SubscribeToClientEvents;
+public record GetEventStream;
 
 /// <summary>
 /// Streaming handler that subscribes to all IDispatchToClient notifications via the
 /// mediator's built-in subscription support and streams them as SSE events.
 /// </summary>
-[Handler]
 public class ClientEventStreamHandler(IMediator mediator)
 {
     [HandlerEndpoint(
-        Route = "/events/stream",
         Streaming = EndpointStreaming.ServerSentEvents,
         Summary = "Subscribe to real-time domain events via Server-Sent Events")]
-    [HandlerAllowAnonymous]
     public async IAsyncEnumerable<ClientEvent> Handle(
-        SubscribeToClientEvents message,
+        GetEventStream message,
         [EnumeratorCancellation] CancellationToken cancellationToken)
     {
         await foreach (var evt in mediator.SubscribeAsync<IDispatchToClient>(cancellationToken: cancellationToken))

src/Foundatio.Mediator.Abstractions/IMediator.cs

@@ -137,11 +137,11 @@ public interface IMediator
     /// <remarks>
     /// Typical usage is in streaming SSE endpoints that push domain events to connected clients:
     /// <code>
-    /// public IAsyncEnumerable&lt;IDispatchToClient&gt; Handle(
-    ///     SubscribeToClientEvents message,
+    /// public IAsyncEnumerable&lt;INotification&gt; Handle(
+    ///     GetEventStream message,
     ///     CancellationToken ct)
     /// {
-    ///     return mediator.SubscribeAsync&lt;IDispatchToClient&gt;(cancellationToken: ct);
+    ///     return mediator.SubscribeAsync&lt;INotification&gt;(cancellationToken: ct);
     /// }
     /// </code>
     /// </remarks>

src/Foundatio.Mediator/HandlerAnalyzer.cs

@@ -936,7 +936,7 @@ private static string RemoveVerbPrefix(string name)
     /// </summary>
     private static readonly string[] EntitySuffixes =
     [
-        "Paginated", "Details", "Detail", "Summary", "ById", "Paged", "List"
+        "Paginated", "Details", "Detail", "Summary", "ById", "Paged", "Stream", "List"
     ];
 
     /// <summary>

tests/Foundatio.Mediator.Tests/EndpointGenerationTests.cs

@@ -1516,11 +1516,11 @@ public void StreamingEndpoint_DefaultFormat_ReturnsOkWithStream()
 
             [assembly: MediatorConfiguration(EndpointDiscovery = EndpointDiscovery.All)]
 
-            public record SubscribeToEvents;
+            public record GetEventStream;
 
             public class EventStreamHandler
             {
-                public async IAsyncEnumerable<string> HandleAsync(SubscribeToEvents query) { yield return "event"; }
+                public async IAsyncEnumerable<string> HandleAsync(GetEventStream query) { yield return "event"; }
             }
             """;
 
@@ -1545,12 +1545,12 @@ public void StreamingEndpoint_SseFormat_UsesTypedResultsServerSentEvents()
 
             [assembly: MediatorConfiguration(EndpointDiscovery = EndpointDiscovery.All)]
 
-            public record SubscribeToEvents;
+            public record GetEventStream;
 
             public class EventStreamHandler
             {
                 [HandlerEndpoint(Streaming = EndpointStreaming.ServerSentEvents, SseEventType = "event")]
-                public async IAsyncEnumerable<string> HandleAsync(SubscribeToEvents query) { yield return "event"; }
+                public async IAsyncEnumerable<string> HandleAsync(GetEventStream query) { yield return "event"; }
             }
             """;
 

tests/Foundatio.Mediator.Tests/EndpointRouteConventionTests.cs

@@ -453,6 +453,29 @@ public class OrderHandler
         AssertNoRouteContains(endpointSource, "summary");
     }
 
+    [Fact]
+    public void EntitySuffix_Stream_StrippedFromEntityName()
+    {
+        var source = """
+            using Foundatio.Mediator;
+
+            [assembly: MediatorConfiguration(EndpointDiscovery = EndpointDiscovery.All)]
+
+            public record GetEventStream();
+
+            public class EventHandler
+            {
+                public string Handle(GetEventStream query) => "stream";
+            }
+            """;
+
+        var endpointSource = GenerateEndpointSource(source);
+        if (endpointSource is null) return;
+
+        AssertEndpoint(endpointSource, "GET", "/api/events");
+        AssertNoRouteContains(endpointSource, "stream");
+    }
+
     [Fact]
     public void EntitySuffix_Paginated_StrippedFromEntityName()
     {