adding health check support (#245)

Author: Aaronontheweb

Directory.Packages.props

@@ -1,10 +1,10 @@
 <Project>
   <PropertyGroup Label="SharedVersions">
     <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
-    <AkkaVersion>1.5.41</AkkaVersion>
-    <AkkaHostingVersion>1.5.40</AkkaHostingVersion>
-    <AkkaManagementVersion>1.5.37</AkkaManagementVersion>
-    <PetabridgeCmdVersion>1.4.4</PetabridgeCmdVersion>
+    <AkkaVersion>1.5.51</AkkaVersion>
+    <AkkaHostingVersion>1.5.51</AkkaHostingVersion>
+    <AkkaManagementVersion>1.5.50</AkkaManagementVersion>
+    <PetabridgeCmdVersion>1.4.5</PetabridgeCmdVersion>
     <AspireVersion>9.3.0</AspireVersion>
     <PlaywrightVersion>1.52.0</PlaywrightVersion>
   </PropertyGroup>
@@ -16,7 +16,7 @@
     <PackageVersion Include="Akka.Discovery.KubernetesApi" Version="$(AkkaManagementVersion)" />
     <PackageVersion Include="Akka.Hosting" Version="$(AkkaHostingVersion)" />
     <PackageVersion Include="Akka.Management" Version="$(AkkaManagementVersion)" />
-    <PackageVersion Include="Akka.Persistence.Sql.Hosting" Version="1.5.40.1" />
+    <PackageVersion Include="Akka.Persistence.Sql.Hosting" Version="1.5.51" />
     <PackageVersion Include="Akka.Streams" Version="$(AkkaVersion)" />
     <PackageVersion Include="Akka.Streams.TestKit" Version="$(AkkaVersion)" />
     <PackageVersion Include="Aspire.Hosting.Azure.Storage" Version="$(AspireVersion)" />

global.json

@@ -1,6 +1,6 @@
 {
   "sdk": {
     "rollForward": "latestMinor",
-    "version": "9.0.305"
+    "version": "9.0.302"
   }
 }

src/DrawTogether/Config/AkkaConfiguration.cs

@@ -33,14 +33,19 @@ public static IServiceCollection ConfigureAkka(this IServiceCollection services,
         {
             builder.ConfigureNetwork(provider)
                 .AddDrawingProtocolSerializer()
+                .WithAkkaClusterReadinessCheck()
+                .WithActorSystemLivenessCheck()
                 .WithSqlPersistence(
                     connectionString: connectionString,
                     providerName: ProviderName.SqlServer2022,
                     databaseMapping: DatabaseMapping.SqlServer,
                     tagStorageMode: TagMode.TagTable,
                     deleteCompatibilityMode: true,
                     useWriterUuidColumn: true,
-                    autoInitialize: true)
+                    autoInitialize: true, journalBuilder: journalBuilder =>
+                    {
+                        journalBuilder.WithHealthCheck();
+                    })
                 .AddAllDrawingsIndexActor(roleName)
                 .AddDrawingSessionActor(roleName)
                 .AddLocalDrawingSessionActor();

src/DrawTogether/Program.cs

@@ -1,3 +1,4 @@
+using System.Text.Json;
 using Microsoft.AspNetCore.Components.Authorization;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.EntityFrameworkCore;
@@ -6,6 +7,7 @@
 using DrawTogether.Config;
 using DrawTogether.Data;
 using DrawTogether.Email;
+using Microsoft.AspNetCore.Diagnostics.HealthChecks;
 using Microsoft.AspNetCore.ResponseCompression;
 using MudBlazor.Services;
 using Petabridge.Cmd.Cluster;
@@ -25,6 +27,8 @@
 builder.Services.AddRazorComponents()
     .AddInteractiveServerComponents();
 
+builder.Services.AddHealthChecks();
+
 // If you also want WebAssembly SSR, include this line:
 builder.Services.AddServerSideBlazor();
 builder.Services.AddMudServices();
@@ -99,6 +103,33 @@
 app.UseResponseCompression();
 app.UseAntiforgery();
 
+app.MapHealthChecks("/healthz", new HealthCheckOptions
+{
+    Predicate = _ => true, // include all checks
+    ResponseWriter = async (ctx, report) =>
+    {
+        ctx.Response.ContentType = "application/json; charset=utf-8";
+
+        var payload = new
+        {
+            status = report.Status.ToString(),
+            totalDuration = report.TotalDuration,
+            checks = report.Entries.Select(e => new
+            {
+                name = e.Key,
+                status = e.Value.Status.ToString(),
+                duration = e.Value.Duration,
+                description = e.Value.Description,
+                tags = e.Value.Tags,
+                data = e.Value.Data   // anything you added via context.Registration
+            })
+        };
+
+        await ctx.Response.WriteAsync(JsonSerializer.Serialize(payload, new JsonSerializerOptions { WriteIndented = true }));
+        // or in .NET 8+: await ctx.Response.WriteAsJsonAsync(payload);
+    }
+});
+
 app.MapRazorComponents<App>()
     .AddInteractiveServerRenderMode();