Add HealthCheckCompletedNotification

src/Umbraco.Core/HealthChecks/HealthCheckResults.cs

@@ -1,4 +1,4 @@
 using System.Text;
 using Microsoft.Extensions.Logging;
 using Umbraco.Extensions;
 
@@ -53,6 +53,8 @@
         return new HealthCheckResults(results, allChecksSuccessful);
     }
 
+    public static async Task<HealthCheckResults> Create(HealthCheck check) => await Create(new List<HealthCheck>() { check });
+
     public void LogResults()
     {
         Logger.LogInformation("Scheduled health check results:");

src/Umbraco.Core/Notifications/HealthCheckCompletedNotification.cs

@@ -0,0 +1,13 @@
+using Umbraco.Cms.Core.HealthChecks;
+
+namespace Umbraco.Cms.Core.Notifications;
+
+public class HealthCheckCompletedNotification : INotification
+{
+    public HealthCheckCompletedNotification(HealthCheckResults healthCheckResults)
+    {
+        HealthCheckResults = healthCheckResults;
+    }
+
+    public HealthCheckResults HealthCheckResults { get; }
+}

src/Umbraco.Infrastructure/BackgroundJobs/Jobs/HealthCheckNotifierJob.cs

@@ -6,9 +6,11 @@
 using Umbraco.Cms.Core;
 using Umbraco.Cms.Core.Configuration;
 using Umbraco.Cms.Core.Configuration.Models;
+using Umbraco.Cms.Core.Events;
 using Umbraco.Cms.Core.HealthChecks;
 using Umbraco.Cms.Core.HealthChecks.NotificationMethods;
 using Umbraco.Cms.Core.Logging;
+using Umbraco.Cms.Core.Notifications;
 using Umbraco.Cms.Core.Runtime;
 using Umbraco.Cms.Core.Scoping;
 using Umbraco.Cms.Core.Services;
@@ -38,6 +40,7 @@
     private readonly ILogger<HealthCheckNotifierJob> _logger;
     private readonly HealthCheckNotificationMethodCollection _notifications;
     private readonly IProfilingLogger _profilingLogger;
+    private readonly IEventAggregator _eventAggregator;
     private readonly ICoreScopeProvider _scopeProvider;
     private HealthChecksSettings _healthChecksSettings;
 
@@ -58,14 +61,16 @@
         ICoreScopeProvider scopeProvider,
         ILogger<HealthCheckNotifierJob> logger,
         IProfilingLogger profilingLogger,
-        ICronTabParser cronTabParser)
+        ICronTabParser cronTabParser,
+        IEventAggregator eventAggregator)
     {
         _healthChecksSettings = healthChecksSettings.CurrentValue;
         _healthChecks = healthChecks;
         _notifications = notifications;
         _scopeProvider = scopeProvider;
         _logger = logger;
         _profilingLogger = profilingLogger;
+        _eventAggregator = eventAggregator;
 
         Period = healthChecksSettings.CurrentValue.Notification.Period;
         Delay = DelayCalculator.GetDelay(healthChecksSettings.CurrentValue.Notification.FirstRunTime, cronTabParser, logger, TimeSpan.FromMinutes(3));
@@ -106,6 +111,8 @@
             HealthCheckResults results = await HealthCheckResults.Create(checks);
             results.LogResults();
 
+            _eventAggregator.Publish(new HealthCheckCompletedNotification(results));
+
             // Send using registered notification methods that are enabled.
             foreach (IHealthCheckNotificationMethod notificationMethod in _notifications.Where(x => x.Enabled))
             {

src/Umbraco.Web.BackOffice/HealthChecks/HealthCheckController.cs

@@ -7,7 +7,9 @@
 using Microsoft.Extensions.Options;
 using Umbraco.Cms.Core;
 using Umbraco.Cms.Core.Configuration.Models;
+using Umbraco.Cms.Core.Events;
 using Umbraco.Cms.Core.HealthChecks;
+using Umbraco.Cms.Core.Notifications;
 using Umbraco.Cms.Web.BackOffice.Controllers;
 using Umbraco.Cms.Web.Common.Attributes;
 using Umbraco.Cms.Web.Common.Authorization;
@@ -24,14 +26,18 @@ public class HealthCheckController : UmbracoAuthorizedJsonController
     private readonly HealthCheckCollection _checks;
     private readonly IList<Guid> _disabledCheckIds;
     private readonly ILogger<HealthCheckController> _logger;
+    private readonly IEventAggregator _eventAggregator;
+    private readonly HealthChecksSettings _healthChecksSettings;
 
     /// <summary>
     ///     Initializes a new instance of the <see cref="HealthCheckController" /> class.
     /// </summary>
-    public HealthCheckController(HealthCheckCollection checks, ILogger<HealthCheckController> logger, IOptions<HealthChecksSettings> healthChecksSettings)
+    public HealthCheckController(HealthCheckCollection checks, ILogger<HealthCheckController> logger, IOptions<HealthChecksSettings> healthChecksSettings, IEventAggregator eventAggregator)
     {
         _checks = checks ?? throw new ArgumentNullException(nameof(checks));
         _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+        _eventAggregator = eventAggregator ?? throw new ArgumentException(nameof(eventAggregator));
+        _healthChecksSettings = healthChecksSettings?.Value ?? throw new ArgumentException(nameof(healthChecksSettings));
 
         HealthChecksSettings healthCheckConfig =
             healthChecksSettings.Value ?? throw new ArgumentNullException(nameof(healthChecksSettings));
@@ -80,6 +86,16 @@ public async Task<object> GetStatus(Guid id)
             {
                 _logger.LogDebug("Running health check: " + check.Name);
             }
+
+            if (!_healthChecksSettings.Notification.Enabled)
+            {
+                return await check.GetStatus();
+            }
+
+            HealthCheckResults results = await HealthCheckResults.Create(check);
+            _eventAggregator.Publish(new HealthCheckCompletedNotification(results));
+
+
             return await check.GetStatus();
         }
         catch (Exception ex)

tests/Umbraco.Tests.UnitTests/Umbraco.Infrastructure/BackgroundJobs/Jobs/HealthCheckNotifierJobTests.cs

@@ -10,6 +10,7 @@
 using Umbraco.Cms.Core;
 using Umbraco.Cms.Core.Configuration;
 using Umbraco.Cms.Core.Configuration.Models;
+using Umbraco.Cms.Core.Events;
 using Umbraco.Cms.Core.HealthChecks;
 using Umbraco.Cms.Core.HealthChecks.NotificationMethods;
 using Umbraco.Cms.Core.Logging;
@@ -105,7 +106,8 @@ private HealthCheckNotifierJob CreateHealthCheckNotifier(
             mockScopeProvider.Object,
             mockLogger.Object,
             mockProfilingLogger.Object,
-            Mock.Of<ICronTabParser>());
+            Mock.Of<ICronTabParser>(),
+            Mock.Of<IEventAggregator>());
     }
 
     private void VerifyNotificationsNotSent() => VerifyNotificationsSentTimes(Times.Never());