Add topics view and improve dark theme (#13)

* Add subscriptions view

* Improve dark theme message error visibility

* Add mono font for JSON view

* Update changelog

* Updates

* Update

* Update

* Update changelog

* Update

* update

* Update nuget version

Author: filipbekic01

.github/workflows/deploy.yaml

@@ -43,7 +43,7 @@ jobs:
   DeployImage:
     runs-on: ubuntu-latest
     env:
-      ResQueueImageVersion: "1.2.0"
+      ResQueueImageVersion: "1.3.0"
       DockerRegistry: ghcr.io
       DockerRepository: filipbekic01/resqueue
     steps:

CHANGELOG.md

@@ -2,6 +2,24 @@
 
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
+## [v1.3.0] - 2025-01-09
+
+### Added
+
+- Topics table view with filters
+- Recurring job indicator in table view
+
+### Changed
+
+- One click less for auto-refresh action
+- JSON view uses mono font now
+- Dark theme message colors
+- Sticky-top actions when scroll is present
+
+### Fixed
+
+- Queue messages count invalidation on refresh
+
 ## [v1.2.0] - 2025-01-05
 
 ### Added

backend/ResQueue/ResQueue/Dtos/Messages/SubscriptionDto.cs

@@ -0,0 +1,9 @@
+namespace ResQueue.Dtos.Messages;
+
+public record SubscriptionDto(
+    string TopicName,
+    string DestinationType,
+    string DestinationName,
+    int SubscriptionType,
+    string RoutingKey
+);

backend/ResQueue/ResQueue/Endpoints/SubscriptionsEndpoints.cs

@@ -0,0 +1,22 @@
+using ResQueue.Features.Subscriptions.GetSubscriptions;
+
+namespace ResQueue.Endpoints;
+
+public static class SubscriptionsEndpoints
+{
+    public static void MapSubscriptionsEndpoints(this IEndpointRouteBuilder routes)
+    {
+        RouteGroupBuilder group = routes.MapGroup("subscriptions");
+
+        group.MapGet("",
+            async (IGetSubscriptionsFeature feature) =>
+            {
+                var result = await feature.ExecuteAsync(new GetSubscriptionsRequest(
+                ));
+
+                return result.IsSuccess
+                    ? Results.Ok(result.Value!.Subscriptions)
+                    : Results.Problem(result.Problem!);
+            });
+    }
+}

backend/ResQueue/ResQueue/Features/Messages/GetMessages/GetMessagesFeature.cs

@@ -1,5 +1,4 @@
 using Dapper;
-using Microsoft.Extensions.Options;
 using ResQueue.Dtos.Messages;
 using ResQueue.Enums;
 using ResQueue.Factories;

backend/ResQueue/ResQueue/Features/Subscriptions/GetSubscriptions/GetSubscriptionsFeature.cs

@@ -0,0 +1,54 @@
+using Dapper;
+using ResQueue.Dtos.Messages;
+using ResQueue.Enums;
+using ResQueue.Factories;
+using ResQueue.Providers.DbConnectionProvider;
+
+namespace ResQueue.Features.Subscriptions.GetSubscriptions;
+
+public record GetSubscriptionsRequest();
+
+public record GetSubscriptionsResponse(List<SubscriptionDto> Subscriptions);
+
+public class GetSubscriptionsFeature(
+    IDatabaseConnectionFactory connectionFactory,
+    IDbConnectionProvider conn
+) : IGetSubscriptionsFeature
+{
+    public async Task<OperationResult<GetSubscriptionsResponse>> ExecuteAsync(GetSubscriptionsRequest request)
+    {
+        await using var connection = connectionFactory.CreateConnection();
+
+        var subscriptions = await connection.QueryAsync<SubscriptionDto>(GetSqlQueryText());
+
+        return OperationResult<GetSubscriptionsResponse>.Success(new GetSubscriptionsResponse(
+            Subscriptions: subscriptions.ToList()
+        ));
+    }
+
+    private string GetSqlQueryText()
+    {
+        return conn.SqlEngine switch
+        {
+            ResQueueSqlEngine.Postgres => $"""
+                                           SELECT 
+                                               s.topic_name AS TopicName,
+                                               s.destination_type AS DestinationType,
+                                               s.destination_name AS DestinationName,
+                                               s.subscription_type AS SubscriptionType,
+                                               s.routing_key AS RoutingKey
+                                           FROM {conn.Schema}.subscriptions s
+                                           """,
+            ResQueueSqlEngine.SqlServer => $"""
+                                            SELECT 
+                                                s.TopicName,
+                                                s.DestinationType,
+                                                s.DestinationName,
+                                                s.SubscriptionType,
+                                                s.RoutingKey
+                                            FROM {conn.Schema}.Subscriptions s
+                                            """,
+            _ => throw new NotSupportedException("Unsupported SQL Engine")
+        };
+    }
+}

backend/ResQueue/ResQueue/Features/Subscriptions/GetSubscriptions/IGetSubscriptionsFeature.cs

@@ -0,0 +1,6 @@
+namespace ResQueue.Features.Subscriptions.GetSubscriptions;
+
+public interface IGetSubscriptionsFeature
+{
+    Task<OperationResult<GetSubscriptionsResponse>> ExecuteAsync(GetSubscriptionsRequest request);
+}

backend/ResQueue/ResQueue/ResQueue.csproj

@@ -28,7 +28,7 @@
 
         <!-- NuGet package properties -->
         <PackageId>ResQueue.MassTransit</PackageId>
-        <Version>1.2.0</Version>
+        <Version>1.3.0</Version>
         <Authors>Filip Bekić, Miroljub Tomić</Authors>
         <Company>ResQueue</Company>
         <Description>MassTransit SQL Transport Web UI</Description>

backend/ResQueue/ResQueue/ResQueueExtensions.cs

@@ -8,6 +8,7 @@
 using ResQueue.Features.Messages.PurgeQueue;
 using ResQueue.Features.Messages.RequeueMessages;
 using ResQueue.Features.Messages.RequeueSpecificMessages;
+using ResQueue.Features.Subscriptions.GetSubscriptions;
 using ResQueue.Providers.DbConnectionProvider;
 
 namespace ResQueue;
@@ -36,6 +37,7 @@ public static IServiceCollection AddResQueue(this IServiceCollection services,
         services.AddTransient<IGetMessagesFeature, GetMessagesFeature>();
         services.AddTransient<IGetSingleMessageFeature, GetSingleMessageFeature>();
         services.AddTransient<IPurgeQueueFeature, PurgeQueueFeature>();
+        services.AddTransient<IGetSubscriptionsFeature, GetSubscriptionsFeature>();
 
         return services;
     }
@@ -88,6 +90,7 @@ public static IApplicationBuilder UseResQueue(this WebApplication app, string pr
         api.MapQueueEndpoints();
         api.MapMessageEndpoints();
         api.MapJobsEndpoints();
+        api.MapSubscriptionsEndpoints();
 
         return app;
     }

backend/ResQueue/WebSample/Program.cs

@@ -93,7 +93,7 @@ public static void Main(string[] args)
         app.MapGet("/publish",
             async (IPublishEndpoint endpoint) => { await endpoint.Publish(new YourMessage(Guid.NewGuid())); });
 
-        app.MapGet("/schedule",
+        app.MapGet("/start-job",
             async (IPublishEndpoint endpoint) =>
             {
                 var jobId = await endpoint.AddOrUpdateRecurringJob(nameof(AwesomeConsumer), new AwesomeRequest(),