support deletion tracking

Author: thefringeninja

src/SqlStreamStore.Server/SqlStreamStore.Server.csproj

@@ -5,7 +5,8 @@
     <TargetLatestRuntimePatch>true</TargetLatestRuntimePatch>
     <LangVersion>latest</LangVersion>
     <CrossGenDuringPublish>false</CrossGenDuringPublish>
-    <LibraryVersion Condition="$(LibraryVersion) == ''">1.2.0-beta.3.26</LibraryVersion>
+    <LibraryVersion Condition="$(LibraryVersion) == ''">1.2.0-beta.3.28</LibraryVersion>
+    <StartupObject></StartupObject>
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="ILLink.Tasks" Version="0.1.5-preview-1841731" />

src/SqlStreamStore.Server/SqlStreamStoreFactory.cs

@@ -42,11 +42,26 @@ public IStreamStore Create()
         }
 
         public InMemoryStreamStore CreateInMemoryStreamStore()
-            => new InMemoryStreamStore();
+        {
+            if (_configuration.Schema != default)
+            {
+                LogNotSupported(mysql, nameof(_configuration.Schema));
+            }
+
+            if (_configuration.DisableDeletionTracking)
+            {
+                LogNotSupported(mysql, nameof(_configuration.DisableDeletionTracking));
+            }
+
+            return new InMemoryStreamStore();
+        }
 
         public MsSqlStreamStoreV3 CreateMsSqlStreamStore()
         {
-            var settings = new MsSqlStreamStoreV3Settings(_configuration.ConnectionString);
+            var settings = new MsSqlStreamStoreV3Settings(_configuration.ConnectionString)
+            {
+                DisableDeletionTracking = _configuration.DisableDeletionTracking
+            };
 
             if (_configuration.Schema != null)
             {
@@ -57,11 +72,24 @@ public MsSqlStreamStoreV3 CreateMsSqlStreamStore()
         }
 
         public MySqlStreamStore CreateMySqlStreamStore()
-            => new MySqlStreamStore(new MySqlStreamStoreSettings(_configuration.ConnectionString));
+        {
+            if (_configuration.Schema != default)
+            {
+                LogNotSupported(mysql, nameof(_configuration.Schema));
+            }
+
+            return new MySqlStreamStore(new MySqlStreamStoreSettings(_configuration.ConnectionString)
+            {
+                DisableDeletionTracking = _configuration.DisableDeletionTracking
+            });
+        }
 
         public PostgresStreamStore CreatePostgresStreamStore()
         {
-            var settings = new PostgresStreamStoreSettings(_configuration.ConnectionString);
+            var settings = new PostgresStreamStoreSettings(_configuration.ConnectionString)
+            {
+                DisableDeletionTracking = _configuration.DisableDeletionTracking
+            };
 
             if (_configuration.Schema != null)
             {
@@ -70,5 +98,11 @@ public PostgresStreamStore CreatePostgresStreamStore()
 
             return new PostgresStreamStore(settings);
         }
+
+        private static void LogNotSupported(string provider, string configurationKey) =>
+            s_Log.Warning(
+                "Configuration key '{configurationKey}' is not supported for provider {provider}. It will be ignored.",
+                configurationKey,
+                provider);
     }
 }

src/SqlStreamStore.Server/SqlStreamStoreServerConfiguration.cs

@@ -32,6 +32,8 @@ internal class SqlStreamStoreServerConfiguration
         public string Schema => _configuration.Schema;
         public string Provider => _configuration.Provider.ToLowerInvariant();
 
+        public bool DisableDeletionTracking => _configuration.DisableDeletionTracking;
+
         public SqlStreamStoreServerConfiguration(
             IDictionary environment,
             string[] args)
@@ -120,6 +122,7 @@ private class ConfigurationData
             [Sensitive] public string ConnectionString => _configuration.GetValue<string>(nameof(ConnectionString));
             public string Schema => _configuration.GetValue<string>(nameof(Schema));
             public string Provider => _configuration.GetValue<string>(nameof(Provider));
+            public bool DisableDeletionTracking => _configuration.GetValue<bool>(nameof(DisableDeletionTracking));
 
             public ConfigurationData(IConfigurationRoot configuration)
             {
@@ -172,7 +175,8 @@ public override void Load()
                     [nameof(Provider)] = "inmemory",
                     [nameof(LogLevel)] = nameof(LogEventLevel.Information),
                     [nameof(Schema)] = default,
-                    [nameof(UseCanonicalUris)] = default
+                    [nameof(UseCanonicalUris)] = default,
+                    [nameof(DisableDeletionTracking)] = default
                 };
 
                 _log(nameof(Default), Data);