Add stroage to event hub on idops server

SwissLife-OSS · Jun 3, 2024 · 2dcf002 · 2dcf002
1 parent bcaaf71
commit 2dcf002
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 0 deletions.
diff --git a/src/Server/src/Abstractions/Configuration/IdOpsServerOptions.cs b/src/Server/src/Abstractions/Configuration/IdOpsServerOptions.cs
@@ -31,6 +31,15 @@ public class EventHubOptions
         public string? ConnectionString { get; set; }
 
         public string? Namespace { get; set; }
+
+        public EventStorageHubOptions? Storage { get; set; }
+    }
+
+    public sealed class EventStorageHubOptions
+    {
+        public string? ConnectionString { get; set; }
+
+        public string? Url { get; set; }
     }
 
     public enum MessagingTransport

diff --git a/src/Server/src/Core/Configuration/IdOpsServerBuilderExtensions.cs b/src/Server/src/Core/Configuration/IdOpsServerBuilderExtensions.cs
@@ -186,6 +186,23 @@ private static void UseEventHub(
                     }
 
                     k.ReceiveEndpoint("identity-events", e => e.ConfigureConsumers(contex));
+
+                    if (options.Storage is { } storageOption)
+                    {
+                        if (storageOption.Url is { } url)
+                        {
+                            k.Storage(new Uri(url), new DefaultAzureCredential());
+                        }
+                        else if (storageOption.ConnectionString is { } connectionString)
+                        {
+                            k.Storage(connectionString);
+                        }
+                        else
+                        {
+                            throw new ApplicationException(
+                                "EventHub storage configuration is missing. Please check your settings.");
+                        }
+                    }
                 });
             });
         }