Merge pull request #55 from Mythetech/feat/dev-event-viewer

feat: dev event viewer

Author: thatplatypus

Apollo.Components/Editor/ToolsMenu.razor

@@ -1,4 +1,5 @@
 @using Apollo.Components.Infrastructure.MessageBus
+@using Apollo.Components.Infrastructure.Environment
 @using Apollo.Components.NuGet.Commands
 @using Apollo.Components.Tools.Commands
 @using Apollo.Components.Theme
@@ -11,6 +12,12 @@
     <MudMenuItem Icon="@ApolloIcons.Search" OnClick="@(async () => await Bus.PublishAsync(new OpenRegexTesterDialog()))">
         Regex Tester
     </MudMenuItem>
+    @if (Environment.IsDevelopment())
+    {
+        <MudMenuItem Icon="@ApolloIcons.Events" OnClick="@(async () => await Bus.PublishAsync(new OpenEventViewerDialog()))">
+            Event Viewer
+        </MudMenuItem>
+    }
     <MudMenu StartIcon="@ApolloIcons.Guid" Label="Generate GUID">
         <MudMenuItem Icon="@ApolloIcons.Guid" OnClick="@(async () => await Bus.PublishAsync(new GenerateGuid()))">
             GUID
@@ -23,5 +30,6 @@
 
 @code {
     [Inject] public IMessageBus Bus { get; set; } = default!;
+    [Inject] public IRuntimeEnvironment Environment { get; set; } = default!;
 }
 

Apollo.Components/Infrastructure/MessageBus/BusRegistrationExtensions.cs

@@ -50,6 +50,7 @@ public static void RegisterConsumerType(this IMessageBus bus, Type messageType,
 
     public static IServiceCollection AddMessageBus(this IServiceCollection services)
     {
+        services.AddSingleton<CapturedEventState>();
         services.AddSingleton<IMessageBus, InMemoryMessageBus>();
 
         services.RegisterConsumers(Assembly.GetExecutingAssembly());
@@ -59,6 +60,7 @@ public static IServiceCollection AddMessageBus(this IServiceCollection services)
 
     public static IServiceCollection AddMessageBus(this IServiceCollection services,  params Assembly[] assemblies)
     {
+        services.AddSingleton<CapturedEventState>();
         services.AddSingleton<IMessageBus, InMemoryMessageBus>();
 
         foreach (var assembly in assemblies)

Apollo.Components/Infrastructure/MessageBus/CapturedEventState.cs

@@ -0,0 +1,91 @@
+using System.Text.Json;
+
+namespace Apollo.Components.Infrastructure.MessageBus;
+
+public sealed class CapturedEventState
+{
+    private readonly object _gate = new();
+    private readonly List<CapturedEvent> _events = new();
+    private readonly JsonSerializerOptions _serializerOptions = new()
+    {
+        WriteIndented = true
+    };
+
+    public event Action? Changed;
+
+    public int MaxEvents { get; set; } = 2000;
+
+    public IReadOnlyList<CapturedEvent> GetEventsSnapshot()
+    {
+        lock (_gate)
+        {
+            return _events
+                .OrderByDescending(e => e.Timestamp)
+                .ToList();
+        }
+    }
+
+    public IReadOnlyList<CapturedEventAggregate> GetAggregateSnapshot()
+    {
+        lock (_gate)
+        {
+            return _events
+                .GroupBy(e => e.EventType)
+                .Select(g => new CapturedEventAggregate(g.Key, g.Count()))
+                .OrderByDescending(x => x.Count)
+                .ToList();
+        }
+    }
+
+    public void Clear()
+    {
+        lock (_gate)
+        {
+            _events.Clear();
+        }
+
+        Changed?.Invoke();
+    }
+
+    public void Add(Type eventType, object payload)
+    {
+        var serialized = JsonSerializer.Serialize(payload, eventType, _serializerOptions);
+        var captured = new CapturedEvent(
+            Guid.NewGuid(),
+            DateTimeOffset.UtcNow,
+            eventType.FullName ?? eventType.Name,
+            serialized);
+
+        lock (_gate)
+        {
+            _events.Add(captured);
+            TrimToMax();
+        }
+
+        Changed?.Invoke();
+    }
+
+    private void TrimToMax()
+    {
+        if (MaxEvents <= 0)
+            return;
+
+        var overflow = _events.Count - MaxEvents;
+        if (overflow <= 0)
+            return;
+
+        _events.RemoveRange(0, overflow);
+    }
+}
+
+public sealed record CapturedEvent(
+    Guid Id,
+    DateTimeOffset Timestamp,
+    string EventType,
+    string Payload);
+
+public sealed record CapturedEventAggregate(
+    string EventType,
+    int Count);
+
+

Apollo.Components/Infrastructure/MessageBus/InMemoryMessageBus.cs

@@ -1,5 +1,6 @@
 namespace Apollo.Components.Infrastructure.MessageBus;
 using Microsoft.Extensions.Logging;
+using Apollo.Components.Infrastructure.Environment;
 
 public class InMemoryMessageBus : IMessageBus
 {
@@ -9,15 +10,36 @@ public class InMemoryMessageBus : IMessageBus
 
     private readonly IServiceProvider _serviceProvider;
     private readonly ILogger<InMemoryMessageBus> _logger;
+    private readonly CapturedEventState _capturedEventState;
 
-    public InMemoryMessageBus(IServiceProvider serviceProvider, ILogger<InMemoryMessageBus> logger)
+    internal bool CaptureDebugInformation { get; }
+
+    public InMemoryMessageBus(
+        IServiceProvider serviceProvider,
+        ILogger<InMemoryMessageBus> logger,
+        CapturedEventState capturedEventState,
+        IRuntimeEnvironment runtimeEnvironment)
     {
         _serviceProvider = serviceProvider;
         _logger = logger;
+        _capturedEventState = capturedEventState;
+        CaptureDebugInformation = runtimeEnvironment.IsDevelopment();
     }
 
     public async Task PublishAsync<TMessage>(TMessage message) where TMessage : class
     {
+        if (CaptureDebugInformation)
+        {
+            try
+            {
+                _capturedEventState.Add(typeof(TMessage), message);
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "Error capturing message {MessageType}", typeof(TMessage).Name);
+            }
+        }
+
         var registeredConsumers = GetOrResolveConsumers<TMessage>();
 
         var manualSubscribers = _subscribers.TryGetValue(typeof(TMessage), out var subscribers)

Apollo.Components/Theme/ApolloIcons.cs

@@ -121,4 +121,6 @@ public static class ApolloIcons
     public const string Guid = Icons.Material.TwoTone.Fingerprint;
 
     public const string GuidV7 = Icons.Material.TwoTone.Schedule;
+
+    public const string Events = Icons.Material.TwoTone.EventNote;
 }

Apollo.Components/Tools/Commands/OpenEventViewerDialog.cs

@@ -0,0 +1,5 @@
+namespace Apollo.Components.Tools.Commands;
+
+public record OpenEventViewerDialog();
+
+

Apollo.Components/Tools/Consumers/EventViewerDialogOpener.cs

@@ -0,0 +1,30 @@
+using Apollo.Components.Infrastructure.MessageBus;
+using Apollo.Components.Tools.Commands;
+using MudBlazor;
+
+namespace Apollo.Components.Tools.Consumers;
+
+public sealed class EventViewerDialogOpener : IConsumer<OpenEventViewerDialog>
+{
+    private readonly IDialogService _dialogService;
+
+    public EventViewerDialogOpener(IDialogService dialogService)
+    {
+        _dialogService = dialogService;
+    }
+
+    public async Task Consume(OpenEventViewerDialog message)
+    {
+        var options = new DialogOptions
+        {
+            CloseOnEscapeKey = true,
+            NoHeader = true,
+            MaxWidth = MaxWidth.ExtraLarge,
+            FullWidth = true,
+        };
+
+        await _dialogService.ShowAsync<EventViewerDialog>("Event Viewer", options);
+    }
+}
+
+