Implement email notification config on top of config store

src/ServiceControl.Persistence.EFCore/Implementation/NotificationsDataStore.cs

@@ -1,7 +1,14 @@
 namespace ServiceControl.Persistence.EFCore.Implementation;
 
-public class NotificationsDataStore : INotificationsDataStore
+using DbContexts;
+using Microsoft.Extensions.DependencyInjection;
+
+public class NotificationsDataStore(IServiceProvider serviceProvider) : INotificationsDataStore
 {
-    public Task<INotificationsManager> CreateNotificationsManager() =>
-        throw new NotImplementedException();
+    public Task<INotificationsManager> CreateNotificationsManager()
+    {
+        var scope = serviceProvider.CreateAsyncScope();
+        ServiceControlDbContext serviceControlDbContext = scope.ServiceProvider.GetRequiredService<ServiceControlDbContext>();
+        return Task.FromResult<INotificationsManager>(new NotificationsManager(scope, serviceControlDbContext));
+    }
 }

src/ServiceControl.Persistence.EFCore/Implementation/NotificationsManager.cs

@@ -1,14 +1,35 @@
 namespace ServiceControl.Persistence.EFCore.Implementation;
 
-using ServiceControl.Notifications;
+using DbContexts;
+using Infrastructure;
+using Notifications;
 
-public class NotificationsManager : INotificationsManager
+public class NotificationsManager(IAsyncDisposable scope, ServiceControlDbContext dbContext) : INotificationsManager
 {
-    public Task<NotificationsSettings> LoadSettings() =>
-        throw new NotImplementedException();
+    NotificationsSettings? _settings;
 
-    public Task SaveChanges() =>
-        throw new NotImplementedException();
+    public Task SaveChanges()
+    {
+        if (_settings == null)
+        {
+            return Task.CompletedTask;
+        }
 
-    public ValueTask DisposeAsync() => default;
-}
+        return dbContext.StoreSetting(SettingKeys.NotificationEmails, _settings.Email, CancellationToken.None);
+    }
+
+    public async Task<NotificationsSettings> LoadSettings()
+    {
+        var settings = await dbContext.GetSetting<EmailNotifications>(SettingKeys.NotificationEmails, CancellationToken.None);
+        _settings = new NotificationsSettings() { Email = settings ?? new EmailNotifications() };
+        return _settings;
+    }
+
+    public async ValueTask DisposeAsync()
+    {
+        await dbContext.DisposeAsync();
+        await scope.DisposeAsync();
+
+        GC.SuppressFinalize(this);
+    }
+}

src/ServiceControl.Persistence.EFCore/Infrastructure/SettingKeys.cs

@@ -8,4 +8,5 @@ static class SettingKeys
     public const string AuditServiceMetadata = "AuditServiceMetadata";
     public const string ReportMasks = "ReportMasks";
     public const string LicensedEndpointDetails = "LicensedEndpointDetails";
+    public const string NotificationEmails = "NotificationEmails";
 }

src/ServiceControl.Persistence.Tests.PostgreSql/ServiceControl.Persistence.Tests.PostgreSql.csproj

@@ -36,7 +36,6 @@
     <Compile Remove="..\ServiceControl.Persistence.Tests\Recoverability\EditMessageTests.cs" />
     <Compile Remove="..\ServiceControl.Persistence.Tests\Recoverability\RetryConfirmationProcessorTests.cs" />
     <Compile Remove="..\ServiceControl.Persistence.Tests\RetryStateTests.cs" />
-    <Compile Remove="..\ServiceControl.Persistence.Tests\NotificationsDataStoreTests.cs" />
   </ItemGroup>
 
 </Project>

src/ServiceControl.Persistence.Tests.SqlServer/ServiceControl.Persistence.Tests.SqlServer.csproj

@@ -36,7 +36,6 @@
     <Compile Remove="..\ServiceControl.Persistence.Tests\Recoverability\EditMessageTests.cs" />
     <Compile Remove="..\ServiceControl.Persistence.Tests\Recoverability\RetryConfirmationProcessorTests.cs" />
     <Compile Remove="..\ServiceControl.Persistence.Tests\RetryStateTests.cs" />
-    <Compile Remove="..\ServiceControl.Persistence.Tests\NotificationsDataStoreTests.cs" />
   </ItemGroup>
 
 </Project>