Include ServicePulse frontend code into ServiceControl

Author: johnsimons

src/Directory.Packages.props

@@ -61,6 +61,7 @@
     <PackageVersion Include="Particular.Licensing.Sources" Version="6.1.0" />
     <PackageVersion Include="Particular.LicensingComponent.Report" Version="1.0.0" />
     <PackageVersion Include="Particular.Obsoletes" Version="1.0.0" />
+    <PackageVersion Include="Particular.PlatformSample.ServicePulse" Version="2.4.0" />
     <PackageVersion Include="Polly.Core" Version="8.5.2" />
     <PackageVersion Include="PropertyChanged.Fody" Version="4.1.0" />
     <PackageVersion Include="PropertyChanging.Fody" Version="1.30.3" />

src/ServiceControl/Hosting/Commands/RunCommand.cs

@@ -1,8 +1,12 @@
 namespace ServiceControl.Hosting.Commands
 {
+    using System;
+    using System.IO;
+    using System.Reflection;
     using System.Threading.Tasks;
     using Infrastructure.WebApi;
     using Microsoft.AspNetCore.Builder;
+    using Microsoft.Extensions.FileProviders;
     using NServiceBus;
     using Particular.ServiceControl;
     using Particular.ServiceControl.Hosting;
@@ -23,8 +27,18 @@ public override async Task Execute(HostArguments args, Settings settings)
             hostBuilder.AddServiceControl(settings, endpointConfiguration);
             hostBuilder.AddServiceControlApi();
 
+            var servicePulsePath = Path.Combine(AppContext.BaseDirectory, "platform", "servicepulse", "ServicePulse.dll");
+            var manifestEmbeddedFileProvider = new ManifestEmbeddedFileProvider(Assembly.LoadFrom(servicePulsePath), "wwwroot");
+            var fileProvider = new CompositeFileProvider(hostBuilder.Environment.WebRootFileProvider, manifestEmbeddedFileProvider);
+            var defaultFilesOptions = new DefaultFilesOptions { FileProvider = fileProvider };
+            var staticFileOptions = new StaticFileOptions { FileProvider = fileProvider };
+
             var app = hostBuilder.Build();
-            app.UseServiceControl();
+            app.UseServiceControl()
+                .UseMiddleware<AppConstantsMiddleware>()
+                .UseDefaultFiles(defaultFilesOptions)
+                .UseStaticFiles(staticFileOptions);
+
             await app.RunAsync(settings.RootUrl);
         }
     }

src/ServiceControl/Infrastructure/WebApi/AppConstantsMiddleware.cs

@@ -0,0 +1,47 @@
+namespace ServiceControl.Infrastructure.WebApi
+{
+    using System.Net.Mime;
+    using System.Text.Json;
+    using System.Threading.Tasks;
+    using Microsoft.AspNetCore.Http;
+
+    class AppConstantsMiddleware
+    {
+        readonly RequestDelegate next;
+        readonly string content;
+        static AppConstantsMiddleware() => FileVersion = ServiceControlVersion.GetFileVersion();
+        static readonly string FileVersion;
+
+        public AppConstantsMiddleware(RequestDelegate next)
+        {
+            this.next = next;
+
+            var settings = ServicePulseSettings.GetFromEnvironmentVariables();
+            var constants = new
+            {
+                default_route = "/dashboard",
+                service_control_url = "api/",
+                monitoring_urls = new[] { settings.MonitoringUri.ToString() },
+                showPendingRetry = settings.ShowPendingRetry,
+                version = FileVersion,
+                embedded = true
+            };
+            var options = new JsonSerializerOptions { PropertyNamingPolicy = null };
+
+            content = $"window.defaultConfig = {JsonSerializer.Serialize(constants, options)}";
+        }
+
+        public async Task InvokeAsync(HttpContext context)
+        {
+            if (context.Request.Path.StartsWithSegments("/js/app.constants.js"))
+            {
+                context.Response.ContentType = MediaTypeNames.Text.JavaScript;
+
+                await context.Response.WriteAsync(content);
+                return;
+            }
+
+            await next(context);
+        }
+    }
+}

src/ServiceControl/Infrastructure/WebApi/ServicePulseSettings.cs

@@ -0,0 +1,70 @@
+using System;
+using System.Text.Json;
+
+class ServicePulseSettings
+{
+    public required Uri MonitoringUri { get; init; }
+
+    public required string DefaultRoute { get; init; }
+
+    public required bool ShowPendingRetry { get; init; }
+
+
+    public static ServicePulseSettings GetFromEnvironmentVariables()
+    {
+        var monitoringUrls = ParseLegacyMonitoringValue(Environment.GetEnvironmentVariable("MONITORING_URLS"));
+        var monitoringUrl = Environment.GetEnvironmentVariable("MONITORING_URL");
+
+        monitoringUrl ??= monitoringUrls;
+        monitoringUrl ??= "http://localhost:33633/";
+
+        var monitoringUri = monitoringUrl == "!" ? null : new Uri(monitoringUrl);
+        var defaultRoute = Environment.GetEnvironmentVariable("DEFAULT_ROUTE") ?? "/dashboard";
+
+        var showPendingRetryValue = Environment.GetEnvironmentVariable("SHOW_PENDING_RETRY");
+        bool.TryParse(showPendingRetryValue, out var showPendingRetry);
+
+        return new ServicePulseSettings
+        {
+            MonitoringUri = monitoringUri,
+            DefaultRoute = defaultRoute,
+            ShowPendingRetry = showPendingRetry,
+        };
+    }
+
+    static string ParseLegacyMonitoringValue(string value)
+    {
+        if (value is null)
+        {
+            return null;
+        }
+
+        var cleanedValue = value.Replace('\'', '"');
+        var json = $$"""{"Addresses":{{cleanedValue}}}""";
+
+        MonitoringUrls result;
+
+        try
+        {
+            result = JsonSerializer.Deserialize<MonitoringUrls>(json);
+        }
+        catch (JsonException)
+        {
+            return null;
+        }
+
+        var addresses = result?.Addresses;
+
+        if (addresses is not null && addresses.Length > 0)
+        {
+            return addresses[0];
+        }
+
+        return null;
+    }
+
+    class MonitoringUrls
+    {
+        public string[] Addresses { get; set; } = [];
+    }
+}

src/ServiceControl/ServiceControl.csproj

@@ -32,6 +32,7 @@
     <PackageReference Include="NServiceBus.CustomChecks" />
     <PackageReference Include="NServiceBus.Extensions.Hosting" />
     <PackageReference Include="NServiceBus.Extensions.Logging" />
+    <PackageReference Include="Particular.PlatformSample.ServicePulse"/>
     <PackageReference Include="ServiceControl.Contracts" />
     <PackageReference Include="System.Reactive.Linq" />
     <PackageReference Include="Yarp.ReverseProxy" />

src/ServiceControl/WebApplicationExtensions.cs

@@ -7,7 +7,7 @@ namespace ServiceControl;
 
 public static class WebApplicationExtensions
 {
-    public static void UseServiceControl(this WebApplication app)
+    public static IApplicationBuilder UseServiceControl(this WebApplication app)
     {
         app.UseForwardedHeaders(new ForwardedHeadersOptions { ForwardedHeaders = ForwardedHeaders.All });
         app.UseResponseCompression();
@@ -16,5 +16,7 @@ public static void UseServiceControl(this WebApplication app)
         app.MapHub<MessageStreamerHub>("/api/messagestream");
         app.UseCors();
         app.MapControllers();
+
+        return app;
     }
 }