Add missing validation for the NATS stream provider (dotnet#9668)

Add missing validation for the Nats stream provider

Author: galvesribeiro

src/Orleans.Streaming.NATS/Hosting/NatsStreamConfigurator.cs

@@ -13,9 +13,11 @@ public SiloNatsStreamConfigurator(string name, Action<Action<IServiceCollection>
     {
         this.ConfigureDelegate(services =>
         {
-            services.ConfigureNamedOptionForLogging<NatsOptions>(name)
+            services
+                .ConfigureNamedOptionForLogging<NatsOptions>(name)
                 .ConfigureNamedOptionForLogging<SimpleQueueCacheOptions>(name)
-                .ConfigureNamedOptionForLogging<HashRingStreamQueueMapperOptions>(name);
+                .ConfigureNamedOptionForLogging<HashRingStreamQueueMapperOptions>(name)
+                .AddTransient<IConfigurationValidator>(sp => new NatsStreamOptionsValidator(sp.GetRequiredService<IOptionsMonitor<NatsOptions>>().Get(name), name));
         });
     }
 
@@ -48,8 +50,10 @@ public ClusterClientNatsStreamConfigurator(string name, IClientBuilder builder)
         builder
             .ConfigureServices(services =>
             {
-                services.ConfigureNamedOptionForLogging<NatsOptions>(name)
-                    .ConfigureNamedOptionForLogging<HashRingStreamQueueMapperOptions>(name);
+                services
+                    .ConfigureNamedOptionForLogging<NatsOptions>(name)
+                    .ConfigureNamedOptionForLogging<HashRingStreamQueueMapperOptions>(name)
+                    .AddTransient<IConfigurationValidator>(sp => new NatsStreamOptionsValidator(sp.GetRequiredService<IOptionsMonitor<NatsOptions>>().Get(name), name));
             });
     }
 
@@ -66,4 +70,4 @@ public ClusterClientNatsStreamConfigurator ConfigurePartitioning(
             ob.Configure(options => options.TotalQueueCount = numOfparitions));
         return this;
     }
-}
+}

src/Orleans.Streaming.NATS/NatsOptions.cs

@@ -1,4 +1,5 @@
 using System.Text.Json;
+using Orleans.Runtime;
 using NATS.Client.Core;
 
 namespace Orleans.Streaming.NATS;
@@ -49,5 +50,17 @@ public class NatsOptions
     /// <summary>
     /// System.Text.Json serializer options to be used by the NATS provider.
     /// </summary>
-    public JsonSerializerOptions JsonSerializerOptions { get; set; } = default!;
+    public JsonSerializerOptions? JsonSerializerOptions { get; set; }
+}
+
+public class NatsStreamOptionsValidator(NatsOptions options, string? name = null) : IConfigurationValidator
+{
+    public void ValidateConfiguration()
+    {
+        if (string.IsNullOrWhiteSpace(options.StreamName))
+        {
+            throw new OrleansConfigurationException(
+                $"The {nameof(NatsOptions.StreamName)} is required for the NATS stream provider '{name}'.");
+        }
+    }
 }

src/Orleans.Streaming.NATS/Providers/NatsConnectionManager.cs

@@ -32,7 +32,9 @@ public NatsConnectionManager(string providerName, ILoggerFactory loggerFactory,
         this._loggerFactory = loggerFactory;
         this._logger = this._loggerFactory.CreateLogger<NatsConnectionManager>();
         this._options = options;
+        this._options.JsonSerializerOptions ??= new();
         this._options.JsonSerializerOptions.TypeInfoResolverChain.Add(NatsSerializerContext.Default);
+
         if (this._options.NatsClientOptions is null)
         {
             this._options.NatsClientOptions = NatsOpts.Default with