Add support for IOptions(Monitor) in http host extension

Author: C0nquistadore

src/Dibix.Http.Host/Configuration/OptionsMonitorSubscriberOptions.cs

@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+
+namespace Dibix.Http.Host
+{
+    internal sealed class OptionsMonitorSubscriberOptions
+    {
+        public ICollection<Func<IServiceProvider, IDisposable?>> Subscribers { get; } = new Collection<Func<IServiceProvider, IDisposable?>>();
+    }
+}

src/Dibix.Http.Host/Configuration/OptionsMonitorSubscriberService.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Options;
+
+namespace Dibix.Http.Host
+{
+    internal sealed class OptionsMonitorSubscriberService : IHostedService
+    {
+        private readonly IOptions<OptionsMonitorSubscriberOptions> _options;
+        private readonly IServiceProvider _serviceProvider;
+        private readonly ICollection<IDisposable> _disposables;
+
+        public OptionsMonitorSubscriberService(IOptions<OptionsMonitorSubscriberOptions> options, IServiceProvider serviceProvider)
+        {
+            _options = options;
+            _disposables = new Collection<IDisposable>();
+            _serviceProvider = serviceProvider;
+        }
+
+        public Task StartAsync(CancellationToken cancellationToken)
+        {
+            foreach (Func<IServiceProvider, IDisposable?> subscriber in _options.Value.Subscribers)
+            {
+                IDisposable? disposable = subscriber(_serviceProvider);
+                if (disposable != null)
+                    _disposables.Add(disposable);
+            }
+
+            return Task.CompletedTask;
+        }
+
+        public Task StopAsync(CancellationToken cancellationToken)
+        {
+            foreach (IDisposable disposable in _disposables)
+            {
+                disposable.Dispose();
+            }
+
+            return Task.CompletedTask;
+        }
+    }
+}

src/Dibix.Http.Host/Registration/HttpHostExtensionRegistrar.cs

@@ -12,6 +12,7 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
 
 namespace Dibix.Http.Host
 {
@@ -61,6 +62,9 @@ IHttpHostExtensionConfigurationBuilder IHttpHostExtensionConfigurationBuilder.En
                 return this;
             }
 
+            IHttpHostExtensionConfigurationBuilder IHttpHostExtensionConfigurationBuilder.ConfigureOptions<TOptions>(string sectionName, Action<TOptions, string?>? optionsMonitorSubscriber) where TOptions : class => Configure(Configuration.GetSection(sectionName), optionsMonitorSubscriber);
+            IHttpHostExtensionConfigurationBuilder IHttpHostExtensionConfigurationBuilder.ConfigureOptions<TOptions>(IConfiguration configuration, Action<TOptions, string?>? optionsMonitorSubscriber) where TOptions : class => Configure(configuration, optionsMonitorSubscriber);
+
             IHttpHostExtensionConfigurationBuilder IHttpHostExtensionConfigurationBuilder.ConfigureJwtBearer(Action<JwtBearerOptions> configure)
             {
                 _services.PostConfigure(JwtBearerDefaults.AuthenticationScheme, configure);
@@ -122,6 +126,18 @@ async Task IHttpHostExtensionRegistrar.Configure(IHost host)
                 return this;
             }
 
+            private IHttpHostExtensionConfigurationBuilder Configure<TOptions>(IConfiguration configuration, Action<TOptions, string?>? optionsMonitorSubscriber) where TOptions : class
+            {
+                _services.Configure<TOptions>(configuration);
+                if (optionsMonitorSubscriber != null)
+                {
+                    Func<IServiceProvider, IDisposable?> subscribeToOptionsMonitor = x => x.GetRequiredService<IOptionsMonitor<TOptions>>().OnChange(optionsMonitorSubscriber);
+                    _services.Configure<OptionsMonitorSubscriberOptions>(x => x.Subscribers.Add(subscribeToOptionsMonitor));
+                    _services.AddHostedService<OptionsMonitorSubscriberService>();
+                }
+                return this;
+            }
+
             private void SubscribeToShutdown(IServiceProvider services)
             {
                 IHostApplicationLifetime hostApplicationLifetime = services.GetRequiredService<IHostApplicationLifetime>();

src/Dibix.Http.Server/Registration/IHttpHostExtensionConfigurationBuilder.cs

@@ -10,7 +10,9 @@ public interface IHttpHostExtensionConfigurationBuilder
 #endif
 
         IHttpHostExtensionConfigurationBuilder EnableRequestIdentityProvider();
+        IHttpHostExtensionConfigurationBuilder ConfigureOptions<TOptions>(string sectionName, Action<TOptions, string> optionsMonitorSubscriber = null) where TOptions : class;
 #if NET
+        IHttpHostExtensionConfigurationBuilder ConfigureOptions<TOptions>(Microsoft.Extensions.Configuration.IConfiguration configuration, Action<TOptions, string> optionsMonitorSubscriber = null) where TOptions : class;
         IHttpHostExtensionConfigurationBuilder ConfigureJwtBearer(Action<Microsoft.AspNetCore.Authentication.JwtBearer.JwtBearerOptions> configure);
         IHttpHostExtensionConfigurationBuilder EnableCustomAuthentication<THandler, TOptions>(string schemeName) where THandler : Microsoft.AspNetCore.Authentication.AuthenticationHandler<TOptions> where TOptions : Microsoft.AspNetCore.Authentication.AuthenticationSchemeOptions, new();
         IHttpHostExtensionConfigurationBuilder EnableCustomAuthentication<THandler, TOptions>(string schemeName, Action<TOptions> configureOptions) where THandler : Microsoft.AspNetCore.Authentication.AuthenticationHandler<TOptions> where TOptions : Microsoft.AspNetCore.Authentication.AuthenticationSchemeOptions, new();