event subscription support

Author: dj-nitehawk

Client/Pages/Counter.razor

@@ -4,15 +4,16 @@
 
 <h1>Counter</h1>
 
-<p role="status">Current count: @currentCount</p>
+<p role="status">Current count: @_currentCount</p>
 
 <button class="btn btn-primary" @onclick="IncrementCount">Click me</button>
 
 @code {
-    private int currentCount = 0;
+    private int _currentCount;
 
     private void IncrementCount()
     {
-        currentCount++;
+        _currentCount++;
     }
-}
+
+}

Client/Pages/FetchData.razor

@@ -0,0 +1,42 @@
+@page "/test"
+@using bWasm.Shared
+@using FastEndpoints
+
+<PageTitle>Test</PageTitle>
+
+<h1>Command Send: @_cmdResult</h1>
+<h1>Event Receive: @_evntResult</h1>
+
+@code
+{
+    private string _cmdResult = "Sending command to server...";
+    private string _evntResult = "Waiting for event result...";
+
+    protected override async Task OnInitializedAsync()
+    {
+        _cmdResult = (await new CreateOrderCommand
+                          {
+                              OrderId = 1001,
+                              CustomerName = "Holly Simms"
+                          }
+                          .RemoteExecuteAsync()).Message;
+
+        _ = EventResultCheckerTask();
+    }
+
+    async Task EventResultCheckerTask()
+    {
+        while (true)
+        {
+            await Task.Delay(1000);
+
+            if (OrderCreatedEventHandler.Result is null || OrderCreatedEventHandler.Result == _evntResult)
+                continue;
+
+            _evntResult = OrderCreatedEventHandler.Result;
+            StateHasChanged();
+
+            return;
+        }
+    }
+}

Client/Pages/Test.razor

@@ -14,5 +14,18 @@
     c =>
     {
         c.Register<CreateOrderCommand, CreateOrderResult>();
+        c.Subscribe<OrderCreatedEvent, OrderCreatedEventHandler>();
     });
-await app.RunAsync();
+await app.RunAsync();
+
+sealed class OrderCreatedEventHandler : IEventHandler<OrderCreatedEvent>
+{
+    internal static string? Result { get; private set; }
+
+    public Task HandleAsync(OrderCreatedEvent e, CancellationToken c)
+    {
+        Result = $"{e.Description} Order Id: {e.OrderId}";
+
+        return Task.CompletedTask;
+    }
+}

Client/Program.cs

@@ -20,8 +20,8 @@
             </NavLink>
         </div>
         <div class="nav-item px-3">
-            <NavLink class="nav-link" href="fetchdata">
-                <span class="oi oi-list-rich" aria-hidden="true"></span> Fetch data
+            <NavLink class="nav-link" href="test">
+                <span class="oi oi-list-rich" aria-hidden="true"></span> Test
             </NavLink>
         </div>
     </nav>
@@ -36,4 +36,5 @@
     {
         collapseNavMenu = !collapseNavMenu;
     }
-}
+
+}

Client/Shared/NavMenu.razor

@@ -9,7 +9,7 @@
     <ItemGroup>
         <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly" Version="8.0.7"/>
         <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.DevServer" Version="8.0.7" PrivateAssets="all"/>
-        <PackageReference Include="FastEndpoints.Messaging.Remote.Core" Version="5.27.0"/>
+        <PackageReference Include="FastEndpoints.Messaging.Remote.Core" Version="5.27.0.11-beta"/>
         <ProjectReference Include="..\Shared\bWasm.Contracts.csproj"/>
     </ItemGroup>
 

Client/bWasm.Client.csproj

@@ -14,17 +14,34 @@
 app.MapHandlers(
     h =>
     {
-        h.Register<CreateOrderCommand, CreateOrderHandler, CreateOrderResult>();
+        h.Register<CreateOrderCommand, CreateOrderCommandHandler, CreateOrderResult>();
+        h.RegisterEventHub<OrderCreatedEvent>();
     });
 app.MapFallbackToFile("index.html");
 app.Run();
 
-public sealed class CreateOrderHandler : ICommandHandler<CreateOrderCommand, CreateOrderResult>
+public sealed class CreateOrderCommandHandler : ICommandHandler<CreateOrderCommand, CreateOrderResult>
 {
-    public Task<CreateOrderResult> ExecuteAsync(CreateOrderCommand cmd, CancellationToken _)
-        => Task.FromResult(
+    public Task<CreateOrderResult> ExecuteAsync(CreateOrderCommand cmd, CancellationToken ct)
+    {
+        _ = Task.Run(
+            async () =>
+            {
+                //broadcast an event after 3 seconds
+
+                await Task.Delay(3000);
+                new OrderCreatedEvent
+                {
+                    OrderId = cmd.OrderId,
+                    Description = "Successfully created"
+                }.Broadcast(ct);
+            },
+            ct);
+
+        return Task.FromResult(
             new CreateOrderResult
             {
                 Message = $"Order {cmd.OrderId} created for {cmd.CustomerName}"
             });
+    }
 }

Server/Program.cs

@@ -9,7 +9,7 @@
     <ItemGroup>
         <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Server" Version="8.0.7"/>
         <PackageReference Include="Grpc.AspNetCore.Web" Version="2.63.0"/>
-        <PackageReference Include="FastEndpoints.Messaging.Remote" Version="5.27.0"/>
+        <PackageReference Include="FastEndpoints.Messaging.Remote" Version="5.27.0.11-beta"/>
         <ProjectReference Include="..\Client\bWasm.Client.csproj"/>
         <ProjectReference Include="..\Shared\bWasm.Contracts.csproj"/>
     </ItemGroup>

Server/bWasm.Server.csproj

@@ -0,0 +1,17 @@
+#pragma warning disable CS8618
+
+    using FastEndpoints;
+
+    namespace bWasm.Shared
+    {
+        public class CreateOrderCommand : ICommand<CreateOrderResult>
+        {
+            public int OrderId { get; set; }
+            public string CustomerName { get; set; }
+        }
+
+        public class CreateOrderResult
+        {
+            public string Message { get; set; }
+        }
+    }

Shared/CreateOrder.cs

@@ -0,0 +1,12 @@
+#pragma warning disable CS8618
+
+    using FastEndpoints;
+
+    namespace bWasm.Shared
+    {
+        public sealed class OrderCreatedEvent : IEvent
+        {
+            public int OrderId { get; set; }
+            public string Description { get; set; }
+        }
+    }

Shared/CreateOrderCommand.cs

@@ -11,6 +11,6 @@
     </ItemGroup>
 
     <ItemGroup>
-        <PackageReference Include="FastEndpoints.Messaging.Core" Version="5.27.0"/>
+        <PackageReference Include="FastEndpoints.Messaging.Core" Version="5.27.0.11-beta"/>
     </ItemGroup>
 </Project>